network

package

Go to main page

Versions in this module

v0

v0.0.9

Jul 4, 2026

Changes in this version

+ const RuntimePeerID

+ type ChannelPolicyResolver interface

+ GetNetworkChannel func(ctx context.Context, ref store.NetworkChannelRef) (store.NetworkChannelEntry, error)

type Delivery

+ Mode string

type Envelope

+ Mentions []string

type Manager

+ func (m *Manager) SendFromRuntimePeer(ctx context.Context, req RuntimeSendRequest) (string, error)

type RouterOption

+ func WithRouterActivationTopK(limit int) RouterOption

+ func WithRouterChannelPolicyResolver(resolver ChannelPolicyResolver) RouterOption

+ func WithRouterLogger(logger *slog.Logger) RouterOption

+ func WithRouterThreadParticipantResolver(resolver ThreadParticipantResolver) RouterOption

+ type RuntimeSendRequest struct

+ Body json.RawMessage

+ CausationID *string

+ Channel string

+ DirectID *string

+ ExpiresAt *int64

+ Ext ExtensionMap

+ ID *string

+ Kind Kind

+ Mentions []string

+ ReplyTo *string

+ Surface *Surface

+ ThreadID *string

+ To *string

+ TraceID *string

+ WorkID *string

+ WorkspaceID string

type SendRequest

+ Mentions []string

+ type ThreadParticipantResolver interface

+ ListThreadParticipants func(ctx context.Context, ref store.NetworkChannelRef, threadID string) ([]store.NetworkThreadParticipant, error)

v0.0.8

Jun 22, 2026

v0.0.7

Jun 4, 2026

v0.0.6

Jun 3, 2026

v0.0.5

May 29, 2026

v0.0.4

May 27, 2026

v0.0.3

May 27, 2026

v0.0.2

May 27, 2026

v0.0.1

May 26, 2026

retracted

Changes in this version

+ const AuditDirectionDelivered

+ const AuditDirectionReceived

+ const AuditDirectionRejected

+ const AuditDirectionSent

+ const DefaultMaxReplayAge

+ const ProtocolV0

+ const StatusDisabled

+ const StatusDisconnected

+ const StatusRunning

+ var ErrDirectRoomCollision = errors.New("network: direct room collision")

+ var ErrDuplicateEnvelope = errors.New("network: duplicate envelope")

+ var ErrEnvelopeNotTarget = errors.New("network: envelope not targeted to a local peer")

+ var ErrEnvelopeTooLarge = errors.New("network: envelope too large")

+ var ErrExpired = errors.New("network: expired")

+ var ErrInvalidBody = errors.New("network: invalid body")

+ var ErrInvalidEnvelope = errors.New("network: invalid envelope")

+ var ErrInvalidField = errors.New("network: invalid field")

+ var ErrInvalidKind = errors.New("network: invalid kind")

+ var ErrInvalidStateTransition = errors.New("network: invalid work state transition")

+ var ErrLegacyFieldRejected = errors.New("network: legacy field rejected")

+ var ErrLocalPeerNotFound = errors.New("network: local peer not found")

+ var ErrMissingField = errors.New("network: missing field")

+ var ErrReplayTooOld = errors.New("network: replay window exceeded")

+ var ErrTargetPeerNotFound = errors.New("network: target peer not found")

+ var ErrTaskChannelMismatch = errors.New("network: task channel mismatch")

+ var ErrTaskChannelStale = errors.New("network: stale task channel")

+ var ErrTaskIngressCapabilityDenied = errors.New("network: task ingress capability denied")

+ var ErrTaskIngressPeerNotFound = errors.New("network: task ingress peer not found")

+ var ErrTaskIngressUnavailable = errors.New("network: task ingress is not configured")

+ var ErrVerificationFailed = errors.New("network: verification failed")

+ var ErrWorkActorNotAllowed = errors.New("network: work actor not allowed")

+ var ErrWorkClosed = errors.New("network: work closed")

+ var ErrWorkContainerMismatch = errors.New("network: work container mismatch")

+ var ErrWorkNotFound = errors.New("network: work not found")

+ func BroadcastSubject(workspaceID string, channel string) (string, error)

+ func DirectRoomIdentity(workspaceID string, channel string, localPeer string, remotePeer string) (string, string, string, error)

+ func DirectSubject(workspaceID string, channel string, peerID string) (string, error)

+ func IsTerminalState(state WorkState) bool

