util

Documentation

Index

• func GetEnvDefault(key string, defaultVal string) string
• func StatsDGauge(label string, value int64)
• func StatsDTiming(label string, start, end time.Time)
• type ProxyTCP
  • func NewProxyTCP(lAddr, rAddr string) (*ProxyTCP, error)
  • func (p *ProxyTCP) AcceptLoop()
  • func (p *ProxyTCP) Addr() string
  • func (p *ProxyTCP) Close()
  • func (p *ProxyTCP) Connections() []net.Conn
  • func (p *ProxyTCP) KillConnected()

Functions

func GetEnvDefault

func GetEnvDefault(key string, defaultVal string) string

func StatsDGauge

func StatsDGauge(label string, value int64)

func StatsDTiming

func StatsDTiming(label string, start, end time.Time)

Types

type ProxyTCP

type ProxyTCP struct {
	sync.Mutex
	// contains filtered or unexported fields
}

ProxyTCP is a basic TCP proxy which can terminate connections. It can be used to test reconnect behaviour.

func NewProxyTCP

func NewProxyTCP(lAddr, rAddr string) (*ProxyTCP, error)

func (*ProxyTCP) AcceptLoop

func (p *ProxyTCP) AcceptLoop()

func (*ProxyTCP) Addr

func (p *ProxyTCP) Addr() string

func (*ProxyTCP) Close

func (p *ProxyTCP) Close()

func (*ProxyTCP) Connections

func (p *ProxyTCP) Connections() []net.Conn

func (*ProxyTCP) KillConnected

func (p *ProxyTCP) KillConnected()