evcollector

Documentation

Index

• type Collector
  • func New(addr, namespace string, maxBatchSize int32, logger Logger, ...) *Collector
  • func (c *Collector) Start()
  • func (c *Collector) Stop()
• type Config
• type Logger
• type ReceiverParams

Types

type Collector

type Collector struct {
	Addr      string
	Namespace string
	// contains filtered or unexported fields
}

func New

func New(addr, namespace string, maxBatchSize int32, logger Logger, client rest.Interface) *Collector

func (*Collector) Start

func (c *Collector) Start()

func (*Collector) Stop

func (c *Collector) Stop()

type Config

type Config struct {
	MaxBatchSize int32
	Receivers    []*ReceiverParams
}

type Logger

type Logger interface {
	Info(msg string, keysAndValues ...any)
	Error(msg string, keysAndValues ...any)
	Debug(msg string, keysAndValues ...any)
}

type ReceiverParams

type ReceiverParams struct {
	ServiceName      string
	ServiceNamespace string
	Port             string
	WatchedNamespace string
}