leaderonlyreceiver

Documentation

Overview

Leader-only-receiver wraps any metrics receiver and starts it only when agent is a leader.

Index

• func Module() fx.Option
• func NewFactory(etcdClient *etcd.Client) receiver.Factory
• func WrapConfig(id component.ID, cfg any) (component.ID, any)
• func WrapConfigIf(condition bool, id component.ID, cfg any) (component.ID, any)
• type Config
  • func (c *Config) Validate() error

Functions

func Module

func Module() fx.Option

Module provides receiver factory.

func NewFactory

func NewFactory(etcdClient *etcd.Client) receiver.Factory

NewFactory creates a new aperture_leader_only receiver factory using given leader election.

func WrapConfig

func WrapConfig(id component.ID, cfg any) (component.ID, any)

WrapConfig returns configuration of leader-only receiver wrapping given receiver.

func WrapConfigIf

func WrapConfigIf(condition bool, id component.ID, cfg any) (component.ID, any)

WrapConfigIf returns configuration of leader-only receiver wrapping given receiver if condition is true. Otherwise, returns original id and config.

Types

type Config

type Config struct {
	Inner map[string]any `mapstructure:"config"`
	// Type of the wrapped receiver
	InnerType component.Type `mapstructure:"type"`
	// contains filtered or unexported fields
}

Config is a config for leader-only-receiver.

func (*Config) Validate

func (c *Config) Validate() error

Validate implements component.ConfigValidator.