sessionstore

package module

Go to main page

Versions in this module

v0

v0.9.0

Sep 13, 2026

Changes in this version

type DispositionOutcomeKind

+ const DispositionRefused

type Envelope

+ AttemptID string

+ AttemptJournalEpoch uint64

+ DispositionKind string

type EnvelopeKind

+ const EnvelopeKindCommandDisposition

type Option

+ func WithJournalDispositionEvidence() Option

type Store

+ func (s *Store) ReadDispositionEvidence(ctx context.Context, req DispositionEvidenceRequest) (DispositionEvidence, error)

v0.8.0

Sep 12, 2026

Changes in this version

+ type ClaimDispositionCommandRequest struct

+ ClaimExpiresAt time.Time

+ CommandID sessionwire.CommandID

+ ExpectedRevision uint64

+ Residency *ResidencyGrant

+ SessionID sessionwire.SessionID

+ TenantID sessionwire.TenantID

+ type RejectDispositionCommandRequest struct

+ CommandID sessionwire.CommandID

+ ExpectedRevision uint64

+ ResidencyEpoch ResidencyEpoch

+ SessionID sessionwire.SessionID

+ TenantID sessionwire.TenantID

type Store

+ func (s *Store) ClaimDispositionCommand(ctx context.Context, req ClaimDispositionCommandRequest) (DispositionInboxEntry, bool, error)

+ func (s *Store) RejectDispositionCommand(ctx context.Context, req RejectDispositionCommandRequest) (DispositionInboxEntry, bool, error)

v0.7.0

Sep 12, 2026

Changes in this version

+ const DispositionCommandCursorRecordVersion

+ const MaxDispositionCommandCursorRecordBytes

+ type DispositionCommandCursor struct

+ ConsumedOrder uint64

+ LeaseEpoch uint64

+ SessionID sessionwire.SessionID

+ TenantID sessionwire.TenantID

+ UpdatedAt time.Time

+ type DispositionCommandCursorEntry struct

+ Cursor DispositionCommandCursor

+ Revision uint64

type InboxError

+ Order uint64

type InboxErrorCode

+ const InboxErrorOrder

+ type ListSessionDispositionCommandsRequest struct

+ AfterOrder uint64

+ Limit int

+ SessionID sessionwire.SessionID

+ TenantID sessionwire.TenantID

+ type LoadDispositionCommandCursorRequest struct

+ SessionID sessionwire.SessionID

+ TenantID sessionwire.TenantID

+ type SaveDispositionCommandCursorRequest struct

+ ConsumedOrder uint64

+ LeaseEpoch uint64

+ SessionID sessionwire.SessionID

+ TenantID sessionwire.TenantID

+ type SessionDispositionCommandPage struct

+ Commands []DispositionInboxEntry

+ Limit int

+ NextAfterOrder uint64

type Store

+ func (s *Store) ListSessionDispositionCommands(ctx context.Context, req ListSessionDispositionCommandsRequest) (SessionDispositionCommandPage, error)

+ func (s *Store) LoadDispositionCommandCursor(ctx context.Context, req LoadDispositionCommandCursorRequest) (DispositionCommandCursorEntry, error)

+ func (s *Store) SaveDispositionCommandCursor(ctx context.Context, req SaveDispositionCommandCursorRequest) (DispositionCommandCursorEntry, error)

v0.6.0

Sep 9, 2026

Changes in this version

+ type BeginDispositionAttemptRequest struct

+ AttemptID DispositionAttemptID

+ CommandID sessionwire.CommandID

+ ExpectedRevision uint64

+ JournalEpoch JournalEpoch

+ ResidencyEpoch ResidencyEpoch

+ SessionID sessionwire.SessionID

+ StartedAt time.Time

+ TenantID sessionwire.TenantID

+ type DispositionAttempt struct

+ AttemptID DispositionAttemptID

+ JournalEpoch JournalEpoch

+ ResidencyEpoch ResidencyEpoch

+ StartedAt time.Time

+ type DispositionAttemptID string

+ type DispositionClaim struct

+ ExpiresAt time.Time

+ ResidencyEpoch ResidencyEpoch

+ type DispositionEvidence struct

+ AttemptID DispositionAttemptID

+ AttemptJournalEpoch JournalEpoch

+ AuthorFenceSeq uint64

+ AuthorJournalEpoch JournalEpoch

+ DispositionSeq uint64

+ EventID sessionwire.EventID

+ EventSeq uint64

+ Kind DispositionOutcomeKind

+ type DispositionEvidenceReader interface

+ ReadDispositionEvidence func(ctx context.Context, req DispositionEvidenceRequest) (DispositionEvidence, error)

+ type DispositionEvidenceRequest struct

+ Attempt DispositionAttempt

+ Binding SessionBinding

+ CommandID sessionwire.CommandID

+ Kind CommandKind

+ RuntimeCommandID RuntimeCommandID

+ SessionID sessionwire.SessionID

+ TenantID sessionwire.TenantID

type DispositionInboxRecord

+ Attempt *DispositionAttempt

+ Claim *DispositionClaim

+ Outcome *DispositionOutcome

+ type DispositionOutcome struct

+ AttemptID DispositionAttemptID

+ AttemptJournalEpoch JournalEpoch

+ AuthorFenceSeq uint64

+ AuthorJournalEpoch JournalEpoch

+ DispositionSeq uint64

+ EventID sessionwire.EventID

+ EventSeq uint64

+ Kind DispositionOutcomeKind

+ SettledAt time.Time

+ SettlingResidencyEpoch ResidencyEpoch

+ type DispositionOutcomeKind string

+ const DispositionApplied

+ const DispositionNoOp

+ const DispositionNotApplied

+ type JournalEpoch uint64

type Option