+ func NormalizeAuditEntry(sessionID string, direction string, envelope Envelope, reason string, ...) (store.NetworkAuditEntry, error)

+ func NormalizeDirectRoomPeers(localPeer string, remotePeer string) (string, string, error)

+ func PreviewTextForRawBody(kind Kind, raw json.RawMessage) string

+ func ResolveGreetSummary(card PeerCard, summary string) string

+ func RouteToken(peerID string) (string, error)

+ func ValidateChannel(channel string) error

+ func ValidateConversationID(id string, field string) error

+ func ValidateConversationRef(ref ConversationRef) error

+ func ValidateDirectRoomBinding(workspaceID string, channel string, directID string, peerA string, ...) error

+ func ValidateDirectRoomPeers(peerA string, peerB string) error

+ func ValidateEnvelope(env Envelope, opts ValidateOptions) error

+ func ValidateEnvelopeConversation(env Envelope) error

+ func ValidatePeerID(peerID string) error

+ func ValidateSurface(surface Surface) error

+ func ValidateWorkID(id string) error

+ func ValidateWorkState(state WorkState) error

+ func ValidateWorkTransition(from WorkState, to WorkState) error

+ func ValidateWorkspaceID(workspaceID string) error

+ type AuditStore interface

+ WriteNetworkAudit func(ctx context.Context, entry store.NetworkAuditEntry) error

+ type AuditWriter interface

+ RecordDelivered func(ctx context.Context, sessionID string, envelope Envelope) error

+ RecordReceived func(ctx context.Context, sessionID string, envelope Envelope) error

+ RecordRejected func(ctx context.Context, sessionID string, envelope Envelope, reason string) error

+ RecordSent func(ctx context.Context, sessionID string, envelope Envelope) error

+ type AuditWriterOption func(*FileAuditWriter)

+ type Body interface

+ Kind func() Kind

+ func DecodeBody(kind Kind, raw json.RawMessage) (Body, error)

+ type CapabilityBody struct

+ Capability CapabilityEnvelopePayload

+ func (CapabilityBody) Kind() Kind

+ type CapabilityEnvelopePayload struct

+ ArtifactsExpected []string

+ Constraints []string

+ ContextNeeded []string

+ Digest string

+ Examples []string

+ ExecutionOutline []string

+ ID string

+ Outcome string

+ Requirements []string

+ Summary string

+ Version string

+ type ChannelInfo struct

+ Channel string

+ PeerCount int

+ WorkspaceID string

+ type ConversationRef struct

+ Channel string

+ DirectID string

+ Surface Surface

+ ThreadID string

+ WorkspaceID string

+ func ConversationRefFromEnvelope(env Envelope) (ConversationRef, error)

+ func (r ConversationRef) ContainerKey() string

+ func (r ConversationRef) IsDirect() bool

+ func (r ConversationRef) IsThread() bool

+ func (r ConversationRef) Validate() error

+ type Delivery struct

+ Envelope Envelope

+ PeerID string

+ SessionID string

+ type Envelope struct

+ Body json.RawMessage

+ CausationID *string

+ Channel string

+ DirectID *string

+ ExpiresAt *int64

+ Ext ExtensionMap

+ From string

+ ID string

+ Kind Kind

+ Proof *Proof

+ Protocol string

+ ReplyTo *string

+ Surface *Surface

+ TS int64

+ ThreadID *string

+ To *string

+ TraceID *string

+ WorkID *string

+ WorkspaceID string

+ func NormalizeEnvelope(env Envelope, opts ValidateOptions) (Envelope, error)

+ func ParseEnvelope(data []byte, opts ValidateOptions) (Envelope, error)

+ func (e *Envelope) UnmarshalJSON(data []byte) error

+ func (e Envelope) DecodeBody() (Body, error)

+ func (e Envelope) IsBroadcast() bool

+ func (e Envelope) IsDirected() bool

+ type ExtensionMap map[string]json.RawMessage

+ type FileAuditWriter struct

+ func NewAuditWriter(path string, auditStore AuditStore, opts ...AuditWriterOption) (*FileAuditWriter, error)

+ func (w *FileAuditWriter) RecordDelivered(ctx context.Context, sessionID string, envelope Envelope) error

+ func (w *FileAuditWriter) RecordReceived(ctx context.Context, sessionID string, envelope Envelope) error

