host

Sep 30, 2026

Changes in this version

type DrainReport

+ Abandoned []DrainSession

+ Parked []DrainSession

+ type DrainSession struct

+ SessionID sessionwire.SessionID

+ TenantID sessionwire.TenantID

Sep 30, 2026

Changes in this version

type Composition

+ RuntimeProfile RuntimeProfile

+ type RuntimeProfile uint8

+ const RuntimeProfileBestEffort

+ const RuntimeProfileDurable

+ func (p RuntimeProfile) String() string

Sep 29, 2026

Changes in this version

type LiveTextOptions

+ IncludeToolSteps bool

Sep 27, 2026

Changes in this version

type Composition

+ MaxCommandBodyBytes int64

Sep 26, 2026

Changes in this version

type LiveTextOptions

+ IncludeReasoning bool

Sep 26, 2026

Changes in this version

type Composition

+ LiveText *LiveTextOptions

+ type LiveTextOptions struct

+ BurstBytes int

+ FlushInterval time.Duration

+ RateBytesPerSecond int

Sep 23, 2026

Changes in this version

+ const DefaultPublicJournalCapacity

+ var ErrPublicJournalScope = errors.New(...)

+ type PublicJournal struct

+ func NewPublicJournal(reader RuntimeJournalReader, tenant sessionwire.TenantID, ...) (*PublicJournal, error)

+ func (j *PublicJournal) ReadPublicJournal(ctx context.Context, req sessionstore.ReadPublicJournalRequest) (sessionwire.JournalPage, error)

+ type PublicJournals struct

+ func NewPublicJournals(capacity int) *PublicJournals

+ func (p *PublicJournals) Reader(reader RuntimeJournalReader, tenant sessionwire.TenantID, ...) (*PublicJournal, error)

+ type RuntimeJournalReader interface

+ ReadPublicJournal func(context.Context, sessionstore.ReadPublicJournalRequest) (sessionwire.JournalPage, error)

+ ReadRuntimeJournal func(context.Context, sessionstore.ReadRuntimeJournalRequest) (sessionstore.RuntimePage, error)

Sep 20, 2026

Changes in this version

+ var ErrServiceActive = compose.ErrServiceActive

+ var ErrServiceDisposed = compose.ErrServiceDisposed

+ var ErrServiceNotStarted = compose.ErrServiceNotStarted

type Service

+ func (s *Service) CloseUnstarted(ctx context.Context) error

+ type ServiceLifecycleError = compose.ServiceLifecycleError

Sep 19, 2026

Changes in this version

type Collaborators

+ Logger *slog.Logger

Sep 19, 2026

Changes in this version

+ var ErrUndiallableEndpoint = hostconfig.ErrUndiallableEndpoint

Sep 17, 2026

Changes in this version

+ const HostLinkPathPrefix

+ const StepCloseStore

+ func Run(ctx context.Context, blueprint Composition, listen ListenOptions) error

+ type AttachError struct

+ Cause error

+ Code sessionwire.HostLinkErrorCode

+ CurrentLeaseEpoch uint64

+ Reason string

+ Step string

+ Unreleased []string

+ func (e *AttachError) Error() string

+ func (e *AttachError) HostLinkCode() (sessionwire.HostLinkErrorCode, bool)

+ func (e *AttachError) Unwrap() error

+ type AttachRequest struct

+ ActorID string

+ AgentID sessionwire.AgentID

+ Mode sessionwire.HostLinkAttachMode

+ RuntimeCompatibilityID string

+ SessionID sessionwire.SessionID

+ TenantID sessionwire.TenantID

+ TraceID string

+ type Collaborators struct

+ Auth AuthVerifier

+ Backend *storage.Composite

+ Checkpointer Checkpointer

+ JournalStores map[EvidenceKey]sessionstore.DispositionEvidenceReader

+ NamespaceLayout NamespaceLayout

+ Registrar Registrar

+ RigSessionIDs RigSessionIDs

+ StoreOptions []sessionstore.Option

+ Workspaces Workspaces

+ type Composition struct

+ Clock CompositionClock

+ Collaborators Collaborators

+ CompatibilityTimeout time.Duration

+ Drain DrainOptions

+ Generation uint64

+ Link LinkOptions

+ Options Options

+ WorkPoll time.Duration

+ type CompositionClock interface

+ After func(time.Duration) <-chan time.Time

+ NewTimer func(time.Duration) *time.Timer

+ NewWarmTimer func(time.Duration) WarmTimer

+ Now func() time.Time

+ type DrainFailure struct

+ Err error

+ SessionID sessionwire.SessionID

+ Step string

+ TenantID sessionwire.TenantID

+ func (f DrainFailure) Error() string

+ func (f DrainFailure) Unwrap() error

+ type DrainOptions struct

+ Grace time.Duration

+ IdleBoundary time.Duration

+ PublishBound time.Duration

+ type DrainReport struct

+ Failures []DrainFailure

+ Generation uint64

+ State sessionwire.HostLinkDrainState

+ type EvidenceKey struct

+ StorageBindingID string

+ TenantID sessionwire.TenantID

+ type InvalidCompositionError struct

+ Cause error

+ Field string

+ Reason string

+ func (e *InvalidCompositionError) Error() string

+ func (e *InvalidCompositionError) Unwrap() error

+ type LinkOptions struct

+ MaxBindings int

+ MaxBindingsPerLink int

+ MaxTenantLinks int

+ PingInterval time.Duration

+ PongTimeout time.Duration

