hostlink

Sep 27, 2026

Changes in this version

+ const CapabilityPayloadReference

Sep 26, 2026

Changes in this version

+ const ClientQueueMaxBytes

+ const DefaultTransientBurstBytes

+ const DefaultTransientRateBytesPerSecond

+ const MaxTransientFrameBytes

type Config

+ TransientBurstBytes int

+ TransientRateBytesPerSecond int

Sep 25, 2026

Changes in this version

+ const CapabilityAttributionPrincipal

Sep 23, 2026

Changes in this version

type AttachRefusal

+ RuntimeCompatibilityID string

type Refusal

+ const RefusalMismatchBuildUnknown

Sep 19, 2026

Changes in this version

+ const CapabilityGateResponse

type Config

+ Capabilities []string

Sep 17, 2026

Changes in this version

+ const MethodAttach

+ type AttachRefusal struct

+ Cause error

+ Code sessionwire.HostLinkErrorCode

+ CurrentLeaseEpoch uint64

+ Reason string

+ func (e *AttachRefusal) Error() string

+ func (e *AttachRefusal) Unwrap() error

+ type AttachRequest struct

+ ActorID string

+ AgentID sessionwire.AgentID

+ IdempotencyKey string

+ Key registry.Key

+ Mode sessionwire.HostLinkAttachMode

+ RuntimeCompatibilityID string

+ TraceID string

+ type Attacher interface

+ Attach func(context.Context, AttachRequest) (sessionwire.HostLinkRegistryObservation, error)

type Multiplexer

+ func (m *Multiplexer) Attach(ctx context.Context, request sessionwire.HostLinkAttachRequest) (sessionwire.HostLinkRegistryObservation, error)

type MultiplexerOptions

+ Attacher Attacher

type Refusal

+ const RefusalAttachFailed

+ const RefusalAttachRefused

+ const RefusalAttachUnsupported

+ const RefusalHolderEpochUnknown

+ const RefusalUnpublishableAttach

Sep 13, 2026

Changes in this version

+ const ChannelPrefix

+ const MethodBind

+ const MethodDrain

+ const MethodDrainStatus

+ const MethodUnbind

+ var MaxChannelBytes = len(ChannelPrefix) + 1 + 2*base64.RawURLEncoding.EncodedLen(sessionwire.MaxIDBytes)

+ func ChannelFor(key registry.Key) string

+ type Admission interface

+ Draining func() bool

+ type Authenticator interface

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

+ type BindError struct

+ Cause error

+ Key registry.Key

+ Reason string

+ Refusal Refusal

+ func (e *BindError) Error() string

+ func (e *BindError) HostLinkError() (sessionwire.HostLinkError, bool)

+ func (e *BindError) Unwrap() error

+ type Binding struct

+ Channel string

+ IdempotencyKey string

+ Key registry.Key

+ LeaseEpoch uint64

+ Link LinkID

+ type CommandConsumer interface

+ Hint func(sessionwire.CommandID)

+ type CommandConsumers interface

+ ConsumerFor func(registry.Key) (CommandConsumer, bool)

+ type Config struct

+ Authenticator Authenticator

+ Multiplexer *Multiplexer

+ PingInterval time.Duration

+ PongTimeout time.Duration

+ TenantID sessionwire.TenantID

+ type DrainObserver interface

+ ObserveDrain func(DrainScope) (DrainStatus, bool)

+ type DrainScope struct

+ Key registry.Key

+ func (s DrainScope) WholeHost() bool

+ type DrainScopeReporter interface

+ BegunScope func() (registry.Key, bool)

+ type DrainStarter interface

+ StartDrain func(DrainScope) (DrainStatus, error)

+ type DrainStatus struct

+ Generation uint64

+ State sessionwire.HostLinkDrainState

+ type InvalidMultiplexerOptionsError struct

+ Field string

+ Reason string

+ func (e *InvalidMultiplexerOptionsError) Error() string

+ type LinkID string

+ type Multiplexer struct

+ func NewMultiplexer(options MultiplexerOptions) (*Multiplexer, error)

+ func (m *Multiplexer) Bind(link LinkID, request sessionwire.HostLinkBindRequest) (Binding, error)

+ func (m *Multiplexer) CloseLink(link LinkID) []Binding

+ func (m *Multiplexer) Deliver(link LinkID, channel string, delivery sessionwire.HostLinkCommandDelivery) error

+ func (m *Multiplexer) InvalidateSession(key registry.Key) []Binding

+ func (m *Multiplexer) Len() int

+ func (m *Multiplexer) LinkBindings(link LinkID) []Binding

+ func (m *Multiplexer) MaySubscribe(link LinkID, channel string) bool

+ func (m *Multiplexer) ObserveDrain(request sessionwire.HostLinkDrainRequest) (sessionwire.HostLinkDrainObservation, error)

+ func (m *Multiplexer) Replicas(key registry.Key) []LinkID

+ func (m *Multiplexer) StartDrain(request sessionwire.HostLinkDrainRequest) (sessionwire.HostLinkDrainObservation, error)

+ func (m *Multiplexer) Unbind(link LinkID, request sessionwire.HostLinkUnbindRequest) error

+ type MultiplexerOptions struct

+ Admission Admission

+ Consumers CommandConsumers

+ DrainObserver DrainObserver

+ DrainStarter DrainStarter

+ FixedSessionID sessionwire.SessionID

+ HostGeneration uint64

+ HostID sessionwire.HostID

+ MaxBindings int

+ MaxBindingsPerLink int

+ Residencies Residencies

+ TenantID sessionwire.TenantID

+ type Refusal string

+ const RefusalDrainUnavailable

+ const RefusalDrainUnsupported

+ const RefusalEpochMismatch

+ const RefusalForeignHost

+ const RefusalForeignTenant

+ const RefusalHostNotAdmitting

+ const RefusalMalformedRequest

+ const RefusalNoDrainInProgress

+ const RefusalNoHostCapacity

+ const RefusalNoLinkCapacity

+ const RefusalNotBound

+ const RefusalReleasing

+ const RefusalResidencyReleased

+ const RefusalRuntimeMismatch

+ const RefusalSessionNotAdmitting

+ const RefusalStaleHostGeneration

+ const RefusalUnknownSession

+ const RefusalWrongDrainScope

+ type Residencies interface

+ Get func(registry.Key) (registry.Entry, bool)

+ type Server interface

+ Close func(context.Context) error

+ Handler func() http.Handler

+ Publish func(channel string, payload []byte) error

+ func NewCentrifugeServer(config Config) (Server, error)