Function TestStatsDumper

stats_test.go:91–177

(t *testing.T)

}

func TestStatsDumper(t *testing.T) {
	// Check that the StatsDumper correctly reports the metrics gathered from
	// the components. The tests check both the reports printed to the standard
	// output and metrics published to the MetricClient.
	toml := `
[input]
name="statsInput"

[[filter]]
name="statsFilter"

[[filter]]
name="statsFilter"

[[filter]]
name="statsFilter"

[output]
name="statsOutput"
procs=2
fields=["field0"]

[upload]
name="statsUpload"

[metrics]
name="MockMetrics"
`
	components := baker.Components{
		Inputs: []baker.InputDesc{{Name: "statsInput",
			Config: &struct{}{},
			New:    func(baker.InputParams) (baker.Input, error) { return statsInput{}, nil },
		}},
		Filters: []baker.FilterDesc{{Name: "statsFilter",
			Config: &struct{}{},
			New:    func(baker.FilterParams) (baker.Filter, error) { return statsFilter{}, nil },
		}},
		Outputs: []baker.OutputDesc{{Name: "statsOutput",
			Config: &struct{}{},
			New:    func(baker.OutputParams) (baker.Output, error) { return statsOutput{}, nil },
		}},
		Uploads: []baker.UploadDesc{{Name: "statsUpload",
			Config: &struct{}{},
			New:    func(baker.UploadParams) (baker.Upload, error) { return statsUpload{}, nil },
		}},
		Metrics:     []baker.MetricsDesc{testutil.MockMetricsDesc},
		FieldByName: func(n string) (baker.FieldIndex, bool) { return 0, true },
		FieldNames:  []string{"foo", "bar"},
	}

	cfg, err := baker.NewConfigFromToml(strings.NewReader(toml), components)
	if err != nil {
		t.Fatal(err)
	}

	tp, err := baker.NewTopologyFromConfig(cfg)
	if err != nil {
		t.Fatal(err)