heartbeats

Documentation

Index

• func Invoke(*Heartbeats)
• func Merge(originalService, mergedService *heartbeatv1.Service)
• func Module() fx.Option
• func PeersWatcherModule() fx.Option
• func RegisterControllerInfoService(grpc *grpc.Server, handler *Heartbeats) error
• func RegisterControllerInfoServiceHTTP() fx.Option
• type ConstructorIn
• type Heartbeats
  • func Provide(in ConstructorIn) (*Heartbeats, error)
  • func (h *Heartbeats) GetControllerInfo(context.Context, *emptypb.Empty) (*heartbeatv1.ControllerInfo, error)
• type PeersOut
• type ServiceKey

Functions

func Invoke

func Invoke(*Heartbeats)

Invoke enables heartbeats in FX.

func Merge

func Merge(originalService, mergedService *heartbeatv1.Service)

Merge merges `mergedService` into `originalService`. This sums `EntitiesCount`.

func Module

func Module() fx.Option

Module returns the module for heartbeats.

func PeersWatcherModule

func PeersWatcherModule() fx.Option

PeersWatcherModule is a fx module that watches all agent peers.

func RegisterControllerInfoService

func RegisterControllerInfoService(grpc *grpc.Server, handler *Heartbeats) error

RegisterControllerInfoService registers the controller info service with the given gRPC server.

func RegisterControllerInfoServiceHTTP

func RegisterControllerInfoServiceHTTP() fx.Option

RegisterControllerInfoServiceHTTP registers the controller info service with the given gRPC gateway.

Types

type ConstructorIn

type ConstructorIn struct {
	fx.In

	Lifecycle                   fx.Lifecycle
	Unmarshaller                config.Unmarshaller
	JobGroup                    *jobs.JobGroup                     `name:"heartbeats-job-group"`
	GRPClientConnectionBuilder  grpcclient.ClientConnectionBuilder `name:"heartbeats-grpc-client"`
	HTTPClient                  *http.Client                       `name:"heartbeats-http-client"`
	StatusRegistry              status.Registry
	EntityCache                 *entitycache.EntityCache `optional:"true"`
	AgentInfo                   *agentinfo.AgentInfo     `optional:"true"`
	PeersWatcher                *peers.PeerDiscovery     `name:"fluxninja-peers-watcher" optional:"true"`
	EtcdClient                  *etcdclient.Client
	PolicyFactory               *controlplane.PolicyFactory            `optional:"true"`
	ServiceControlPointCache    *cache.Cache[selectors.ControlPointID] `optional:"true"`
	KubernetesControlPointCache kubernetes.ControlPointCache           `optional:"true"`
}

ConstructorIn injects dependencies into the Heartbeats constructor.

type Heartbeats

type Heartbeats struct {
	heartbeatv1.UnimplementedControllerInfoServiceServer

	ControllerInfo *heartbeatv1.ControllerInfo

	APIKey string
	// contains filtered or unexported fields
}

Heartbeats is the struct that holds information about heartbeats.

func Provide

func Provide(in ConstructorIn) (*Heartbeats, error)

Provide provides a new instance of Heartbeats.

func (*Heartbeats) GetControllerInfo

func (h *Heartbeats) GetControllerInfo(context.Context, *emptypb.Empty) (*heartbeatv1.ControllerInfo, error)

GetControllerInfo returns the controller info.

type PeersOut

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

PeersOut is a return struct provided to fx.

type ServiceKey

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

ServiceKey holds key for service.