emitter

type Emitter ¶

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

func New(opts Options, sink Sink, iterations Iterations, results Results, logger *slog.Logger) *Emitter

func (e *Emitter) Close()

func (e *Emitter) Done(d event.DoneData)

func (e *Emitter) Dropped() int

func (e *Emitter) Emit(data event.Data)

func (e *Emitter) Events() <-chan event.Event

type Iterations ¶

type Iterations interface {
	Iteration() int
}

Iterations says which iteration an event belongs to. → state.Run

type Options ¶

type Options struct {
	Buffer       int
	StreamEvents bool          // false: only Error and Done events are emitted
	DoneGrace    time.Duration // how long Done waits for a reader when the channel is full
}

Options are the emitter's fixed settings.

type Results ¶

type Results interface {
	SetResult(d event.DoneData)
}

Results records the run's outcome before the done event is sent. → state.Run

type Sink ¶

type Sink interface {
	Write(evt event.Event)
}

Sink receives every event, synchronously, before it is offered to the channel. → the caller's loop.EventSink, or defaults.NoSink