pkginit

Documentation

Index

• Constants
• func AreRoutesValid(config *pkgconfig.Config) (ret error)
• func CreateRouting(stanza pkgconfig.ConfigPipelines, mapCollectors map[string]workers.Worker, ...) error
• func CreateStanza(stanzaName string, config *pkgconfig.Config, ...)
• func GetItemConfig(section string, config *pkgconfig.Config, item pkgconfig.MultiplexInOut) *pkgconfig.Config
• func GetStanzaConfig(config *pkgconfig.Config, item pkgconfig.ConfigPipelines) *pkgconfig.Config
• func InitMultiplexer(mapLoggers map[string]workers.Worker, mapCollectors map[string]workers.Worker, ...)
• func InitPipelines(mapLoggers map[string]workers.Worker, mapCollectors map[string]workers.Worker, ...) error
• func IsCollectorRouted(config *pkgconfig.Config, name string) bool
• func IsLoggerRouted(config *pkgconfig.Config, name string) bool
• func IsMuxEnabled(config *pkgconfig.Config) bool
• func IsPipelinesEnabled(config *pkgconfig.Config) bool
• func IsRouteExist(target string, config *pkgconfig.Config) (ret error)
• func ReloadMultiplexer(mapLoggers map[string]workers.Worker, mapCollectors map[string]workers.Worker, ...)
• func ReloadPipelines(mapLoggers map[string]workers.Worker, mapCollectors map[string]workers.Worker, ...)
• func StanzaNameIsUniq(name string, config *pkgconfig.Config) (ret error)

Constants

const (
	Transformers = "-transformers"
)

Functions

func AreRoutesValid

func AreRoutesValid(config *pkgconfig.Config) (ret error)

func CreateRouting

func CreateRouting(stanza pkgconfig.ConfigPipelines, mapCollectors map[string]workers.Worker, mapLoggers map[string]workers.Worker, logger *logger.Logger) error

func CreateStanza

func CreateStanza(stanzaName string, config *pkgconfig.Config, mapCollectors map[string]workers.Worker, mapLoggers map[string]workers.Worker, logger *logger.Logger, metrics *telemetry.PrometheusCollector)

func GetItemConfig

func GetItemConfig(section string, config *pkgconfig.Config, item pkgconfig.MultiplexInOut) *pkgconfig.Config

func GetStanzaConfig

func GetStanzaConfig(config *pkgconfig.Config, item pkgconfig.ConfigPipelines) *pkgconfig.Config

func InitMultiplexer

func InitMultiplexer(mapLoggers map[string]workers.Worker, mapCollectors map[string]workers.Worker, config *pkgconfig.Config, logger *logger.Logger)

func InitPipelines

func InitPipelines(mapLoggers map[string]workers.Worker, mapCollectors map[string]workers.Worker, config *pkgconfig.Config, logger *logger.Logger, telemetry *telemetry.PrometheusCollector) error

func IsCollectorRouted

func IsCollectorRouted(config *pkgconfig.Config, name string) bool

func IsLoggerRouted

func IsLoggerRouted(config *pkgconfig.Config, name string) bool

func IsMuxEnabled

func IsMuxEnabled(config *pkgconfig.Config) bool

func IsPipelinesEnabled

func IsPipelinesEnabled(config *pkgconfig.Config) bool

func IsRouteExist

func IsRouteExist(target string, config *pkgconfig.Config) (ret error)

func ReloadMultiplexer

func ReloadMultiplexer(mapLoggers map[string]workers.Worker, mapCollectors map[string]workers.Worker, config *pkgconfig.Config, logger *logger.Logger)

func ReloadPipelines

func ReloadPipelines(mapLoggers map[string]workers.Worker, mapCollectors map[string]workers.Worker, config *pkgconfig.Config, logger *logger.Logger)

func StanzaNameIsUniq

func StanzaNameIsUniq(name string, config *pkgconfig.Config) (ret error)