v1

package

Go to main page

Versions in this module

v0

v0.13.2

Oct 16, 2026

v0.13.1

Sep 29, 2026

v0.13.0

Sep 27, 2026

Changes in this version

+ const HostLinkCapabilityPayloadReference

v0.12.0

Sep 25, 2026

Changes in this version

+ const HostLinkCapabilityAttributionPrincipal

+ const MaxMetadataBytes

+ const MaxMetadataFields

+ const MaxMetadataKeyBytes

+ const MaxMetadataValueBytes

type CreateRequest

+ Metadata MessageMetadata

+ Principal *Principal

type GateResponseRequest

+ Principal *Principal

type InputRequest

+ Metadata MessageMetadata

+ Principal *Principal

type InterruptRequest

+ Principal *Principal

+ type MessageMetadata map[string]string

+ func (m MessageMetadata) Validate() error

+ type MetadataValidationCode string

+ const MetadataValidationCodeInvalidKey

+ const MetadataValidationCodeInvalidValue

+ const MetadataValidationCodeReservedKey

+ const MetadataValidationCodeTooLarge

+ const MetadataValidationCodeTooManyFields

+ const MetadataValidationCodeValueTooLarge

+ type MetadataValidationError struct

+ Code MetadataValidationCode

+ Key string

+ func (e *MetadataValidationError) Error() string

+ func (e *MetadataValidationError) Unwrap() error

+ type Principal struct

+ Kind PrincipalKind

+ Subject SubjectID

+ Tenant TenantID

+ func (p *Principal) UnmarshalJSON(data []byte) error

+ func (p Principal) MarshalJSON() ([]byte, error)

+ func (p Principal) Validate() error

+ type PrincipalKind string

+ const PrincipalKindActor

+ const PrincipalKindService

type RestoreRequest

+ Principal *Principal

+ type SubjectID string

+ func (id SubjectID) Validate() error

v0.11.0

Sep 19, 2026

Changes in this version

+ const HostLinkCapabilityGateResponse

v0.10.0

Sep 19, 2026

Changes in this version

+ const HostLinkPathPrefix

+ type HostLinkEndpointCode string

+ const HostLinkEndpointCodeBaseNamesTenant

+ const HostLinkEndpointCodeBaseNotBare

+ const HostLinkEndpointCodeInvalidBase

+ const HostLinkEndpointCodeInvalidTenant

+ const HostLinkEndpointCodeTooLong

+ const HostLinkEndpointCodeUnroutableTenant

+ type HostLinkEndpointError struct

+ Code HostLinkEndpointCode

+ Err error

+ func (e *HostLinkEndpointError) Error() string

+ func (e *HostLinkEndpointError) Unwrap() error

type InternalEndpoint

+ func HostLinkEndpoint(base InternalEndpoint, tenant TenantID) (InternalEndpoint, error)

v0.9.1

Sep 17, 2026

v0.9.0

Sep 16, 2026

Changes in this version

+ func EncodeHostLinkConnectReply(response VersionNegotiationResponse) ([]byte, error)

+ func EncodeHostLinkConnectRequest(request VersionNegotiationRequest) ([]byte, error)

type VersionNegotiationRequest

+ func DecodeHostLinkConnectRequest(data []byte) (VersionNegotiationRequest, error)

type VersionNegotiationResponse

+ func DecodeHostLinkConnectReply(data []byte) (VersionNegotiationResponse, error)

+ func (r VersionNegotiationResponse) HostLinkMethods() []string

+ func (r VersionNegotiationResponse) Supports(method string) bool

+ func (r VersionNegotiationResponse) WithHostLinkMethods(methods ...string) VersionNegotiationResponse

v0.8.0

Sep 15, 2026

Changes in this version

+ const HostLinkChannelPrefix

+ const HostLinkMethodAttach

+ const HostLinkMethodBind

+ const HostLinkMethodDrain

+ const HostLinkMethodDrainStatus

+ const HostLinkMethodUnbind

+ func HostLinkChannel(tenantID TenantID, sessionID SessionID) string

