placement

Sep 27, 2026

Changes in this version

type HostLinks

+ AcceptsPayloadReferences func(ctx context.Context, owner sessionwire.HostLinkRegistryObservation) (bool, error)

type Request

+ PayloadReferences []sessionwire.CommandID

Sep 26, 2026

Changes in this version

+ type AdmissionNotice struct

+ AcceptedOrder uint64

+ CommandID sessionwire.CommandID

+ Deadline time.Time

+ Pending bool

+ SessionID sessionwire.SessionID

+ TenantID sessionwire.TenantID

+ func Notice(entry sessionstore.DispositionInboxEntry) AdmissionNotice

type PendingSweeper

+ func (s *PendingSweeper) PlaceAdmission(ctx context.Context, principal identity.Principal, notice AdmissionNotice) (Result, error)

+ func (s *PendingSweeper) PlaceAdmissionWith(ctx context.Context, principal identity.Principal, notice AdmissionNotice, ...) (Result, error)

+ func (s *PendingSweeper) SweepPlacer() Placer

type PendingSweeperConfig

+ AdmissionPlacer Placer

+ Catalog Catalog

+ Directory Directory

+ SessionCommands SessionCommands

type Reconciler

+ func (r *Reconciler) HolderID() string

+ type SessionCommands interface

+ ListSessionDispositionCommands func(context.Context, sessionstore.ListSessionDispositionCommandsRequest) (sessionstore.SessionDispositionCommandPage, error)

Sep 25, 2026

Changes in this version

type HostLinks

+ AcceptsCommandPrincipal func(ctx context.Context, owner sessionwire.HostLinkRegistryObservation) (bool, error)

type Request

+ PrincipalCommands []sessionwire.CommandID

type Result

+ WithheldPrincipalCommands int

Sep 23, 2026

Changes in this version

+ var ErrNoLaunchTemplate = errors.New("placement: a released dedicated session has no recoverable launch template")

+ var ErrSessionReleased = errors.New("placement: the dedicated session is released and no restore was requested")

type PendingSweepResult

+ Released int

type Request

+ RestoreRequested bool

Sep 20, 2026

Changes in this version

+ var ErrDedicatedEndpointInvalid = errors.New("placement: dedicated workload endpoint is invalid")

+ var ErrDedicatedObservationInvalid = errors.New("placement: dedicated workload observation does not match the intent")

+ var ErrWorkloadEndpointUnsupported = errors.New("placement: workload controller cannot discover a pre-attach endpoint")

+ type DedicatedEndpoint struct

+ HostGeneration uint64

+ HostID sessionwire.HostID

+ InternalEndpoint sessionwire.InternalEndpoint

+ type WorkloadEndpointDiscovery interface

+ WorkloadEndpoint func(context.Context, sessionstore.PlacementIntent) (sessionwire.HostID, uint64, sessionwire.InternalEndpoint, bool, error)

Sep 19, 2026

Changes in this version

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

type HostLinks

+ AcceptsGateResponses func(ctx context.Context, owner sessionwire.HostLinkRegistryObservation) (bool, error)

type Request

+ GateResponses []sessionwire.CommandID

type Result

+ Incapable []sessionwire.HostID

+ Unaddressable []sessionwire.HostID

+ WithheldGateResponses int

Sep 19, 2026

Changes in this version

+ var ErrAttachFailed = errors.New("placement: host answered the attach with a failure")

+ var ErrAttachUnsupported = errors.New("placement: host did not advertise hostlink.attach")

+ var ErrBindAfterAttach = errors.New("placement: the host attached the session but the bind that followed failed")

+ var ErrHostUnreachable = errors.New("placement: host could not be reached")

+ var ErrInvalidPendingSweeperConfig = errors.New("placement: invalid pending-work sweeper configuration")

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

+ type AttachRefusal struct

+ func (e *AttachRefusal) Error() string

+ type CandidateRefusal struct

+ Code sessionwire.HostLinkErrorCode

