mocks

Documentation

Index

• Variables
• func BuildCluster(modifyFn func(cluster *api.Cluster)) *api.Cluster
• func BuildClusterMap(modifyFn func(m []map[string]interface{})) []map[string]interface{}

Variables

var (
	TestClusterID               = "123"
	StrimziOperatorVersion      = "strimzi-cluster-operator.from-cluster"
	DefaultKafkaVersion         = "2.7.0"
	AvailableStrimziVersions, _ = json.Marshal([]api.StrimziVersion{
		{
			Version: StrimziOperatorVersion,
			Ready:   true,
			KafkaVersions: []api.KafkaVersion{
				{
					Version: "2.7.0",
				},
				{
					Version: "2.8.0",
				},
			},
			KafkaIBPVersions: []api.KafkaIBPVersion{
				{
					Version: "2.7",
				},
				{
					Version: "2.8",
				},
			},
		},
	})

	NoAvailableStrimziVersions, _ = json.Marshal([]api.StrimziVersion{
		{
			Version: StrimziOperatorVersion,
			Ready:   false,
			KafkaVersions: []api.KafkaVersion{
				{
					Version: "2.7.0",
				},
				{
					Version: "2.8.0",
				},
			},
			KafkaIBPVersions: []api.KafkaIBPVersion{
				{
					Version: "2.7",
				},
				{
					Version: "2.8",
				},
			},
		},
	})
)

Functions

func BuildCluster

func BuildCluster(modifyFn func(cluster *api.Cluster)) *api.Cluster

build a test cluster

func BuildClusterMap

func BuildClusterMap(modifyFn func(m []map[string]interface{})) []map[string]interface{}