Versions in this module Expand all Collapse all v0 v0.3.5 Apr 26, 2015 v0.3.4 Apr 26, 2015 v0.3.3 Apr 26, 2015 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) + func GetVersion(addr string) (semver.Version, error) + type ChannelStats struct + BackendDepth int64 + ChannelName string + ClientCount int + Clients []*ClientStats + DeferredCount int64 + Depth int64 + E2eProcessingLatency *quantile.E2eProcessingLatencyAggregate + HostAddress string + HostStats []*ChannelStats + InFlightCount int64 + MemoryDepth int64 + MessageCount int64 + Paused bool + RequeueCount int64 + Selected bool + TimeoutCount int64 + TopicName string + func (c *ChannelStats) Add(a *ChannelStats) + func (c *ChannelStats) Host() string + 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 ClientStats struct + AuthIdentity string + AuthIdentityURL string + Authed bool + CipherSuite string + ClientID string + ConnectedDuration time.Duration + Deflate bool + FinishCount int64 + HostAddress string + Hostname string + InFlightCount int + MessageCount int64 + ReadyCount int + RemoteAddress string + RequeueCount int64 + SampleRate int32 + Snappy bool + TLS bool + TLSNegotiatedProtocol string + TLSNegotiatedProtocolIsMutual bool + TLSVersion string + 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) + type ClientsByHost struct + func (c ClientsByHost) Less(i, j int) bool + type Producer struct + BroadcastAddress string + HTTPPort int + Hostname string + OutOfDate bool + RemoteAddresses []string + TCPPort int + Topics ProducerTopics + 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 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 ProducersByHost struct + func (c ProducersByHost) Less(i, j int) bool + type TopicStats struct + Aggregate bool + BackendDepth int64 + ChannelCount int + Channels []*ChannelStats + Depth int64 + E2eProcessingLatency *quantile.E2eProcessingLatencyAggregate + HostAddress string + MemoryDepth int64 + MessageCount int64 + Paused bool + TopicName string + func GetNSQDStats(nsqdHTTPAddrs []string, selectedTopic string) ([]*TopicStats, map[string]*ChannelStats, error) + func (t *TopicStats) Add(a *TopicStats) + func (t *TopicStats) Host() string + 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)
Go to main page