+ func (w *FileAuditWriter) RecordRejected(ctx context.Context, sessionID string, envelope Envelope, reason string) error

+ func (w *FileAuditWriter) RecordSent(ctx context.Context, sessionID string, envelope Envelope) error

+ func (w *FileAuditWriter) RecordTaskIngress(ctx context.Context, audit TaskIngressAudit) error

+ type GreetBody struct

+ PeerCard PeerCard

+ Summary string

+ func (GreetBody) Kind() Kind

+ type Heartbeat struct

+ func (h *Heartbeat) Done() <-chan struct{}

+ func (h *Heartbeat) Stop()

+ type HookDispatcher interface

+ DispatchNetworkDirectRoomOpened func(context.Context, hookspkg.NetworkDirectRoomOpenedPayload) (hookspkg.NetworkDirectRoomOpenedPayload, error)

+ DispatchNetworkMessagePersisted func(context.Context, hookspkg.NetworkMessagePersistedPayload) (hookspkg.NetworkMessagePersistedPayload, error)

+ DispatchNetworkPeerJoined func(context.Context, hookspkg.NetworkPeerJoinedPayload) (hookspkg.NetworkPeerJoinedPayload, error)

+ DispatchNetworkPeerLeft func(context.Context, hookspkg.NetworkPeerLeftPayload) (hookspkg.NetworkPeerLeftPayload, error)

+ DispatchNetworkThreadOpened func(context.Context, hookspkg.NetworkThreadOpenedPayload) (hookspkg.NetworkThreadOpenedPayload, error)

+ DispatchNetworkWorkClosed func(context.Context, hookspkg.NetworkWorkClosedPayload) (hookspkg.NetworkWorkClosedPayload, error)

+ DispatchNetworkWorkOpened func(context.Context, hookspkg.NetworkWorkOpenedPayload) (hookspkg.NetworkWorkOpenedPayload, error)

+ DispatchNetworkWorkTransitioned func(context.Context, hookspkg.NetworkWorkTransitionedPayload) (hookspkg.NetworkWorkTransitionedPayload, error)

+ type Kind string

+ const KindCapability

+ const KindGreet

+ const KindReceipt

+ const KindSay

+ const KindTrace

+ const KindWhois

+ func (k Kind) Validate() error

+ type KindMetric struct

+ Delivered int64

+ Kind Kind

+ Received int64

+ Rejected int64

+ Sent int64

+ type LifecycleAction string

+ const LifecycleActionAdvanced

+ const LifecycleActionIgnored

+ const LifecycleActionOpened

+ const LifecycleActionRejectWork

+ const LifecycleActionUnchanged

+ type LifecycleResult struct

+ Action LifecycleAction

+ ReasonCode *ReasonCode

+ Work Work

+ func ApplyWorkEnvelope(current *Work, env Envelope, at time.Time) (LifecycleResult, error)

+ type LocalPeer struct

+ CapabilityCatalog []sessionpkg.NetworkPeerCapability

+ Channel string

+ JoinedAt time.Time

+ PeerCard PeerCard

+ PeerID string

+ SessionID string

+ WorkspaceID string

+ type Manager struct

+ func NewManager(ctx context.Context, cfg aghconfig.NetworkConfig, prompter deliveryPrompter, ...) (*Manager, error)

+ func (m *Manager) CancelTaskFromPeer(ctx context.Context, ingress TaskIngressContext, taskID string, ...) (*taskpkg.Task, error)

+ func (m *Manager) CreateTaskFromPeer(ctx context.Context, ingress TaskIngressContext, spec taskpkg.CreateTask) (*taskpkg.Task, error)

+ func (m *Manager) EnqueueRunFromPeer(ctx context.Context, ingress TaskIngressContext, spec taskpkg.EnqueueRun) (*taskpkg.Run, error)

+ func (m *Manager) Inbox(ctx context.Context, sessionID string) ([]Envelope, error)

+ func (m *Manager) JoinChannel(ctx context.Context, join sessionpkg.NetworkPeerJoin) error

+ func (m *Manager) LeaveChannel(ctx context.Context, sessionID string) error

+ func (m *Manager) ListChannels(ctx context.Context, workspaceID string) ([]ChannelInfo, error)

+ func (m *Manager) ListPeers(ctx context.Context, workspaceID string, channel string) ([]PeerInfo, error)

+ func (m *Manager) OnTurnEnd(sessionID string)

