util

Aug 26, 2014

Changes in this version

+ func ParseOpts(cfg *nsq.Config, opts StringArray) error

Jul 25, 2014

Changes in this version

+ func APIRequestNegotiateV1(method string, endpoint string, body io.Reader) (*simplejson.Json, error)

+ func ApiRequestV1(endpoint string, v interface{}) error

+ func IsValidChannelName(name string) bool

+ func IsValidTopicName(name string) bool

+ func NegotiateAPIResponseWrapper(w http.ResponseWriter, req *http.Request, f func() (interface{}, error))

+ func POSTRequired(req *http.Request, f func() (interface{}, error)) func() (interface{}, error)

+ func V1APIResponseWrapper(w http.ResponseWriter, req *http.Request, f func() (interface{}, error))

+ func V1ApiResponse(w http.ResponseWriter, code int, data interface{})

+ type HTTPError struct

+ Code int

+ Text string

+ func (e HTTPError) Error() string

Feb 6, 2014

Changes in this version

+ func Coerce(v interface{}, opt interface{}, arg string) (interface{}, error)

+ func ResolveOptions(options interface{}, flagSet *flag.FlagSet, cfg map[string]interface{})

Dec 7, 2013

Changes in this version

+ func FloatToPercent(i float64) string

+ func NanoSecondToHuman(v float64) string

+ func ParseReaderOpts(r *nsq.Reader, opts StringArray) error

+ func PercSuffix(i float64) string

+ type E2eProcessingLatencyAggregate struct

+ Addr string

+ Channel string

+ Count int

+ Percentiles []map[string]float64

+ Topic string

+ func E2eProcessingLatencyAggregateFromJson(j *simplejson.Json, topic, channel, host string) *E2eProcessingLatencyAggregate

+ func (A *E2eProcessingLatencyAggregate) Add(B *E2eProcessingLatencyAggregate, N int) *E2eProcessingLatencyAggregate

+ func (e *E2eProcessingLatencyAggregate) Host() string

+ func (e *E2eProcessingLatencyAggregate) Len() int

+ func (e *E2eProcessingLatencyAggregate) Less(i, j int) bool

+ func (e *E2eProcessingLatencyAggregate) Swap(i, j int)

+ func (e *E2eProcessingLatencyAggregate) Target(key string) ([]string, string)

+ type FloatArray []float64

+ func (a *FloatArray) Set(param string) error

+ func (a *FloatArray) String() string

+ func (a FloatArray) Len() int

+ func (a FloatArray) Less(i, j int) bool

+ func (a FloatArray) Swap(i, j int)

+ type PercentileResult struct

+ Count int

+ Percentiles []map[string]float64

+ func (pr *PercentileResult) String() string

+ type Quantile struct

+ MoveWindowTime time.Duration

+ Percentiles []float64

+ func NewQuantile(WindowTime time.Duration, Percentiles []float64) *Quantile

+ func (q *Quantile) Insert(msgStartTime int64)

+ func (q *Quantile) IsDataStale(now time.Time) bool

+ func (q *Quantile) Merge(them *Quantile)

+ func (q *Quantile) PercentileResult() *PercentileResult

+ func (q *Quantile) QueryHandler() *quantile.Stream

Oct 23, 2013

Changes in this version

+ func ApiRequest(endpoint string) (*simplejson.Json, error)

+ func NewDeadlineTransport(timeout time.Duration) *http.Transport

+ func SendFramedResponse(w io.Writer, frameType int32, data []byte) (int, error)

+ func SendResponse(w io.Writer, data []byte) (int, error)

+ type ChildErr interface

+ Parent func() error

+ type ClientErr struct

+ Code string

+ Desc string

+ ParentErr error

+ func NewClientErr(parent error, code string, description string) *ClientErr

+ func (e *ClientErr) Error() string

+ func (e *ClientErr) Parent() error

+ type FatalClientErr struct

+ Code string

+ Desc string

+ ParentErr error

+ func NewFatalClientErr(parent error, code string, description string) *FatalClientErr

+ func (e *FatalClientErr) Error() string

+ func (e *FatalClientErr) Parent() error

+ type Protocol interface

+ IOLoop func(conn net.Conn) error

Aug 26, 2013

Changes in this version

+ func HTTPServer(listener net.Listener, handler http.Handler)

+ func StatsdHostKey(h string) string

+ func TCPServer(listener net.Listener, handler TCPHandler)

+ type TCPHandler interface

+ Handle func(net.Conn)

May 13, 2013

Changes in this version

+ func Version(app string) string

Feb 8, 2013

Changes in this version

+ type Getter interface

+ Get func(key string) (string, error)

+ type PostParams struct

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

Jan 7, 2013

Changes in this version

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

+ func Commafy(i interface{}) string

type ReqParams

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

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

+ type StatsdClient struct

+ 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

Oct 25, 2012

Changes in this version

+ const BINARY_VERSION

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

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

+ func GetTopicChannelArgs(rp *ReqParams) (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 MockConn struct

+ 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 ReqParams struct

+ Body []byte

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

+ func (r *ReqParams) Query(key string) (string, error)

+ type StringArray []string

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

+ func (a *StringArray) String() string

+ type TcpHandler interface

+ Handle func(net.Conn)

+ type WaitGroupWrapper struct

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