nsqd

package

Go to main page

Versions in this module

v0

v0.3.6

Sep 24, 2015

Changes in this version

+ var ErrIDBackwards = errors.New("ID went backward")

type NSQD

+ func New(opts *Options) *NSQD

+ func (n *NSQD) RealHTTPSAddr() *net.TCPAddr

+ type Options struct

+ AuthHTTPAddresses []string

+ BroadcastAddress string

+ ClientTimeout time.Duration

+ DataPath string

+ DeflateEnabled bool

+ E2EProcessingLatencyPercentiles []float64

+ E2EProcessingLatencyWindowTime time.Duration

+ HTTPAddress string

+ HTTPSAddress string

+ ID int64

+ Logger logger

+ MaxBodySize int64

+ MaxBytesPerFile int64

+ MaxDeflateLevel int

+ MaxHeartbeatInterval time.Duration

+ MaxMsgSize int64

+ MaxMsgTimeout time.Duration

+ MaxOutputBufferSize int64

+ MaxOutputBufferTimeout time.Duration

+ MaxRdyCount int64

+ MaxReqTimeout time.Duration

+ MemQueueSize int64

+ MsgTimeout time.Duration

+ NSQLookupdTCPAddresses []string

+ QueueScanDirtyPercent float64

+ QueueScanInterval time.Duration

+ QueueScanRefreshInterval time.Duration

+ QueueScanSelectionCount int

+ QueueScanWorkerPoolMax int

+ SnappyEnabled bool

+ StatsdAddress string

+ StatsdInterval time.Duration

+ StatsdMemStats bool

+ StatsdPrefix string

+ SyncEvery int64

+ SyncTimeout time.Duration

+ TCPAddress string

+ TLSCert string

+ TLSClientAuthPolicy string

+ TLSKey string

+ TLSMinVersion uint16

+ TLSRequired int

+ TLSRootCAFile string

+ Verbose bool

+ func NewOptions() *Options

v0.3.5

Apr 26, 2015

v0.3.4

Apr 26, 2015

v0.3.3

Apr 26, 2015

Changes in this version

type NSQD

+ func (n *NSQD) GetStartTime() time.Time

+ func (n *NSQD) RealHTTPAddr() *net.TCPAddr

+ func (n *NSQD) RealTCPAddr() *net.TCPAddr

v0.3.2

Feb 8, 2015

v0.3.1

Jan 22, 2015

Changes in this version

+ const MOVEFILE_REPLACE_EXISTING — windows/amd64

+ const TLSNotRequired

+ const TLSRequired

+ const TLSRequiredExceptHTTP

v0.3.0

Nov 18, 2014

v0.2.31

Aug 26, 2014

Changes in this version

type NSQD

+ func (n *NSQD) GetError() error

+ func (n *NSQD) GetHealth() string

+ func (n *NSQD) IsHealthy() bool

+ func (n *NSQD) SetHealth(err error)

v0.2.30

Jul 28, 2014

Changes in this version

type ClientStats

+ CipherSuite string

+ TLSNegotiatedProtocol string

+ TLSNegotiatedProtocolIsMutual bool

+ TLSVersion string

v0.2.29

Jul 25, 2014

Changes in this version

+ const ERROR_SUCCESS — windows/amd64

+ const ERROR_UNABLE_TO_MOVE_REPLACEMENT — windows/amd64

+ const ERROR_UNABLE_TO_MOVE_REPLACEMENT_2 — windows/amd64

+ const ERROR_UNABLE_TO_REMOVE_REPLACED — windows/amd64

+ const MsgIDLength

+ const REPLACEFILE_IGNORE_MERGE_ERRORS — windows/amd64

+ func GetLastError() uint32 — windows/amd64

type ClientStats

+ AuthIdentity string

+ AuthIdentityURL string

+ Authed bool

+ type Message struct

+ Attempts uint16

+ Body []byte

+ ID MessageID

+ Timestamp int64

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

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

+ type MessageID [MsgIDLength]byte

type NSQD

+ func (n *NSQD) IsAuthEnabled() bool

v0.2.28

Apr 29, 2014

Changes in this version

+ const DefaultBufferSize

+ var ErrSequenceExpired = errors.New("sequence expired")

+ var ErrTimeBackwards = errors.New("time has gone backwards")

+ func NewNSQDOptions() *nsqdOptions

+ type BackendQueue interface

+ Close func() error

+ Delete func() error

+ Depth func() int64

+ Empty func() error

+ Put func([]byte) error

+ ReadChan func() chan []byte

+ type Channel struct

+ func NewChannel(topicName string, channelName string, context *context, ...) *Channel

+ func (c *Channel) AddClient(clientID int64, client Consumer)

+ func (c *Channel) Close() error

+ func (c *Channel) Delete() error

+ func (c *Channel) Depth() int64

