ticker

Documentation

Index

• type Ticker
• type TickerImpl
  • func New(fs ...TickerOpt) (*TickerImpl, error)
  • func (t *TickerImpl) Start() (func() error, error)
• type TickerOpt
  • func WithEntitlementsRepository(r repository.EntitlementsRepository) TickerOpt
  • func WithLogger(l *zerolog.Logger) TickerOpt
  • func WithMessageQueue(mq msgqueue.MessageQueue) TickerOpt
  • func WithPartitionId(pid string) TickerOpt
  • func WithRepository(r repository.EngineRepository) TickerOpt
  • func WithTenantAlerter(ta *alerting.TenantAlertManager) 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 WithEntitlementsRepository

func WithEntitlementsRepository(r repository.EntitlementsRepository) TickerOpt

func WithLogger

func WithLogger(l *zerolog.Logger) TickerOpt

func WithMessageQueue

func WithMessageQueue(mq msgqueue.MessageQueue) TickerOpt

func WithPartitionId

func WithPartitionId(pid string) TickerOpt

func WithRepository

func WithRepository(r repository.EngineRepository) TickerOpt

func WithTenantAlerter

func WithTenantAlerter(ta *alerting.TenantAlertManager) TickerOpt

type TickerOpts

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