+ type ListenOptions struct

+ Address string

+ Listener net.Listener

+ ReadHeaderTimeout time.Duration

+ type NamespaceLayout func(sessionwire.TenantID, sessionwire.SessionID) string

+ type Residency struct

+ AgentID sessionwire.AgentID

+ Attached bool

+ JournalEpoch uint64

+ JournalEpochHeld bool

+ LeaseEpoch uint64

+ RuntimeCompatibilityID string

+ SessionID sessionwire.SessionID

+ TenantID sessionwire.TenantID

+ type RigSessionIDs func(context.Context, sessionwire.TenantID, sessionwire.SessionID) (uuid.UUID, error)

+ type Service struct

+ func Compose(ctx context.Context, blueprint Composition) (*Service, error)

+ func (s *Service) Attach(ctx context.Context, request AttachRequest) (Residency, error)

+ func (s *Service) Department() *department.Department

+ func (s *Service) Handler() http.Handler

+ func (s *Service) Host() *Host

+ func (s *Service) Live() bool

+ func (s *Service) MetricsHandler() http.Handler

+ func (s *Service) Ready() bool

+ func (s *Service) Routes() http.Handler

+ func (s *Service) Start(ctx context.Context) error

+ func (s *Service) Stop(ctx context.Context) (DrainReport, error)

+ type WarmTimer interface

+ C func() <-chan time.Time

+ Reset func(time.Duration) bool

+ Stop func() bool

+ type Workspaces interface

+ EnsureWorkspace func(context.Context, sessionwire.TenantID, sessionwire.SessionID) (string, error)

+ ReleaseWorkspace func(context.Context, sessionwire.TenantID, sessionwire.SessionID) error

Sep 13, 2026

Changes in this version

+ const MaxCommandQueueSize

+ const MaxReconcileBatch

+ const MinClaimAttemptsBeforeDeadline

+ const MinHeartbeatsBeforeExpiry

+ type AuthVerifier interface

+ VerifyTenant func(context.Context, sessionwire.TenantID, string) error

+ type Checkpointer interface

+ Checkpoint func(ctx context.Context, tenant sessionwire.TenantID, ...) error

+ type Clock interface

+ NewTimer func(time.Duration) *time.Timer

+ Now func() time.Time

+ type Host struct

+ func New(options Options) (*Host, error)

+ func (h *Host) ApplyDeadline() time.Duration

+ func (h *Host) Auth() AuthVerifier

+ func (h *Host) Capacity() uint64

+ func (h *Host) ClaimTTL() time.Duration

+ func (h *Host) Clock() Clock

+ func (h *Host) CommandQueueSize() int

+ func (h *Host) Department() *department.Department

+ func (h *Host) FixedSessionID() sessionwire.SessionID

+ func (h *Host) ID() sessionwire.HostID

+ func (h *Host) InternalEndpoint() sessionwire.InternalEndpoint

+ func (h *Host) IsolationClass() sessionwire.HostIsolationClass

+ func (h *Host) Placement() sessionwire.HostPlacement

+ func (h *Host) ReconcileBatch() int

+ func (h *Host) ReconcileInterval() time.Duration

+ func (h *Host) RegistryExpiry() time.Duration

+ func (h *Host) RegistryHeartbeat() time.Duration

+ func (h *Host) SessionStore() SessionStore

+ func (h *Host) WarmTTL() time.Duration

+ func (h *Host) Workspaces() WorkspaceProvider

+ type InvalidOptionsError struct

+ Cause error

+ Code OptionErrorCode

+ Field string

+ Reason string

+ func (e *InvalidOptionsError) Error() string

+ func (e *InvalidOptionsError) Unwrap() error

+ type OptionErrorCode string

+ const OptionErrorCodeAboveBound

+ const OptionErrorCodeClaimMargin

+ const OptionErrorCodeDedicatedCap

+ const OptionErrorCodeDedicatedFixed

+ const OptionErrorCodeHeartbeatMargin

+ const OptionErrorCodeInvalid

+ const OptionErrorCodeMissing

+ const OptionErrorCodeNotPositive

+ const OptionErrorCodePooledFixed

+ const OptionErrorCodeUnknownEnum

+ type Options struct

+ ApplyDeadline time.Duration

+ Auth AuthVerifier

+ Capacity uint64

+ ClaimTTL time.Duration

+ Clock Clock

+ CommandQueueSize int

+ Department *department.Department

+ FixedSessionID sessionwire.SessionID

+ HostID sessionwire.HostID

+ InternalEndpoint sessionwire.InternalEndpoint

+ IsolationClass sessionwire.HostIsolationClass

+ Placement sessionwire.HostPlacement

+ ReconcileBatch int

+ ReconcileInterval time.Duration

+ RegistryExpiry time.Duration

+ RegistryHeartbeat time.Duration

+ SessionStore SessionStore

+ WarmTTL time.Duration

+ Workspaces WorkspaceProvider

+ type Registrar interface

+ Register func(context.Context) ([]department.Registration, error)

+ type RegistrarFunc func(context.Context) ([]department.Registration, error)

+ func (f RegistrarFunc) Register(ctx context.Context) ([]department.Registration, error)

+ type SessionStore interface

+ LoadSession func(context.Context, sessionwire.TenantID, sessionwire.SessionID) ([]byte, error)

+ type WorkspaceProvider interface

+ EnsureWorkspace func(context.Context, sessionwire.TenantID, sessionwire.SessionID) (string, error)