ticker

Documentation

Index

• type Ticker
• type TickerImpl
  • func New(fs ...TickerOpt) (*TickerImpl, error)
  • func (t *TickerImpl) Start() (func() error, error)
• type TickerOpt
  • func WithLogger(l *zerolog.Logger) TickerOpt
  • func WithMessageQueue(mq msgqueue.MessageQueue) TickerOpt
  • func WithRepository(r repository.EngineRepository) TickerOpt
• type TickerOpts

Types

type Ticker

type Ticker interface {
	Start(ctx context.Context) error
}

type TickerImpl

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

func New

func New(fs ...TickerOpt) (*TickerImpl, error)

func (*TickerImpl) Start

func (t *TickerImpl) Start() (func() error, error)

type TickerOpt

type TickerOpt func(*TickerOpts)

func WithLogger

func WithLogger(l *zerolog.Logger) TickerOpt

func WithMessageQueue

func WithMessageQueue(mq msgqueue.MessageQueue) TickerOpt

func WithRepository

func WithRepository(r repository.EngineRepository) TickerOpt

type TickerOpts

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