activator

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

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

type Deps struct {
	Store             store.Store   // lists Functions for idle reclaim; read for a Failed phase while activating
	Endpoints         Endpoints     // ready-upstream resolver (required)
	Scaler            Scaler        // scale-intent writer (required)
	Clock             clock.Clock   // default clock.System()
	Logger            *slog.Logger  // default slog.Default()
	ActivationTimeout time.Duration // cold-start hold bound; default 30s
	PollInterval      time.Duration // ready-poll cadence; default 25ms
	ReclaimInterval   time.Duration // idle-reclaim cadence for Run; default 30s
	Calls             *CallTracker  // counts the calls to each worker (ADR-0143), which idle reclaim also reads; nil ⇒ uncounted
}

type Endpoints interface {
	// Upstream returns the ready upstream URL for fn and whether one exists. The URL's path, if
	// any, is where fn's worker serves it (a pool worker's /function/<name>, ADR-0046).
	Upstream(ctx context.Context, fn FunctionRef) (upstream string, ready bool, err error)
}

type FunctionRef struct {
	Namespace v1.NamespaceName
	Name      v1.ObjectName
	Revision  v1.ObjectName // "" ⇒ the serving revision
	UID       v1.UID        // set with Revision
}

type ProtocolFunc func(ctx context.Context, fn FunctionRef) (v1.FunctionProtocol, error)

type ResponseDeadline struct {
	At     time.Time
	Limit  time.Duration
	Source string // "spec.timeout" or "invoke.defaultTimeout"
}

type Scaler interface {
	ScaleTo(ctx context.Context, fn FunctionRef, replicas int) error
}