-
Notifications
You must be signed in to change notification settings - Fork 950
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
feature: events service logic code of all links
Signed-off-by: Michael Wan <[email protected]>
- Loading branch information
Showing
45 changed files
with
8,538 additions
and
34 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,142 @@ | ||
| package main | ||
|
|
||
| import ( | ||
| "context" | ||
| "encoding/json" | ||
| "fmt" | ||
| "io" | ||
| "os" | ||
| "sort" | ||
| "strings" | ||
| "time" | ||
|
|
||
| "github.com/alibaba/pouch/apis/filters" | ||
| "github.com/alibaba/pouch/apis/types" | ||
| "github.com/spf13/cobra" | ||
| ) | ||
|
|
||
| // eventsDescription is used to describe events command in detail and auto generate command doc. | ||
| var eventsDescription = "" | ||
|
|
||
| // EventsCommand use to implement 'events' command. | ||
| type EventsCommand struct { | ||
| baseCommand | ||
| since string | ||
| until string | ||
| filter []string | ||
| } | ||
|
|
||
| // Init initialize events command. | ||
| func (e *EventsCommand) Init(c *Cli) { | ||
| e.cli = c | ||
| e.cmd = &cobra.Command{ | ||
| Use: "events [OPTIONS]", | ||
| Short: "Get real time events from the daemon", | ||
| Args: cobra.NoArgs, | ||
| RunE: func(cmd *cobra.Command, args []string) error { | ||
| return e.runEvents() | ||
| }, | ||
| Example: eventsExample(), | ||
| } | ||
| e.addFlags() | ||
| } | ||
|
|
||
| // addFlags adds flags for specific command. | ||
| func (e *EventsCommand) addFlags() { | ||
| flagSet := e.cmd.Flags() | ||
|
|
||
| flagSet.StringVarP(&e.since, "since", "s", "", "Show all events created since timestamp") | ||
| flagSet.StringVarP(&e.until, "until", "u", "", "Stream events until this timestamp") | ||
| flagSet.StringSliceVarP(&e.filter, "filter", "f", []string{}, "Filter output based on conditions provided") | ||
| } | ||
|
|
||
| // runEvents is the entry of events command. | ||
| func (e *EventsCommand) runEvents() error { | ||
| ctx := context.Background() | ||
| apiClient := e.cli.Client() | ||
|
|
||
| eventFilterArgs := filters.NewArgs() | ||
|
|
||
| // TODO: parse params | ||
| for _, f := range e.filter { | ||
| var err error | ||
| eventFilterArgs, err = filters.ParseFlag(f, eventFilterArgs) | ||
| if err != nil { | ||
| return err | ||
| } | ||
| } | ||
|
|
||
| responseBody, err := apiClient.Events(ctx, e.since, e.until, eventFilterArgs) | ||
| if err != nil { | ||
| return err | ||
| } | ||
|
|
||
| return streamEvents(responseBody, os.Stdout) | ||
| } | ||
|
|
||
| // streamEvents decodes prints the incoming events in the provided output. | ||
| func streamEvents(input io.Reader, output io.Writer) error { | ||
| return DecodeEvents(input, func(event types.EventsMessage, err error) error { | ||
| if err != nil { | ||
| return err | ||
| } | ||
| printOutput(event, output) | ||
| return nil | ||
| }) | ||
| } | ||
|
|
||
| type eventProcessor func(event types.EventsMessage, err error) error | ||
|
|
||
| // printOutput prints all types of event information. | ||
| // Each output includes the event type, actor id, name and action. | ||
| // Actor attributes are printed at the end if the actor has any. | ||
| func printOutput(event types.EventsMessage, output io.Writer) { | ||
| // RFC3339NanoFixed is our own version of RFC339Nano because we want one | ||
| // that pads the nano seconds part with zeros to ensure | ||
| // the timestamps are aligned in the logs. | ||
| RFC3339NanoFixed := "2006-01-02T15:04:05.000000000Z07:00" | ||
|
|
||
| if event.TimeNano != 0 { | ||
| fmt.Fprintf(output, "%s ", time.Unix(0, event.TimeNano).Format(RFC3339NanoFixed)) | ||
| } else if event.Time != 0 { | ||
| fmt.Fprintf(output, "%s ", time.Unix(event.Time, 0).Format(RFC3339NanoFixed)) | ||
| } | ||
|
|
||
| fmt.Fprintf(output, "%s %s %s", event.Type, event.Action, event.Actor.ID) | ||
|
|
||
| if len(event.Actor.Attributes) > 0 { | ||
| var attrs []string | ||
| var keys []string | ||
| for k := range event.Actor.Attributes { | ||
| keys = append(keys, k) | ||
| } | ||
| sort.Strings(keys) | ||
| for _, k := range keys { | ||
| v := event.Actor.Attributes[k] | ||
| attrs = append(attrs, fmt.Sprintf("%s=%s", k, v)) | ||
| } | ||
| fmt.Fprintf(output, " (%s)", strings.Join(attrs, ", ")) | ||
| } | ||
| fmt.Fprint(output, "\n") | ||
| } | ||
|
|
||
| // DecodeEvents decodes event from input stream | ||
| func DecodeEvents(input io.Reader, ep eventProcessor) error { | ||
| dec := json.NewDecoder(input) | ||
| for { | ||
| var event types.EventsMessage | ||
| err := dec.Decode(&event) | ||
| if err != nil && err == io.EOF { | ||
| break | ||
| } | ||
|
|
||
| if procErr := ep(event, err); procErr != nil { | ||
| return procErr | ||
| } | ||
| } | ||
| return nil | ||
| } | ||
|
|
||
| func eventsExample() string { | ||
| return "" | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,44 @@ | ||
| package client | ||
|
|
||
| import ( | ||
| "context" | ||
| "io" | ||
| "net/url" | ||
| "time" | ||
|
|
||
| "github.com/alibaba/pouch/apis/filters" | ||
|
|
||
| timetypes "github.com/docker/engine-api/types/time" | ||
| ) | ||
|
|
||
| // Events returns a stream of events in the daemon in a ReadClosed. | ||
| // It's up to the caller to close the stream. | ||
| func (client *APIClient) Events(ctx context.Context, since string, until string, f filters.Args) (io.ReadCloser, error) { | ||
| query := url.Values{} | ||
| now := time.Now() | ||
|
|
||
| // TODO: parse since and until params | ||
| if until != "" { | ||
| ts, err := timetypes.GetTimestamp(until, now) | ||
| if err != nil { | ||
| return nil, err | ||
| } | ||
| query.Set("until", ts) | ||
| } | ||
|
|
||
| if f.Len() > 0 { | ||
| filtersJSON, err := filters.ToParam(f) | ||
| if err != nil { | ||
| return nil, err | ||
| } | ||
|
|
||
| query.Set("filters", filtersJSON) | ||
| } | ||
|
|
||
| resp, err := client.get(ctx, "/events", query, nil) | ||
| if err != nil { | ||
| return nil, err | ||
| } | ||
|
|
||
| return resp.Body, nil | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1 @@ | ||
| package client |
Oops, something went wrong.