Documentation
¶
Index ¶
- type ActiveMQ
- func (a *ActiveMQ) Description() string
- func (a *ActiveMQ) Gather(acc telegraf.Accumulator) error
- func (a *ActiveMQ) GatherQueuesMetrics(acc telegraf.Accumulator, queues Queues)
- func (a *ActiveMQ) GatherSubscribersMetrics(acc telegraf.Accumulator, subscribers Subscribers)
- func (a *ActiveMQ) GatherTopicsMetrics(acc telegraf.Accumulator, topics Topics)
- func (a *ActiveMQ) GetMetrics(u string) ([]byte, error)
- func (a *ActiveMQ) Init() error
- func (a *ActiveMQ) QueuesURL() string
- func (a *ActiveMQ) SampleConfig() string
- func (a *ActiveMQ) SubscribersURL() string
- func (a *ActiveMQ) TopicsURL() string
- type Queue
- type Queues
- type Stats
- type Subscriber
- type Subscribers
- type Topic
- type Topics
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ActiveMQ ¶
type ActiveMQ struct {
Server string `toml:"server"`
Port int `toml:"port"`
URL string `toml:"url"`
Username string `toml:"username"`
Password string `toml:"password"`
Webadmin string `toml:"webadmin"`
ResponseTimeout config.Duration `toml:"response_timeout"`
tls.ClientConfig
// contains filtered or unexported fields
}
func (*ActiveMQ) Description ¶
func (*ActiveMQ) GatherQueuesMetrics ¶
func (a *ActiveMQ) GatherQueuesMetrics(acc telegraf.Accumulator, queues Queues)
func (*ActiveMQ) GatherSubscribersMetrics ¶
func (a *ActiveMQ) GatherSubscribersMetrics(acc telegraf.Accumulator, subscribers Subscribers)
func (*ActiveMQ) GatherTopicsMetrics ¶
func (a *ActiveMQ) GatherTopicsMetrics(acc telegraf.Accumulator, topics Topics)
func (*ActiveMQ) SampleConfig ¶
func (*ActiveMQ) SubscribersURL ¶
type Stats ¶
type Stats struct {
XMLName xml.Name `xml:"stats"`
Size int `xml:"size,attr"`
ConsumerCount int `xml:"consumerCount,attr"`
EnqueueCount int `xml:"enqueueCount,attr"`
DequeueCount int `xml:"dequeueCount,attr"`
PendingQueueSize int `xml:"pendingQueueSize,attr"`
DispatchedQueueSize int `xml:"dispatchedQueueSize,attr"`
DispatchedCounter int `xml:"dispatchedCounter,attr"`
EnqueueCounter int `xml:"enqueueCounter,attr"`
DequeueCounter int `xml:"dequeueCounter,attr"`
}
type Subscriber ¶
type Subscriber struct {
XMLName xml.Name `xml:"subscriber"`
ClientID string `xml:"clientId,attr"`
SubscriptionName string `xml:"subscriptionName,attr"`
ConnectionID string `xml:"connectionId,attr"`
DestinationName string `xml:"destinationName,attr"`
Selector string `xml:"selector,attr"`
Active string `xml:"active,attr"`
Stats Stats `xml:"stats"`
}
type Subscribers ¶
type Subscribers struct {
XMLName xml.Name `xml:"subscribers"`
SubscriberItems []Subscriber `xml:"subscriber"`
}
Click to show internal directories.
Click to hide internal directories.