+ func (m *Manager) Send(ctx context.Context, req SendRequest) (string, error)

+ func (m *Manager) Shutdown(ctx context.Context) error

+ func (m *Manager) Status(ctx context.Context) (*Status, error)

+ func (m *Manager) UpdateTaskFromPeer(ctx context.Context, ingress TaskIngressContext, taskID string, ...) (*taskpkg.Task, error)

+ func (m *Manager) WaitInbox(ctx context.Context, sessionID string, channel string) ([]Envelope, error)

+ type ManagerOption func(*managerOptions)

+ func WithManagerAuditWriter(auditor AuditWriter) ManagerOption

+ func WithManagerClock(now func() time.Time) ManagerOption

+ func WithManagerConversationStore(conversations store.NetworkConversationStore) ManagerOption

+ func WithManagerHookDispatcher(dispatcher HookDispatcher) ManagerOption

+ func WithManagerLogger(logger *slog.Logger) ManagerOption

+ func WithManagerTaskService(tasks TaskService) ManagerOption

+ type MetricSample struct

+ Labels map[string]string

+ Name string

+ Value int64

+ type PeerCard struct

+ ArtifactsSupported []string

+ Capabilities []string

+ DisplayName *string

+ Ext ExtensionMap

+ PeerID string

+ ProfilesSupported []string

+ TrustModesSupported []string

+ func DefaultPeerCard(peerID string) (PeerCard, error)

+ type PeerInfo struct

+ CapabilityCatalog []sessionpkg.NetworkPeerCapability

+ CapabilityCatalogKnown bool

+ Channel string

+ ExpiresAt *time.Time

+ JoinedAt *time.Time

+ LastSeen *time.Time

+ LastSeenAgeSeconds *int64

+ Local bool

+ PeerCard PeerCard

+ PeerID string

+ PresenceState PresenceState

+ SessionID *string

+ WorkspaceID string

+ type PeerLifecycleEvent struct

+ Kind PeerLifecycleKind

+ Peer PeerInfo

+ Timestamp time.Time

+ type PeerLifecycleKind string

+ const PeerLifecycleJoined

+ const PeerLifecycleLeft

+ type PeerRegistry struct

+ func NewPeerRegistry(greetInterval time.Duration, opts ...PeerRegistryOption) (*PeerRegistry, error)

+ func (r *PeerRegistry) ExpireRemotes(at time.Time) []RemotePeerEntry

+ func (r *PeerRegistry) GreetInterval() time.Duration

+ func (r *PeerRegistry) HasPresence(workspaceID string, channel string, peerID string, at time.Time) bool

+ func (r *PeerRegistry) LeaveLocal(sessionID string) (LocalPeer, bool)

+ func (r *PeerRegistry) ListChannels(workspaceID string, at time.Time) []ChannelInfo

+ func (r *PeerRegistry) ListPeers(workspaceID string, channel string, at time.Time) []PeerInfo

+ func (r *PeerRegistry) LocalByPeer(workspaceID string, channel string, peerID string) (LocalPeer, bool)

+ func (r *PeerRegistry) LocalBySession(sessionID string) (LocalPeer, bool)

+ func (r *PeerRegistry) LocalPeers(workspaceID string, channel string) []LocalPeer

+ func (r *PeerRegistry) LookupPresence(workspaceID string, channel string, peerID string, at time.Time) (PeerInfo, bool)

+ func (r *PeerRegistry) MatchLocalPeers(workspaceID string, channel string, query string) []LocalPeer

+ func (r *PeerRegistry) RefreshRemote(workspaceID string, channel string, card PeerCard, seenAt time.Time) (RemotePeerEntry, bool, error)

+ func (r *PeerRegistry) RefreshRemoteDetailed(workspaceID string, channel string, card PeerCard, ...) (RemoteRefreshResult, error)

+ func (r *PeerRegistry) RefreshRemoteWithCapabilityCatalog(workspaceID string, channel string, card PeerCard, ...) (RemotePeerEntry, bool, error)

+ func (r *PeerRegistry) RegisterLocal(sessionID string, workspaceID string, channel string, card PeerCard, ...) (LocalPeer, error)

+ func (r *PeerRegistry) RegisterLocalWithCapabilityCatalog(sessionID string, workspaceID string, channel string, card PeerCard, ...) (LocalPeer, error)

+ func (r *PeerRegistry) RemoteByPeer(workspaceID string, channel string, peerID string, at time.Time) (RemotePeerEntry, bool)

