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

lookupd

package

Go to main page

Versions in this module

v0

v0.2.23

Oct 23, 2013

Changes in this version

type ChannelStats

+ func (c *ChannelStats) Host() string

type TopicStats

+ func (t *TopicStats) Host() string

v0.2.22

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)

v0.2.21

Jun 9, 2013

v0.2.20

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)