core

Jan 20, 2026

Changes in this version

+ type InterruptContextsProvider interface

+ GetInterruptContexts func() []*InterruptCtx

Nov 20, 2025

Changes in this version

+ func AppendAddressSegment(ctx context.Context, segType AddressSegmentType, segID string, subID string) context.Context

+ func BatchResumeWithData(ctx context.Context, resumeData map[string]any) context.Context

+ func GetInterruptState[T any](ctx context.Context) (wasInterrupted bool, hasState bool, state T)

+ func GetNextResumptionPoints(ctx context.Context) (map[string]bool, error)

+ func GetResumeContext[T any](ctx context.Context) (isResumeTarget bool, hasData bool, data T)

+ func PopulateInterruptState(ctx context.Context, id2Addr map[string]Address, ...) context.Context

+ func SignalToPersistenceMaps(is *InterruptSignal) (map[string]Address, map[string]InterruptState)

+ type Address []AddressSegment

+ func GetCurrentAddress(ctx context.Context) Address

+ func (p Address) Equals(other Address) bool

+ func (p Address) String() string

+ type AddressSegment struct

+ ID string

+ SubID string

+ Type AddressSegmentType

+ type AddressSegmentType string

+ type CheckPointStore interface

+ Get func(ctx context.Context, checkPointID string) ([]byte, bool, error)

+ Set func(ctx context.Context, checkPointID string, checkPoint []byte) error

+ type InterruptConfig struct

+ LayerPayload any

+ type InterruptCtx struct

+ Address Address

+ ID string

+ Info any

+ IsRootCause bool

+ Parent *InterruptCtx

+ func ToInterruptContexts(is *InterruptSignal, addrModifier func(Address) Address) []*InterruptCtx

+ func (ic *InterruptCtx) EqualsWithoutID(other *InterruptCtx) bool

+ type InterruptInfo struct

+ Info any

+ IsRootCause bool

+ func (i *InterruptInfo) String() string

+ type InterruptOption func(*InterruptConfig)

+ func WithLayerPayload(payload any) InterruptOption

+ type InterruptSignal struct

+ ID string

+ Subs []*InterruptSignal

+ func FromInterruptContexts(contexts []*InterruptCtx) *InterruptSignal

+ func Interrupt(ctx context.Context, info any, state any, subContexts []*InterruptSignal, ...) (*InterruptSignal, error)

+ func (is *InterruptSignal) Error() string

+ type InterruptState struct

+ LayerSpecificPayload any

+ State any

+ func (is *InterruptState) String() string