nsq

package

Go to main page

Versions in this module

v0

v0.2.22

Aug 26, 2013

Changes in this version

+ var ErrNotConnected = errors.New("not connected")

+ var ErrOverMaxInFlight = errors.New("over configure max-inflight")

+ var ErrStopped = errors.New("stopped")

type Reader

+ LookupdPollJitter float64

+ LowRdyIdleTimeout time.Duration

+ TLSConfig *tls.Config

+ TLSv1 bool

type Writer

+ Addr string

+ func (w *Writer) MultiPublishAsync(topic string, body [][]byte, doneChan chan *WriterTransaction, ...) error

+ func (w *Writer) PublishAsync(topic string, body []byte, doneChan chan *WriterTransaction, ...) error

+ func (w *Writer) String() string

+ type WriterTransaction struct

+ Args []interface{}

+ Data []byte

+ Error error

+ FrameType int32

v0.2.21

Jun 9, 2013

v0.2.20

May 13, 2013

Changes in this version

+ type Writer struct

+ HeartbeatInterval int

+ LongIdentifier string

+ ShortIdentifier string

+ WriteTimeout time.Duration

+ func NewWriter(heartbeatInterval int) *Writer

+ func (this *Writer) ConnectToNSQ(addr string) error

+ func (this *Writer) MultiPublish(topic string, body [][]byte) (int32, []byte, error)

+ func (this *Writer) Publish(topic string, body []byte) (int32, []byte, error)

+ func (this *Writer) Stop()

v0.2.19

Apr 12, 2013

v0.2.18

Feb 28, 2013

v0.2.17

Feb 8, 2013

Changes in this version

+ type ChildError interface

+ Parent func() error

type ClientErr

+ Code string

+ ParentErr error

+ func (e *ClientErr) Parent() error

type Command

+ func Touch(id MessageID) *Command

+ 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 PeerInfo

+ BroadcastAddress string

type Reader

+ func (q *Reader) SetMaxBackoffDuration(duration time.Duration)

v0.2.16

Jan 7, 2013

Changes in this version

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

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

type Command

+ func MultiPublish(topic string, bodies [][]byte) (*Command, error)

+ func (c *Command) Write(w io.Writer) error

type LookupPeer

+ Info PeerInfo

type Message

+ func (m *Message) Write(w io.Writer) error

+ type MessageID [MsgIdLength]byte

v0.2.15

Oct 25, 2012

Changes in this version

+ const DefaultClientTimeout

+ const FrameTypeError

+ const FrameTypeMessage

+ const FrameTypeResponse

+ const MaxReadyCount

+ const MsgIdLength

+ const StateClosing

+ const StateConnected

+ const StateDisconnected

+ const StateInit

+ const StateSubscribed

+ const VERSION

+ var ErrAlreadyConnected = errors.New("already connected")

+ var MagicV1 = []byte(" V1")

+ var MagicV2 = []byte(" V2")

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

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

+ func IsValidChannelName(name string) bool

+ func IsValidTopicName(name string) bool

+ func ReadMagic(r io.Reader) (int32, error)

+ func ReadResponse(r io.Reader) ([]byte, error)

+ func SendCommand(w io.Writer, cmd *Command) error

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

+ func UnpackResponse(response []byte) (int32, []byte, error)

+ type AsyncHandler interface

+ HandleMessage func(message *Message, responseChannel chan *FinishedMessage)

+ type ClientErr struct

+ Desc string

+ Err string

+ func NewClientErr(err string, description string) *ClientErr

+ func (e *ClientErr) Description() string

+ func (e *ClientErr) Error() string

+ type Command struct

+ Body []byte

+ Name []byte

+ Params [][]byte

+ func Announce(topic string, channel string, port int, ips []string) *Command

+ func Finish(id []byte) *Command

+ func Identify(version string, tcpPort int, httpPort int, address string) *Command

+ func Nop() *Command

+ func Ping() *Command

+ func Publish(topic string, body []byte) *Command

+ func Ready(count int) *Command

+ func Register(topic string, channel string) *Command

+ func Requeue(id []byte, timeoutMs int) *Command

+ func StartClose() *Command

+ func Subscribe(topic string, channel string, shortIdentifier string, longIdentifier string) *Command

+ func UnRegister(topic string, channel string) *Command

+ func (c *Command) String() string

+ type FailedMessageLogger interface

+ LogFailedMessage func(message *Message)

+ type FinishedMessage struct

+ Id []byte

+ RequeueDelayMs int

+ Success bool

+ type Handler interface

+ HandleMessage func(message *Message) error

+ type LookupPeer struct

+ PeerInfo PeerInfo

+ func NewLookupPeer(addr string, connectCallback func(*LookupPeer)) *LookupPeer

+ func (lp *LookupPeer) Close() error

+ func (lp *LookupPeer) Command(cmd *Command) ([]byte, error)

+ func (lp *LookupPeer) Connect() error

+ func (lp *LookupPeer) Read(data []byte) (int, error)

+ func (lp *LookupPeer) String() string

+ func (lp *LookupPeer) Write(data []byte) (int, error)

+ type Message struct

+ Attempts uint16

+ Body []byte

+ Id []byte

+ Timestamp int64

+ func DecodeMessage(byteBuf []byte) (*Message, error)

+ func NewMessage(id []byte, body []byte) *Message

+ func (m *Message) Encode(w io.Writer) error

+ func (m *Message) EncodeBytes() ([]byte, error)

+ type PeerInfo struct

+ Address string

+ HttpPort int

+ TcpPort int

+ Version string

+ type Protocol interface

+ IOLoop func(conn net.Conn) error

+ type Reader struct

+ ChannelName string

+ DefaultRequeueDelay time.Duration

+ ExitChan chan int

+ LongIdentifier string

+ LookupdPollInterval time.Duration

+ MaxAttemptCount uint16

+ MaxRequeueDelay time.Duration

+ MessagesFinished uint64

+ MessagesReceived uint64

+ MessagesRequeued uint64

+ ReadTimeout time.Duration

+ ShortIdentifier string

+ TopicName string

+ VerboseLogging bool

+ WriteTimeout time.Duration

+ func NewReader(topic string, channel string) (*Reader, error)

+ func (q *Reader) AddAsyncHandler(handler AsyncHandler)

+ func (q *Reader) AddHandler(handler Handler)

+ func (q *Reader) ConnectToLookupd(addr string) error

+ func (q *Reader) ConnectToNSQ(addr string) error

+ func (q *Reader) ConnectionMaxInFlight() int

+ func (q *Reader) IsStarved() bool

+ func (q *Reader) MaxInFlight() int

+ func (q *Reader) SetMaxInFlight(maxInFlight int)

+ func (q *Reader) Stop()

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL