trigger

package

v0.1.0 Latest Latest Go to latest Published: Sep 2, 2026 License: Apache-2.0 Imports: 4 Imported by: 0

Details

Package trigger defines sans-I/O policies and their immutable transitions.

View Source

const HandoffBoundaryName = "handoff-participant-boundary"

View Source

const SourceWindowName = "memory-source-window"

This section is empty.

This section is empty.

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

func NewHandoffBoundary(position int64, activation handoff.Activate) (HandoffBoundary, error)

func (b HandoffBoundary) Activation() handoff.Activate

func (b HandoffBoundary) Position() int64

type HandoffBoundaryPolicy struct{}

func (HandoffBoundaryPolicy) Activate(
	signal HandoffBoundary,
	state source.Cursor,
) Transition[source.Cursor, handoff.Prepare]

func (HandoffBoundaryPolicy) InitialState() source.Cursor

type Policy[Signal, State, Action any] interface {
	InitialState() State
	Activate(Signal, State) Transition[State, Action]
}

Policy maps one signal and activation state to a pure transition.

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

func (w ProcessSourceWindow) After() int64

func (w ProcessSourceWindow) Through() int64

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

func NewSourceHighWatermark(sequence, limit int64) (SourceHighWatermark, error)

func (s SourceHighWatermark) Limit() int64

func (s SourceHighWatermark) Sequence() int64

type SourceWindowPolicy struct{}

func (SourceWindowPolicy) Activate(
	signal SourceHighWatermark,
	state source.Cursor,
) Transition[source.Cursor, ProcessSourceWindow]

func (SourceWindowPolicy) InitialState() source.Cursor

type Transition[S, A any] struct {
	// contains filtered or unexported fields
}

Transition is the complete result of one pure Trigger activation.

func NewTransition[S, A any](state S, actions ...A) Transition[S, A]

func (t Transition[S, A]) Actions() []A

func (t Transition[S, A]) State() S