Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

clusterinfo

package

Go to main page

Versions in this module

v1

v1.3.0

Dec 26, 2023

v1.2.1

Aug 16, 2021

v1.2.0

Aug 28, 2019

v1.1.0

Aug 19, 2018

v1.1.0-rc1

Jul 31, 2018

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)