protocol

package

Go to main page

Versions in this module

v0

v0.0.21

Oct 18, 2026

v0.0.20

Oct 13, 2026

v0.0.19

Oct 13, 2026

v0.0.18

Oct 13, 2026

v0.0.17

Oct 11, 2026

v0.0.16

Oct 10, 2026

v0.0.15

Oct 10, 2026

v0.0.14

Oct 10, 2026

Changes in this version

type AuditEvent

+ ID int64

v0.0.13

Oct 9, 2026

v0.0.12

Oct 8, 2026

v0.0.11

Oct 8, 2026

v0.0.10

Oct 7, 2026

v0.0.9

Oct 2, 2026

v0.0.8

Aug 29, 2026

v0.0.7

Aug 28, 2026

v0.0.6

Aug 26, 2026

v0.0.5

Aug 25, 2026

Changes in this version

+ var AllQueryNames = []QueryName

+ var AllReviewAxes = []ReviewAxis

+ var AllRoleIds = []RoleId

+ var AllSeverityLevels = []SeverityLevel

+ var AllSignalTopics = []SignalTopic

+ var AllSliceExecutionModes = []SliceExecutionMode

+ var AllVoteTypes = []VoteType

+ var PhaseSpecs = map[PhaseId]PhaseSpec

+ func DedupKey(epochID, phase, kind, stepSeq string) string

+ func ReviewWorkflowID(epochId, phaseId string, round int) string

type AuditEvent

+ DedupKey string

+ type EpochState struct

+ ActiveSessionCount int

+ ActiveSessions []RegisterSessionSignal

+ BlockerCount int

+ CompletedPhases []PhaseId

+ CurrentPhase PhaseId

+ CurrentRole RoleId

+ EpochId string

+ LastError *string

+ ReviewCycles map[string][]ReviewCycleRecord

+ ReviewVotes map[ReviewAxis]VoteType

+ SliceProgress []SliceProgressSignal

+ TransitionHistory []TransitionRecord

+ type EpochStateMachine struct

+ func NewEpochStateMachine(epochId string, specs map[PhaseId]PhaseSpec) *EpochStateMachine

+ func NewEpochStateMachineFromState(state *EpochState, specs map[PhaseId]PhaseSpec) *EpochStateMachine

+ func (sm *EpochStateMachine) Advance(toPhase PhaseId, triggeredBy string, conditionMet string, timestamp time.Time) (*TransitionRecord, error)

+ func (sm *EpochStateMachine) AvailableTransitions() []PhaseId

+ func (sm *EpochStateMachine) HasConsensus() bool

+ func (sm *EpochStateMachine) RecordBlocker(resolved bool)

+ func (sm *EpochStateMachine) RecordFailedTransition(fromPhase, toPhase PhaseId, timestamp time.Time, triggeredBy string, err error)

+ func (sm *EpochStateMachine) RecordVote(axis ReviewAxis, vote VoteType) error

+ func (sm *EpochStateMachine) State() *EpochState

+ func (sm *EpochStateMachine) ValidateAdvance(toPhase PhaseId) []string

type EventType

+ const EventEpochCancelled

+ type PhaseAdvanceSignal struct

+ ConditionMet string

+ ToPhase PhaseId

+ TriggeredBy string

+ type PhaseSpec struct

+ Transitions []PhaseId

+ type QueryName string

+ const QueryActiveSessions

+ const QueryAvailableTransitions

+ const QueryCurrentState

+ const QueryFullState

+ const QuerySliceProgressState

+ func ParseQueryName(s string) (QueryName, bool)

+ func (q QueryName) IsValid() bool

+ func (q QueryName) String() string

+ type QueryStateResult struct

+ ActiveSessionCount int

+ AvailableTransitions []PhaseId

+ CurrentPhase PhaseId

+ CurrentRole RoleId

+ LastError *string

+ TransitionHistory []TransitionRecord

+ Votes map[ReviewAxis]VoteType

+ type RegisterSessionSignal struct

+ EpochId string

+ Model string

+ ModelHarness string

+ Role string

+ SessionId string

+ type ReviewAxis string

+ const AxisCorrectness

+ const AxisElegance

+ const AxisTestQuality

+ func (a ReviewAxis) IsValid() bool

+ type ReviewCycleRecord struct

+ FindingCounts map[SeverityLevel]int

+ Round int

+ SliceId string

+ Timestamp time.Time

+ Votes map[ReviewAxis]VoteType

+ func (r ReviewCycleRecord) IsCleanExit() bool

+ type ReviewVoteSignal struct

+ Axis ReviewAxis

