crontab

Documentation

Index

• Variables
• type Crontab
  • func New(logger zerolog.Logger, locker rueidislock.Locker, register RegisterFunc) *Crontab
  • func (c *Crontab) Close() error
  • func (c *Crontab) Lock(ctx context.Context) (context.Context, context.CancelFunc, error)
  • func (c *Crontab) Register(name string, task PeriodicTask) error
  • func (c *Crontab) Start() error
• type Logger
  • func (l *Logger) Error(err error, msg string, keysAndValues ...any)
  • func (l *Logger) Info(msg string, keysAndValues ...any)
• type PeriodicTask
• type Register
• type RegisterFunc

Variables

var ProviderSet = wire.NewSet(New)

Types

type Crontab

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

func New

func New(
	logger zerolog.Logger,
	locker rueidislock.Locker,
	register RegisterFunc,
) *Crontab

func (*Crontab) Close

func (c *Crontab) Close() error

func (*Crontab) Lock

func (c *Crontab) Lock(ctx context.Context) (context.Context, context.CancelFunc, error)

func (*Crontab) Register

func (c *Crontab) Register(name string, task PeriodicTask) error

func (*Crontab) Start

func (c *Crontab) Start() error

type Logger

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

func (*Logger) Error

func (l *Logger) Error(err error, msg string, keysAndValues ...any)

func (*Logger) Info

func (l *Logger) Info(msg string, keysAndValues ...any)

type PeriodicTask

type PeriodicTask func() (string, func() error)

type Register

type Register interface {
	Register(string, PeriodicTask) error
}

type RegisterFunc

type RegisterFunc func(Register)