+ type PeerRegistryOption func(*PeerRegistry)

+ func WithPeerRegistryClock(now func() time.Time) PeerRegistryOption

+ type Presence struct

+ LastSeenAgeSeconds *int64

+ State PresenceState

+ func DerivePresence(peer PeerInfo, now time.Time, greetInterval time.Duration) Presence

+ type PresenceState string

+ const PresenceStateActive

+ const PresenceStateExpired

+ const PresenceStateInactive

+ const PresenceStateLocal

+ const PresenceStateUnknown

+ type Proof map[string]json.RawMessage

+ type ReasonCode string

+ const ReasonCodeBusy

+ const ReasonCodeConversationNotFound

+ const ReasonCodeDuplicate

+ const ReasonCodeExpired

+ const ReasonCodeInternal

+ const ReasonCodeInvalidSurface

+ const ReasonCodeLegacyFieldRejected

+ const ReasonCodeMalformed

+ const ReasonCodeNotFound

+ const ReasonCodeNotTarget

+ const ReasonCodeUnsupportedKind

+ const ReasonCodeUnsupportedProfile

+ const ReasonCodeVerificationFailed

+ const ReasonCodeWorkClosed

+ const ReasonCodeWorkContainerMismatch

+ func (r ReasonCode) Validate() error

+ type ReceiptBody struct

+ Detail *string

+ ForID string

+ ReasonCode *ReasonCode

+ Status ReceiptStatus

+ func (ReceiptBody) Kind() Kind

+ type ReceiptStatus string

+ const ReceiptStatusAccepted

+ const ReceiptStatusCanceled

+ const ReceiptStatusDuplicate

+ const ReceiptStatusExpired

+ const ReceiptStatusRejected

+ const ReceiptStatusUnsupported

+ func (s ReceiptStatus) Validate() error

+ type RemotePeerEntry struct

+ CapabilityCatalog []sessionpkg.NetworkPeerCapability

+ CapabilityCatalogKnown bool

+ Channel string

+ ExpiresAt time.Time

+ LastSeen time.Time

+ PeerCard PeerCard

+ PeerID string

+ WorkspaceID string

+ type RemoteRefreshResult struct

+ Entry RemotePeerEntry

+ Expired []RemotePeerEntry

+ Joined bool

+ Stored bool

+ type RouteResult struct

+ Deliveries []Delivery

+ Duplicate bool

+ Envelope *Envelope

+ Generated []Envelope

+ Ignored bool

+ PeerEvents []PeerLifecycleEvent

+ ReasonCode *ReasonCode

+ Rejected bool

+ type Router struct

+ func NewRouter(peers *PeerRegistry, transport RouterTransport, maxReplayAge time.Duration, ...) (*Router, error)

+ func (r *Router) Leave(sessionID string) (LocalPeer, bool)

+ func (r *Router) PrepareSend(ctx context.Context, req SendRequest) (SendResult, error)

+ func (r *Router) PublishGreet(ctx context.Context, sessionID string, summary string) (SendResult, error)

+ func (r *Router) PublishPrepared(ctx context.Context, prepared SendResult) (SendResult, error)

+ func (r *Router) Receive(ctx context.Context, payload []byte) (RouteResult, error)

+ func (r *Router) Send(ctx context.Context, req SendRequest) (SendResult, error)

+ func (r *Router) StartHeartbeat(ctx context.Context, sessionID string, summary string) (*Heartbeat, error)

+ type RouterOption func(*Router)

+ func WithRouterClock(now func() time.Time) RouterOption

+ type RouterTransport interface

+ Publish func(ctx context.Context, subject string, payload []byte) error

+ type SayBody struct

+ Artifacts []json.RawMessage

+ Intent string

+ Text string

+ func (SayBody) Kind() Kind

+ type SendRequest struct

+ Body json.RawMessage

+ CausationID *string

+ Channel string

+ DirectID *string

+ ExpiresAt *int64

+ Ext ExtensionMap

+ ID *string

+ Kind Kind

+ ReplyTo *string

+ SessionID string

+ Surface *Surface

+ ThreadID *string

+ To *string

+ TraceID *string

+ WorkID *string

+ WorkspaceID string

+ type SendResult struct

+ Envelope Envelope

+ ID string

+ Subject string

+ type Status struct

+ Channels int

+ ConversationMessages int64

