Versions in this module Expand all Collapse all v1 v1.0.0-compat Mar 22, 2017 v0 v0.3.8 May 26, 2016 v0.3.7 Feb 24, 2016 v0.3.6 Sep 24, 2015 Changes in this version + type ChannelStats struct + BackendDepth int64 + ChannelName string + ClientCount int + Clients []*ClientStats + DeferredCount int64 + Depth int64 + E2eProcessingLatency *quantile.E2eProcessingLatencyAggregate + Hostname string + InFlightCount int64 + MemoryDepth int64 + MessageCount int64 + Node string + NodeStats []*ChannelStats + Paused bool + RequeueCount int64 + Selected bool + TimeoutCount int64 + TopicName string + func (c *ChannelStats) Add(a *ChannelStats) + 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 + ConnectTs int64 + ConnectedDuration time.Duration + Deflate bool + FinishCount int64 + Hostname string + InFlightCount int + MessageCount int64 + Name string + Node string + 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 + func (s *ClientStats) UnmarshalJSON(b []byte) error + 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 ClusterInfo struct + func New(log logger, client *http_api.Client) *ClusterInfo + func (c *ClusterInfo) CreateTopicChannel(topicName string, channelName string, lookupdHTTPAddrs []string) error + func (c *ClusterInfo) DeleteChannel(topicName string, channelName string, lookupdHTTPAddrs []string, ...) error + func (c *ClusterInfo) DeleteTopic(topicName string, lookupdHTTPAddrs []string, nsqdHTTPAddrs []string) error + func (c *ClusterInfo) EmptyChannel(topicName string, channelName string, lookupdHTTPAddrs []string, ...) error + func (c *ClusterInfo) EmptyTopic(topicName string, lookupdHTTPAddrs []string, nsqdHTTPAddrs []string) error + func (c *ClusterInfo) GetLookupdProducers(lookupdHTTPAddrs []string) (Producers, error) + func (c *ClusterInfo) GetLookupdTopicChannels(topic string, lookupdHTTPAddrs []string) ([]string, error) + func (c *ClusterInfo) GetLookupdTopicProducers(topic string, lookupdHTTPAddrs []string) (Producers, error) + func (c *ClusterInfo) GetLookupdTopics(lookupdHTTPAddrs []string) ([]string, error) + func (c *ClusterInfo) GetNSQDProducers(nsqdHTTPAddrs []string) (Producers, error) + func (c *ClusterInfo) GetNSQDStats(producers Producers, selectedTopic string) ([]*TopicStats, map[string]*ChannelStats, error) + func (c *ClusterInfo) GetNSQDTopicProducers(topic string, nsqdHTTPAddrs []string) (Producers, error) + func (c *ClusterInfo) GetNSQDTopics(nsqdHTTPAddrs []string) ([]string, error) + func (c *ClusterInfo) GetProducers(lookupdHTTPAddrs []string, nsqdHTTPAddrs []string) (Producers, error) + func (c *ClusterInfo) GetTopicProducers(topicName string, lookupdHTTPAddrs []string, nsqdHTTPAddrs []string) (Producers, error) + func (c *ClusterInfo) GetVersion(addr string) (semver.Version, error) + func (c *ClusterInfo) PauseChannel(topicName string, channelName string, lookupdHTTPAddrs []string, ...) error + func (c *ClusterInfo) PauseTopic(topicName string, lookupdHTTPAddrs []string, nsqdHTTPAddrs []string) error + func (c *ClusterInfo) TombstoneNodeForTopic(topic string, node string, lookupdHTTPAddrs []string) error + func (c *ClusterInfo) UnPauseChannel(topicName string, channelName string, lookupdHTTPAddrs []string, ...) error + func (c *ClusterInfo) UnPauseTopic(topicName string, lookupdHTTPAddrs []string, nsqdHTTPAddrs []string) error + type ErrList []error + func (l ErrList) Error() string + func (l ErrList) Errors() []error + type PartialErr interface + Errors func() []error + type Producer struct + BroadcastAddress string + HTTPPort int + Hostname string + OutOfDate bool + RemoteAddress string + RemoteAddresses []string + TCPPort int + Topics ProducerTopics + Version string + VersionObj semver.Version + func (p *Producer) Address() string + func (p *Producer) HTTPAddress() string + func (p *Producer) IsInconsistent(numLookupd int) bool + func (p *Producer) TCPAddress() string + func (p *Producer) UnmarshalJSON(b []byte) error + 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 Producers []*Producer + func (t Producers) HTTPAddrs() []string + func (t Producers) Len() int + func (t Producers) Search(needle string) *Producer + func (t Producers) Swap(i, j int) + type ProducersByHost struct + func (c ProducersByHost) Less(i, j int) bool + type TopicStats struct + BackendDepth int64 + Channels []*ChannelStats + Depth int64 + E2eProcessingLatency *quantile.E2eProcessingLatencyAggregate + Hostname string + MemoryDepth int64 + MessageCount int64 + Node string + NodeStats []*TopicStats + Paused bool + TopicName string + func (t *TopicStats) Add(a *TopicStats) + 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