+ func WithDispositionEvidence(reader DispositionEvidenceReader) Option

+ type SettleDispositionCommandRequest struct

+ CommandID sessionwire.CommandID

+ ExpectedRevision uint64

+ ResidencyEpoch ResidencyEpoch

+ SessionID sessionwire.SessionID

+ TenantID sessionwire.TenantID

type Store

+ func (s *Store) BeginDispositionAttempt(ctx context.Context, req BeginDispositionAttemptRequest) (DispositionInboxEntry, error)

+ func (s *Store) SettleDispositionCommand(ctx context.Context, req SettleDispositionCommandRequest) (DispositionInboxEntry, bool, error)

v0.5.0

Sep 5, 2026

Changes in this version

+ const CatalogPublicCreateRecordVersion

+ const DispositionInboxRecordVersion

+ const PublicCreateReservationVersion

+ type AdmitDispositionCommandRequest struct

+ AcceptedAt time.Time

+ ApplyDeadline time.Time

+ Binding SessionBinding

+ CommandID sessionwire.CommandID

+ Kind CommandKind

+ Payload []byte

+ PayloadObject *sessionwire.ObjectMetadata

+ ProposedRuntimeCommandID RuntimeCommandID

+ SessionID sessionwire.SessionID

+ TenantID sessionwire.TenantID

+ type AdmitPublicCreateRequest struct

+ Identity PublicCreateIdentity

+ Payload []byte

+ PayloadObject *sessionwire.ObjectMetadata

type CatalogRecord

+ PublicCreate *PublicCreateReservation

+ type DispositionCommandDescriptor struct

+ Binding SessionBinding

+ CommandID sessionwire.CommandID

+ Kind CommandKind

+ Payload []byte

+ PayloadDigest string

+ PayloadObject *sessionwire.ObjectMetadata

+ PayloadSize uint64

+ PublicCreate bool

+ RuntimeCommandID RuntimeCommandID

+ SessionID sessionwire.SessionID

+ TenantID sessionwire.TenantID

+ type DispositionDueCommandPage struct

+ Commands []DispositionInboxEntry

+ Examined int

+ Limit int

+ NextCursor sessionwire.Cursor

+ Unreadable int

+ type DispositionInboxEntry struct

+ AcceptedOrder uint64

+ Record DispositionInboxRecord

+ Revision uint64

+ type DispositionInboxRecord struct

+ AcceptedAt time.Time

+ ApplyDeadline time.Time

+ Descriptor DispositionCommandDescriptor

+ State InboxState

+ type GetDispositionCommandRequest struct

+ CommandID sessionwire.CommandID

+ SessionID sessionwire.SessionID

+ TenantID sessionwire.TenantID

+ type ListDueDispositionCommandsRequest struct

+ Cursor sessionwire.Cursor

+ DueAtOrBefore time.Time

+ Limit int

+ Shard int

+ type PreparePublicCreateRequest struct

+ AcceptedAt time.Time

+ ApplyDeadline time.Time

+ Identity PublicCreateIdentity

+ InitialWorkload DesiredWorkload

+ ProposedRuntimeCommandID RuntimeCommandID

+ type PublicCreateIdentity struct

+ Binding SessionBinding

+ CommandID sessionwire.CommandID

+ Kind CommandKind

+ PayloadDigest string

+ PayloadSize uint64

+ SessionID sessionwire.SessionID

+ Target HostTargetKey

+ TenantID sessionwire.TenantID

+ type PublicCreatePreparation struct

+ Catalog CatalogEntry

+ Reservation PublicCreateReservation

+ type PublicCreateReservation struct

+ AcceptedAt time.Time

+ ApplyDeadline time.Time

+ Identity PublicCreateIdentity

+ InitialWorkload DesiredWorkload

+ RuntimeCommandID RuntimeCommandID

+ type PutCommandPayloadRequest struct

+ Body io.Reader

+ MediaType string

+ SHA256 [32]byte

+ SessionID sessionwire.SessionID

+ SizeBytes uint64

+ TenantID sessionwire.TenantID

type Store

+ func (s *Store) AdmitDispositionCommand(ctx context.Context, req AdmitDispositionCommandRequest) (DispositionInboxEntry, bool, error)

+ func (s *Store) AdmitPublicCreate(ctx context.Context, req AdmitPublicCreateRequest) (DispositionInboxEntry, bool, error)

+ func (s *Store) GetDispositionCommand(ctx context.Context, req GetDispositionCommandRequest) (DispositionInboxEntry, error)

+ func (s *Store) ListDueDispositionCommands(ctx context.Context, req ListDueDispositionCommandsRequest) (DispositionDueCommandPage, error)

+ func (s *Store) PreparePublicCreate(ctx context.Context, req PreparePublicCreateRequest) (PublicCreatePreparation, error)

+ func (s *Store) PutCommandPayload(ctx context.Context, req PutCommandPayloadRequest) (sessionwire.ObjectMetadata, error)

v0.4.0

Sep 5, 2026

Changes in this version

+ const CatalogBindingRecordVersion

+ type AcquireResidencyRequest struct

+ SessionID sessionwire.SessionID

+ TenantID sessionwire.TenantID

type CatalogRecord

+ Binding SessionBinding

type CreateCatalogEntryRequest

+ Binding SessionBinding

+ type GetObjectMetadataRequest struct

+ ExpectedKind ObjectKind

+ Reference sessionwire.ObjectReference

+ SessionID sessionwire.SessionID

+ TenantID sessionwire.TenantID

type ObjectErrorCode

+ const ObjectErrorMetadataUnavailable

+ type ProtocolMode string

+ const ProtocolModeDisposition

+ const ProtocolModeLegacy

+ type ResidencyAcquireCleanupError struct

