lookupd

Jul 28, 2014

Changes in this version

type ClientStats

+ CipherSuite string

+ TLSNegotiatedProtocol string

+ TLSNegotiatedProtocolIsMutual bool

+ TLSVersion string

Jul 25, 2014

Changes in this version

+ func GetVersion(addr string) (*semver.Version, error)

type ClientStats

+ AuthIdentity string

+ AuthIdentityUrl string

+ Authed bool

+ RemoteAddress string

Apr 29, 2014

Changes in this version

type ClientStats

+ ClientID string

+ Hostname string

Feb 16, 2014

Changes in this version

+ type ClientStats struct

+ ConnectedDuration time.Duration

+ Deflate bool

+ FinishCount int64

+ HostAddress string

+ Identifier string

+ InFlightCount int

+ MessageCount int64

+ ReadyCount int

+ RequeueCount int64

+ SampleRate int32

+ Snappy bool

+ TLS bool

+ UserAgent string

+ Version string

+ func (c *ClientStats) HasSampleRate() bool

+ func (c *ClientStats) HasUserAgent() bool

+ type ClientStatsList []*ClientStats

+ func (c ClientStatsList) Len() int

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

Feb 6, 2014

Changes in this version

type ClientInfo

+ ClientUserAgent string

+ Deflate bool

+ SampleRate int32

+ Snappy bool

+ TLS bool

type TopicStats

+ Paused bool

Dec 7, 2013

Changes in this version

type ChannelStats

+ E2eProcessingLatency *util.E2eProcessingLatencyAggregate

type TopicStats

+ E2eProcessingLatency *util.E2eProcessingLatencyAggregate

Oct 23, 2013

Changes in this version

type ChannelStats

+ func (c *ChannelStats) Host() string

type TopicStats

+ func (t *TopicStats) Host() string

Aug 26, 2013

Changes in this version

type ChannelStats

+ TopicName string

+ func (c *ChannelStats) Add(a *ChannelStats)

+ type ClientInfoList []*ClientInfo

+ func (c ClientInfoList) Len() int

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

+ type ProducerTopic struct

+ Tombstoned bool

+ Topic string

+ type ProducerTopics []ProducerTopic

+ func (pt ProducerTopics) Len() int

+ func (pt ProducerTopics) Less(i, j int) bool

+ func (pt ProducerTopics) Swap(i, j int)

type TopicStats

+ Channels []*ChannelStats

+ TopicName string

+ func (t *TopicStats) Add(a *TopicStats)

May 13, 2013

Changes in this version

+ func GetLookupdTopicChannels(topic string, lookupdHTTPAddrs []string) ([]string, error)

+ func GetLookupdTopicProducers(topic string, lookupdHTTPAddrs []string) ([]string, error)

+ func GetLookupdTopics(lookupdHTTPAddrs []string) ([]string, error)

+ func GetNSQDTopicProducers(topic string, nsqdHTTPAddrs []string) ([]string, error)

+ func GetNSQDTopics(nsqdHTTPAddrs []string) ([]string, error)

+ type ChannelStats struct

+ BackendDepth int64

+ ChannelName string

+ ClientCount int

+ Clients []*ClientInfo

+ DeferredCount int64

+ Depth int64

+ HostAddress string

+ HostStats []*ChannelStats

+ InFlightCount int64

+ MemoryDepth int64

+ MessageCount int64

+ Paused bool

+ RequeueCount int64

+ Selected bool

+ TimeoutCount int64

+ Topic string

+ func (c *ChannelStats) AddHostStats(a *ChannelStats)

+ func (c *ChannelStats) Target(key string) (string, string)

+ type ChannelStatsByHost struct

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

+ type ChannelStatsList []*ChannelStats

+ func (c ChannelStatsList) Len() int

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

+ type ClientInfo struct

+ ClientIdentifier string

+ ClientVersion string

+ ConnectedDuration time.Duration

+ FinishCount int64

+ HostAddress string

+ InFlightCount int

+ MessageCount int64

+ ReadyCount int

+ RequeueCount int64

+ type ClientInfos []*ClientInfo

+ func (c ClientInfos) Len() int

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

+ type ClientsByHost struct

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

+ type Producer struct

+ Address string

+ BroadcastAddress string

+ Hostname string

+ HttpPort int

+ OutOfDate bool

+ RemoteAddresses []string

+ TcpPort int

+ Topics []string

+ Version string

+ VersionObj *semver.Version

+ func GetLookupdProducers(lookupdHTTPAddrs []string) ([]*Producer, error)

+ func (p *Producer) HTTPAddress() string

+ func (p *Producer) IsInconsistent(numLookupd int) bool

+ func (p *Producer) TCPAddress() string

+ type ProducerList []*Producer

+ func (t ProducerList) Len() int

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

+ type ProducersByHost struct

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

+ type TopicStats struct

+ Aggregate bool

+ BackendDepth int64

+ ChannelCount int

+ Depth int64

+ HostAddress string

+ MemoryDepth int64

+ MessageCount int64

+ Topic string

+ func GetNSQDStats(nsqdHTTPAddrs []string, selectedTopic string) ([]*TopicStats, map[string]*ChannelStats, error)

+ func (t *TopicStats) AddHostStats(a *TopicStats)

+ func (t *TopicStats) Target(key string) (string, string)

+ type TopicStatsByHost struct

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

+ type TopicStatsList []*TopicStats

+ func (t TopicStatsList) Len() int

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