util

Documentation

Index

• Constants
• func ApiResponse(w http.ResponseWriter, statusCode int, statusTxt string, data interface{})
• func ByteToBase10(b []byte) (n uint64, err error)
• func Commafy(i interface{}) string
• func GetChannelsForTopic(topic string, lookupdHTTPAddrs []string) ([]string, error)
• func GetTopicChannelArgs(rp Getter) (string, string, error)
• func StringAdd(s []string, a string) []string
• func StringUnion(s []string, a []interface{}) []string
• func TcpServer(listener net.Listener, handler TcpHandler)
• type Getter
• type MockConn
  • func (c MockConn) Close() error
  • func (c MockConn) LocalAddr() net.Addr
  • func (c MockConn) RemoteAddr() net.Addr
  • func (c MockConn) SetDeadline(t time.Time) error
  • func (c MockConn) SetReadDeadline(t time.Time) error
  • func (c MockConn) SetWriteDeadline(t time.Time) error
• type PostParams
  • func (p *PostParams) Get(key string) (string, error)
• type ReqParams
  • func NewReqParams(req *http.Request) (*ReqParams, error)
  • func (r *ReqParams) Get(key string) (string, error)
  • func (r *ReqParams) GetAll(key string) ([]string, error)
• type StatsdClient
  • func NewStatsdClient(addr string, prefix string) *StatsdClient
  • func (c *StatsdClient) Close() error
  • func (c *StatsdClient) CreateSocket() error
  • func (c *StatsdClient) Decr(stat string, count int) error
  • func (c *StatsdClient) Gauge(stat string, value int) error
  • func (c *StatsdClient) Incr(stat string, count int) error
  • func (c *StatsdClient) String() string
  • func (c *StatsdClient) Timing(stat string, delta int) error
• type StringArray
  • func (a *StringArray) Set(s string) error
  • func (a *StringArray) String() string
• type TcpHandler
• type WaitGroupWrapper
  • func (w *WaitGroupWrapper) Wrap(cb func())

Constants

const BINARY_VERSION = "0.2.19"

Functions

func ApiResponse

func ApiResponse(w http.ResponseWriter, statusCode int, statusTxt string, data interface{})

func ByteToBase10

func ByteToBase10(b []byte) (n uint64, err error)

func Commafy

func Commafy(i interface{}) string

func GetChannelsForTopic

func GetChannelsForTopic(topic string, lookupdHTTPAddrs []string) ([]string, error)

func GetTopicChannelArgs

func GetTopicChannelArgs(rp Getter) (string, string, error)

func StringAdd

func StringAdd(s []string, a string) []string

func StringUnion

func StringUnion(s []string, a []interface{}) []string

func TcpServer

func TcpServer(listener net.Listener, handler TcpHandler)

Types

type Getter

type Getter interface {
	Get(key string) (string, error)
}

type MockConn

type MockConn struct {
	io.ReadWriter
}

func (MockConn) Close

func (c MockConn) Close() error

func (MockConn) LocalAddr

func (c MockConn) LocalAddr() net.Addr

func (MockConn) RemoteAddr

func (c MockConn) RemoteAddr() net.Addr

func (MockConn) SetDeadline

func (c MockConn) SetDeadline(t time.Time) error

func (MockConn) SetReadDeadline

func (c MockConn) SetReadDeadline(t time.Time) error

func (MockConn) SetWriteDeadline

func (c MockConn) SetWriteDeadline(t time.Time) error

type PostParams

type PostParams struct {
	*http.Request
}

func (*PostParams) Get

func (p *PostParams) Get(key string) (string, error)

type ReqParams

type ReqParams struct {
	url.Values
	Body []byte
}

func NewReqParams

func NewReqParams(req *http.Request) (*ReqParams, error)

func (*ReqParams) Get

func (r *ReqParams) Get(key string) (string, error)

func (*ReqParams) GetAll

func (r *ReqParams) GetAll(key string) ([]string, error)

type StatsdClient

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

func NewStatsdClient

func NewStatsdClient(addr string, prefix string) *StatsdClient

func (*StatsdClient) Close

func (c *StatsdClient) Close() error

func (*StatsdClient) CreateSocket

func (c *StatsdClient) CreateSocket() error

func (*StatsdClient) Decr

func (c *StatsdClient) Decr(stat string, count int) error

func (*StatsdClient) Gauge

func (c *StatsdClient) Gauge(stat string, value int) error

func (*StatsdClient) Incr

func (c *StatsdClient) Incr(stat string, count int) error

func (*StatsdClient) String

func (c *StatsdClient) String() string

func (*StatsdClient) Timing

func (c *StatsdClient) Timing(stat string, delta int) error

type StringArray

type StringArray []string

func (*StringArray) Set

func (a *StringArray) Set(s string) error

func (*StringArray) String

func (a *StringArray) String() string

type TcpHandler

type TcpHandler interface {
	Handle(net.Conn)
}

type WaitGroupWrapper

type WaitGroupWrapper struct {
	sync.WaitGroup
}

func (*WaitGroupWrapper) Wrap

func (w *WaitGroupWrapper) Wrap(cb func())