+ func (e *ResidencyAcquireCleanupError) Error() string

+ func (e *ResidencyAcquireCleanupError) Release(ctx context.Context) error

+ func (e *ResidencyAcquireCleanupError) Unwrap() error

+ type ResidencyEpoch uint64

+ type ResidencyError struct

+ Cause error

+ Operation string

+ func (e *ResidencyError) Error() string

+ func (e *ResidencyError) Unwrap() error

+ type ResidencyGrant struct

+ func (g *ResidencyGrant) Epoch() ResidencyEpoch

+ func (g *ResidencyGrant) Lost() <-chan struct{}

+ func (g *ResidencyGrant) Release(ctx context.Context) error

+ type SessionBinding struct

+ BindingVersion string

+ ProtocolMode ProtocolMode

+ RuntimeSessionID string

+ StorageBindingID string

type Store

+ func (s *Store) AcquireResidency(ctx context.Context, req AcquireResidencyRequest) (*ResidencyGrant, error)

+ func (s *Store) GetObjectMetadata(ctx context.Context, req GetObjectMetadataRequest) (sessionwire.ObjectMetadata, error)

v0.3.0

Sep 5, 2026

Changes in this version

type ReadPublicJournalRequest

+ ScanLimit int

v0.2.0

Sep 5, 2026

Changes in this version

type ReadPublicJournalRequest

+ Tail bool

v0.1.0

Sep 1, 2026

Changes in this version

+ const CatalogRecordVersion

+ const DefaultControlShards

+ const DefaultHostTargetReconcilePages

+ const DefaultJournalOverflowThresholdBytes

+ const DefaultJournalPageBytes

+ const DefaultShutdownTimeout

+ const EnvelopeVersion

+ const GateIntentRecordVersion

+ const HostRegistrationRecordVersion

+ const HostTargetRecordVersion

+ const InboxRecordVersion

+ const MaxCatalogOpenGates

+ const MaxCatalogRecordBytes

+ const MaxCommandClaimTTL

+ const MaxControlShards

+ const MaxDesiredWorkloadPayloadBytes

+ const MaxEnvelopeBytes

+ const MaxGateIntentBytes

+ const MaxHostRegistrationRecordBytes

+ const MaxHostRegistrationTTL

+ const MaxHostTargetAvailableCapacity

+ const MaxHostTargetReconcilePages

+ const MaxHostTargetRecordBytes

+ const MaxHostTargetTTL

+ const MaxInboxPayloadBytes

+ const MaxInboxRecordBytes

+ const MaxInlineBodyBytes

+ const MaxReconciliationClaimRecordBytes

+ const MaxReconciliationClaimTTL

+ const MaxSessionPointerRecordBytes

+ const MinControlShards

+ const MinGateIntentRemnantAge

+ const ReconciliationClaimRecordVersion

+ const SessionPointerRecordVersion

+ func EncodeEnvelope(env Envelope) ([]byte, error)

+ type AcquireReconciliationClaimRequest struct

+ ExpiresAt time.Time

+ HolderID string

+ SessionID sessionwire.SessionID

+ TenantID sessionwire.TenantID

+ type AdmitCommandRequest struct

+ AcceptedAt time.Time

+ ApplyDeadline time.Time

+ CommandID sessionwire.CommandID

+ Kind CommandKind

+ Payload []byte

+ PayloadRef sessionwire.ObjectReference

+ ProposedRuntimeCommandID RuntimeCommandID

+ SessionID sessionwire.SessionID

+ TenantID sessionwire.TenantID

+ type BeginApplyingCommandRequest struct

+ ClaimExpiresAt time.Time

+ CommandID sessionwire.CommandID

+ ExpectedRevision uint64

+ LeaseEpoch uint64

+ SessionID sessionwire.SessionID

+ TenantID sessionwire.TenantID

+ type BodyReference struct

+ Reference sessionwire.ObjectReference

+ SHA256 [32]byte

+ SizeBytes uint64

+ func BodyReferenceFromObjectMetadata(metadata sessionwire.ObjectMetadata) (BodyReference, error)

+ func (r BodyReference) ObjectMetadata() (sessionwire.ObjectMetadata, error)

+ type BodySlot struct

+ Inline []byte

+ Reference *BodyReference

+ type CatalogEntry struct

+ Record CatalogRecord

+ Revision uint64

+ type CatalogError struct

+ Cause error

+ Code CatalogErrorCode

+ Epoch uint64

+ Field string

+ Revision uint64

+ func (e *CatalogError) Error() string

+ func (e *CatalogError) Unwrap() error

+ type CatalogErrorCode string

+ const CatalogErrorBackend

+ const CatalogErrorConflict

+ const CatalogErrorCursor

+ const CatalogErrorDeleted

+ const CatalogErrorEpoch

+ const CatalogErrorIdentity

+ const CatalogErrorInvalid

+ const CatalogErrorMalformed

+ const CatalogErrorNotFound

+ const CatalogErrorSequence

+ const CatalogErrorTooLarge

+ const CatalogErrorTooSoon

+ const CatalogErrorUnknown

+ const CatalogErrorVersion

+ type CatalogRecord struct

+ AgentID sessionwire.AgentID

+ Checkpoint CheckpointSummary

+ CreatedAt time.Time

+ DesiredGeneration uint64

+ DesiredIdempotencyKey string

+ DesiredPlacement sessionwire.HostPlacement

+ DesiredWorkload DesiredWorkload

+ LastActiveAt time.Time

+ LastEventID sessionwire.EventID

+ LastJournalSeq uint64

+ LeaseEpoch uint64

+ OpenGates []sessionwire.GateProjection

+ Residency sessionwire.SessionResidency

+ RuntimeCompatibilityID string

+ SessionID sessionwire.SessionID

+ State sessionwire.SessionState

