lookupd

Documentation

Index

• 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
  • func (c *ChannelStats) Add(a *ChannelStats)
  • func (c *ChannelStats) Target(key string) (string, string)
• type ChannelStatsByHost
  • func (c ChannelStatsByHost) Less(i, j int) bool
• type ChannelStatsList
  • func (c ChannelStatsList) Len() int
  • func (c ChannelStatsList) Swap(i, j int)
• type ClientInfo
• type ClientInfoList
  • func (c ClientInfoList) Len() int
  • func (c ClientInfoList) Swap(i, j int)
• type ClientsByHost
  • func (c ClientsByHost) Less(i, j int) bool
• type Producer
  • 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
  • func (t ProducerList) Len() int
  • func (t ProducerList) Swap(i, j int)
• type ProducerTopic
• type ProducerTopics
  • func (pt ProducerTopics) Len() int
  • func (pt ProducerTopics) Less(i, j int) bool
  • func (pt ProducerTopics) Swap(i, j int)
• type ProducersByHost
  • func (c ProducersByHost) Less(i, j int) bool
• type TopicStats
  • func GetNSQDStats(nsqdHTTPAddrs []string, selectedTopic string) ([]*TopicStats, map[string]*ChannelStats, error)
  • func (t *TopicStats) Add(a *TopicStats)
  • func (t *TopicStats) Target(key string) (string, string)
• type TopicStatsByHost
  • func (c TopicStatsByHost) Less(i, j int) bool
• type TopicStatsList
  • func (t TopicStatsList) Len() int
  • func (t TopicStatsList) Swap(i, j int)

Functions

func GetLookupdTopicChannels

func GetLookupdTopicChannels(topic string, lookupdHTTPAddrs []string) ([]string, error)

GetLookupdTopicChannels returns a []string containing a union of the channels from all the given lookupd for the given topic

func GetLookupdTopicProducers

func GetLookupdTopicProducers(topic string, lookupdHTTPAddrs []string) ([]string, error)

GetLookupdTopicProducers returns a []string of the broadcast_address:http_port of all the producers for a given topic by unioning the results returned from the given lookupd

func GetLookupdTopics

func GetLookupdTopics(lookupdHTTPAddrs []string) ([]string, error)

GetLookupdTopics returns a []string containing a union of all the topics from all the given lookupd

func GetNSQDTopicProducers

func GetNSQDTopicProducers(topic string, nsqdHTTPAddrs []string) ([]string, error)

GetNSQDTopicProducers returns a []string containing the addresses of all the nsqd that produce the given topic out of the given nsqd

func GetNSQDTopics

func GetNSQDTopics(nsqdHTTPAddrs []string) ([]string, error)

GetNSQDTopics returns a []string containing all the topics produced by the given nsqd

Types

type ChannelStats

type ChannelStats struct {
	HostAddress   string
	TopicName     string
	ChannelName   string
	Depth         int64
	MemoryDepth   int64
	BackendDepth  int64
	InFlightCount int64
	DeferredCount int64
	RequeueCount  int64
	TimeoutCount  int64
	MessageCount  int64
	ClientCount   int
	Selected      bool
	HostStats     []*ChannelStats
	Clients       []*ClientInfo
	Paused        bool
}

func (*ChannelStats) Add

func (c *ChannelStats) Add(a *ChannelStats)

func (*ChannelStats) Target

func (c *ChannelStats) Target(key string) (string, string)

type ChannelStatsByHost

type ChannelStatsByHost struct {
	ChannelStatsList
}

func (ChannelStatsByHost) Less

func (c ChannelStatsByHost) Less(i, j int) bool

type ChannelStatsList

type ChannelStatsList []*ChannelStats

func (ChannelStatsList) Len

func (c ChannelStatsList) Len() int

func (ChannelStatsList) Swap

func (c ChannelStatsList) Swap(i, j int)

type ClientInfo

