Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

nsq

package module

Go to main page

Versions in this module

v1

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