worker

type BaseWorker struct {
	Ctx   context.Context
	App   application.Application
	Name  string // name of the lock (eg: "user_deactivation_notification"), to use when claiming a lock
	Owner string // owner of the lock (eg, the name of the Pod), to use when claiming a lock
	Do    func() // the function to run the business code at each cycle of the worker
	Opts  []pglock.ClientOption
	// contains filtered or unexported fields
}

type Worker interface {
	Start(freq time.Duration)
	Stop()
	IsStopped() bool
}