gamma

type PodPorts interface {
	// PodPortClasses returns the class of every port of service
	// ("<ns>/<name>") as this node's tables serve it, and whether the node
	// knows the service's ports at all. known is false when it holds no row
	// of the service: then nothing is known here, and this node judges
	// nothing of it. What another node that does hold it judged is in the
	// route's status (judged.go), and is what this node then goes by.
	PodPortClasses(ctx context.Context, service string) (classes map[uint32]registryv1.PortProtocol, known bool)
}

type Reconciler struct {
	client.Client

	// APIReader reads the API directly, without a cache. Used only to read
	// the EndpointSlices of a route-named Service whose targetPort is a name
	// (resolveNamedTargetPorts). Nil disables that resolution.
	APIReader client.Reader

	// PodPorts says what the pods of a user's Service declare, for a route's
	// status (podports.go). Nil: such a port is reported as not checked.
	PodPorts PodPorts
	// PodPortsChanged delivers an event each time what PodPorts answers has
	// changed (the cache's OnPodPortsChanged): every route's status is then
	// judged again. Nil: the status follows only what the reconciler watches.
	PodPortsChanged <-chan event.GenericEvent

	// Sink receives the projected per-service rules (the snapshot cache).
	Sink RouteSink
	// MeshDomain resolves a backend Service to its data-plane cluster name.
	MeshDomain string
	Log        *slog.Logger

	// Now is the clock of the status writer's back-off; nil is time.Now.
	Now func() time.Time

	// After runs f after d; nil is time.AfterFunc. It is the timer that keeps
	// a held-back status's wait when a reconcile ends in an error (wakeIn).
	After func(d time.Duration, f func())
	// contains filtered or unexported fields
}

type RouteSink interface {
	SetServiceRoutes(routes map[string][]proxy.GammaRoute)
	// SetServiceChainFilters receives the service-wide ALWAYS-ON extension filters
	// (proposal 025 M4 CHAIN scope), keyed by "<ns>/<svc>": at most one per service,
	// from a CHAIN-scope HTTPFilter with a same-namespace Service targetRef. Enabled
	// at the service's capture vhost.
	SetServiceChainFilters(filters map[string]proxy.ExtensionFilter)
	// SetServiceInboundFilters receives the destination-side (INBOUND scope, 027 M3)
	// filters, keyed by "<ns>/<svc>": enabled on the target service's own pods'
	// inbound listeners. At most one per service.
	SetServiceInboundFilters(filters map[string]proxy.ExtensionFilter)
	// SetRouteTargetPorts receives the real Service port(s) of each route target
	// (proposal 023 M2), keyed by the same "<ns>/<svc>" route-target key as
	// SetServiceRoutes. Sourced from the HTTPRoute/GRPCRoute parentRef port; lets the
	// cap_http vhost host-match a client dialing the target's REAL port.
	SetRouteTargetPorts(ports map[string][]uint32)
	// SetServicePortMaps receives the port map of every Service a route names
	// as its parent or as a backend and that the registrar did not generate
	// (proposal 043, "A Service is a port map"), keyed "<ns>/<svc>": Service
	// port -> the pod port its targetPort names, 0 when the targetPort is a
	// name. A route's ports are ports of the SERVICE; the mesh resolves them
	// to pod ports through this.
	SetServicePortMaps(portMaps map[string]map[uint32]uint32)
}