+ TenantID sessionwire.TenantID

+ func (r CatalogRecord) PlacementIntent() (PlacementIntent, error)

+ func (r CatalogRecord) Status() (sessionwire.SessionStatus, error)

+ func (r CatalogRecord) Summary() (sessionwire.SessionSummary, error)

+ type CheckpointSummary struct

+ CapturedAt time.Time

+ JournalSeq uint64

+ Reference sessionwire.ObjectReference

+ type ClaimCommandRequest struct

+ ClaimExpiresAt time.Time

+ CommandID sessionwire.CommandID

+ ExpectedRevision uint64

+ LeaseEpoch uint64

+ SessionID sessionwire.SessionID

+ TenantID sessionwire.TenantID

+ type ClearHostRegistrationRequest struct

+ LeaseEpoch uint64

+ SessionID sessionwire.SessionID

+ TenantID sessionwire.TenantID

+ type ClearSessionPointerRequest struct

+ LeaseEpoch uint64

+ SessionID sessionwire.SessionID

+ TenantID sessionwire.TenantID

+ type Clock interface

+ Now func() time.Time

+ type CommandApplication struct

+ CapturedTip uint64

+ CommandID sessionwire.CommandID

+ EffectEventID sessionwire.EventID

+ EffectSeq uint64

+ Outcome CommandApplicationOutcome

+ PrefixEpoch uint64

+ PrefixSeq uint64

+ RuntimeCommandID RuntimeCommandID

+ SupersedingEpoch uint64

+ type CommandApplicationOutcome string

+ const CommandApplicationAbandoned

+ const CommandApplicationAbsent

+ const CommandApplicationCommitted

+ const CommandApplicationConflicted

+ const CommandApplicationUnresolved

+ type CommandClaim struct

+ ExpiresAt time.Time

+ LeaseEpoch uint64

+ type CommandKind string

+ type CommandResult struct

+ CompletedAt time.Time

+ EventID sessionwire.EventID

+ JournalSeq uint64

+ type CompleteCommandRequest struct

+ CommandID sessionwire.CommandID

+ ExpectedRevision uint64

+ LeaseEpoch uint64

+ Result CommandResult

+ SessionID sessionwire.SessionID

+ TenantID sessionwire.TenantID

+ type CreateCatalogEntryRequest struct

+ AgentID sessionwire.AgentID

+ CreatedAt time.Time

+ DesiredPlacement sessionwire.HostPlacement

+ DesiredWorkload DesiredWorkload

+ IdempotencyKey string

+ LastActiveAt time.Time

+ Residency sessionwire.SessionResidency

+ RuntimeCompatibilityID string

+ SessionID sessionwire.SessionID

+ State sessionwire.SessionState

+ TenantID sessionwire.TenantID

+ type DesiredWorkload struct

+ Payload []byte

+ PayloadVersion string

+ type DrainHostTargetRequest struct

+ HostGeneration uint64

+ HostID sessionwire.HostID

+ Key HostTargetKey

+ type DueCommand struct

+ Entry InboxEntry

+ type DueCommandPage struct

+ Commands []DueCommand

+ Examined int

+ Limit int

+ NextCursor sessionwire.Cursor

+ Unreadable int

+ type DueGate struct

+ Gate sessionwire.GateProjection

+ SessionID sessionwire.SessionID

+ TenantID sessionwire.TenantID

+ type DueGatePage struct

+ Examined int

+ Gates []DueGate

+ Limit int

+ NextCursor sessionwire.Cursor

+ Remnants []RemnantGateIntent

+ Unreadable int

+ type Envelope struct

+ CommandID sessionwire.CommandID

+ CommandKind string

+ EventID sessionwire.EventID

+ Kind EnvelopeKind

+ LeaseEpoch uint64

+ Public BodySlot

+ RecordID string

+ Runtime BodySlot

+ RuntimeCommandID uuid.UUID

+ func DecodeEnvelope(frame []byte) (Envelope, error)

+ type EnvelopeError struct

+ Cause error

+ Code EnvelopeErrorCode

+ Field string

+ func (e *EnvelopeError) Error() string

+ func (e *EnvelopeError) Unwrap() error

+ type EnvelopeErrorCode string

+ const EnvelopeErrorDigest

+ const EnvelopeErrorField

+ const EnvelopeErrorInvalid

+ const EnvelopeErrorKind

+ const EnvelopeErrorLength

+ const EnvelopeErrorMalformed

+ const EnvelopeErrorMissing

+ const EnvelopeErrorOrder

+ const EnvelopeErrorTooLarge

+ const EnvelopeErrorTrailing

+ const EnvelopeErrorVersion

+ type EnvelopeKind uint8

+ const EnvelopeKindApplicationPrefix

+ const EnvelopeKindOpeningFence

+ const EnvelopeKindPublicEvent

+ const EnvelopeKindRuntimeControl

+ type FindCommandApplicationRequest struct

+ CommandID sessionwire.CommandID

+ SessionID sessionwire.SessionID

+ TenantID sessionwire.TenantID

+ type GetCatalogEntryRequest struct

+ SessionID sessionwire.SessionID

+ TenantID sessionwire.TenantID

+ type GetCommandRequest struct

+ CommandID sessionwire.CommandID

+ SessionID sessionwire.SessionID

+ TenantID sessionwire.TenantID

+ type GetHostRegistrationRequest struct

+ SessionID sessionwire.SessionID

+ TenantID sessionwire.TenantID

+ type GetObjectRequest struct

+ ExpectedKind ObjectKind

+ Metadata sessionwire.ObjectMetadata

+ SessionID sessionwire.SessionID

+ TenantID sessionwire.TenantID

+ type GetReconciliationClaimRequest struct

+ SessionID sessionwire.SessionID