+ type HostLinkAttachMode string

+ const HostLinkAttachModeCreate

+ const HostLinkAttachModeRestore

+ type HostLinkAttachRequest struct

+ ActorID string

+ AgentID AgentID

+ HostGeneration uint64

+ HostID HostID

+ IdempotencyKey string

+ Mode HostLinkAttachMode

+ RuntimeCompatibilityID string

+ SessionID SessionID

+ TenantID TenantID

+ TraceID string

+ Version WireVersion

+ func (r *HostLinkAttachRequest) UnmarshalJSON(data []byte) error

+ func (r HostLinkAttachRequest) MarshalJSON() ([]byte, error)

+ func (r HostLinkAttachRequest) Validate() error

v0.7.0

Aug 29, 2026

Changes in this version

+ const MaxIDBytes

+ func CanonicalDeadlineUnixMillis(deadline time.Time) string

+ type AgentCapabilitySummary struct

+ AgentID AgentID

+ Capabilities []string

+ RuntimeCompatibilityID string

+ func (s *AgentCapabilitySummary) UnmarshalJSON(data []byte) error

+ func (s AgentCapabilitySummary) AdditionalFields() map[string]json.RawMessage

+ func (s AgentCapabilitySummary) MarshalJSON() ([]byte, error)

+ func (s AgentCapabilitySummary) Validate() error

+ type AgentID string

+ func (id AgentID) Validate() error

+ type CommandEnvelope struct

+ CommandID CommandID

+ Version WireVersion

+ func (e CommandEnvelope) Validate() error

+ type CommandID string

+ func DeterministicCommandID(domain string, fields ...string) (CommandID, error)

+ func (id *CommandID) UnmarshalJSON(data []byte) error

+ func (id CommandID) Validate() error

+ type CommandIDFramingCode string

+ const CommandIDFramingCodeFieldTooLong

+ const CommandIDFramingCodeTooManyFields

+ type CommandIDFramingError struct

+ Code CommandIDFramingCode

+ func (e *CommandIDFramingError) Error() string

+ type CommandState string

+ const CommandStateAccepted

+ const CommandStateApplied

+ const CommandStatePending

+ const CommandStateRejected

+ type CommandStatus struct

+ AcceptedOrder uint64

+ CommandID CommandID

+ Error *ErrorDetail

+ State CommandState

+ func (s *CommandStatus) UnmarshalJSON(data []byte) error

+ func (s CommandStatus) AdditionalFields() map[string]json.RawMessage

+ func (s CommandStatus) MarshalJSON() ([]byte, error)

+ func (s CommandStatus) Validate() error

+ type CreateRequest struct

+ AgentID AgentID

+ Blocks json.RawMessage

+ SessionID SessionID

+ func (r *CreateRequest) UnmarshalJSON(data []byte) error

+ func (r CreateRequest) Validate() error

+ type Cursor string

+ type DepartmentCapabilitySummary struct

+ Agents []AgentCapabilitySummary

+ func (s *DepartmentCapabilitySummary) UnmarshalJSON(data []byte) error

+ func (s DepartmentCapabilitySummary) AdditionalFields() map[string]json.RawMessage

+ func (s DepartmentCapabilitySummary) MarshalJSON() ([]byte, error)

+ func (s DepartmentCapabilitySummary) Validate() error

+ type EnduringPublication struct

+ Body json.RawMessage

+ CoveredThrough uint64

+ EventID EventID

+ JournalSeq uint64

+ SessionID SessionID

+ TenantID TenantID

+ func (p *EnduringPublication) UnmarshalJSON(data []byte) error

+ func (p EnduringPublication) AdditionalFields() map[string]json.RawMessage

+ func (p EnduringPublication) MarshalJSON() ([]byte, error)

+ func (p EnduringPublication) RecordType() SessionRecordType

+ func (p EnduringPublication) Validate() error

+ type EphemeralPublication struct

+ Body json.RawMessage

+ SessionID SessionID

+ TenantID TenantID

+ func (p *EphemeralPublication) UnmarshalJSON(data []byte) error

