integration

package
v0.0.0-...-5962cd0 Latest Latest
Warning

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

Go to latest
Published: Apr 2, 2018 License: Apache-2.0 Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

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 TcpSyslogServer

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

func (*TcpSyslogServer) Run

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL