Documentation
¶
Overview ¶
Package continuation provides in-memory contract implementations for protocol-neutral proxy-owned response continuation ports.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func MaterializeCall ¶
func MaterializeCall(ctx context.Context, input lipcont.MaterializeInput, base lipapi.Call) (lipapi.Call, lipcont.MaterializedTrajectory, error)
MaterializeCall resolves proxy-owned continuation state into a fresh item-authority call. Client continuation values are consumed by the store; the core-owned A-leg identity remains available to continuity stages.
func NewResponseID ¶
func NewResponseID(ctx context.Context) (lipcont.ResponseID, error)
NewResponseID delegates ID generation to the SDK authority.
Types ¶
type MemoryStore ¶
type MemoryStore = lipcont.MemoryStore
MemoryStore is a compatibility name for the SDK-owned continuation store. Core uses the public protocol-neutral implementation and adds no mutable continuation state of its own.
func NewMemoryStore ¶
func NewMemoryStore() *MemoryStore
func NewMemoryStoreWithLimits ¶
func NewMemoryStoreWithLimits(limits lipcont.StorageLimits) *MemoryStore
type StreamRecorder ¶
type StreamRecorder = lipcont.StreamRecorder
StreamRecorder is a compatibility name for the SDK-owned recorder.
func NewStreamRecorder ¶
func NewStreamRecorder(recorder lipcont.Recorder, record lipcont.ContinuationRecord, cleanup func()) *StreamRecorder
Source Files
Click to show internal directories.
Click to hide internal directories.