status

Documentation

Index

• type BeaconSender
  • func NewBeaconSender(c Config, opt grpc.DialOption, log logr.Logger) (*BeaconSender, error)
  • func (s *BeaconSender) Run(ctx context.Context)
• type ComponentStatusSender
  • func New(c Config, fn componentStatusComposer, opt grpc.DialOption, log logr.Logger) (*ComponentStatusSender, error)
  • func (s *ComponentStatusSender) Run(ctx context.Context)
• type Config
  • func (c *Config) Validate() error
• type PodStatusSender
  • func NewPodStatusSender(c Config, ns, label string, opt grpc.DialOption, log logr.Logger) (*PodStatusSender, error)
  • func (s *PodStatusSender) Run(ctx context.Context)

Types

type BeaconSender

type BeaconSender struct {
	// contains filtered or unexported fields
}

BeaconSender sends beacon messages to the cluster manager.

func NewBeaconSender

func NewBeaconSender(
	c Config,
	opt grpc.DialOption,
	log logr.Logger,
) (*BeaconSender, error)

NewBeaconSender creates a new BeaconSender for sending beacon messages.

func (*BeaconSender) Run

func (s *BeaconSender) Run(ctx context.Context)

Run starts the beacon sender.

type ComponentStatusSender

type ComponentStatusSender struct {
	// contains filtered or unexported fields
}

ComponentStatusSender sends component status data to the cluster manager.

func New

func New(c Config, fn componentStatusComposer, opt grpc.DialOption, log logr.Logger) (*ComponentStatusSender, error)

New creates a new ComponentStatusSender.

func (*ComponentStatusSender) Run

func (s *ComponentStatusSender) Run(ctx context.Context)

Run starts the component status sender.

type Config

type Config struct {
	// Enable is the flag to enable sending component status.
	Enable bool `yaml:"enable"`
	// Name is the name of the component.
	Name string `yaml:"name"`
	// ClusterManagerServerWorkerServiceAddr is the address of the cluster manager server worker service.
	ClusterManagerServerWorkerServiceAddr string `yaml:"clusterManagerServerWorkerServiceAddr"`
	// InitalDelay is the inital delay at which the sender sends the first status message to the server.
	InitalDelay time.Duration `yaml:"initialDelay"`
	// Interval is the interval at which the sender sends status message to the server.
	Interval time.Duration `yaml:"interval"`
}

Config is the configuration for the sender.

func (*Config) Validate

func (c *Config) Validate() error

Validate validates the configuration.

type PodStatusSender

type PodStatusSender struct {
	// contains filtered or unexported fields
}

PodStatusSender sends pod status messages to the cluster manager.

func NewPodStatusSender

func NewPodStatusSender(
	c Config,
	ns, label string,
	opt grpc.DialOption,
	log logr.Logger,
) (*PodStatusSender, error)

NewPodStatusSender creates a new PodStatusSender for sending pod status.

func (*PodStatusSender) Run

func (s *PodStatusSender) Run(ctx context.Context)

Run starts the pod status sender.