Versions in this module Expand all Collapse all v0 v0.1.3 Jul 15, 2026 v0.1.3-rc.1 Jul 8, 2026 v0.1.2 Jul 7, 2026 v0.1.1 Jul 7, 2026 v0.1.0 Jul 7, 2026 Changes in this version + const DefaultPoll + const DefaultStreamPoll + type ActionEntry struct + Action string + Call int64 + Fault string + State ActionState + Trust string + type ActionState string + const ActionBlocked + const ActionDone + const ActionRunning + type EgressEntry struct + Allowed bool + Host string + Reason string + type Event struct + Action string + Actor spine.ActorType + Allowed bool + Call int64 + Child string + Err string + Fault string + Goal string + Host string + Input json.RawMessage + IsError bool + Kind Kind + Reason string + Result string + Seq int64 + StopReason string + Text string + Time time.Time + Tool string + ToolUseID string + Trust string + Turn int + Usage *Usage + func History(ctx context.Context, log spine.Log, id string) ([]Event, error) + type FanoutChild struct + Blocked int + ID string + Objective string + Parent string + Result string + Seal RecordState + State FanoutState + Trust string + Turns int + type FanoutState string + const FanoutDone + const FanoutFailed + const FanoutRunning + type Kind string + const KindActionAdmitted + const KindActionCompleted + const KindActionRejected + const KindAssistant + const KindChildCompleted + const KindChildSpawned + const KindConverged + const KindEgressDecision + const KindRecordSealed + const KindRecordVerified + const KindSessionStarted + const KindStalled + const KindToolCall + const KindToolResult + const KindTurnCompleted + const KindTurnStarted + type Option func(*Session) + func WithClock(clk clock.Timing) Option + func WithID(id string) Option + func WithPollInterval(d time.Duration) Option + func WithStreamPoll(d time.Duration) Option + type Projection struct + Actions []ActionEntry + Admitted int + Completed int + Containment string + Egress []EgressEntry + EgressAllowed int + EgressBlocked int + Err string + Fanout []FanoutChild + Objective string + Record RecordState + Rejected int + Result string + Terminal bool + Turns int + Usage Usage + func NewProjection() Projection + func Project(evs []Event) Projection + func Reduce(p Projection, ev Event) Projection + type RecordState string + const RecordRecording + const RecordSealed + const RecordVerified + type Session struct + func New(log spine.Log, b bus.Bus, opts ...Option) *Session + func (s *Session) ID() string + func (s *Session) Reporter() mission.Reporter + func (s *Session) Resume(ctx context.Context, rt *runtime.Runtime, key resource.Key) + func (s *Session) Submit(ctx context.Context, rt *runtime.Runtime, spec goal.Spec) (resource.Key, error) + func (s *Session) Subscribe(ctx context.Context, afterSeq int64) (<-chan Event, error) + func (s *Session) Wait(ctx context.Context) (string, error) + type Stream struct + func (s *Stream) Subscribe(ctx context.Context, afterSeq int64) (<-chan Event, error) + type Usage struct + CacheReadTokens int + CacheWriteTokens int + InputTokens int + OutputTokens int
Go to main page