package events
import "github.com/containerd/containerd/cmd/ctr/commands/events"
Index ¶
Variables ¶
var Command = cli.Command{ Name: "events", Aliases: []string{"event"}, Usage: "display containerd events", Action: func(context *cli.Context) error { client, ctx, cancel, err := commands.NewClient(context) if err != nil { return err } defer cancel() eventsClient := client.EventService() eventsCh, errCh := eventsClient.Subscribe(ctx, context.Args()...) open := true for open { var e *events.Envelope select { case e = <-eventsCh: case err, open = <-errCh: return err } if e != nil { var out []byte if e.Event != nil { v, err := typeurl.UnmarshalAny(e.Event) if err != nil { return err } out, err = json.Marshal(v) if err != nil { return err } } if _, err := fmt.Println( e.Timestamp, e.Namespace, e.Topic, string(out), ); err != nil { return err } } } return nil }, }
Command is the cli command for displaying containerd events
Source Files ¶
- Version
- v1.1.3
- Published
- Aug 22, 2018
- Platform
- linux/amd64
- Imports
- 7 packages
- Last checked
- 10 seconds ago –
Tools for package owners.