job.go 347 B

12345678910111213141516171819202122232425
  1. package server
  2. import (
  3. "context"
  4. "github.com/go-nunu/nunu-layout-advanced/pkg/log"
  5. )
  6. type Job struct {
  7. log *log.Logger
  8. }
  9. func NewJob(
  10. log *log.Logger,
  11. ) *Job {
  12. return &Job{
  13. log: log,
  14. }
  15. }
  16. func (j *Job) Start(ctx context.Context) error {
  17. // eg: kafka consumer
  18. return nil
  19. }
  20. func (j *Job) Stop(ctx context.Context) error {
  21. return nil
  22. }