+ TenantID sessionwire.TenantID

+ type GetSessionPointerRequest struct

+ SessionID sessionwire.SessionID

+ TenantID sessionwire.TenantID

+ type HostAdvertisement struct

+ Accepting bool

+ AvailableCapacity uint64

+ ExpiresAt time.Time

+ InternalEndpoint sessionwire.InternalEndpoint

+ IsolationClass sessionwire.HostIsolationClass

+ type HostRegistration struct

+ ExpiresAt time.Time

+ LeaseEpoch uint64

+ ObservedAt time.Time

+ Route *HostRoute

+ SessionID sessionwire.SessionID

+ TenantID sessionwire.TenantID

+ func (r HostRegistration) Observation() (sessionwire.HostLinkRegistryObservation, error)

+ type HostRegistrationEntry struct

+ Registration HostRegistration

+ Revision uint64

+ type HostRoute struct

+ Accepting bool

+ AgentID sessionwire.AgentID

+ HostGeneration uint64

+ HostID sessionwire.HostID

+ InternalEndpoint sessionwire.InternalEndpoint

+ Placement sessionwire.HostPlacement

+ Residency sessionwire.SessionResidency

+ RuntimeCompatibilityID string

+ type HostTarget struct

+ Advertisement *HostAdvertisement

+ HostGeneration uint64

+ HostID sessionwire.HostID

+ Key HostTargetKey

+ ObservedAt time.Time

+ func (t HostTarget) Report() (sessionwire.HostLinkCapacityReport, error)

+ type HostTargetEntry struct

+ Revision uint64

+ Target HostTarget

+ type HostTargetError struct

+ Cause error

+ Code HostTargetErrorCode

+ Field string

+ Generation uint64

+ Revision uint64

+ func (e *HostTargetError) Error() string

+ func (e *HostTargetError) Unwrap() error

+ type HostTargetErrorCode string

+ const HostTargetErrorBackend

+ const HostTargetErrorConflict

+ const HostTargetErrorCursor

+ const HostTargetErrorDeleted

+ const HostTargetErrorGeneration

+ const HostTargetErrorIdentity

+ const HostTargetErrorInvalid

+ const HostTargetErrorMalformed

+ const HostTargetErrorNotFound

+ const HostTargetErrorTooLarge

+ const HostTargetErrorUnknown

+ const HostTargetErrorVersion

+ const HostTargetErrorWithdrawn

+ type HostTargetKey struct

+ AgentID sessionwire.AgentID

+ Placement sessionwire.HostPlacement

+ RuntimeCompatibilityID string

+ type HostTargetPage struct

+ Hosts []sessionwire.HostLinkCapacityReport

+ LapsedSkipped int

+ NextCursor sessionwire.Cursor

+ UnreadableSkipped int

+ type HostTargetReconcileResult struct

+ Contended int

+ Exhausted bool

+ NextCursor sessionwire.Cursor

+ Scanned int

+ StillLive int

+ Unreadable int

+ Unverified int

+ Withdrawn int

+ type InboxEntry struct

+ AcceptedOrder uint64

+ Record InboxRecord

+ Revision uint64

+ func (e InboxEntry) CommandStatus() (sessionwire.CommandStatus, error)

+ type InboxError struct

+ Cause error

+ Code InboxErrorCode

+ Epoch uint64

+ Field string

+ Revision uint64

+ func (e *InboxError) Error() string

+ func (e *InboxError) Unwrap() error

+ type InboxErrorCode string

+ const InboxErrorBackend

+ const InboxErrorClaimHeld

+ const InboxErrorClaimLost

+ const InboxErrorCommandMismatch

+ const InboxErrorConflict

+ const InboxErrorCursor

+ const InboxErrorDeadline

+ const InboxErrorDeleted

+ const InboxErrorEpoch

+ const InboxErrorEvidence

+ const InboxErrorIdentity

+ const InboxErrorInvalid

+ const InboxErrorMalformed

+ const InboxErrorNotFound

+ const InboxErrorState

+ const InboxErrorTerminal

+ const InboxErrorTooLarge

+ const InboxErrorUnknown

+ const InboxErrorVersion

+ type InboxRecord struct

+ AcceptedAt time.Time

+ ApplyDeadline time.Time

+ Claim CommandClaim

+ CommandID sessionwire.CommandID

+ Kind CommandKind

+ Payload []byte

+ PayloadRef sessionwire.ObjectReference

+ Rejection *sessionwire.ErrorDetail

+ Result CommandResult

+ RuntimeCommandID RuntimeCommandID

+ SessionID sessionwire.SessionID

+ State InboxState

+ TenantID sessionwire.TenantID

+ type InboxState string

+ const InboxStateApplied

+ const InboxStateApplying

+ const InboxStateClaimed

+ const InboxStatePending

+ const InboxStateRejected

+ type InvalidBackendError struct

+ Component string

+ func (e *InvalidBackendError) Error() string

+ type InvalidBackgroundWorkError struct

+ func (*InvalidBackgroundWorkError) Error() string

+ type InvalidIdentityError struct

+ Cause error

+ Field string

+ func (e *InvalidIdentityError) Error() string

+ func (e *InvalidIdentityError) Unwrap() error

+ type InvalidLimitError struct

+ Field string

+ Max int64

+ Min int64

+ Value int64

+ func (e *InvalidLimitError) Error() string

+ type InvalidOptionError struct

+ Cause error

+ Field string

+ func (e *InvalidOptionError) Error() string

+ func (e *InvalidOptionError) Unwrap() error

+ type JournalError struct

+ Cause error

+ Code JournalErrorCode

+ Epoch uint64

+ Field string

+ func (e *JournalError) Error() string

+ func (e *JournalError) Unwrap() error

