pkgutils

package
v0.44.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: May 9, 2024 License: MIT Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

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

Functions

func GetName added in v0.41.0 

func GetName(name string) string

func GetRoutes 

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

Types

type FakeLogger added in v0.40.2 

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

func NewFakeLogger added in v0.40.2 

func NewFakeLogger() *FakeLogger

func NewFakeLoggerWithBufferSize added in v0.40.2 

func NewFakeLoggerWithBufferSize(bufferSize int) *FakeLogger

func (*FakeLogger) AddDefaultRoute added in v0.40.2 

func (c *FakeLogger) AddDefaultRoute(wrk Worker)

func (*FakeLogger) AddDroppedRoute added in v0.40.2 

func (c *FakeLogger) AddDroppedRoute(wrk Worker)

func (*FakeLogger) GetInputChannel added in v0.40.2 

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

func (*FakeLogger) GetName added in v0.40.2 

func (c *FakeLogger) GetName() string

func (*FakeLogger) ReadConfig added in v0.40.2 

func (c *FakeLogger) ReadConfig()

func (*FakeLogger) ReloadConfig added in v0.40.2 

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

func (*FakeLogger) SetLoggers added in v0.40.2 

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

func (*FakeLogger) StartCollect added in v0.44.0 

func (c *FakeLogger) StartCollect()

func (*FakeLogger) Stop added in v0.40.2 

func (c *FakeLogger) Stop()

type GenericWorker added in v0.44.0 

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

func NewGenericWorker added in v0.44.0 

func NewGenericWorker(config *pkgconfig.Config, logger *logger.Logger, name string, descr string, bufferSize int) *GenericWorker

func (*GenericWorker) AddDefaultRoute added in v0.44.0 

func (w *GenericWorker) AddDefaultRoute(wrk Worker)

func (*GenericWorker) AddDroppedRoute added in v0.44.0 

func (w *GenericWorker) AddDroppedRoute(wrk Worker)

func (*GenericWorker) CollectDone added in v0.44.0 

func (w *GenericWorker) CollectDone()

func (*GenericWorker) GetConfig added in v0.44.0 

func (w *GenericWorker) GetConfig() *pkgconfig.Config

func (*GenericWorker) GetDefaultRoutes added in v0.44.0 

func (w *GenericWorker) GetDefaultRoutes() []Worker

func (*GenericWorker) GetDroppedRoutes added in v0.44.0 

func (w *GenericWorker) GetDroppedRoutes() []Worker

func (*GenericWorker) GetInputChannel added in v0.44.0 

func (w *GenericWorker) GetInputChannel() chan dnsutils.DNSMessage

func (*GenericWorker) GetLogger added in v0.44.0 

func (w *GenericWorker) GetLogger() *logger.Logger

func (*GenericWorker) GetName added in v0.44.0 

func (w *GenericWorker) GetName() string

func (*GenericWorker) GetOutputChannel added in v0.44.0 

func (w *GenericWorker) GetOutputChannel() chan dnsutils.DNSMessage

func (*GenericWorker) GetOutputChannelAsList added in v0.44.0 

func (w *GenericWorker) GetOutputChannelAsList() []chan dnsutils.DNSMessage

func (*GenericWorker) LogError added in v0.44.0 

func (w *GenericWorker) LogError(msg string, v ...interface{})

func (*GenericWorker) LogFatal added in v0.44.0 

func (w *GenericWorker) LogFatal(v ...interface{})

func (*GenericWorker) LogInfo added in v0.44.0 

func (w *GenericWorker) LogInfo(msg string, v ...interface{})

func (*GenericWorker) Loggers added in v0.44.0 

func (w *GenericWorker) Loggers() ([]chan dnsutils.DNSMessage, []string)

func (*GenericWorker) LoggingDone added in v0.44.0 

func (w *GenericWorker) LoggingDone()

func (*GenericWorker) Monitor added in v0.44.0 

func (w *GenericWorker) Monitor()

func (*GenericWorker) NewConfig added in v0.44.0 

func (w *GenericWorker) NewConfig() chan *pkgconfig.Config

func (*GenericWorker) OnLoggerStopped added in v0.44.0 

func (w *GenericWorker) OnLoggerStopped() chan bool

func (*GenericWorker) OnStop added in v0.44.0 

func (w *GenericWorker) OnStop() chan bool

func (*GenericWorker) ProcessorIsBusy added in v0.44.0 

func (w *GenericWorker) ProcessorIsBusy()

func (*GenericWorker) ReadConfig added in v0.44.0 

func (w *GenericWorker) ReadConfig()

func (*GenericWorker) ReloadConfig added in v0.44.0 

func (w *GenericWorker) ReloadConfig(config *pkgconfig.Config)

func (*GenericWorker) SendTo added in v0.44.0 

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

func (*GenericWorker) SetConfig added in v0.44.0 

func (w *GenericWorker) SetConfig(config *pkgconfig.Config)

func (*GenericWorker) SetDefaultRoutes added in v0.44.0 

func (w *GenericWorker) SetDefaultRoutes(next []Worker)

func (*GenericWorker) SetLoggers added in v0.44.0 

func (w *GenericWorker) SetLoggers(loggers []Worker)

func (*GenericWorker) StartCollect added in v0.44.0 

func (w *GenericWorker) StartCollect()

func (*GenericWorker) StartLogging added in v0.44.0 

func (w *GenericWorker) StartLogging()

func (*GenericWorker) Stop added in v0.44.0 

func (w *GenericWorker) Stop()

func (*GenericWorker) StopLogger added in v0.44.0 

func (w *GenericWorker) StopLogger()

func (*GenericWorker) WorkerIsBusy added in v0.44.0 

func (w *GenericWorker) WorkerIsBusy(name string)

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()
	StartCollect()
	GetInputChannel() chan dnsutils.DNSMessage
	ReadConfig()
	ReloadConfig(config *pkgconfig.Config)
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.