integration

package
v0.0.0-...-5214980 Latest Latest
Warning

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

Go to latest
Published: Apr 25, 2024 License: Apache-2.0 Imports: 18 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) ExitChannel

func (runner *BlackboxRunner) ExitChannel() <-chan error

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
	CertPrefixOverride 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

Jump to

Keyboard shortcuts

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