Function TestFileWriterCompareInOut

output/filewriter_test.go:216–272

(t *testing.T)

}

func TestFileWriterCompareInOut(t *testing.T) {
	defer testutil.DisableLogging()()

	tests := []struct {
		name       string
		numRecords int
		wait       time.Duration
		rotate     time.Duration
		comps      []string
	}{
		{
			name:       "year-month-rotation-out.gz",
			numRecords: 500,
			wait:       1 * time.Millisecond,
			rotate:     time.Second,
			comps:      []string{"{{.Year}}", "{{.Month}}", "{{.Rotation}}-out.csv.gz"},
		},
		{
			name:       "year-month-out.gz",
			numRecords: 500,
			wait:       0,
			rotate:     time.Second,
			comps:      []string{"{{.Year}}", "{{.Month}}", "out.csv.gz"},
		},
		{
			name:       "year-month-rotation-out.zst",
			numRecords: 500,
			wait:       1 * time.Millisecond,
			rotate:     time.Second,
			comps:      []string{"{{.Year}}", "{{.Month}}", "{{.Rotation}}-out.csv.zst"},
		},
		{
			name:       "year-month-out.zst",
			numRecords: 500,
			wait:       0,
			rotate:     time.Second,
			comps:      []string{"{{.Year}}", "{{.Month}}", "out.csv.zst"},
		},
		{
			name:       "disable-rotation",
			numRecords: 500,
			wait:       0,
			rotate:     -1,
			comps:      []string{"disable-rotation.out.csv.zst"},
		},
		{
			name:       "field0-out.zst",
			numRecords: 20,
			wait:       1 * time.Millisecond,
			rotate:     time.Second,
			comps:      []string{"{{.Field0}}-out.csv.zst"},
		},
	}
	for _, tt := range tests {
		t.Run(tt.name, testFileWriterCompareInOut(tt.numRecords, tt.wait, tt.rotate, tt.comps...))
	}
}