+ type JournalErrorCode string

+ const JournalErrorBackend

+ const JournalErrorClosed

+ const JournalErrorCursor

+ const JournalErrorFenced

+ const JournalErrorIntegrity

+ const JournalErrorInvalid

+ const JournalErrorLeaseHeld

+ const JournalErrorLeaseLost

+ const JournalErrorTooLarge

+ const JournalErrorUnknown

+ type JournalWriter struct

+ func (w *JournalWriter) Append(ctx context.Context, env Envelope) (uint64, error)

+ func (w *JournalWriter) Close(ctx context.Context) error

+ func (w *JournalWriter) Epoch() uint64

+ func (w *JournalWriter) Sequence() uint64

+ type KeyspaceError struct

+ Cause error

+ Code KeyspaceErrorCode

+ func (e *KeyspaceError) Error() string

+ func (e *KeyspaceError) Unwrap() error

+ type KeyspaceErrorCode string

+ const KeyspaceBackend

+ const KeyspaceBindingAmbiguous

+ const KeyspaceBindingNotFound

+ const KeyspaceHashCollision

+ const KeyspaceLayoutMismatch

+ const KeyspaceLegacySession

+ const KeyspaceLegacyTenant

+ const KeyspaceMarkerAmbiguous

+ const KeyspaceMarkerMalformed

+ const KeyspaceScopeInvalid

+ type Limits struct

+ MaxPageSize int

+ func DefaultLimits() Limits

+ type ListCompatibleHostsRequest struct

+ Cursor sessionwire.Cursor

+ Key HostTargetKey

+ Limit int

+ type ListDueCommandsRequest struct

+ Cursor sessionwire.Cursor

+ DueAtOrBefore time.Time

+ Limit int

+ Shard int

+ type ListDueGatesRequest struct

+ Cursor sessionwire.Cursor

+ DueAtOrBefore time.Time

+ Limit int

+ Shard int

+ type ListSessionsRequest struct

+ Cursor sessionwire.Cursor

+ Limit int

+ TenantID sessionwire.TenantID

+ type ObjectError struct

+ Cause error

+ Code ObjectErrorCode

+ Field string

+ func (e *ObjectError) Error() string

+ func (e *ObjectError) Unwrap() error

+ type ObjectErrorCode string

+ const ObjectErrorBackend

+ const ObjectErrorCanceled

+ const ObjectErrorConflict

+ const ObjectErrorDigest

+ const ObjectErrorIntegrity

+ const ObjectErrorInvalid

+ const ObjectErrorSize

+ const ObjectErrorSource

+ type ObjectKind string

+ const ObjectKindArtifact

+ const ObjectKindAttachment

+ const ObjectKindCommandPayload

+ const ObjectKindContinuation

+ const ObjectKindJournalPublic

+ const ObjectKindJournalRuntime

+ const ObjectKindRuntimeCheckpoint

+ const ObjectKindRuntimeObject

+ const ObjectKindToolResult

+ const ObjectKindWorkspaceCheckpoint

+ type OpenGateRequest struct

+ Gate sessionwire.GateProjection

+ LeaseEpoch uint64

+ SessionID sessionwire.SessionID

+ TenantID sessionwire.TenantID

+ type OpenJournalRequest struct

+ SessionID sessionwire.SessionID

+ TenantID sessionwire.TenantID

+ type Option func(*config) error

+ func WithClock(clock Clock) Option

+ func WithControlShards(shards int) Option

+ func WithIOProviderOwnership(closer io.Closer) Option

+ func WithLegacySingleTenant(defaultTenant sessionwire.TenantID) Option

+ func WithLimits(limits Limits) Option

+ func WithLogger(logger *slog.Logger) Option

+ func WithProviderOwnership(closer ProviderCloser) Option

+ func WithShutdownTimeout(timeout time.Duration) Option

+ type PlacementIntent struct

+ AgentID sessionwire.AgentID

+ Generation uint64

+ Placement sessionwire.HostPlacement

+ RuntimeCompatibilityID string

+ SessionID sessionwire.SessionID

+ TenantID sessionwire.TenantID

+ Workload DesiredWorkload

+ type PointerError struct

+ Cause error

+ Code PointerErrorCode

+ Epoch uint64

+ Field string

+ Revision uint64

+ Sequence uint64

+ func (e *PointerError) Error() string

+ func (e *PointerError) Unwrap() error

+ type PointerErrorCode string

+ const PointerErrorBackend

+ const PointerErrorCleared

+ const PointerErrorConflict

+ const PointerErrorDeleted

+ const PointerErrorEpoch

+ const PointerErrorIdentity

+ const PointerErrorInvalid

+ const PointerErrorMalformed

+ const PointerErrorNotFound

+ const PointerErrorSequence

+ const PointerErrorTooLarge

+ const PointerErrorUnknown

+ const PointerErrorVersion

+ type ProviderCloser interface

+ Close func(context.Context) error

+ type PublishHostTargetRequest struct

+ Advertisement HostAdvertisement

+ HostGeneration uint64

+ HostID sessionwire.HostID

+ Key HostTargetKey

+ ObservedAt time.Time

+ type PutHostRegistrationRequest struct

+ ExpiresAt time.Time

+ LeaseEpoch uint64

+ ObservedAt time.Time

+ Route HostRoute

+ SessionID sessionwire.SessionID

+ TenantID sessionwire.TenantID

+ type PutObjectRequest struct

+ Body io.Reader

+ Kind ObjectKind

+ MediaType string

+ SHA256 [32]byte

+ SessionID sessionwire.SessionID

+ SizeBytes uint64

+ TenantID sessionwire.TenantID

+ type ReadGatesRequest struct

+ SessionID sessionwire.SessionID

+ TenantID sessionwire.TenantID

