Struct endpointManager

pkg/endpointmanager/manager.go:51–107

endpointManager is a structure designed for containing state about the collection of locally running endpoints.

// endpointManager is a structure designed for containing state about the
// collection of locally running endpoints.
type endpointManager struct {
	logger *slog.Logger

	config EndpointManagerConfig

	health cell.Health

	// mutex protects endpoints and endpointsAux
	mutex lock.RWMutex

	// endpoints is the global list of endpoints indexed by ID. mutex must
	// be held to read and write.
	endpoints    map[uint16]*endpoint.Endpoint
	endpointsAux map[string]*endpoint.Endpoint

	// mcastManager handles IPv6 multicast group join/leave for pods. This is required for the
	// node to receive ICMPv6 NDP messages, especially NS (Neighbor Solicitation) message, so
	// pod's IPv6 address is discoverable.
	mcastManager *mcastmanager.MCastManager

	// EndpointSynchronizer updates external resources (e.g., Kubernetes) with
	// up-to-date information about endpoints managed by the endpoint manager.
	EndpointResourceSynchronizer

	// subscribers are notified when events occur in the endpointManager.
	subscribers map[Subscriber]struct{}

	// checkHealth supports endpoint garbage collection by verifying the health
	// of an endpoint.
	checkHealth EndpointCheckerFunc

	// deleteEndpoint is the function used to remove the endpoint from the
	// endpointManager and clean it up. Always set to RemoveEndpoint.
	deleteEndpoint endpointDeleteFunc

	// A mark-and-sweep garbage collector may operate on the endpoint list.
	// This is configured via WithPeriodicEndpointGC() and will mark
	// endpoints for removal on one run of the controller, then in the
	// subsequent controller run will remove the endpoints.
	markedEndpoints []uint16

	// controllers associated with the endpoint manager.
	controllers *controller.Manager

	policyMapPressure *policyMapPressure

	// localNodeStore allows to retrieve information and observe changes about
	// the local node.
	localNodeStore *node.LocalNodeStore

	// Allocator for local endpoint identifiers.
	epIDAllocator *epIDAllocator

	monitorAgent monitoragent.Agent

	policyUpdateCallbackDetails
}