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

func RegisterControllerInfoServiceHTTP

func RegisterControllerInfoServiceHTTP() fx.Option

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
}

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)

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.