| package cmd |
| |
| import ( |
| "context" |
| |
| "github.com/spf13/cobra" |
| "go.skia.org/infra/perf/go/ingest/process" |
| ) |
| |
| // ingestCmd represents the ingest command |
| var ingestCmd = &cobra.Command{ |
| Use: "ingest", |
| Short: "Run the ingestion process.", |
| Long: `Continuously imports files as they arrive from |
| the configured ingestion sources and populates the datastore |
| with that data. |
| `, |
| RunE: func(cmd *cobra.Command, args []string) error { |
| return process.Start(context.Background(), local, instanceConfig) |
| }, |
| } |
| |
| func ingestInit() { |
| rootCmd.AddCommand(ingestCmd) |
| } |