advertise

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

type Inventory interface {
	Inventory(ctx context.Context) ([]digest.Digest, error)
}

type MetricsHooks struct {
	// OnReconcileStart fires when a reconcile pass begins.
	OnReconcileStart func()
	// OnReconcileEnd fires after each reconcile pass with the elapsed
	// duration, the total inventory size, and the count of digests
	// added/removed from the announced set.
	OnReconcileEnd func(dur time.Duration, inventorySize, added, removed int)
	// OnReconcileError fires when a reconcile pass aborts on Inventory error.
	OnReconcileError func(err error)
	// OnReconcileUnavailable fires when a reconcile pass aborts
	// because the inventory backend (containerd) is unavailable.
	// Distinct from OnReconcileError so dashboards can separate
	// "real error" from "backend hiccup that we deliberately
	// tolerated by preserving the announced set". Per plan
	// "containerd unavailable pauses advertise/reconcile
	// rather than treating everything as absent".
	OnReconcileUnavailable func()
	// OnProvide fires after each successful DHT.Provide call.
	OnProvide func()
	// OnProvideError fires after each failed DHT.Provide call.
	OnProvideError func()
	// OnWithdraw fires after each successful DHT.Withdraw call.
	OnWithdraw func()
	// OnWithdrawError fires after each failed DHT.Withdraw call.
	OnWithdrawError func()
}

type Openable interface {
	Open(ctx context.Context, d digest.Digest) (io.ReadCloser, int64, error)
}

type Option func(*Advertiser)