scheduler

Documentation

Index

• type PeriodicExecutor
  • func NewPeriodicExecutor(interval time.Duration, log logging.Logger) *PeriodicExecutor
  • func (pe *PeriodicExecutor) Close() error
  • func (pe *PeriodicExecutor) Start(ctx context.Context, task func(ctx context.Context) error)

Types

type PeriodicExecutor

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

func NewPeriodicExecutor

func NewPeriodicExecutor(interval time.Duration, log logging.Logger) *PeriodicExecutor

func (*PeriodicExecutor) Close

func (pe *PeriodicExecutor) Close() error

func (*PeriodicExecutor) Start

func (pe *PeriodicExecutor) Start(ctx context.Context, task func(ctx context.Context) error)