input

Documentation

Index

• func InitMetrics()
• func NewPickle(config cfg.Config, addr string, tbl *table.Table, bad *badmetrics.BadMetrics) (net.Listener, error)
• func NewPlain(config cfg.Config, addr string, tbl *table.Table, ...) (net.Listener, error)
• func SetLogger(l *logging.Logger)
• func StartAMQP(config cfg.Config, tbl *table.Table, bad *badmetrics.BadMetrics)
• type Amqp
• type Handler
• type Pickle
  • func (p *Pickle) Handle(c net.Conn)
• type Plain
  • func (p *Plain) Handle(c net.Conn)

Functions

func InitMetrics

func InitMetrics()

func NewPickle

func NewPickle(config cfg.Config, addr string, tbl *table.Table, bad *badmetrics.BadMetrics) (net.Listener, error)

func NewPlain

func NewPlain(config cfg.Config, addr string, tbl *table.Table, badMetrics *badmetrics.BadMetrics) (net.Listener, error)

func SetLogger

func SetLogger(l *logging.Logger)

func StartAMQP

func StartAMQP(config cfg.Config, tbl *table.Table, bad *badmetrics.BadMetrics)

Types

type Amqp

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

type Handler

type Handler interface {
	Handle(net.Conn)
}

type Pickle

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

func (*Pickle) Handle

func (p *Pickle) Handle(c net.Conn)

type Plain

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

func (*Plain) Handle

func (p *Plain) Handle(c net.Conn)