util

Documentation

Index

• Constants
• 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
  • 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
  • func NewReqParams(req *http.Request) (*ReqParams, error)
  • func (r *ReqParams) Query(key string) (string, 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.15"

Functions

func ApiResponse

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

func GetChannelsForTopic

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

func GetTopicChannelArgs

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

监听并连接不同的 handle

Types

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 ReqParams

type ReqParams struct {
	Body []byte
	// contains filtered or unexported fields
}

func NewReqParams

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

func (*ReqParams) Query

func (r *ReqParams) Query(key string) (string, 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())

作用是异步的执行 cb