azureservicebusreceiver

README

OpenTelemetry Collector Azure Service Bus Receiver

The azureservicebusreceiver enables the collection of metrics from Azure Service Bus. For details about which metrics that are produced, see documentation.

Configuration

Using default credentials:

azureservicebus:
  namespace_fqdn: yournamespace.servicebus.windows.net
  collection_interval: 1m
  auth: default_credentials

Using managed identity:

azureservicebus:
  namespace_fqdn: yournamespace.servicebus.windows.net
  collection_interval: 1m
  auth: managed_identity
  client_id: ${env:CLIENT_ID}

Using service principal authentication:

azureservicebus:
  namespace_fqdn: yournamespace.servicebus.windows.net
  collection_interval: 1m
  auth: service_principal
  tenant_id: ${env:TENANT_ID}
  client_id: ${env:CLIENT_ID}
  client_secret: ${env:CLIENT_SECRET}

Using connection string (not recommended):

azureservicebus:
  namespace_fqdn: yournamespace.servicebus.windows.net
  collection_interval: 1m
  auth: connection_string
  connection_string: ${env:CONNECTION_STRING}

Contributing

Developing

Clone the repository
Make changes to the receiver
Run make build-local to build a local collector to ./collector
TBC..

Documentation

Index

• func NewFactory() receiver.Factory
• type Config
  • func (cfg *Config) Validate() (err error)

Functions

func NewFactory

func NewFactory() receiver.Factory

NewFactory creates a factory for azureservicebus receiver.

Types

type Config

type Config struct {
	scraperhelper.ControllerConfig `mapstructure:",squash"`
	metadata.MetricsBuilderConfig  `mapstructure:",squash"`
	NamespaceFqdn                  string `mapstructure:"namespace_fqdn"`
	Authentication                 string `mapstructure:"auth"`
	ConnectionString               string `mapstructure:"connection_string"`
	TenantId                       string `mapstructure:"tenant_id"`
	ClientId                       string `mapstructure:"client_id"`
	ClientSecret                   string `mapstructure:"client_secret"`
}

func (*Config) Validate

func (cfg *Config) Validate() (err error)