Add event publishing to kne_cli and controller server

[alexmasi]

No description provided.

[github-actions]

Pull Request Test Coverage Report for Build 5471004216

• 11 of 102 (10.78%) changed or added relevant lines in 5 files are covered.
• 25 unchanged lines in 1 file lost coverage.
• Overall coverage decreased (-1.1%) to 65.012%

---

Changes Missing Coverage	Covered Lines	Changed/Added Lines	%
cmd/topology/topology.go	7	9	77.78%
cmd/deploy/deploy.go	2	5	40.0%
topo/topo.go	2	10	20.0%
deploy/deploy.go	0	30	0.0%
cmd/root.go	0	48	0.0%

Files with Coverage Reduction	New Missed Lines	%
cmd/root.go	25	5.44%

Totals
Change from base Build 5418025002:	-1.1%
Covered Lines:	3666
Relevant Lines:	5639

---

💛 - Coveralls

[alexmasi]

Now all of the functionality is in place, cmd line flags can now be supplied with a config file using viper:

$ cat ~/.kne/config.yaml
report_usage: false
progress: true

This example sets the default values of the --report_usage and --progress flags. The hierarchy for flag values is as follows:

1. The value specified as a flag when calling the CLI
2. The value found in the kne config file
3. The default value specified using viper.SetDefault()
4. The default value specified using the flag default

[alexmasi]

Next step is to break into 3 PRs:

1. Adding viper and restructure CLI
2. Adding usage pkg
3. Adding event publishing to deploy.go, topo.go, and the necessary flags to set them from the CLI and controller server

[alexmasi]

need to merge from main after #396 is merged

[alexmasi]

/gcbrun

[bormanp]

Put the entire thing in a method so you can say:

// reportUsage returns a function to defer by the caller.
//
//      if d.ReportUsage {
//              finish = d.reportUsage(ctx)
//              defer finish(rerr)
//      }
func (d *Deployment) reportUsage(ctx context.Context) func(error) {
        r, err := metrics.NewReporter(ctx, d.ReportUsageProjectID, d.ReportUsageTopicID)
        if err != nil {
                log.Warningf("Unable to create metrics reporter: %v", err)
                return func(_ error) {}
        }
        if id, err := r.ReportDeployClusterStart(ctx, d.event()); err != nil {
                log.Warningf("Unable to report cluster deployment start event: %v", err)
                return func(_ error) { r.Close() }
        }
        return func(rerr error) {
                if err := r.ReportDeployClusterEnd(ctx, id, rerr); err != nil {
                        log.Warningf("Unable to report cluster deployment end event: %v", err)
                }
        }
}

[alexmasi]

done

[alexmasi]

/gcbrun

[alexmasi]

/gcbrun

[alexmasi]

/gcbrun