cron

Documentation

Index

• type ClientCron
  • func NewClientCron() *ClientCron
  • func (a *ClientCron) AddJob(name string, spec time.Duration, fixTime string, handler CronHandler)
  • func (a *ClientCron) Close(shutdownTime time.Duration) error
  • func (a *ClientCron) Start(ctx context.Context) error
• type CronHandler
• type CronRuntime
  • func NewCronRuntime(c *ClientCron, shutdownTime time.Duration, l zerolog.Logger) (*CronRuntime, error)
  • func (e *CronRuntime) AddHandler(name string, spec time.Duration, h CronHandler)
  • func (e *CronRuntime) AddHandlerFixTime(name string, fixTime string, h CronHandler)
  • func (e *CronRuntime) Run(ctx context.Context)

Types

type ClientCron

type ClientCron struct {
	// contains filtered or unexported fields
}

func NewClientCron

func NewClientCron() *ClientCron

func (*ClientCron) AddJob

func (a *ClientCron) AddJob(name string, spec time.Duration, fixTime string, handler CronHandler)

func (*ClientCron) Close

func (a *ClientCron) Close(shutdownTime time.Duration) error

func (*ClientCron) Start

func (a *ClientCron) Start(ctx context.Context) error

type CronHandler

type CronHandler func(context.Context) error

type CronRuntime

type CronRuntime struct {
	// contains filtered or unexported fields
}

func NewCronRuntime

func NewCronRuntime(c *ClientCron, shutdownTime time.Duration, l zerolog.Logger) (*CronRuntime, error)

func (*CronRuntime) AddHandler

func (e *CronRuntime) AddHandler(name string, spec time.Duration, h CronHandler)

func (*CronRuntime) AddHandlerFixTime

func (e *CronRuntime) AddHandlerFixTime(name string, fixTime string, h CronHandler)

func (*CronRuntime) Run

func (e *CronRuntime) Run(ctx context.Context)