type ClientInfo struct {
	HostAddress       string
	ClientVersion     string
	ClientIdentifier  string
	ConnectedDuration time.Duration
	InFlightCount     int
	ReadyCount        int
	FinishCount       int64
	RequeueCount      int64
	MessageCount      int64
}

type ClientInfoList

type ClientInfoList []*ClientInfo

func (ClientInfoList) Len

func (c ClientInfoList) Len() int

func (ClientInfoList) Swap

func (c ClientInfoList) Swap(i, j int)

type ClientsByHost

type ClientsByHost struct {
	ClientInfoList
}

func (ClientsByHost) Less

func (c ClientsByHost) Less(i, j int) bool

type Producer

type Producer struct {
	RemoteAddresses  []string        `json:"remote_addresses"`
	Address          string          `json:"address"` //TODO: remove for 1.0
	Hostname         string          `json:"hostname"`
	BroadcastAddress string          `json:"broadcast_address"`
	TcpPort          int             `json:"tcp_port"`
	HttpPort         int             `json:"http_port"`
	Version          string          `json:"version"`
	VersionObj       *semver.Version `json:-`
	Topics           ProducerTopics  `json:"topics"`
	OutOfDate        bool
}

func GetLookupdProducers

func GetLookupdProducers(lookupdHTTPAddrs []string) ([]*Producer, error)

GetLookupdProducers returns a slice of pointers to Producer structs containing metadata for each node connected to given lookupds

func (*Producer) HTTPAddress

func (p *Producer) HTTPAddress() string

func (*Producer) IsInconsistent

func (p *Producer) IsInconsistent(numLookupd int) bool

IsInconsistent checks for cases where an unexpected number of nsqd connections are reporting the same information to nsqlookupd (ie: multiple instances are using the same broadcast address), or cases where some nsqd are not reporting to all nsqlookupd.

func (*Producer) TCPAddress

func (p *Producer) TCPAddress() string

type ProducerList

type ProducerList []*Producer

func (ProducerList) Len

func (t ProducerList) Len() int

func (ProducerList) Swap

func (t ProducerList) Swap(i, j int)

type ProducerTopic

type ProducerTopic struct {
	Topic      string `json:"topic"`
	Tombstoned bool   `json:"tombstoned"`
}

type ProducerTopics

type ProducerTopics []ProducerTopic

func (ProducerTopics) Len

func (pt ProducerTopics) Len() int

func (ProducerTopics) Less

func (pt ProducerTopics) Less(i, j int) bool

func (ProducerTopics) Swap

func (pt ProducerTopics) Swap(i, j int)

type ProducersByHost

type ProducersByHost struct {
	ProducerList
}

func (ProducersByHost) Less

func (c ProducersByHost) Less(i, j int) bool

type TopicStats

type TopicStats struct {
	HostAddress  string
	TopicName    string
	Depth        int64
	MemoryDepth  int64
	BackendDepth int64
	MessageCount int64
	ChannelCount int
	Aggregate    bool
	Channels     []*ChannelStats
}

func GetNSQDStats

func GetNSQDStats(nsqdHTTPAddrs []string, selectedTopic string) ([]*TopicStats, map[string]*ChannelStats, error)

GetNSQDStats returns aggregate topic and channel stats from the given NSQD instances

if selectedTopic is empty, this will return stats for *all* topic/channels and the ChannelStats dict will be keyed by topic + ':' + channel

func (*TopicStats) Add

func (t *TopicStats) Add(a *TopicStats)

func (*TopicStats) Target

func (t *TopicStats) Target(key string) (string, string)

type TopicStatsByHost

type TopicStatsByHost struct {
	TopicStatsList
}

func (TopicStatsByHost) Less

func (c TopicStatsByHost) Less(i, j int) bool

type TopicStatsList

type TopicStatsList []*TopicStats

func (TopicStatsList) Len

func (t TopicStatsList) Len() int

func (TopicStatsList) Swap

func (t TopicStatsList) Swap(i, j int)