+ HostGeneration uint64

+ HostID sessionwire.HostID

type Config

+ ActorID string

+ Links HostLinks

+ Logger *slog.Logger

+ ReplaceAttempts int

+ ReplaceBackoff time.Duration

+ Wait func(context.Context, time.Duration) error

+ type HostLinks interface

+ Attach func(ctx context.Context, endpoint sessionwire.InternalEndpoint, ...) (sessionwire.HostLinkRegistryObservation, error)

+ Bind func(ctx context.Context, endpoint sessionwire.InternalEndpoint, ...) error

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

+ RouteFor func(tenant sessionwire.TenantID, session sessionwire.SessionID) (sessionwire.HostID, bool)

+ Unbind func(ctx context.Context, req sessionwire.HostLinkUnbindRequest) error

+ type PendingCommands interface

+ ControlShards func() int

+ ListDueDispositionCommands func(context.Context, sessionstore.ListDueDispositionCommandsRequest) (sessionstore.DispositionDueCommandPage, error)

+ type PendingSweepResult struct

+ Attached int

+ Deferred int

+ Examined int

+ Failures int

+ NoController int

+ Outcomes map[Outcome]int

+ Pages int

+ Resumed bool

+ Sessions int

+ Shard int

+ Truncated bool

+ Unreadable int

+ type PendingSweeper struct

+ func NewPendingSweeper(cfg PendingSweeperConfig) (*PendingSweeper, error)

+ func (s *PendingSweeper) Horizon() time.Duration

+ func (s *PendingSweeper) Logger() *slog.Logger

+ func (s *PendingSweeper) Sweep(ctx context.Context, principal identity.Principal) (PendingSweepResult, error)

+ type PendingSweeperConfig struct

+ Authorizer SweepAuthorizer

+ Clock Clock

+ Horizon time.Duration

+ Logger *slog.Logger

+ MaxPages int

+ PageLimit int

+ Pending PendingCommands

+ Placer Placer

+ type Placer interface

+ Reconcile func(ctx context.Context, req Request) (Result, error)

type Reconciler

+ func (r *Reconciler) ActorID() string

+ func (r *Reconciler) Logger() *slog.Logger

type Request

+ Wake []sessionwire.CommandID

type Result

+ Attached sessionwire.HostLinkRegistryObservation

+ Bound bool

+ Delivered int

+ DeliveryFailures int

+ Excluded []sessionwire.HostID

+ Failed []sessionwire.HostID

+ Refused []CandidateRefusal

+ Replacements int

+ Unreachable []sessionwire.HostID

+ type SweepAuthorizer interface

+ AuthorizeServiceSweep func(ctx context.Context, principal identity.Principal) error

Sep 18, 2026

Changes in this version

+ func WorkloadName(intent sessionstore.PlacementIntent) string

type WorkloadController

+ DeleteWorkload func(context.Context, sessionstore.PlacementIntent) error

+ ObserveWorkload func(context.Context, sessionstore.PlacementIntent) (sessionwire.HostLinkRegistryObservation, bool, error)

+ RequestDrain func(context.Context, sessionstore.PlacementIntent) (sessionwire.HostLinkDrainObservation, error)

+ type WorkloadIdentity struct

+ AgentID sessionwire.AgentID

+ Generation uint64

+ Name string

+ RuntimeCompatibilityID string

+ SessionID sessionwire.SessionID

+ TenantID sessionwire.TenantID

+ func DeriveWorkloadIdentity(intent sessionstore.PlacementIntent) WorkloadIdentity

Sep 15, 2026

Changes in this version

+ var ErrInvalidConfig = errors.New("placement: invalid reconciler configuration")

+ var ErrInvalidSweeperConfig = errors.New("placement: invalid record sweeper configuration")

+ var ErrNoWorkloadController = errors.New("placement: this replica reconciles no dedicated workloads")

+ func ReusableOwner(owner sessionwire.HostLinkRegistryObservation, ...) bool

+ type Catalog interface

+ GetCatalogEntry func(ctx context.Context, req sessionstore.GetCatalogEntryRequest) (sessionstore.CatalogEntry, error)

+ UpdateCatalogDesiredState func(ctx context.Context, req sessionstore.UpdateCatalogDesiredStateRequest) (sessionstore.CatalogEntry, error)

+ type ClaimSweep interface

+ ReleaseReconciliationClaim func(context.Context, sessionstore.ReleaseReconciliationClaimRequest) (sessionstore.ReconciliationClaimEntry, error)

+ type ClaimSweepResult struct

+ Absent int

+ Examined int

+ Held int

+ Lapsed int

+ Released int

+ type Claims interface

+ AcquireReconciliationClaim func(ctx context.Context, req sessionstore.AcquireReconciliationClaimRequest) (sessionstore.ReconciliationClaimEntry, error)

+ ReleaseReconciliationClaim func(ctx context.Context, req sessionstore.ReleaseReconciliationClaimRequest) (sessionstore.ReconciliationClaimEntry, error)

+ type Clock interface

+ Now func() time.Time

+ type Config struct

+ CandidateLimit int

+ Catalog Catalog

+ ClaimTTL time.Duration

+ Claims Claims

+ Clock Clock

+ Directory Directory

+ HolderID string

+ Workloads WorkloadController

+ type Decision struct

+ Outcome Outcome

+ Owner sessionwire.HostLinkRegistryObservation

+ Target sessionwire.HostLinkCapacityReport

+ func Decide(record sessionstore.CatalogRecord, ...) Decision

+ type Desired struct

+ Placement sessionwire.HostPlacement

+ RuntimeCompatibilityID string

+ Workload sessionstore.DesiredWorkload

+ type Directory interface

+ Candidates func(ctx context.Context, req sessionstore.ListCompatibleHostsRequest) (sessionstore.HostTargetPage, error)

+ Owner func(ctx context.Context, tenant sessionwire.TenantID, ...) (sessionwire.HostLinkRegistryObservation, bool, error)

+ type Outcome uint8

+ const OutcomeAttachPooled

+ const OutcomeNoCapacity

+ const OutcomeReconcileDedicated

+ const OutcomeReuseOwner

+ const OutcomeUndecided

+ func (o Outcome) String() string

+ type Reconciler struct

+ func NewReconciler(cfg Config) (*Reconciler, error)

+ func (r *Reconciler) Reconcile(ctx context.Context, req Request) (Result, error)

+ type RecordSweeper struct

+ func NewRecordSweeper(cfg SweeperConfig) (*RecordSweeper, error)

+ func (s *RecordSweeper) SweepClaims(ctx context.Context, refs []SessionRef) (ClaimSweepResult, error)

+ func (s *RecordSweeper) SweepTargets(ctx context.Context) (TargetSweepResult, error)

+ type Request struct

+ Desired *Desired

+ SessionID sessionwire.SessionID

+ TenantID sessionwire.TenantID

+ type Result struct

+ ClaimExpiresAt time.Time

+ Decision Decision

+ Deferred bool

+ DesiredWrites int

+ Intent sessionstore.PlacementIntent

+ type SessionRef struct

+ SessionID sessionwire.SessionID

+ TenantID sessionwire.TenantID

+ type SweeperConfig struct

+ Claims ClaimSweep

+ HolderID string

+ MaxPages int

+ PageLimit int

+ Targets TargetSweep

+ type TargetSweep interface

+ ReconcileHostTargets func(context.Context, sessionstore.ReconcileHostTargetsRequest) (sessionstore.HostTargetReconcileResult, error)

+ type TargetSweepResult struct

+ Contended int

+ Exhausted bool

+ Resumed bool

+ Retained int

+ Scanned int

+ Unranked int

+ Unreadable int

+ Unverified int

+ type WorkloadController interface

+ EnsureWorkload func(ctx context.Context, intent sessionstore.PlacementIntent) error