azure_storage_queue

package
v0.0.0-...-39b996b Latest Latest
Warning

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

Go to latest
Published: Nov 7, 2019 License: MIT Imports: 8 Imported by: 0

README

Telegraf Input Plugin: Azure Storage Queue

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 to true.
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

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL