diff --git a/receiver/dockerstatsreceiver/README.md b/receiver/dockerstatsreceiver/README.md index 6d7241fc4a7e..5437a9a9702f 100644 --- a/receiver/dockerstatsreceiver/README.md +++ b/receiver/dockerstatsreceiver/README.md @@ -27,7 +27,7 @@ resource usage of cpu, memory, network, and the ## Configuration -The following settings are for both logs and metrics receier: +The following settings are for both logs and metrics receiver: - `endpoint` (default = `unix:///var/run/docker.sock`): Address to reach the desired Docker daemon. - `excluded_images` (no default, all running containers monitored): A list of strings, diff --git a/receiver/dockerstatsreceiver/logs_receiver.go b/receiver/dockerstatsreceiver/logs_receiver.go index 2e450d7506a0..ad1b451ed0a1 100644 --- a/receiver/dockerstatsreceiver/logs_receiver.go +++ b/receiver/dockerstatsreceiver/logs_receiver.go @@ -98,13 +98,13 @@ func newDockerEventPoller( } func (d *dockerEventPoller) Start(ctx context.Context) { - for { - filterArgs := filters.NewArgs() - for k, v := range d.config.Logs.Filters { - for _, elem := range v { - filterArgs.Add(k, elem) - } + filterArgs := filters.NewArgs() + for k, v := range d.config.Logs.Filters { + for _, elem := range v { + filterArgs.Add(k, elem) } + } + for { // event stream can be interrupted by async errors (connection or other). // client caller must retry to restart processing. retry with backoff here // except for context cancellation.