queuephase

type EmitFunc ¶

type EmitFunc func(context.Context, Phase)

type Emitter ¶

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

Emitter turns durable state transitions into one bounded duration span per phase. It never invents traffic: a span exists only after the queue journal proves either a state transition or disappearance of a previously observed active intent.

func New() *Emitter

func NewWithEmitter(emit EmitFunc) *Emitter

func (e *Emitter) Observe(ctx context.Context, snapshot queueintent.Snapshot, now time.Time)

type Phase ¶

type Phase struct {
	Intent queueintent.Intent
	Start  time.Time
	End    time.Time
}