Rename eventhub -> eventhub_consumer
This commit is contained in:
parent
f69b639aa9
commit
79aad9f06a
|
@ -40,7 +40,7 @@ import (
|
||||||
_ "github.com/influxdata/telegraf/plugins/inputs/ecs"
|
_ "github.com/influxdata/telegraf/plugins/inputs/ecs"
|
||||||
_ "github.com/influxdata/telegraf/plugins/inputs/elasticsearch"
|
_ "github.com/influxdata/telegraf/plugins/inputs/elasticsearch"
|
||||||
_ "github.com/influxdata/telegraf/plugins/inputs/ethtool"
|
_ "github.com/influxdata/telegraf/plugins/inputs/ethtool"
|
||||||
_ "github.com/influxdata/telegraf/plugins/inputs/eventhub"
|
_ "github.com/influxdata/telegraf/plugins/inputs/eventhub_consumer"
|
||||||
_ "github.com/influxdata/telegraf/plugins/inputs/exec"
|
_ "github.com/influxdata/telegraf/plugins/inputs/exec"
|
||||||
_ "github.com/influxdata/telegraf/plugins/inputs/execd"
|
_ "github.com/influxdata/telegraf/plugins/inputs/execd"
|
||||||
_ "github.com/influxdata/telegraf/plugins/inputs/fail2ban"
|
_ "github.com/influxdata/telegraf/plugins/inputs/fail2ban"
|
||||||
|
|
|
@ -5,7 +5,7 @@ This plugin provides a consumer for use with Azure Event Hubs and Azure IoT Hub.
|
||||||
## Configuration
|
## Configuration
|
||||||
|
|
||||||
```toml
|
```toml
|
||||||
[[inputs.eventhub]]
|
[[inputs.eventhub_consumer]]
|
||||||
## The default behavior is to create a new Event Hub client from environment variables.
|
## The default behavior is to create a new Event Hub client from environment variables.
|
||||||
## This requires one of the following sets of environment variables to be set:
|
## This requires one of the following sets of environment variables to be set:
|
||||||
##
|
##
|
||||||
|
@ -95,4 +95,4 @@ The main focus for development of this plugin is Azure IoT hub:
|
||||||
- Authentication with [AAD TokenProvider environment variables](https://github.com/Azure/azure-event-hubs-go#aad-tokenprovider-environment-variables)
|
- Authentication with [AAD TokenProvider environment variables](https://github.com/Azure/azure-event-hubs-go#aad-tokenprovider-environment-variables)
|
||||||
|
|
||||||
## Not implemented:
|
## Not implemented:
|
||||||
- [Event Processor Host](https://github.com/Azure/azure-event-hubs-go#event-processor-host) (should only be needed when using multiple Telegraf instances consuming the same partition)
|
- [Event Processor Host](https://github.com/Azure/azure-event-hubs-go#event-processor-host) (should only be needed when using multiple Telegraf instances consuming the same partition)
|
|
@ -416,7 +416,7 @@ func (e *EventHub) Stop() {
|
||||||
}
|
}
|
||||||
|
|
||||||
func init() {
|
func init() {
|
||||||
inputs.Add("eventhub", func() telegraf.Input {
|
inputs.Add("eventhub_consumer", func() telegraf.Input {
|
||||||
return &EventHub{}
|
return &EventHub{}
|
||||||
})
|
})
|
||||||
}
|
}
|
Loading…
Reference in New Issue