+ func (p EphemeralPublication) AdditionalFields() map[string]json.RawMessage

+ func (p EphemeralPublication) MarshalJSON() ([]byte, error)

+ func (p EphemeralPublication) RecordType() SessionRecordType

+ func (p EphemeralPublication) Validate() error

+ type ErrorCode string

+ const ErrorCodeCommandRejected

+ const ErrorCodeGateExpired

+ const ErrorCodeGateNotResumable

+ const ErrorCodeGateResolved

+ const ErrorCodeGateResponseInvalid

+ const ErrorCodeInvalidRequest

+ const ErrorCodeRuntimeUnavailable

+ const ErrorCodeSessionNotFound

+ const ErrorCodeUnsupportedVersion

+ type ErrorDetail struct

+ Code ErrorCode

+ Message string

+ Retryable bool

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

+ func (e ErrorDetail) AdditionalFields() map[string]json.RawMessage

+ func (e ErrorDetail) MarshalJSON() ([]byte, error)

+ func (e ErrorDetail) Validate() error

+ type ErrorEnvelope struct

+ Error ErrorDetail

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

+ func (e ErrorEnvelope) AdditionalFields() map[string]json.RawMessage

+ func (e ErrorEnvelope) MarshalJSON() ([]byte, error)

+ func (e ErrorEnvelope) Validate() error

+ type EventID string

+ func (id EventID) Validate() error

+ type GateAnswerability string

+ const GateAnswerabilityExpired

+ const GateAnswerabilityResident

+ const GateAnswerabilitySubmitted

+ const GateAnswerabilitySuspended

+ const GateAnswerabilityUnavailable

+ type GateControl struct

+ Action string

+ Label string

+ func (c *GateControl) UnmarshalJSON(data []byte) error

+ func (c GateControl) AdditionalFields() map[string]json.RawMessage

+ func (c GateControl) MarshalJSON() ([]byte, error)

+ type GateFieldKind string

+ const GateFieldKindConfirm

+ const GateFieldKindMultiSelect

+ const GateFieldKindSelect

+ const GateFieldKindText

+ type GateID string

+ func (id GateID) Validate() error

+ type GatePage struct

+ Gates []GateProjection

+ JournalTip uint64

+ NextCursor Cursor

+ OpenGateCount uint64

+ PreviousCursor Cursor

+ func (p *GatePage) UnmarshalJSON(data []byte) error

+ func (p GatePage) AdditionalFields() map[string]json.RawMessage

+ func (p GatePage) MarshalJSON() ([]byte, error)

+ func (p GatePage) Validate() error

+ type GateProjection struct

+ Answerability GateAnswerability

+ Deadline time.Time

+ GateID GateID

+ Kind string

+ OpenedEventID EventID

+ OpenedJournalSeq uint64

+ Prompt GatePrompt

+ func (p *GateProjection) UnmarshalJSON(data []byte) error

+ func (p GateProjection) AdditionalFields() map[string]json.RawMessage

+ func (p GateProjection) MarshalJSON() ([]byte, error)

+ func (p GateProjection) Validate() error

+ type GatePrompt struct

+ Body string

+ Controls []GateControl

+ Origin string

+ Schema GatePromptSchema

+ Title string

+ func (p *GatePrompt) UnmarshalJSON(data []byte) error

+ func (p GatePrompt) AdditionalFields() map[string]json.RawMessage

+ func (p GatePrompt) MarshalJSON() ([]byte, error)

+ func (p GatePrompt) Validate() error

+ type GatePromptField struct

+ Default json.RawMessage

+ Kind GateFieldKind

+ Label string

+ Name string

+ Options []GatePromptOption

+ Required bool

+ func (f *GatePromptField) UnmarshalJSON(data []byte) error

+ func (f GatePromptField) AdditionalFields() map[string]json.RawMessage

+ func (f GatePromptField) MarshalJSON() ([]byte, error)

+ func (f GatePromptField) Validate() error

+ type GatePromptOption struct

+ Label string

+ Value string

+ func (o *GatePromptOption) UnmarshalJSON(data []byte) error

