integration

Documentation

Index

• func CreateConfigFile(config blackbox.Config) string
• type BlackboxRunner
  • func NewBlackboxRunner(blackboxPath string) *BlackboxRunner
  • func (runner *BlackboxRunner) StartWithConfig(config blackbox.Config, tailerCount int)
  • func (runner *BlackboxRunner) Stop()
• type Inbox
  • func NewInbox() *Inbox
  • func (i *Inbox) Handle(m *syslog.Message) *syslog.Message
• type SyslogServer
  • func NewSyslogServer(inbox *Inbox) *SyslogServer
  • func (s *SyslogServer) Start()
  • func (s *SyslogServer) Stop()
• type TLSSyslogServer
  • func (s *TLSSyslogServer) Run() error
  • func (s *TLSSyslogServer) Stop()
• type TcpSyslogServer
  • func (s *TcpSyslogServer) Run(signals <-chan os.Signal, ready chan<- struct{}) error

Functions

func CreateConfigFile

func CreateConfigFile(config blackbox.Config) string

Types

type BlackboxRunner

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

func NewBlackboxRunner

func NewBlackboxRunner(blackboxPath string) *BlackboxRunner

func (*BlackboxRunner) StartWithConfig

func (runner *BlackboxRunner) StartWithConfig(config blackbox.Config, tailerCount int)

func (*BlackboxRunner) Stop

func (runner *BlackboxRunner) Stop()

type Inbox

type Inbox struct {
	Messages chan *syslog.Message
}

func NewInbox

func NewInbox() *Inbox

func (*Inbox) Handle

func (i *Inbox) Handle(m *syslog.Message) *syslog.Message

type SyslogServer

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

func NewSyslogServer

func NewSyslogServer(inbox *Inbox) *SyslogServer

func (*SyslogServer) Start

func (s *SyslogServer) Start()

func (*SyslogServer) Stop

func (s *SyslogServer) Stop()

type TLSSyslogServer

type TLSSyslogServer struct {
	Addr   string
	Buffer *gbytes.Buffer
	// contains filtered or unexported fields
}

func (*TLSSyslogServer) Run

func (s *TLSSyslogServer) Run() error

func (*TLSSyslogServer) Stop

func (s *TLSSyslogServer) Stop()

type TcpSyslogServer

type TcpSyslogServer struct {
	Addr   string
	Buffer *gbytes.Buffer
}

func (*TcpSyslogServer) Run

func (s *TcpSyslogServer) Run(signals <-chan os.Signal, ready chan<- struct{}) error