We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 7cf5712 commit 380dd83Copy full SHA for 380dd83
probe/docker/registry.go
@@ -176,7 +176,9 @@ func (r *registry) listenForEvents() bool {
176
// Next, start listening for events. We do this before fetching
177
// the list of containers so we don't miss containers created
178
// after listing but before listening for events.
179
- events := make(chan *docker_client.APIEvents)
+ // Use a buffered chan so the client library can run ahead of the listener
180
+ // - Docker will drop an event if it is not collected quickly enough.
181
+ events := make(chan *docker_client.APIEvents, 1024)
182
if err := r.client.AddEventListener(events); err != nil {
183
log.Errorf("docker registry: %s", err)
184
return true
0 commit comments