nsq

package module

Go to main page

Versions in this module

v1

v1.0.6

Jun 4, 2016

Changes in this version

type Producer

+ func (w *Producer) DeferredPublish(topic string, delay time.Duration, body []byte) error

+ func (w *Producer) DeferredPublishAsync(topic string, delay time.Duration, body []byte, ...) error

v1.0.5

Sep 20, 2015

Changes in this version

type Command

+ func DeferredPublish(topic string, delay time.Duration, body []byte) *Command

+ type ConfigFlag struct

+ func (c *ConfigFlag) Set(opt string) (err error)

+ func (c *ConfigFlag) String() string

v1.0.4

Apr 8, 2015

Changes in this version

+ var ErrClosing = errors.New("closing")

+ type BackoffStrategy interface

+ Calculate func(attempt int) time.Duration

type Config

+ BackoffStrategy BackoffStrategy

+ DialTimeout time.Duration

+ LocalAddr net.Addr

+ RDYRedistributeInterval time.Duration

type ConnDelegate

+ OnContinue func(*Conn)

+ type ExponentialStrategy struct

+ func (s *ExponentialStrategy) Calculate(attempt int) time.Duration

+ type FullJitterStrategy struct

+ func (s *FullJitterStrategy) Calculate(attempt int) time.Duration

type LogLevel

+ func (lvl LogLevel) String() string

type Producer

+ func (w *Producer) Ping() error

v1.0.3

Feb 7, 2015

v1.0.2

Jan 22, 2015

Changes in this version

type Consumer

+ func (r *Consumer) Stats() *ConsumerStats

+ type ConsumerStats struct

+ Connections int

+ MessagesFinished uint64

+ MessagesReceived uint64

+ MessagesRequeued uint64

type Message

+ NSQDAddress string

v1.0.1

Nov 10, 2014

Changes in this version

+ const FrameTypeError

+ const FrameTypeMessage

+ const FrameTypeResponse

+ const LogLevelDebug

+ const LogLevelDebugPrefix

+ const LogLevelError

+ const LogLevelErrorPrefix

+ const LogLevelInfo

+ const LogLevelInfoPrefix

+ const LogLevelWarning

+ const LogLevelWarningPrefix

+ const MsgIDLength

+ const StateClosing

+ const StateConnected

+ const StateDisconnected

+ const StateInit

+ const StateSubscribed

+ const VERSION

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

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

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

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

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

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

+ func IsValidChannelName(name string) bool

+ func IsValidTopicName(name string) bool

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

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

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

+ type AuthResponse struct

+ Identity string

+ IdentityUrl string

+ PermissionCount int64

+ type Command struct

+ Body []byte

+ Name []byte

+ Params [][]byte

+ func Auth(secret string) (*Command, error)

+ func Finish(id MessageID) *Command

+ func Identify(js map[string]interface{}) (*Command, error)

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

+ 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 MessageID, delay time.Duration) *Command

+ func StartClose() *Command

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

+ func Touch(id MessageID) *Command

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

+ func (c *Command) String() string

+ func (c *Command) WriteTo(w io.Writer) (int64, error)

+ type Config struct

+ AuthSecret string

+ BackoffMultiplier time.Duration

+ ClientID string

+ DefaultRequeueDelay time.Duration

+ Deflate bool

+ DeflateLevel int

+ HeartbeatInterval time.Duration

+ Hostname string

+ LookupdPollInterval time.Duration

+ LookupdPollJitter float64

+ LowRdyIdleTimeout time.Duration

+ MaxAttempts uint16

+ MaxBackoffDuration time.Duration

+ MaxInFlight int

+ MaxRequeueDelay time.Duration

+ MsgTimeout time.Duration

+ OutputBufferSize int64

+ OutputBufferTimeout time.Duration

+ ReadTimeout time.Duration

+ SampleRate int32

+ Snappy bool

+ TlsConfig *tls.Config

+ TlsV1 bool

+ UserAgent string

+ WriteTimeout time.Duration

+ func NewConfig() *Config

+ func (c *Config) Set(option string, value interface{}) error

+ func (c *Config) Validate() error

+ type Conn struct

+ func NewConn(addr string, config *Config, delegate ConnDelegate) *Conn

+ func (c *Conn) Close() error

+ func (c *Conn) Connect() (*IdentifyResponse, error)

+ func (c *Conn) Flush() error

+ func (c *Conn) IsClosing() bool

+ func (c *Conn) LastMessageTime() time.Time