+ DeliveryQueueDepth int

+ DeliveryWorkers int

+ DirectResolves int64

+ Enabled bool

+ HandoffTaggedEvents int64

+ KindMetrics []KindMetric

+ LastDisconnect string

+ ListenerHost string

+ ListenerPort int

+ LocalPeers int

+ MessagesDelivered int64

+ MessagesReceived int64

+ MessagesRejected int64

+ MessagesSent int64

+ Metrics []MetricSample

+ OpenDirectRooms int64

+ OpenThreads int64

+ OpenWorkItems int64

+ QueuedMessages int

+ QueuedSessions int

+ RemotePeers int

+ Status string

+ WorkTransitions int64

+ WorkflowTaggedEvents int64

+ type Surface string

+ const SurfaceDirect

+ const SurfaceThread

+ func (s Surface) Validate() error

+ type TaskIngressAudit struct

+ Action string

+ Channel string

+ Direction string

+ Payload any

+ PeerID string

+ Reason string

+ RequestID string

+ WorkspaceID string

+ type TaskIngressAuditWriter interface

+ RecordTaskIngress func(ctx context.Context, audit TaskIngressAudit) error

+ type TaskIngressContext struct

+ CausationID string

+ Channel string

+ DirectID string

+ PeerID string

+ ReplyTo string

+ RequestID string

+ Surface Surface

+ ThreadID string

+ TraceID string

+ WorkID string

+ WorkspaceID string

+ func (c TaskIngressContext) Validate() error

+ type TaskService interface

+ CancelTask func(ctx context.Context, id string, req taskpkg.CancelTask, ...) (*taskpkg.Task, error)

+ CreateTask func(ctx context.Context, spec taskpkg.CreateTask, actor taskpkg.ActorContext) (*taskpkg.Task, error)

+ EnqueueRun func(ctx context.Context, spec taskpkg.EnqueueRun, actor taskpkg.ActorContext) (*taskpkg.Run, error)

+ GetTask func(ctx context.Context, id string, actor taskpkg.ActorContext) (*taskpkg.View, error)

+ UpdateTask func(ctx context.Context, id string, patch taskpkg.Patch, ...) (*taskpkg.Task, error)

+ type TraceBody struct

+ ArtifactRefs []json.RawMessage

+ Message string

+ Result json.RawMessage

+ State WorkState

+ func (TraceBody) Kind() Kind

+ type Transport struct

+ func NewTransport(ctx context.Context, cfg aghconfig.NetworkConfig, opts ...TransportOption) (*Transport, error)

+ func (t *Transport) ClientURL() string

+ func (t *Transport) Drain(ctx context.Context) error

+ func (t *Transport) Port() int

+ func (t *Transport) Publish(ctx context.Context, subject string, payload []byte) error

+ func (t *Transport) Shutdown(ctx context.Context) error

+ func (t *Transport) Subscribe(subject string, handler func(*nats.Msg)) (*nats.Subscription, error)

+ type TransportOption func(*transportOptions)

+ func WithTransportDisconnectHandler(handler func(error)) TransportOption

+ func WithTransportLogger(logger *slog.Logger) TransportOption

+ func WithTransportPublishTimeout(timeout time.Duration) TransportOption

+ func WithTransportReadyTimeout(timeout time.Duration) TransportOption

+ func WithTransportReconnectHandler(handler func()) TransportOption

+ type ValidateOptions struct

+ MaxReplayAge time.Duration

+ Now time.Time

+ type WhoisBody struct

+ PeerCard *PeerCard

+ Query string

+ Type WhoisType

+ func (WhoisBody) Kind() Kind

+ type WhoisType string

+ const WhoisTypeRequest

+ const WhoisTypeResponse

+ func (t WhoisType) Validate() error

+ type Work struct

+ CreatedAt time.Time

+ ID string

+ Initiator string

+ Ref ConversationRef

+ State WorkState

+ Target string

+ TerminalAt *time.Time

+ UpdatedAt time.Time

+ func OpenWork(env Envelope, at time.Time) (Work, error)

+ func (i Work) IsParticipant(peerID string) bool

+ func (i Work) Validate() error

+ type WorkState string

+ const WorkStateCanceled

+ const WorkStateCompleted

+ const WorkStateFailed

+ const WorkStateNeedsInput

+ const WorkStateSubmitted

+ const WorkStateWorking

+ func (s WorkState) Validate() error

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