Documentation ¶
Overview ¶
Package dlog provides utilities to read Docker Logs API stream format.
Index ¶
Examples ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewReader ¶
NewReader returns a reader that strips off the message headers from the underlying raw docker logs stream and returns the messages.
Example ¶
package main import ( "bufio" "context" "fmt" "log" "net" "net/http" "github.com/ahmetalpbalkan/dlog" ) func main() { client := &http.Client{ Transport: &http.Transport{ DialContext: func(ctx context.Context, network, addr string) (net.Conn, error) { conn, err := net.Dial("unix", "/var/run/docker.sock") if err != nil { return nil, fmt.Errorf("cannot connect docker socket: %v", err) } return conn, nil }}} url := "http://-/containers/CONTAINER_NAME/logs?stdout=1&stderr=1&follow=1" resp, err := client.Get(url) if err != nil { log.Fatalf("request failed: %v", err) } defer resp.Body.Close() if resp.StatusCode != http.StatusOK { log.Fatalf("unexpected status code: %s", resp.Status) } // At this point we have a logs stream, here is how to read each log line // from container: r := dlog.NewReader(resp.Body) s := bufio.NewScanner(r) for s.Scan() { log.Println(s) } if err := s.Err(); err != nil { log.Fatalf("read error: %v", err) } }
Output:
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.