heartbeats

type ConstructorIn struct {
	fx.In

	Lifecycle                        fx.Lifecycle
	ExtensionConfig                  *extconfig.FluxNinjaExtensionConfig
	GRPCServer                       *grpc.Server
	JobGroup                         *jobs.JobGroup                     `name:"heartbeats-job-group"`
	GRPClientConnectionBuilder       grpcclient.ClientConnectionBuilder `name:"heartbeats-grpc-client"`
	HTTPClient                       *http.Client                       `name:"heartbeats-http-client"`
	StatusRegistry                   status.Registry
	Entities                         *entities.Entities   `optional:"true"`
	AgentInfo                        *agentinfo.AgentInfo `optional:"true"`
	PeersWatcher                     *peers.PeerDiscovery `name:"fluxninja-peers-watcher" optional:"true"`
	EtcdClient                       *etcdclient.Client
	Election                         *election.Election                          `optional:"true"`
	PolicyFactory                    *controlplane.PolicyFactory                 `optional:"true"`
	FlowControlPoints                *cache.Cache[selectors.TypedControlPointID] `optional:"true"`
	AutoscaleKubernetesControlPoints autoscalediscovery.AutoScaleControlPoints   `optional:"true"`
}

type Heartbeats struct {
	heartbeatv1.UnimplementedControllerInfoServiceServer

	ControllerInfo *heartbeatv1.ControllerInfo

	APIKey string
	// contains filtered or unexported fields
}

type PeersOut struct {
	fx.Out
	PeerWatcher *peers.PeerDiscovery `name:"fluxninja-peers-watcher" optional:"true"`
}

type ServiceKey struct {
	Name string `json:"name"`
}