Function TestPlugin

plugins/destination/s3/client/client_test.go:27–54

(t *testing.T)

)

func TestPlugin(t *testing.T) {
	zero := int64(0)
	for _, ft := range []filetypes.FormatType{
		filetypes.FormatTypeCSV,
		filetypes.FormatTypeJSON,
		filetypes.FormatTypeParquet,
	} {
		s := spec.Spec{
			Bucket:         bucket,
			Region:         region,
			Path:           t.TempDir()[1:],
			NoRotate:       true,
			BatchSizeBytes: &zero,
			BatchSize:      &zero,
			FileSpec:       filetypes.FileSpec{Format: ft},
		}

		t.Run("generic/"+string(ft), func(t *testing.T) {
			t.Parallel()
			testPlugin(t, &s)
		})

		t.Run("write/"+string(ft), func(t *testing.T) {
			t.Parallel()
			testPluginCustom(t, &s)
		})
	}
}

func testPlugin(t *testing.T, s *spec.Spec) {
	ctx := context.Background()