router

package

v0.7.1 Latest Latest Go to latest Published: Feb 22, 2021 License: Apache-2.0 Imports: 10 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/akkeris/logtrain

Links

Open Source Insights

Documentation ¶

Index ¶

type Drain
- func Create(endpoint string, maxconnections uint32, sticky bool) (*Drain, error)
type Metric
type Router
- func NewRouter(datasources []storage.DataSource, stickyPools bool, maxConnections uint32) (*Router, error)

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Drain ¶

type Drain struct {
	Input    chan syslog.Packet
	Info     chan string
	Error    chan error
	Endpoint string
	// contains filtered or unexported fields
}

Drain creates an output to the specified schema and manages back pressure and sends packets down to the ouptut.

func Create ¶

func Create(endpoint string, maxconnections uint32, sticky bool) (*Drain, error)

Create a new drain

func (*Drain) Close ¶

func (drain *Drain) Close() error

Close closes the drain

func (*Drain) Dial ¶

func (drain *Drain) Dial() error

Dial connects to the endpoint via the specified schema

func (*Drain) Errors ¶

func (drain *Drain) Errors() uint32

Errors returns the amount of errors that has occured on the drain

func (*Drain) MaxConnections ¶

func (drain *Drain) MaxConnections() uint32

MaxConnections returns the maximum allowed connections

func (*Drain) OpenConnections ¶

func (drain *Drain) OpenConnections() uint32

OpenConnections returns the open connections

func (*Drain) Pressure ¶

func (drain *Drain) Pressure() float64

Pressure returns a value between 0-1 represent the percent of full buffers

func (*Drain) ResetMetrics ¶

func (drain *Drain) ResetMetrics()

ResetMetrics sets the sent and errors values to zero

func (*Drain) Sent ¶

func (drain *Drain) Sent() uint32

Sent returns the amount of packets sent since inception or the last time ResetMetrics was fired

type Metric ¶

type Metric struct {
	MaxConnections uint32
	Connections    uint32
	Pressure       float64
	Sent           uint32
	Errors         uint32
}

type Router ¶

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

func NewRouter ¶

func NewRouter(datasources []storage.DataSource, stickyPools bool, maxConnections uint32) (*Router, error)

func (*Router) AddInput ¶

func (router *Router) AddInput(in input.Input, id string) error

func (*Router) Close ¶

func (router *Router) Close() error

func (*Router) DeadPackets ¶

func (router *Router) DeadPackets() int

func (*Router) Dial ¶

func (router *Router) Dial() error

func (*Router) Metrics ¶

func (router *Router) Metrics() map[string]Metric

func (*Router) RemoveInput ¶

func (router *Router) RemoveInput(id string) error

func (*Router) ResetMetrics ¶

func (router *Router) ResetMetrics()

Source Files ¶

View all Source files

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