core

Oct 15, 2023

Changes in this version

+ func NewRunner(ctx context.Context, cfgFile string, registery *prometheus.Registry, ...) (*controller, *zap.Logger, error)

Sep 19, 2023

Changes in this version

+ var TotalGlobalFilteredFrame = promauto.NewCounter(prometheus.CounterOpts{ ... })

+ var TotalLostInputFrame = promauto.NewCounter(prometheus.CounterOpts{ ... })

+ var TotalLostOutputFrame = promauto.NewCounterVec(prometheus.CounterOpts{ ... }, []string{ ... })

+ var TotalOGFilteredFrame = promauto.NewCounterVec(prometheus.CounterOpts{ ... }, []string{ ... })

+ var TotalRecvInputFrame = promauto.NewCounter(prometheus.CounterOpts{ ... })

+ var TotalRecvOutputFrame = promauto.NewCounterVec(prometheus.CounterOpts{ ... }, []string{ ... })

+ func NewBufferFromBufferConfig(c *config.BufferConfig, inCounter, lostCounter types.Counter) (types.Buffer, error)

+ func NewOutputBufferFromBufferConfig(c *config.BufferConfig) (types.Buffer, error)

+ type Controller struct

+ func NewController(cfg *config.Config, logger *zap.Logger) *Controller

+ func (c *Controller) OnShutdown(f func() error)

+ func (c *Controller) OnStartup(f func() error)

+ func (c *Controller) PrometheusListen(ctx context.Context)

+ func (c *Controller) Run(ctx context.Context) error

+ func (c *Controller) Setup() error

+ func (c *Controller) SetupOutputGroup() error

+ type OutputGroup struct