source.go

package v1alpha1

import (
	"fmt"
)

type Source struct {
	// +kubebuilder:default=default
	Name      string           `json:"name,omitempty" protobuf:"bytes,1,opt,name=name"`
	Cron      *Cron            `json:"cron,omitempty" protobuf:"bytes,2,opt,name=cron"`
	STAN      *STAN            `json:"stan,omitempty" protobuf:"bytes,3,opt,name=stan"`
	Kafka     *KafkaSource     `json:"kafka,omitempty" protobuf:"bytes,4,opt,name=kafka"`
	HTTP      *HTTPSource      `json:"http,omitempty" protobuf:"bytes,5,opt,name=http"`
	S3        *S3Source        `json:"s3,omitempty" protobuf:"bytes,8,opt,name=s3"`
	DB        *DBSource        `json:"db,omitempty" protobuf:"bytes,6,opt,name=db"`
	Volume    *VolumeSource    `json:"volume,omitempty" protobuf:"bytes,9,opt,name=volume"`
	JetStream *JetStreamSource `json:"jetstream,omitempty" protobuf:"bytes,10,opt,name=jetstream"`
	// +kubebuilder:default={duration: "100ms", steps: 20, factorPercentage: 200, jitterPercentage: 10}
	Retry Backoff `json:"retry,omitempty" protobuf:"bytes,7,opt,name=retry"`
}

func (s Source) get() urner {
	if v := s.Cron; v != nil {
		return v
	} else if v := s.DB; v != nil {
		return v
	} else if v := s.HTTP; v != nil {
		return v
	} else if v := s.Kafka; v != nil {
		return v
	} else if v := s.S3; v != nil {
		return v
	} else if v := s.STAN; v != nil {
		return v
	} else if v := s.Volume; v != nil {
		return v
	} else if v := s.JetStream; v != nil {
		return v
	}
	panic(fmt.Errorf("invalid source %q", s.Name))
}

func (s Source) GenURN(cluster, namespace string) string {
	return s.get().GenURN(cluster, namespace)
}