status

Dec 3, 2024

Changes in this version

+ type BeaconSender struct

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

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

+ type ComponentStatusSender struct

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

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

+ type Config struct

+ ClusterManagerServerWorkerServiceAddr string

+ Enable bool

+ InitalDelay time.Duration

+ Interval time.Duration

+ Name string

+ func (c *Config) Validate() error

+ type PodStatusSender struct

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

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