+ func (c *Conn) LastRDY() int64

+ func (c *Conn) MaxRDY() int64

+ func (c *Conn) RDY() int64

+ func (c *Conn) Read(p []byte) (int, error)

+ func (c *Conn) RemoteAddr() net.Addr

+ func (c *Conn) SetLogger(l logger, lvl LogLevel, format string)

+ func (c *Conn) SetRDY(rdy int64)

+ func (c *Conn) String() string

+ func (c *Conn) Write(p []byte) (int, error)

+ func (c *Conn) WriteCommand(cmd *Command) error

+ type ConnDelegate interface

+ OnBackoff func(*Conn)

+ OnClose func(*Conn)

+ OnError func(*Conn, []byte)

+ OnHeartbeat func(*Conn)

+ OnIOError func(*Conn, error)

+ OnMessage func(*Conn, *Message)

+ OnMessageFinished func(*Conn, *Message)

+ OnMessageRequeued func(*Conn, *Message)

+ OnResponse func(*Conn, []byte)

+ OnResume func(*Conn)

+ type Consumer struct

+ StopChan chan int

+ func NewConsumer(topic string, channel string, config *Config) (*Consumer, error)

+ func (r *Consumer) AddConcurrentHandlers(handler Handler, concurrency int)

+ func (r *Consumer) AddHandler(handler Handler)

+ func (r *Consumer) ChangeMaxInFlight(maxInFlight int)

+ func (r *Consumer) ConnectToNSQD(addr string) error

+ func (r *Consumer) ConnectToNSQDs(addresses []string) error

+ func (r *Consumer) ConnectToNSQLookupd(addr string) error

+ func (r *Consumer) ConnectToNSQLookupds(addresses []string) error

+ func (r *Consumer) DisconnectFromNSQD(addr string) error

+ func (r *Consumer) DisconnectFromNSQLookupd(addr string) error

+ func (r *Consumer) IsStarved() bool

+ func (r *Consumer) SetBehaviorDelegate(cb interface{})

+ func (r *Consumer) SetLogger(l logger, lvl LogLevel)

+ func (r *Consumer) Stop()

+ type DiscoveryFilter interface

+ Filter func([]string) []string

+ type ErrIdentify struct

+ Reason string

+ func (e ErrIdentify) Error() string

+ type ErrProtocol struct

+ Reason string

+ func (e ErrProtocol) Error() string

+ type FailedMessageLogger interface

+ LogFailedMessage func(message *Message)

+ type Handler interface

+ HandleMessage func(message *Message) error

+ type HandlerFunc func(message *Message) error

+ func (h HandlerFunc) HandleMessage(m *Message) error

+ type IdentifyResponse struct

+ AuthRequired bool

+ Deflate bool

+ MaxRdyCount int64

+ Snappy bool

+ TLSv1 bool

+ type LogLevel int

+ type Message struct

+ Attempts uint16

+ Body []byte

+ Delegate MessageDelegate

+ ID MessageID

+ Timestamp int64

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

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

+ func (m *Message) DisableAutoResponse()

+ func (m *Message) Finish()

+ func (m *Message) HasResponded() bool

+ func (m *Message) IsAutoResponseDisabled() bool

+ func (m *Message) Requeue(delay time.Duration)

+ func (m *Message) RequeueWithoutBackoff(delay time.Duration)

+ func (m *Message) Touch()

+ func (m *Message) WriteTo(w io.Writer) (int64, error)

+ type MessageDelegate interface

+ OnFinish func(*Message)

+ OnRequeue func(m *Message, delay time.Duration, backoff bool)

+ OnTouch func(*Message)

+ type MessageID [MsgIDLength]byte

+ type Producer struct

+ func NewProducer(addr string, config *Config) (*Producer, error)

+ func (w *Producer) MultiPublish(topic string, body [][]byte) error

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

+ func (w *Producer) Publish(topic string, body []byte) error

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

+ func (w *Producer) SetLogger(l logger, lvl LogLevel)

+ func (w *Producer) Stop()

+ func (w *Producer) String() string

+ type ProducerTransaction struct

+ Args []interface{}

+ Error error

v1.0.0

Aug 11, 2014

v0

v0.3.7

May 25, 2014

v0.3.6

Apr 30, 2014

v0.3.5

Apr 5, 2014

v0.3.4

Nov 20, 2013

v0.3.3

Oct 21, 2013

v0.3.2

Aug 26, 2013

v0.3.1

Feb 8, 2013

v0.3.0

Jan 7, 2013

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