INNER CODE UNIT · Go

buildRabbitmqCluster

rabbitmq/cluster-operator · kubectl-rabbitmq/cluster.go:65

func buildRabbitmqCluster(name string, opts clusterOptions) (*v1beta1.RabbitmqCluster, error) {
	cluster := &v1beta1.RabbitmqCluster{
		TypeMeta: metav1.TypeMeta{
			APIVersion: "rabbitmq.com/v1beta1",
			Kind:       "RabbitmqCluster",
		},
		ObjectMeta: metav1.ObjectMeta{
			Name: name,
		},
		Spec: v1beta1.RabbitmqClusterSpec{},
	}

	// Basic configuration
	if opts.Replicas > 0 {
		cluster.Spec.Replicas = &opts.Replicas
	}
	if opts.Image != "" {
		cluster.Spec.Image = opts.Image

View source record →