+ func (c *Channel) Empty() error

+ func (c *Channel) Exiting() bool

+ func (c *Channel) FinishMessage(clientID int64, id nsq.MessageID) error

+ func (c *Channel) IsPaused() bool

+ func (c *Channel) Pause() error

+ func (c *Channel) PutMessage(msg *nsq.Message) error

+ func (c *Channel) RemoveClient(clientID int64)

+ func (c *Channel) RequeueMessage(clientID int64, id nsq.MessageID, timeout time.Duration) error

+ func (c *Channel) StartDeferredTimeout(msg *nsq.Message, timeout time.Duration) error

+ func (c *Channel) StartInFlightTimeout(msg *nsq.Message, clientID int64, timeout time.Duration) error

+ func (c *Channel) TouchMessage(clientID int64, id nsq.MessageID) error

+ func (c *Channel) UnPause() error

+ type ChannelStats struct

+ BackendDepth int64

+ ChannelName string

+ Clients []ClientStats

+ DeferredCount int

+ Depth int64

+ E2eProcessingLatency *util.PercentileResult

+ InFlightCount int

+ MessageCount uint64

+ Paused bool

+ RequeueCount uint64

+ TimeoutCount uint64

+ func NewChannelStats(c *Channel, clients []ClientStats) ChannelStats

+ type Channels []*Channel

+ func (c Channels) Len() int

+ func (c Channels) Swap(i, j int)

+ type ChannelsByName struct

+ func (c ChannelsByName) Less(i, j int) bool

+ type ClientStats struct

+ ClientID string

+ ConnectTime int64

+ Deflate bool

+ FinishCount uint64

+ Hostname string

+ InFlightCount int64

+ MessageCount uint64

+ Name string

+ ReadyCount int64

+ RemoteAddress string

+ RequeueCount uint64

+ SampleRate int32

+ Snappy bool

+ State int32

+ TLS bool

+ UserAgent string

+ Version string

+ type Consumer interface

+ Close func() error

+ Empty func()

+ Pause func()

+ Stats func() ClientStats

+ TimedOutMessage func()

+ UnPause func()

+ type NSQD struct

+ func NewNSQD(options *nsqdOptions) *NSQD

+ func (n *NSQD) DeleteExistingTopic(topicName string) error

+ func (n *NSQD) Exit()

+ func (n *NSQD) GetExistingTopic(topicName string) (*Topic, error)

+ func (n *NSQD) GetStats() []TopicStats

+ func (n *NSQD) GetTopic(topicName string) *Topic

+ func (n *NSQD) LoadMetadata()

+ func (n *NSQD) Main()

+ func (n *NSQD) Notify(v interface{})

+ func (n *NSQD) PersistMetadata() error

+ type Topic struct

+ func NewTopic(topicName string, context *context) *Topic

+ func (t *Topic) AggregateChannelE2eProcessingLatency() *util.Quantile

+ func (t *Topic) Close() error

+ func (t *Topic) Delete() error

+ func (t *Topic) DeleteExistingChannel(channelName string) error

+ func (t *Topic) Depth() int64

+ func (t *Topic) Empty() error

+ func (t *Topic) Exiting() bool

+ func (t *Topic) GetChannel(channelName string) *Channel

+ func (t *Topic) GetExistingChannel(channelName string) (*Channel, error)

+ func (t *Topic) IsPaused() bool

+ func (t *Topic) Pause() error

+ func (t *Topic) PutMessage(msg *nsq.Message) error

+ func (t *Topic) PutMessages(messages []*nsq.Message) error

+ func (t *Topic) UnPause() error

+ type TopicStats struct

+ BackendDepth int64

+ Channels []ChannelStats

+ Depth int64

+ E2eProcessingLatency *util.PercentileResult

+ MessageCount uint64

+ Paused bool

+ TopicName string

+ func NewTopicStats(t *Topic, channels []ChannelStats) TopicStats

+ type Topics []*Topic

+ func (t Topics) Len() int

+ func (t Topics) Swap(i, j int)

+ type TopicsByName struct

+ func (t TopicsByName) Less(i, j int) bool

+ type Uint64Slice []uint64

+ func (s Uint64Slice) Len() int

+ func (s Uint64Slice) Less(i, j int) bool

+ func (s Uint64Slice) Swap(i, j int)

v0.2.27

Feb 16, 2014

v0.2.26

Feb 7, 2014

v0.2.25

Feb 6, 2014

v0.2.24

Dec 7, 2013

v0.2.23

Oct 23, 2013

v0.2.22

Aug 26, 2013

v0.2.21

Jun 9, 2013

v0.2.20

May 13, 2013

v0.2.19

Apr 12, 2013

v0.2.18

Feb 28, 2013

v0.2.17

Feb 8, 2013

v0.2.16

Jan 7, 2013

v0.2.15

Oct 25, 2012

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