README
¶
Azure Storage Queue Input Plugin
This plugin gathers sizes of Azure Storage Queues.
Configuration:
# Description
[[inputs.azure_storage_queue]]
## Required Azure Storage Account name
account_name = "mystorageaccount"
## Required Azure Storage Account access key
account_key = "storageaccountaccesskey"
## Set to false to disable peeking age of oldest message (executes faster)
# peek_oldest_message_age = true
Metrics
- azure_storage_queues
- tags:
- queue
- account
- fields:
- size (integer, count)
- oldest_message_age_ns (integer, nanoseconds) Age of message at the head of the queue.
Requires
peek_oldest_message_age
to be configured totrue
.
- tags:
Example Output
azure_storage_queues,queue=myqueue,account=mystorageaccount oldest_message_age=799714900i,size=7i 1565970503000000000
azure_storage_queues,queue=myemptyqueue,account=mystorageaccount size=0i 1565970502000000000
Documentation
¶
Index ¶
- type AzureStorageQueue
- func (a *AzureStorageQueue) Description() string
- func (a *AzureStorageQueue) Gather(acc telegraf.Accumulator) error
- func (a *AzureStorageQueue) GatherQueueMetrics(acc telegraf.Accumulator, queueItem azqueue.QueueItem, ...)
- func (a *AzureStorageQueue) GetServiceURL() (azqueue.ServiceURL, error)
- func (a *AzureStorageQueue) Init() error
- func (a *AzureStorageQueue) SampleConfig() string
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AzureStorageQueue ¶
type AzureStorageQueue struct { StorageAccountName string `toml:"account_name"` StorageAccountKey string `toml:"account_key"` PeekOldestMessageAge bool `toml:"peek_oldest_message_age"` Log telegraf.Logger // contains filtered or unexported fields }
func (*AzureStorageQueue) Description ¶
func (a *AzureStorageQueue) Description() string
func (*AzureStorageQueue) Gather ¶
func (a *AzureStorageQueue) Gather(acc telegraf.Accumulator) error
func (*AzureStorageQueue) GatherQueueMetrics ¶
func (a *AzureStorageQueue) GatherQueueMetrics(acc telegraf.Accumulator, queueItem azqueue.QueueItem, properties *azqueue.QueueGetPropertiesResponse, peekedMessage *azqueue.PeekedMessage)
func (*AzureStorageQueue) GetServiceURL ¶
func (a *AzureStorageQueue) GetServiceURL() (azqueue.ServiceURL, error)
func (*AzureStorageQueue) Init ¶
func (a *AzureStorageQueue) Init() error
func (*AzureStorageQueue) SampleConfig ¶
func (a *AzureStorageQueue) SampleConfig() string
Click to show internal directories.
Click to hide internal directories.