clusterinfo

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)