+ type ReadPublicJournalRequest struct

+ Cursor sessionwire.Cursor

+ FromSeq uint64

+ Limit int

+ SessionID sessionwire.SessionID

+ TenantID sessionwire.TenantID

+ type ReadRuntimeJournalRequest struct

+ Cursor sessionwire.Cursor

+ FromSeq uint64

+ Limit int

+ SessionID sessionwire.SessionID

+ TenantID sessionwire.TenantID

+ type ReconcileError struct

+ Cause error

+ Code ReconcileErrorCode

+ ExpiresAt time.Time

+ Field string

+ Revision uint64

+ func (e *ReconcileError) Error() string

+ func (e *ReconcileError) Unwrap() error

+ type ReconcileErrorCode string

+ const ReconcileErrorBackend

+ const ReconcileErrorConflict

+ const ReconcileErrorDeleted

+ const ReconcileErrorHeld

+ const ReconcileErrorIdentity

+ const ReconcileErrorInvalid

+ const ReconcileErrorLapsed

+ const ReconcileErrorMalformed

+ const ReconcileErrorNotFound

+ const ReconcileErrorTooLarge

+ const ReconcileErrorUnknown

+ const ReconcileErrorVersion

+ type ReconcileHostTargetsRequest struct

+ Cursor sessionwire.Cursor

+ Limit int

+ MaxPages int

+ type ReconciliationClaim struct

+ ClaimedAt time.Time

+ ExpiresAt time.Time

+ HolderID string

+ SessionID sessionwire.SessionID

+ TenantID sessionwire.TenantID

+ type ReconciliationClaimEntry struct

+ Claim ReconciliationClaim

+ Revision uint64

+ type RegistryError struct

+ Cause error

+ Code RegistryErrorCode

+ Epoch uint64

+ Field string

+ Revision uint64

+ func (e *RegistryError) Error() string

+ func (e *RegistryError) Unwrap() error

+ type RegistryErrorCode string

+ const RegistryErrorBackend

+ const RegistryErrorConflict

+ const RegistryErrorDeleted

+ const RegistryErrorEpoch

+ const RegistryErrorExpired

+ const RegistryErrorIdentity

+ const RegistryErrorInvalid

+ const RegistryErrorMalformed

+ const RegistryErrorNotFound

+ const RegistryErrorReleased

+ const RegistryErrorTooLarge

+ const RegistryErrorUnknown

+ const RegistryErrorVersion

+ type RejectCommandRequest struct

+ CommandID sessionwire.CommandID

+ ExpectedRevision uint64

+ LeaseEpoch uint64

+ Rejection sessionwire.ErrorDetail

+ SessionID sessionwire.SessionID

+ TenantID sessionwire.TenantID

+ type ReleaseReconciliationClaimRequest struct

+ HolderID string

+ SessionID sessionwire.SessionID

+ TenantID sessionwire.TenantID

+ type RemnantGateIntent struct

+ GateID sessionwire.GateID

+ Revision uint64

+ SessionID sessionwire.SessionID

+ TenantID sessionwire.TenantID

+ type ResolveGateRequest struct

+ GateID sessionwire.GateID

+ LeaseEpoch uint64

+ SessionID sessionwire.SessionID

+ TenantID sessionwire.TenantID

+ type RetireGateDeadlineIntentRequest struct

+ GateID sessionwire.GateID

+ Revision uint64

+ SessionID sessionwire.SessionID

+ TenantID sessionwire.TenantID

+ type RuntimeCommandID string

+ type RuntimePage struct

+ CapturedTip uint64

+ CoveredThrough uint64

+ NextCursor sessionwire.Cursor

+ Records []RuntimeRecord

+ type RuntimeRecord struct

+ Envelope Envelope

+ Seq uint64

+ type SessionPage struct

+ UnreadableSkipped int

+ type SessionPointer struct

+ Kind SessionPointerKind

+ LeaseEpoch uint64

+ Sequence uint64

+ SessionID sessionwire.SessionID

+ Target *sessionwire.ObjectReference

+ TenantID sessionwire.TenantID

+ UpdatedAt time.Time

+ func (p SessionPointer) CheckpointSummary() (CheckpointSummary, error)

+ type SessionPointerEntry struct

+ Pointer SessionPointer

+ Revision uint64

+ type SessionPointerKind string

+ const SessionPointerActiveContinuation

+ const SessionPointerRuntimeCheckpoint

+ const SessionPointerWorkspaceCheckpoint

+ type SetSessionPointerRequest struct

+ LeaseEpoch uint64

+ Sequence uint64

+ SessionID sessionwire.SessionID

+ Target sessionwire.ObjectReference

+ TenantID sessionwire.TenantID

+ type Store struct

+ func Open(ctx context.Context, backend *storage.Composite, opts ...Option) (*Store, error)

+ func (s *Store) AcquireReconciliationClaim(ctx context.Context, req AcquireReconciliationClaimRequest) (ReconciliationClaimEntry, error)

+ func (s *Store) AdmitCommand(ctx context.Context, req AdmitCommandRequest) (InboxEntry, bool, error)

+ func (s *Store) BeginApplyingCommand(ctx context.Context, req BeginApplyingCommandRequest) (InboxEntry, error)

+ func (s *Store) ClaimCommand(ctx context.Context, req ClaimCommandRequest) (InboxEntry, error)

+ func (s *Store) ClearActiveContinuationPointer(ctx context.Context, req ClearSessionPointerRequest) (SessionPointerEntry, error)

+ func (s *Store) ClearHostRegistration(ctx context.Context, req ClearHostRegistrationRequest) (HostRegistrationEntry, error)

+ func (s *Store) ClearRuntimeCheckpointPointer(ctx context.Context, req ClearSessionPointerRequest) (SessionPointerEntry, error)

