Switch back to using UnmarshalText for validating compression types

config/configcompression/compressiontype.go

@@ -31,17 +31,24 @@ const (
 
 // IsCompressed returns false if CompressionType is nil, none, or empty.
 // Otherwise, returns true.
-func (t Type) IsCompressed() bool {
-	return t != typeEmpty && t != typeNone
+func (ct *Type) IsCompressed() bool {
+	return *ct != typeEmpty && *ct != typeNone
 }
 
-func (t Type) Validate() error {
-	switch t {
-	case TypeGzip, TypeZlib, TypeDeflate, TypeSnappy, TypeZstd, TypeLz4,
-		typeNone, typeEmpty:
+func (ct *Type) UnmarshalText(in []byte) error {
+	typ := Type(in)
+	if typ == TypeGzip ||
+		typ == TypeZlib ||
+		typ == TypeDeflate ||
+		typ == TypeSnappy ||
+		typ == TypeZstd ||
+		typ == TypeLz4 ||
+		typ == typeNone ||
+		typ == typeEmpty {
+		*ct = typ
 		return nil
 	}
-	return fmt.Errorf("unsupported compression type %q", t)
+	return fmt.Errorf("unsupported compression type %q", typ)
 }
 
 func (t Type) ValidateParams(p CompressionParams) error {

config/configcompression/compressiontype_test.go

@@ -11,7 +11,7 @@ import (
 	"github.com/stretchr/testify/require"
 )
 
-func TestValidate(t *testing.T) {
+func TestUnmarshalText(t *testing.T) {
 	tests := []struct {
 		name            string
 		compressionName []byte
@@ -72,8 +72,8 @@ func TestValidate(t *testing.T) {
 	}
 	for _, tt := range tests {
 		t.Run(tt.name, func(t *testing.T) {
-			temp := Type(tt.compressionName)
-			err := temp.Validate()
+			temp := typeNone
+			err := temp.UnmarshalText(tt.compressionName)
 			if tt.shouldError {
 				assert.Error(t, err)
 				return