lumberjack

Documentation

Overview

Lumberjack server test tool.

Create lumberjack server endpoint ACKing all received batches only. The server supports all lumberjack protocol versions, which must be explicitly enabled from command line. For printing list of known command line flags run:

tst-lj -h

Index

• type ServiceLumber
  • func (p *ServiceLumber) Collect(pipeline.Collector) error
  • func (p *ServiceLumber) Description() string
  • func (p *ServiceLumber) Init(context pipeline.Context) (int, error)
  • func (p *ServiceLumber) Start(c pipeline.Collector) error
  • func (p *ServiceLumber) Stop() error

Types

type ServiceLumber

type ServiceLumber struct {
	BindAddress string
	V1          bool
	V2          bool
	// Path to CA file
	SSLCA string
	// Path to host cert file
	SSLCert string
	// Path to cert key file
	SSLKey string
	// Use SSL but skip chain & host verification
	InsecureSkipVerify bool
	// contains filtered or unexported fields
}

func (*ServiceLumber) Collect

func (p *ServiceLumber) Collect(pipeline.Collector) error

Gather takes in an accumulator and adds the metrics that the Input gathers. This is called every "interval"

func (*ServiceLumber) Description

func (p *ServiceLumber) Description() string

func (*ServiceLumber) Init

func (p *ServiceLumber) Init(context pipeline.Context) (int, error)

func (*ServiceLumber) Start

func (p *ServiceLumber) Start(c pipeline.Collector) error

Start starts the ServiceInput's service, whatever that may be

func (*ServiceLumber) Stop

func (p *ServiceLumber) Stop() error

Stop stops the services and closes any necessary channels and connections