+ func (o GatePromptOption) AdditionalFields() map[string]json.RawMessage

+ func (o GatePromptOption) MarshalJSON() ([]byte, error)

+ type GatePromptSchema struct

+ Fields []GatePromptField

+ func (s *GatePromptSchema) UnmarshalJSON(data []byte) error

+ func (s GatePromptSchema) AdditionalFields() map[string]json.RawMessage

+ func (s GatePromptSchema) MarshalJSON() ([]byte, error)

+ func (s GatePromptSchema) Validate() error

+ type GateResponseRequest struct

+ Action string

+ ExpectedOpenEventID EventID

+ ExpectedOpenJournalSeq uint64

+ GateID GateID

+ SessionID SessionID

+ Values map[string]json.RawMessage

+ func (r *GateResponseRequest) UnmarshalJSON(data []byte) error

+ func (r GateResponseRequest) Validate() error

+ type HostID string

+ func (id HostID) Validate() error

+ type HostIsolationClass string

+ const HostIsolationClassCrossTenantIsolated

+ const HostIsolationClassTenantExclusive

+ type HostLinkBindRequest struct

+ HostGeneration uint64

+ HostID HostID

+ IdempotencyKey string

+ LeaseEpoch uint64

+ RuntimeCompatibilityID string

+ SessionID SessionID

+ TenantID TenantID

+ Version WireVersion

+ func (r *HostLinkBindRequest) UnmarshalJSON(data []byte) error

+ func (r HostLinkBindRequest) MarshalJSON() ([]byte, error)

+ func (r HostLinkBindRequest) Validate() error

+ type HostLinkCapacityReport struct

+ Accepting bool

+ AgentID AgentID

+ AvailableCapacity uint64

+ ExpiresAt time.Time

+ HostGeneration uint64

+ HostID HostID

+ InternalEndpoint InternalEndpoint

+ IsolationClass HostIsolationClass

+ ObservedAt time.Time

+ Placement HostPlacement

+ RuntimeCompatibilityID string

+ Version WireVersion

+ func (r *HostLinkCapacityReport) UnmarshalJSON(data []byte) error

+ func (r HostLinkCapacityReport) MarshalJSON() ([]byte, error)

+ func (r HostLinkCapacityReport) Validate() error

+ type HostLinkCommandDelivery struct

+ CommandID CommandID

+ func (d *HostLinkCommandDelivery) UnmarshalJSON(data []byte) error

+ func (d HostLinkCommandDelivery) MarshalJSON() ([]byte, error)

+ func (d HostLinkCommandDelivery) Validate() error

+ type HostLinkDrainObservation struct

+ DrainGeneration uint64

+ HostGeneration uint64

+ HostID HostID

+ SessionID SessionID

+ State HostLinkDrainState

+ TenantID TenantID

+ func (o *HostLinkDrainObservation) UnmarshalJSON(data []byte) error

+ func (o HostLinkDrainObservation) MarshalJSON() ([]byte, error)

+ func (o HostLinkDrainObservation) Validate() error

+ type HostLinkDrainRequest struct

+ HostGeneration uint64

+ HostID HostID

+ IdempotencyKey string

+ SessionID SessionID

+ TenantID TenantID

+ Version WireVersion

+ func (r *HostLinkDrainRequest) UnmarshalJSON(data []byte) error

+ func (r HostLinkDrainRequest) MarshalJSON() ([]byte, error)

+ func (r HostLinkDrainRequest) Validate() error

+ type HostLinkDrainState string

+ const HostLinkDrainStateDrained

+ const HostLinkDrainStateDraining

+ type HostLinkError struct

+ Code HostLinkErrorCode

+ CurrentLeaseEpoch uint64

+ RuntimeCompatibilityID string

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

+ func (e HostLinkError) MarshalJSON() ([]byte, error)

+ func (e HostLinkError) Validate() error

+ type HostLinkErrorCode string

+ const HostLinkErrorEpochMismatch

+ const HostLinkErrorNoCapacity

+ const HostLinkErrorNotAdmitting

+ const HostLinkErrorReleasing

+ const HostLinkErrorRuntimeMismatch

+ const HostLinkErrorRuntimeUnavailable

+ type HostLinkRegistryObservation struct

+ Accepting bool

+ AgentID AgentID

+ ExpiresAt time.Time

+ HostGeneration uint64

+ HostID HostID

+ InternalEndpoint InternalEndpoint

+ LeaseEpoch uint64

+ ObservedAt time.Time

+ Placement HostPlacement

+ Residency SessionResidency

+ RuntimeCompatibilityID string

+ SessionID SessionID

+ TenantID TenantID

+ Version WireVersion

+ func (r *HostLinkRegistryObservation) UnmarshalJSON(data []byte) error

+ func (r HostLinkRegistryObservation) MarshalJSON() ([]byte, error)

+ func (r HostLinkRegistryObservation) Validate() error

+ type HostLinkUnbindRequest struct

+ HostGeneration uint64

+ HostID HostID

+ IdempotencyKey string

+ LeaseEpoch uint64

+ SessionID SessionID

+ TenantID TenantID

+ Version WireVersion

+ func (r *HostLinkUnbindRequest) UnmarshalJSON(data []byte) error

+ func (r HostLinkUnbindRequest) MarshalJSON() ([]byte, error)

+ func (r HostLinkUnbindRequest) Validate() error

+ type HostPlacement string

+ const HostPlacementDedicated

+ const HostPlacementPooled

+ type IDValidationCode string

+ const IDValidationCodeEmpty

+ const IDValidationCodeInvalidUTF8

+ const IDValidationCodeTooLong

+ type IDValidationError struct

+ Code IDValidationCode

+ func (e *IDValidationError) Error() string

+ type InputRequest struct

+ Blocks json.RawMessage

+ SessionID SessionID

+ func (r *InputRequest) UnmarshalJSON(data []byte) error

+ func (r InputRequest) Validate() error

+ type InternalEndpoint string

+ func (endpoint InternalEndpoint) Validate() error

+ type InterruptRequest struct

+ SessionID SessionID

+ func (r *InterruptRequest) UnmarshalJSON(data []byte) error

+ func (r InterruptRequest) Validate() error

+ type JournalEvent struct

+ Body json.RawMessage

+ EventID EventID

+ JournalSeq uint64

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

+ func (e JournalEvent) AdditionalFields() map[string]json.RawMessage

+ func (e JournalEvent) MarshalJSON() ([]byte, error)

+ func (e JournalEvent) Validate() error

+ type JournalPage struct

+ CapturedTip uint64

+ CoveredThrough uint64

+ Events []JournalEvent

+ NextCursor Cursor

+ PreviousCursor Cursor

+ func (p *JournalPage) UnmarshalJSON(data []byte) error

+ func (p JournalPage) AdditionalFields() map[string]json.RawMessage

+ func (p JournalPage) MarshalJSON() ([]byte, error)

+ func (p JournalPage) Validate() error

+ type JournalTip struct

+ SessionID SessionID

+ TenantID TenantID

+ Tip uint64

+ func (h *JournalTip) UnmarshalJSON(data []byte) error

+ func (h JournalTip) AdditionalFields() map[string]json.RawMessage

+ func (h JournalTip) MarshalJSON() ([]byte, error)

+ func (h JournalTip) RecordType() SessionRecordType

+ func (h JournalTip) Validate() error

+ type ObjectMetadata struct

+ CreatedAt time.Time

+ Digest string

+ MediaType string

+ Reference ObjectReference

+ SizeBytes uint64

+ func (m *ObjectMetadata) UnmarshalJSON(data []byte) error

+ func (m ObjectMetadata) Validate() error

+ type ObjectReference struct

+ ObjectID string

+ func (r *ObjectReference) UnmarshalJSON(data []byte) error

+ func (r ObjectReference) Validate() error

+ type RequestValidationCode string

+ const RequestValidationCodeDuplicateField

+ const RequestValidationCodeInvalidField

+ const RequestValidationCodeInvalidJSON