+ ReviewerId string

+ Vote VoteType

+ type RoleId string

+ const RoleArchitect

+ const RoleEpoch

+ const RoleReviewer

+ const RoleSupervisor

+ const RoleWorker

+ func (r RoleId) IsValid() bool

+ type SeverityLevel string

+ const SeverityBlocker

+ const SeverityImportant

+ const SeverityMinor

+ func (s SeverityLevel) IsValid() bool

+ type SignalTopic string

+ const SignalAdvancePhase

+ const SignalCompleteSlice

+ const SignalRegisterSession

+ const SignalSliceProgress

+ const SignalStartSlice

+ const SignalSubmitVote

+ func (t SignalTopic) IsValid() bool

+ func (t SignalTopic) String() string

+ type SliceCompleteSignal struct

+ Error *string

+ Output string

+ Success bool

+ type SliceExecutionMode string

+ const SliceMock

+ const SliceSubprocess

+ const SliceTmux

+ func (m SliceExecutionMode) IsValid() bool

+ type SliceProgressSignal struct

+ Completed bool

+ LeafTaskId string

+ SliceId string

+ StageName string

+ type SliceStartSignal struct

+ Command string

+ Mode SliceExecutionMode

+ TimeoutSeconds int

+ type TaskAssignmentState struct

+ AssignmentID provenance.AssignmentID

+ Occupant provenance.ActorID

+ Slot provenance.AssignmentSlotID

+ TaskID provenance.TaskID

+ type TaskAssignmentTransferError struct

+ Kind TaskAssignmentTransferErrorKind

+ func NewTaskAssignmentTransferError(kind TaskAssignmentTransferErrorKind, cause error) *TaskAssignmentTransferError

+ func (e *TaskAssignmentTransferError) Error() string

+ func (e *TaskAssignmentTransferError) Unwrap() error

+ type TaskAssignmentTransferErrorKind uint8

+ const TaskAssignmentTransferAmbiguousAssignment

+ const TaskAssignmentTransferInvalidRequest

+ const TaskAssignmentTransferMismatchedAssignment

+ const TaskAssignmentTransferMissingAssignment

+ const TaskAssignmentTransferReplayConflict

+ const TaskAssignmentTransferStaleAssignment

+ const TaskAssignmentTransferUnavailable

+ const TaskAssignmentTransferUnsupportedSlot

+ func (k TaskAssignmentTransferErrorKind) String() string

type TaskTracker

+ AddComment func(id provenance.TaskID, authorId provenance.AgentID, body string) (provenance.Comment, error)

+ AddEdge func(sourceId provenance.TaskID, targetId string, kind provenance.EdgeKind) error

+ AddLabel func(id provenance.TaskID, label string) error

+ CloseTask func(id provenance.TaskID, reason string) (provenance.Task, error)

+ Create func(namespace, title, description string, taskType provenance.TaskType, ...) (provenance.Task, error)

+ RemoveEdge func(sourceId provenance.TaskID, targetId string, kind provenance.EdgeKind) error

+ RemoveLabel func(id provenance.TaskID, label string) error

+ Reopen func(id provenance.TaskID) (provenance.Task, error)

+ Start func(id provenance.TaskID) (provenance.Task, error)

+ Stop func(id provenance.TaskID) (provenance.Task, error)

+ TransferTaskAssignment func(ctx context.Context, request TransferTaskAssignmentRequest) (TransferTaskAssignmentResult, error)

+ Update func(id provenance.TaskID, fields provenance.UpdateFields) (provenance.Task, error)

+ type TransferTaskAssignmentRequest struct

+ ActorID provenance.ActorID

+ NextAssignmentID provenance.AssignmentID

+ NextOccupant provenance.ActorID

+ Slot provenance.AssignmentSlotID

+ TaskID provenance.TaskID

+ type TransferTaskAssignmentResult struct

+ Next TaskAssignmentState

+ Previous TaskAssignmentState

+ Replayed bool

+ type TransitionError struct

+ Violations []string

+ func (e *TransitionError) Error() string

+ type TransitionRecord struct

+ ConditionMet string

+ FromPhase PhaseId

+ Success bool

+ Timestamp time.Time

+ ToPhase PhaseId

+ TriggeredBy string

+ type VoteType string

+ const VoteAccept

+ const VoteRevise

+ func (v VoteType) IsValid() bool

v0.0.4

Jun 7, 2026

v0.0.3

Jun 5, 2026

v0.0.2

Jun 4, 2026

v0.0.1

Jun 1, 2026

Changes in this version

+ var AllAutomatonRoles = []AutomatonRole

