"Fossies" - the Fresh Open Source Software Archive  

Source code changes of the file "pkg/provider/docker/docker.go" between
traefik-v2.3.2.src.tar.gz and traefik-v2.3.3.src.tar.gz

About: Traefik is a cloud native edge router, a reverse proxy and load balancer for HTTP and TCP-based applications.

docker.go  (traefik-v2.3.2.src):docker.go  (traefik-v2.3.3.src)
package docker package docker
import ( import (
"context" "context"
"errors"
"fmt" "fmt"
"io" "io"
"net" "net"
"net/http" "net/http"
"strconv" "strconv"
"strings" "strings"
"text/template" "text/template"
"time" "time"
"github.com/cenkalti/backoff/v4" "github.com/cenkalti/backoff/v4"
skipping to change at line 310 skipping to change at line 311
eventsc, errc := dockerClient.Events(ctx, options) eventsc, errc := dockerClient.Events(ctx, options)
for { for {
select { select {
case event := <-eventsc: case event := <-eventsc:
if event.Action == "start " || if event.Action == "start " ||
event.Action == " die" || event.Action == " die" ||
strings.HasPrefix (event.Action, "health_status") { strings.HasPrefix (event.Action, "health_status") {
startStopHandle(e vent) startStopHandle(e vent)
} }
case err := <-errc: case err := <-errc:
if err == io.EOF { if errors.Is(err, io.EOF) {
logger.Debug("Pro vider event stream closed") logger.Debug("Pro vider event stream closed")
} }
return err return err
case <-ctx.Done(): case <-ctx.Done():
return nil return nil
} }
} }
} }
} }
return nil return nil
 End of changes. 2 change blocks. 
1 lines changed or deleted 2 lines changed or added

Home  |  About  |  Features  |  All  |  Newest  |  Dox  |  Diffs  |  RSS Feeds  |  Screenshots  |  Comments  |  Imprint  |  Privacy  |  HTTP(S)