pkgutils

Documentation

Index

• Variables
• func CheckConfig(userConfigPath string, dmRef dnsutils.DNSMessage) error
• func GetName(name string) string
• func GetRoutes(routes []Worker) ([]chan dnsutils.DNSMessage, []string)
• func LoadConfig(configPath string, dmRef dnsutils.DNSMessage) (*pkgconfig.Config, error)
• func ReloadConfig(configPath string, config *pkgconfig.Config, dmRef dnsutils.DNSMessage) error
• type FakeLogger
  • func NewFakeLogger() *FakeLogger
  • func NewFakeLoggerWithBufferSize(bufferSize int) *FakeLogger
  • func (c *FakeLogger) AddDefaultRoute(wrk Worker)
  • func (c *FakeLogger) AddDroppedRoute(wrk Worker)
  • func (c *FakeLogger) GetInputChannel() chan dnsutils.DNSMessage
  • func (c *FakeLogger) GetName() string
  • func (c *FakeLogger) ReadConfig()
  • func (c *FakeLogger) ReloadConfig(config *pkgconfig.Config)
  • func (c *FakeLogger) Run()
  • func (c *FakeLogger) SetLoggers(loggers []Worker)
  • func (c *FakeLogger) Stop()
• type RoutingHandler
  • func NewRoutingHandler(config *pkgconfig.Config, console *logger.Logger, name string) RoutingHandler
  • func (rh *RoutingHandler) AddDefaultRoute(wrk Worker)
  • func (rh *RoutingHandler) AddDroppedRoute(wrk Worker)
  • func (rh *RoutingHandler) GetDefaultRoutes() ([]chan dnsutils.DNSMessage, []string)
  • func (rh *RoutingHandler) GetDroppedRoutes() ([]chan dnsutils.DNSMessage, []string)
  • func (rh *RoutingHandler) LogError(msg string, v ...interface{})
  • func (rh *RoutingHandler) LogFatal(msg string)
  • func (rh *RoutingHandler) LogInfo(msg string, v ...interface{})
  • func (rh *RoutingHandler) Run()
  • func (rh *RoutingHandler) SendTo(routes []chan dnsutils.DNSMessage, routesName []string, dm dnsutils.DNSMessage)
  • func (rh *RoutingHandler) SetDefaultRoutes(workers []Worker)
  • func (rh *RoutingHandler) Stop()
• type Worker

Variables

var (
	PrefixLogProcessor   = "processor - "
	PrefixLogCollector   = "collector - "
	PrefixLogLogger      = "logger - "
	PrefixLogRouting     = "routing - "
	PrefixLogTransformer = "transformer - "
)

Functions

func CheckConfig

func CheckConfig(userConfigPath string, dmRef dnsutils.DNSMessage) error

func GetName

func GetName(name string) string

func GetRoutes

func GetRoutes(routes []Worker) ([]chan dnsutils.DNSMessage, []string)

func LoadConfig

func LoadConfig(configPath string, dmRef dnsutils.DNSMessage) (*pkgconfig.Config, error)

func ReloadConfig

func ReloadConfig(configPath string, config *pkgconfig.Config, dmRef dnsutils.DNSMessage) error

Types

type FakeLogger

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

func NewFakeLogger

func NewFakeLogger() *FakeLogger

func NewFakeLoggerWithBufferSize

func NewFakeLoggerWithBufferSize(bufferSize int) *FakeLogger

func (*FakeLogger) AddDefaultRoute

func (c *FakeLogger) AddDefaultRoute(wrk Worker)

func (*FakeLogger) AddDroppedRoute

func (c *FakeLogger) AddDroppedRoute(wrk Worker)

func (*FakeLogger) GetInputChannel

func (c *FakeLogger) GetInputChannel() chan dnsutils.DNSMessage

func (*FakeLogger) GetName

func (c *FakeLogger) GetName() string

func (*FakeLogger) ReadConfig

func (c *FakeLogger) ReadConfig()

func (*FakeLogger) ReloadConfig

func (c *FakeLogger) ReloadConfig(config *pkgconfig.Config)

func (*FakeLogger) Run

func (c *FakeLogger) Run()

func (*FakeLogger) SetLoggers

func (c *FakeLogger) SetLoggers(loggers []Worker)

func (*FakeLogger) Stop

func (c *FakeLogger) Stop()

type RoutingHandler

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

func NewRoutingHandler

func NewRoutingHandler(config *pkgconfig.Config, console *logger.Logger, name string) RoutingHandler

func (*RoutingHandler) AddDefaultRoute

func (rh *RoutingHandler) AddDefaultRoute(wrk Worker)

func (*RoutingHandler) AddDroppedRoute

func (rh *RoutingHandler) AddDroppedRoute(wrk Worker)

func (*RoutingHandler) GetDefaultRoutes

func (rh *RoutingHandler) GetDefaultRoutes() ([]chan dnsutils.DNSMessage, []string)

func (*RoutingHandler) GetDroppedRoutes

func (rh *RoutingHandler) GetDroppedRoutes() ([]chan dnsutils.DNSMessage, []string)

func (*RoutingHandler) LogError

func (rh *RoutingHandler) LogError(msg string, v ...interface{})

func (*RoutingHandler) LogFatal

func (rh *RoutingHandler) LogFatal(msg string)

func (*RoutingHandler) LogInfo

func (rh *RoutingHandler) LogInfo(msg string, v ...interface{})

func (*RoutingHandler) Run

func (rh *RoutingHandler) Run()

func (*RoutingHandler) SendTo

func (rh *RoutingHandler) SendTo(routes []chan dnsutils.DNSMessage, routesName []string, dm dnsutils.DNSMessage)

func (*RoutingHandler) SetDefaultRoutes

func (rh *RoutingHandler) SetDefaultRoutes(workers []Worker)

func (*RoutingHandler) Stop

func (rh *RoutingHandler) Stop()

type Worker

type Worker interface {
	AddDefaultRoute(wrk Worker)
	AddDroppedRoute(wrk Worker)
	SetLoggers(loggers []Worker)
	GetName() string
	Stop()
	Run()
	GetInputChannel() chan dnsutils.DNSMessage
	ReadConfig()
	ReloadConfig(config *pkgconfig.Config)
}