module

type Barrier string

type Binding interface {
	Open(OpenContext) (Instance, error)
}

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

type Context struct {
	Context    context.Context
	TraceID    string
	Metadata   metadata.Set
	RoundTrip  int
	EventID    string
	Sequence   uint64
	ObservedAt time.Time
	Emitter    event.Emitter
}

type Definition interface {
	Name() string
}

type Executor string

type FinishCause string

type FinishContext struct {
	Context
	Cause FinishCause
}

type Handler[T any] func(Context, T) error

type Instance interface {
	Bind(Registrar)
	Finish(FinishContext) error
}

type Lifetime string

type Mutator[T any] func(Context, *T) error

type NopInstance struct{}

type OpenContext struct {
	TraceID   string
	Metadata  metadata.Set
	Lifetime  Lifetime
	RoundTrip int
	StartedAt time.Time
}

type Overflow string

type Policy struct {
	Executor Executor
	Barrier  Barrier
	Overflow Overflow
	Capacity int
}

type ProgramDefinition interface {
	Definition
	Lifetime() Lifetime
	CompileProgram(jsontext.Value) (Binding, error)
}

type Registrar interface {
	OnRequestStarted(Policy, Handler[lifecycle.RequestStarted])
	OnRequestBodyChunk(Policy, Handler[lifecycle.BodyChunk])
	OnRequestBodyEnded(Policy, Handler[lifecycle.RequestBodyEnded])
	OnRoundTripStarted(Policy, Handler[lifecycle.RoundTripStarted])
	OnDirectivePrepared(Policy, Handler[lifecycle.DirectivePrepared])
	OnUpstreamStarted(Policy, Handler[lifecycle.UpstreamStarted])
	OnUpstreamResponseStarted(Policy, Handler[lifecycle.ResponseStarted])
	OnUpstreamBodyChunk(Policy, Handler[lifecycle.BodyChunk])
	OnUpstreamBodyEnded(Policy, Handler[lifecycle.BodyEnded])
	OnRoundTripFinished(Policy, Handler[lifecycle.RoundTripFinished])
	OnRecoveryStarted(Policy, Handler[lifecycle.RecoveryStarted])
	OnRecoveryDecided(Policy, Handler[lifecycle.RecoveryDecided])
	OnRecoveryFinished(Policy, Handler[lifecycle.RecoveryFinished])
	OnDownstreamResponseStarted(Policy, Handler[lifecycle.ResponseStarted])
	OnDownstreamBodyChunk(Policy, Handler[lifecycle.BodyChunk])
	OnDownstreamSSEData(Policy, Handler[lifecycle.SSEData])
	OnDownstreamSSEComment(Policy, Handler[lifecycle.SSEComment])
	OnDownstreamBodyEnded(Policy, Handler[lifecycle.BodyEnded])
	OnRequestFinished(Policy, Handler[lifecycle.RequestFinished])
	MutateOutboundRequest(Policy, Mutator[http.Request])
	MutateOutboundBodyChunk(Policy, Mutator[lifecycle.BodyDraft])
	MutateUpstreamResponse(Policy, Mutator[lifecycle.ResponseDraft])
	MutateUpstreamBodyChunk(Policy, Mutator[lifecycle.BodyDraft])
}

type Spec = directivecontract.ModuleSpec

type Specs = directivecontract.ModuleSpecs