lookupd

package
v0.2.28 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 29, 2014 License: MIT Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

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       []*ClientStats
	Paused        bool

	E2eProcessingLatency *util.E2eProcessingLatencyAggregate
}

func (*ChannelStats) Add added in v0.2.22 

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

func (*ChannelStats) Host added in v0.2.23 

func (c *ChannelStats) Host() string

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 ClientStats added in v0.2.27 

type ClientStats struct {
	HostAddress       string
	Version           string
	ClientID          string
	Hostname          string
	UserAgent         string
	ConnectedDuration time.Duration
	InFlightCount     int
	ReadyCount        int
	FinishCount       int64
	RequeueCount      int64
	MessageCount      int64
	SampleRate        int32
	TLS               bool
	Deflate           bool
	Snappy            bool
}

func (*ClientStats) HasSampleRate added in v0.2.27 

func (c *ClientStats) HasSampleRate() bool

func (*ClientStats) HasUserAgent added in v0.2.27 

func (c *ClientStats) HasUserAgent() bool

type ClientStatsList added in v0.2.27 

type ClientStatsList []*ClientStats

func (ClientStatsList) Len added in v0.2.27 

func (c ClientStatsList) Len() int

func (ClientStatsList) Swap added in v0.2.27 

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

type ClientsByHost 

type ClientsByHost struct {
	ClientStatsList
}

func (ClientsByHost) Less 

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

type Producer 

type Producer struct {
	RemoteAddresses  []string        `json:"remote_addresses"`
	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 added in v0.2.22 

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

type ProducerTopics added in v0.2.22 

type ProducerTopics []ProducerTopic

func (ProducerTopics) Len added in v0.2.22 

func (pt ProducerTopics) Len() int

func (ProducerTopics) Less added in v0.2.22 

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

func (ProducerTopics) Swap added in v0.2.22 

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
	Paused       bool

	E2eProcessingLatency *util.E2eProcessingLatencyAggregate
	// contains filtered or unexported fields
}

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 added in v0.2.22 

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

func (*TopicStats) Host added in v0.2.23 

func (t *TopicStats) Host() string

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)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.