nsqconn

Documentation

Index

• type NsqConn
  • func (nc *NsqConn) Close() error
  • func (nc *NsqConn) Pub(topic string, data []byte) error
  • func (nc *NsqConn) Sub(topic string, handler remote.SubHandler) error
• type NsqConnBuilder
  • func NewNsqBuilder() *NsqConnBuilder
  • func (ncb *NsqConnBuilder) AddLookupdIps(ips ...string) *NsqConnBuilder
  • func (ncb *NsqConnBuilder) AddNsqdIps(ips ...string) *NsqConnBuilder
  • func (ncb *NsqConnBuilder) Build() (remote.PubSub, error)
  • func (ncb *NsqConnBuilder) Channel(c string) *NsqConnBuilder
  • func (ncb *NsqConnBuilder) Set(key string, val interface{}) *NsqConnBuilder

Types

type NsqConn

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

func (*NsqConn) Close

func (nc *NsqConn) Close() error

func (*NsqConn) Pub

func (nc *NsqConn) Pub(topic string, data []byte) error

Sumple pub

func (*NsqConn) Sub

func (nc *NsqConn) Sub(topic string, handler remote.SubHandler) error

type NsqConnBuilder

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

func NewNsqBuilder

func NewNsqBuilder() *NsqConnBuilder

func (*NsqConnBuilder) AddLookupdIps

func (ncb *NsqConnBuilder) AddLookupdIps(ips ...string) *NsqConnBuilder

func (*NsqConnBuilder) AddNsqdIps

func (ncb *NsqConnBuilder) AddNsqdIps(ips ...string) *NsqConnBuilder

func (*NsqConnBuilder) Build

func (ncb *NsqConnBuilder) Build() (remote.PubSub, error)

func (*NsqConnBuilder) Channel

func (ncb *NsqConnBuilder) Channel(c string) *NsqConnBuilder

func (*NsqConnBuilder) Set

func (ncb *NsqConnBuilder) Set(key string, val interface{}) *NsqConnBuilder