daemon

Documentation

Index

• type Daemon
• type DaemonResult
• type Message
• type Option
  • func ScheduleOption(value cron.Schedule) Option
• type Worker
  • func NewWorker(daemon Daemon, errCh chan<- error, opts ...Option) *Worker
  • func (w *Worker) Start(c *cron.Cron)
  • func (w *Worker) Stop()

Types

type Daemon

type Daemon interface {
	Errors() <-chan error
	Messages() <-chan Message
	Name() string
	Start(c *cron.Cron)
	Stop()
	Execute(ctx context.Context) error
}

type DaemonResult

type DaemonResult struct {
	fx.Out

	Daemon Daemon `group:"daemon"`
}

type Message

type Message struct {
	Message string
	Fields  map[string]interface{}
}

type Option

type Option func(option *Worker)

func ScheduleOption

func ScheduleOption(value cron.Schedule) Option

type Worker

type Worker struct {
	Daemon Daemon
	// contains filtered or unexported fields
}

func NewWorker

func NewWorker(daemon Daemon, errCh chan<- error, opts ...Option) *Worker

func (*Worker) Start

func (w *Worker) Start(c *cron.Cron)

func (*Worker) Stop

func (w *Worker) Stop()