+ var AllContextKinds = []ContextKind

+ var AllEventTypes = []EventType

+ var AllPastureRoles = []PastureRole

+ var AllPhaseIds = []PhaseId

+ var DefaultPipeline = Pipeline

+ func MustHaveImpl()

+ func RegisterOpenTaskTracker(impl func(dbPath string) (TaskTracker, error))

+ type AuditEvent struct

+ EpochId string

+ EventType EventType

+ Payload map[string]any

+ Phase PhaseId

+ Role string

+ Timestamp time.Time

+ type AutomatonRole string

+ const AutomatonRoleConsensusReached

+ const AutomatonRoleConstraintChecker

+ const AutomatonRoleCreateFollowup

+ const AutomatonRoleHookHandler

+ const AutomatonRoleNone

+ const AutomatonRoleTransitionGate

+ func (r AutomatonRole) IsValid() bool

+ func (r AutomatonRole) String() string

+ type Context struct

+ ContextId string

+ Kind ContextKind

+ type ContextKind string

+ const ContextEpoch

+ const ContextFollowup

+ const ContextGit

+ const ContextNone

+ const ContextReview

+ const ContextSession

+ const ContextSkill

+ const ContextSlice

+ func (k ContextKind) IsValid() bool

+ func (k ContextKind) String() string

+ type EventType string

+ const EventConstraintChecked

+ const EventPhaseAdvance

+ const EventPhaseTransition

+ const EventReviewCycleStarted

+ const EventSessionRegistered

+ const EventSliceCompleted

+ const EventSliceStarted

+ const EventVoteRecorded

+ func (e EventType) IsValid() bool

+ type PastureRole string

+ const PastureRoleArchitect

+ const PastureRoleNone

+ const PastureRoleReviewer

+ const PastureRoleSupervisor

+ const PastureRoleWorker

+ func (r PastureRole) IsValid() bool

+ func (r PastureRole) String() string

+ type PhaseId string

+ const PhaseCodeReview

+ const PhaseComplete

+ const PhaseElicit

+ const PhaseHandoff

+ const PhaseImplPlan

+ const PhaseImplUAT

+ const PhaseLanding

+ const PhasePlanReview

+ const PhasePropose

+ const PhaseRatify

+ const PhaseRequest

+ const PhaseReview

+ const PhaseWorkerSlices

+ func ParsePhaseId(s string) (PhaseId, error)

+ func (p PhaseId) IsValid() bool

+ func (p PhaseId) String() string

+ type Pipeline []PhaseId

+ func (p Pipeline) Contains(id PhaseId) bool

+ func (p Pipeline) Index(id PhaseId) int

+ func (p Pipeline) Next(id PhaseId) PhaseId

+ func (p Pipeline) PhaseAt(number int) (PhaseId, bool)

+ func (p Pipeline) PhaseNumber(id PhaseId) int

+ type SessionEntry struct

+ ContentPreview *string

+ Depth int

+ EntryId *string

+ EntryIndex int

+ EntryType string

+ Extra *string

+ HasThinking bool

+ HasToolUse bool

+ IsError bool

+ ParentEntryId *string

+ ParentIndex *int

+ Provider string

+ RawByteLength *int

+ Role string

+ SessionId string

+ StopReason *string

+ TimestampMs *int64

+ TokensIn *int

+ TokensOut *int

+ ToolCallId *string

+ ToolInput *string

+ ToolKind *string

+ ToolNamesCsv *string

+ ToolOutput *string

+ type TaskTracker interface

+ AgentCategories func(id provenance.AgentID) (AutomatonRole, PastureRole, error)

+ AttachContext func(ctx context.Context, eventId int64, kind ContextKind, contextId string) error

+ Close func() error

+ EventContexts func(ctx context.Context, eventId int64) ([]Context, error)

+ QueryEvents func(ctx context.Context, epochId string, phase *PhaseId, role *string) ([]AuditEvent, error)

+ QuerySessionEntries func(ctx context.Context, sessionId string) ([]SessionEntry, error)

+ RecordEvent func(ctx context.Context, event AuditEvent) error

+ RecordEventReturningId func(ctx context.Context, event AuditEvent) (int64, error)

+ RecordSessionEntries func(ctx context.Context, entries []SessionEntry) error

+ SetAgentCategories func(id provenance.AgentID, automaton AutomatonRole, pastureRole PastureRole) error

+ Timeline func(ctx context.Context, kind ContextKind, contextId string) ([]AuditEvent, error)

+ func OpenTaskTracker(dbPath string) (TaskTracker, error)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL