coldstart

type ChairClaimer interface {
	ClaimFailed(ctx context.Context, chair chairs.Chair) (chairs.Chair, bool, error)
}

type ChairOptions struct {
	Chairs    ChairSnapshotCache
	Discovery Discovery
	// PeerMetadata verifies DHT candidates before they can complete polling.
	PeerMetadata          ifaces.PeerMetadataDialer
	Coord                 ifaces.ChairCoordinator
	LocalPull             ifaces.LocalChairPullStarter
	Inflight              *inflight.Map
	SelfPeerID            ifaces.NodeID
	CurrentEpoch          func() int64
	InstallHolder         func(chairs.Holder) error
	Claimer               ChairClaimer
	Logger                *slog.Logger
	QueryTimeout          time.Duration
	PollManifest          time.Duration
	PollLayer             time.Duration
	APITimeout            time.Duration
	ChairCount            int
	SeedCount             int
	TrustedFailureClasses []ifaces.FailureClass
	// OnSeedRecruit reports one completed seed-recruitment pass: how many chairs
	// were selectable, how many were contacted, and how many accepted. contacted
	// above the effective scaled cohort means the resolver moved down the ranking,
	// which widens the set of nodes fetching from origin.
	OnSeedRecruit func(kind string, selectable, contacted, accepted int)
	// OnChairDispatch reports the outcome of one please_pull to one chair.
	// reason is "accepted" or why the chair did not count: "rpc_error" (no
	// usable reply inside QueryTimeout), "recently_failed", "stale_chair", or
	// "declined". Only rpc_error is invisible to the chair itself.
	OnChairDispatch func(kind, reason string)
	// OnChairCall times one please_pull attempt against a remote chair.
	// outcome separates a clean reply from "deadline" (QueryTimeout expired),
	// so a run can tell a binding deadline from slow transport: deadline
	// outcomes pile up at QueryTimeout, transport shows a long ok tail.
	OnChairCall func(kind, outcome string, seconds float64)
}

type ChairResolver struct {
	// contains filtered or unexported fields
}

type ChairSnapshotCache interface {
	Snapshot(ctx context.Context, epoch int64) (chairs.Snapshot, error)
	RefreshChair(ctx context.Context, id chairs.ID) (chairs.Chair, error)
}

type ChildDigest struct {
	Digest digest.Digest
	Kind   ifaces.OriginRefKind
}

type Discovery interface {
	FindProviders(ctx context.Context, d digest.Digest) ([]ifaces.Provider, error)
	Health() float64
}

type Resolution struct {
	// Providers are transfer endpoints (host:port) the caller should
	// fetch from, in priority order. Non-empty on success.
	Providers []ifaces.Provider
	// Outcome names which rule fired. Useful for tests and metrics.
	Outcome string
}