emit

Documentation

Index

• type Emitter
  • func NewEmitter(processor Processor, interval time.Duration, sleeper func(time.Duration), ...) Emitter
  • func (e Emitter) Start()
• type Logger
• type Processor

Types

type Emitter

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

func NewEmitter

func NewEmitter(processor Processor, interval time.Duration, sleeper func(time.Duration), logger Logger) Emitter

func (Emitter) Start

func (e Emitter) Start()

type Logger

type Logger interface {
	Error(string, error)
}

type Processor

type Processor interface {
	Process() error
}