router

Documentation

Index

• type Drain
  • func Create(endpoint string, maxconnections uint32, sticky bool) (*Drain, error)
  • func (drain *Drain) Close() error
  • func (drain *Drain) Dial() error
  • func (drain *Drain) Errors() uint32
  • func (drain *Drain) MaxConnections() uint32
  • func (drain *Drain) OpenConnections() uint32
  • func (drain *Drain) Pressure() float64
  • func (drain *Drain) ResetMetrics()
  • func (drain *Drain) Sent() uint32
• type Metric
• type Router
  • func NewRouter(datasources []storage.DataSource, stickyPools bool, maxConnections uint32) (*Router, error)
  • func (router *Router) AddInput(in input.Input, id string) error
  • func (router *Router) Close() error
  • func (router *Router) DeadPackets() int
  • func (router *Router) Dial() error
  • func (router *Router) Metrics() map[string]Metric
  • func (router *Router) RemoveInput(id string) error
  • func (router *Router) ResetMetrics()

Types

type Drain

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

func Create

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

func (*Drain) Close

func (drain *Drain) Close() error

func (*Drain) Dial

func (drain *Drain) Dial() error

func (*Drain) Errors

func (drain *Drain) Errors() uint32

func (*Drain) MaxConnections

func (drain *Drain) MaxConnections() uint32

func (*Drain) OpenConnections

func (drain *Drain) OpenConnections() uint32

func (*Drain) Pressure

func (drain *Drain) Pressure() float64

func (*Drain) ResetMetrics

func (drain *Drain) ResetMetrics()

func (*Drain) Sent

func (drain *Drain) Sent() uint32

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()