ticker

package

v0.51.0-alpha.8 Latest Latest Go to latest Published: Oct 29, 2024 License: MIT Imports: 18 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

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

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

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

type TickerOpt func(*TickerOpts)

func WithEntitlementsRepository(r repository.EntitlementsRepository) TickerOpt

func WithLogger(l *zerolog.Logger) TickerOpt

func WithMessageQueue(mq msgqueue.MessageQueue) TickerOpt

func WithPartition(p *partition.Partition) TickerOpt

func WithRepository(r repository.EngineRepository) TickerOpt

func WithTenantAlerter(ta *alerting.TenantAlertManager) TickerOpt

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