collector

Documentation

Index

• type KmCollector
  • func NewKmCollector(set otelcol.CollectorSettings) (*KmCollector, error)
  • func (col *KmCollector) DryRun(ctx context.Context) error
  • func (col *KmCollector) GetState() State
  • func (col *KmCollector) Run(ctx context.Context) error
  • func (col *KmCollector) Shutdown()
• type State
  • func (s State) String() string

Types

type KmCollector

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

KmCollector is a wrapper around opentelemetry's collector

func NewKmCollector

func NewKmCollector(set otelcol.CollectorSettings) (*KmCollector, error)

NewCollector creates and returns a new instance of Collector.

func (*KmCollector) DryRun

func (col *KmCollector) DryRun(ctx context.Context) error

func (*KmCollector) GetState

func (col *KmCollector) GetState() State

GetState returns current state of the collector server.

func (*KmCollector) Run

func (col *KmCollector) Run(ctx context.Context) error

Run starts the collector according to the given configuration, and waits for it to complete. Consecutive calls to Run are not allowed, Run shouldn't be called once a collector is shut down. Sets up the control logic for config reloading and shutdown.

func (*KmCollector) Shutdown

func (col *KmCollector) Shutdown()

Shutdown shuts down the collector server.

type State

type State int

State defines Collector's state.

const (
	StateStarting State = iota
	StateRunning
	StateClosing
	StateClosed
)

func (State) String

func (s State) String() string