+ const RequestValidationCodeMissingField

+ const RequestValidationCodeUnknownField

+ const RequestValidationCodeUnsupportedVersion

+ type RequestValidationError struct

+ Code RequestValidationCode

+ Field string

+ func (e *RequestValidationError) Error() string

+ type RestoreRequest struct

+ SessionID SessionID

+ func (r *RestoreRequest) UnmarshalJSON(data []byte) error

+ func (r RestoreRequest) Validate() error

+ type SessionID string

+ func (id SessionID) Validate() error

+ type SessionPage struct

+ NextCursor Cursor

+ PreviousCursor Cursor

+ Sessions []SessionSummary

+ func (p *SessionPage) UnmarshalJSON(data []byte) error

+ func (p SessionPage) AdditionalFields() map[string]json.RawMessage

+ func (p SessionPage) MarshalJSON() ([]byte, error)

+ func (p SessionPage) Validate() error

+ type SessionRecordType string

+ const SessionRecordTypeEnduringPublication

+ const SessionRecordTypeEphemeralPublication

+ const SessionRecordTypeJournalTip

+ const SessionRecordTypeSessionReset

+ func SessionRecordTypeOf(data []byte) (SessionRecordType, error)

+ type SessionReset struct

+ JournalTip uint64

+ LastContiguous uint64

+ SessionID SessionID

+ TenantID TenantID

+ func (r *SessionReset) UnmarshalJSON(data []byte) error

+ func (r SessionReset) AdditionalFields() map[string]json.RawMessage

+ func (r SessionReset) MarshalJSON() ([]byte, error)

+ func (r SessionReset) RecordType() SessionRecordType

+ func (r SessionReset) Validate() error

+ type SessionResidency string

+ const SessionResidencyAttaching

+ const SessionResidencyCold

+ const SessionResidencyReleasing

+ const SessionResidencyResident

+ type SessionState string

+ const SessionStateFailed

+ const SessionStateIdle

+ const SessionStateInterrupted

+ const SessionStateRestoring

+ const SessionStateRunning

+ const SessionStateStopped

+ const SessionStateSuspended

+ const SessionStateWaitingOnGate

+ type SessionStatus struct

+ AgentID AgentID

+ JournalTip uint64

+ Residency SessionResidency

+ SessionID SessionID

+ State SessionState

+ UpdatedAt time.Time

+ WaitingGateID GateID

+ func (s *SessionStatus) UnmarshalJSON(data []byte) error

+ func (s SessionStatus) AdditionalFields() map[string]json.RawMessage

+ func (s SessionStatus) MarshalJSON() ([]byte, error)

+ func (s SessionStatus) Validate() error

+ type SessionSummary struct

+ AgentID AgentID

+ CreatedAt time.Time

+ LastActiveAt time.Time

+ SessionID SessionID

+ State SessionState

+ Title string

+ func (s *SessionSummary) UnmarshalJSON(data []byte) error

+ func (s SessionSummary) AdditionalFields() map[string]json.RawMessage

+ func (s SessionSummary) MarshalJSON() ([]byte, error)

+ func (s SessionSummary) Validate() error

+ type TenantID string

+ func (id TenantID) Validate() error

+ type VersionNegotiationRequest struct

+ SupportedVersions []WireVersion

+ func (r *VersionNegotiationRequest) UnmarshalJSON(data []byte) error

+ func (r VersionNegotiationRequest) MarshalJSON() ([]byte, error)

+ func (r VersionNegotiationRequest) Validate() error

+ type VersionNegotiationResponse struct

+ Version WireVersion

+ func NegotiateVersion(request VersionNegotiationRequest) (VersionNegotiationResponse, error)

+ func (r *VersionNegotiationResponse) UnmarshalJSON(data []byte) error

+ func (r VersionNegotiationResponse) AdditionalFields() map[string]json.RawMessage

+ func (r VersionNegotiationResponse) MarshalJSON() ([]byte, error)

+ func (r VersionNegotiationResponse) Validate() error

+ type WireVersion uint8

+ const CurrentWireVersion

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