agent

type BGPRouterManager interface {
	// ReconcileInstances evaluates the provided CiliumBGPNodeConfig
	// and the implementation will configure itself to apply this configuration.
	ReconcileInstances(ctx context.Context, bgpnc *v2.CiliumBGPNodeConfig, ciliumNode *v2.CiliumNode) error

	// GetPeers fetches peer states for all BGP instances managed by this
	// manager. It returns a mapping of instance name to its peer states.
	GetPeers(ctx context.Context, req *GetPeersRequest) (*GetPeersResponse, error)

	// GetPeersLegacy fetches BGP peering state from underlying routing
	// daemon.
	//
	// List of all peers will be returned and if there are multiple
	// instances of BGP daemon running locally, then peers can be
	// differentiated based on local AS number.
	//
	// This is a legacy method used by the REST API and will be replaced in
	// the future.
	GetPeersLegacy(ctx context.Context) ([]*models.BgpPeer, error)

	// GetRoutesLegacy fetches BGP routes from underlying routing daemon's RIBs.
	GetRoutesLegacy(ctx context.Context, params restapi.GetBgpRoutesParams) ([]*models.BgpRoute, error)

	// GetRoutes fetches BGP routes from underlying routing daemon's RIBs.
	GetRoutes(ctx context.Context, req *GetRoutesRequest) (*GetRoutesResponse, error)

	// GetRoutePolicies fetches BGP routing policies from underlying routing daemon.
	GetRoutePolicies(ctx context.Context, params restapi.GetBgpRoutePoliciesParams) ([]*models.BgpRoutePolicy, error)

	// Stop will stop all BGP instances and clean up local state.
	Stop(ctx cell.HookContext) error
}

type Controller struct {
	Logger *slog.Logger

	// CiliumNodeResource provides a stream of events for changes to the local CiliumNode resource.
	CiliumNodeResource daemon_k8s.LocalCiliumNodeResource
	// LocalCiliumNode is the CiliumNode object for the local node.
	LocalCiliumNode *v2.CiliumNode

	// BGP node store
	BGPNodeConfigStore store.BGPCPResourceStore[*v2.CiliumBGPNodeConfig]

	// Sig informs the Controller that a Kubernetes
	// event of interest has occurred.
	//
	// The signal itself provides no other information,
	// when it occurs the Controller will query each
	// informer for the latest API information required
	// to drive it's control loop.
	Sig *signaler.BGPCPSignaler

	// BGPMgr is an implementation of the BGPRouterManager interface
	// and provides a declarative API for configuring BGP peers.
	BGPMgr BGPRouterManager
}

type ControllerParams struct {
	cell.In

	Logger                  *slog.Logger
	Lifecycle               cell.Lifecycle
	Health                  cell.Health
	JobGroup                job.Group
	Shutdowner              hive.Shutdowner
	Sig                     *signaler.BGPCPSignaler
	RouteMgr                BGPRouterManager
	BGPNodeConfigStore      store.BGPCPResourceStore[*v2.CiliumBGPNodeConfig]
	DaemonConfig            *option.DaemonConfig
	LocalCiliumNodeResource daemon_k8s.LocalCiliumNodeResource
}

type GetPeersRequest struct{}

type GetPeersResponse struct {
	Instances []InstancePeerStates
}

type GetRoutesRequest struct {
	TableType types.TableType
	Family    types.Family
}

type GetRoutesResponse struct {
	Instances []InstanceRoutes
}

type InstancePeerStates struct {
	Name  string
	Peers []types.PeerState
}

type InstanceRoutes struct {
	InstanceName string
	NeighborName string
	Routes       []*types.Route
}