+ func (s *Store) ClearWorkspaceCheckpointPointer(ctx context.Context, req ClearSessionPointerRequest) (SessionPointerEntry, error)

+ func (s *Store) Close(ctx context.Context) error

+ func (s *Store) CompleteCommand(ctx context.Context, req CompleteCommandRequest) (InboxEntry, error)

+ func (s *Store) ControlShards() int

+ func (s *Store) CreateCatalogEntry(ctx context.Context, req CreateCatalogEntryRequest) (CatalogEntry, bool, error)

+ func (s *Store) DrainHostTarget(ctx context.Context, req DrainHostTargetRequest) (HostTargetEntry, error)

+ func (s *Store) FindCommandApplication(ctx context.Context, req FindCommandApplicationRequest) (CommandApplication, error)

+ func (s *Store) GetActiveContinuationPointer(ctx context.Context, req GetSessionPointerRequest) (SessionPointerEntry, error)

+ func (s *Store) GetCatalogEntry(ctx context.Context, req GetCatalogEntryRequest) (CatalogEntry, error)

+ func (s *Store) GetCommand(ctx context.Context, req GetCommandRequest) (InboxEntry, error)

+ func (s *Store) GetHostRegistration(ctx context.Context, req GetHostRegistrationRequest) (HostRegistrationEntry, error)

+ func (s *Store) GetObject(ctx context.Context, req GetObjectRequest) (io.ReadCloser, error)

+ func (s *Store) GetReconciliationClaim(ctx context.Context, req GetReconciliationClaimRequest) (ReconciliationClaimEntry, error)

+ func (s *Store) GetRuntimeCheckpointPointer(ctx context.Context, req GetSessionPointerRequest) (SessionPointerEntry, error)

+ func (s *Store) GetWorkspaceCheckpointPointer(ctx context.Context, req GetSessionPointerRequest) (SessionPointerEntry, error)

+ func (s *Store) ListCompatibleHosts(ctx context.Context, req ListCompatibleHostsRequest) (HostTargetPage, error)

+ func (s *Store) ListDueCommands(ctx context.Context, req ListDueCommandsRequest) (DueCommandPage, error)

+ func (s *Store) ListDueGates(ctx context.Context, req ListDueGatesRequest) (DueGatePage, error)

+ func (s *Store) ListSessions(ctx context.Context, req ListSessionsRequest) (SessionPage, error)

+ func (s *Store) OpenGate(ctx context.Context, req OpenGateRequest) (CatalogEntry, error)

+ func (s *Store) OpenJournal(ctx context.Context, req OpenJournalRequest) (*JournalWriter, error)

+ func (s *Store) PublishHostTarget(ctx context.Context, req PublishHostTargetRequest) (HostTargetEntry, error)

+ func (s *Store) PutHostRegistration(ctx context.Context, req PutHostRegistrationRequest) (HostRegistrationEntry, error)

+ func (s *Store) PutObject(ctx context.Context, req PutObjectRequest) (sessionwire.ObjectMetadata, error)

+ func (s *Store) ReadGates(ctx context.Context, req ReadGatesRequest) (sessionwire.GatePage, error)

+ func (s *Store) ReadPublicJournal(ctx context.Context, req ReadPublicJournalRequest) (sessionwire.JournalPage, error)

+ func (s *Store) ReadRuntimeJournal(ctx context.Context, req ReadRuntimeJournalRequest) (RuntimePage, error)

+ func (s *Store) ReconcileHostTargets(ctx context.Context, req ReconcileHostTargetsRequest) (HostTargetReconcileResult, error)

+ func (s *Store) RejectCommand(ctx context.Context, req RejectCommandRequest) (InboxEntry, error)

+ func (s *Store) ReleaseReconciliationClaim(ctx context.Context, req ReleaseReconciliationClaimRequest) (ReconciliationClaimEntry, error)

+ func (s *Store) ResolveGate(ctx context.Context, req ResolveGateRequest) (CatalogEntry, error)

+ func (s *Store) RetireGateDeadlineIntent(ctx context.Context, req RetireGateDeadlineIntentRequest) error

+ func (s *Store) SetActiveContinuationPointer(ctx context.Context, req SetSessionPointerRequest) (SessionPointerEntry, error)

+ func (s *Store) SetRuntimeCheckpointPointer(ctx context.Context, req SetSessionPointerRequest) (SessionPointerEntry, error)

+ func (s *Store) SetWorkspaceCheckpointPointer(ctx context.Context, req SetSessionPointerRequest) (SessionPointerEntry, error)

+ func (s *Store) UpdateCatalogDesiredState(ctx context.Context, req UpdateCatalogDesiredStateRequest) (CatalogEntry, error)

+ func (s *Store) UpdateCatalogHostState(ctx context.Context, req UpdateCatalogHostStateRequest) (CatalogEntry, error)

+ type StoreClosedError struct

+ func (*StoreClosedError) Error() string

+ type UpdateCatalogDesiredStateRequest struct

+ DesiredPlacement sessionwire.HostPlacement

+ DesiredWorkload DesiredWorkload

+ ExpectedRevision uint64

+ IdempotencyKey string

+ RuntimeCompatibilityID string

+ SessionID sessionwire.SessionID

+ TenantID sessionwire.TenantID

+ type UpdateCatalogHostStateRequest struct

+ Checkpoint CheckpointSummary

+ LastActiveAt time.Time

+ LastEventID sessionwire.EventID

+ LastJournalSeq uint64

+ LeaseEpoch uint64

+ OpenGates []sessionwire.GateProjection

+ Residency sessionwire.SessionResidency

+ SessionID sessionwire.SessionID

+ State sessionwire.SessionState

+ TenantID sessionwire.TenantID

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