resource_test.go

package kafka

import "testing"

func TestResourceTypeMarshal(t *testing.T) {
	for i := ResourceTypeUnknown; i <= ResourceTypeDelegationToken; i++ {
		text, err := i.MarshalText()
		if err != nil {
			t.Errorf("couldn't marshal %d to text: %s", i, err)
		}
		var got ResourceType
		err = got.UnmarshalText(text)
		if err != nil {
			t.Errorf("couldn't unmarshal %s to ResourceType: %s", text, err)
		}
		if got != i {
			t.Errorf("got %d, want %d", got, i)
		}
	}
}

// Verify that the text version of ResourceTypeBroker is "Cluster".
// This is added since ResourceTypeBroker and ResourceTypeCluster
// have the same value.
func TestResourceTypeBroker(t *testing.T) {
	text, err := ResourceTypeBroker.MarshalText()
	if err != nil {
		t.Errorf("couldn't marshal %d to text: %s", ResourceTypeBroker, err)
	}
	if string(text) != "Cluster" {
		t.Errorf("got %s, want %s", string(text), "Cluster")
	}
	var got ResourceType
	err = got.UnmarshalText(text)
	if err != nil {
		t.Errorf("couldn't unmarshal %s to ResourceType: %s", text, err)
	}
	if got != ResourceTypeBroker {
		t.Errorf("got %d, want %d", got, ResourceTypeBroker)
	}
}

func TestPatternTypeMarshal(t *testing.T) {
	for i := PatternTypeUnknown; i <= PatternTypePrefixed; i++ {
		text, err := i.MarshalText()
		if err != nil {
			t.Errorf("couldn't marshal %d to text: %s", i, err)
		}
		var got PatternType
		err = got.UnmarshalText(text)
		if err != nil {
			t.Errorf("couldn't unmarshal %s to PatternType: %s", text, err)
		}
		if got != i {
			t.Errorf("got %d, want %d", got, i)
		}
	}
}