Implement DBBindInterface for generic bindings (#1381)

Signed-off-by: Arnob kumar saha <[email protected]>

apis/kubedb/v1alpha2/druid_helpers.go

@@ -803,3 +803,26 @@ func (d *Druid) CertSecretVolumeName(alias DruidCertificateAlias) string {
 func (d *Druid) CertSecretVolumeMountPath(configDir string, cert string) string {
 	return filepath.Join(configDir, cert)
 }
+
+type DruidBind struct {
+	*Druid
+}
+
+var _ DBBindInterface = &DruidBind{}
+
+func (d *DruidBind) ServiceNames() (string, string) {
+	return d.ServiceName(), d.ServiceName()
+}
+
+func (d *DruidBind) Ports() (int, int) {
+	p := int(d.DruidNodeContainerPort(DruidNodeRoleRouters))
+	return p, p
+}
+
+func (d *DruidBind) SecretName() string {
+	return d.GetAuthSecretName()
+}
+
+func (d *DruidBind) CertSecretName() string {
+	return d.GetCertSecretName(DruidClientCert)
+}

apis/kubedb/v1alpha2/rabbitmq_helpers.go

@@ -422,3 +422,31 @@ func (r *RabbitMQ) ReplicasAreReady(lister pslister.PetSetLister) (bool, string,
 	expectedItems := 1
 	return checkReplicasOfPetSet(lister.PetSets(r.Namespace), labels.SelectorFromSet(r.OffshootLabels()), expectedItems)
 }
+
+type RabbitMQBind struct {
+	*RabbitMQ
+}
+
+var _ DBBindInterface = &RabbitMQBind{}
+
+func (d *RabbitMQBind) ServiceNames() (string, string) {
+	return d.ServiceName(), d.DashboardServiceName()
+}
+
+func (d *RabbitMQBind) Ports() (int, int) {
+	dbPort := kubedb.RabbitMQAMQPPort
+	uiPort := kubedb.RabbitMQManagementUIPort
+	if d.Spec.TLS != nil {
+		dbPort = kubedb.RabbitMQAMQPSPort
+		uiPort = kubedb.RabbitMQManagementUIPortWithSSL
+	}
+	return dbPort, uiPort
+}
+
+func (d *RabbitMQBind) SecretName() string {
+	return d.GetAuthSecretName()
+}
+
+func (d *RabbitMQBind) CertSecretName() string {
+	return d.GetCertSecretName(RabbitmqClientCert)
+}

apis/kubedb/v1alpha2/singlestore_helpers.go

@@ -519,3 +519,25 @@ func (s *Singlestore) ReplicasAreReady(lister pslister.PetSetLister) (bool, stri
 	}
 	return checkReplicasOfPetSet(lister.PetSets(s.Namespace), labels.SelectorFromSet(s.OffshootLabels()), expectedItems)
 }
+
+type SinglestoreBind struct {
+	*Singlestore
+}
+
+var _ DBBindInterface = &SinglestoreBind{}
+
+func (d *SinglestoreBind) ServiceNames() (string, string) {
+	return d.ServiceName(), d.ServiceName()
+}
+
+func (d *SinglestoreBind) Ports() (int, int) {
+	return kubedb.SinglestoreDatabasePort, kubedb.SinglestoreStudioPort
+}
+
+func (d *SinglestoreBind) SecretName() string {
+	return d.DefaultUserCredSecretName("root")
+}
+
+func (d *SinglestoreBind) CertSecretName() string {
+	return d.GetCertSecretName(SinglestoreClientCert)
+}

apis/kubedb/v1alpha2/solr_helpers.go

@@ -518,3 +518,25 @@ func (s *Solr) CertSecretVolumeName(alias SolrCertificateAlias) string {
 func (s *Solr) CertSecretVolumeMountPath(configDir string, cert string) string {
 	return filepath.Join(configDir, cert)
 }
+
+type SolrBind struct {
+	*Solr
+}
+
+var _ DBBindInterface = &SolrBind{}
+
+func (d *SolrBind) ServiceNames() (string, string) {
+	return d.ServiceName(), d.ServiceName()
+}
+
+func (d *SolrBind) Ports() (int, int) {
+	return kubedb.SolrRestPort, kubedb.SolrRestPort
+}
+
+func (d *SolrBind) SecretName() string {
+	return d.GetAuthSecretName()
+}
+
+func (d *SolrBind) CertSecretName() string {
+	return d.GetCertSecretName(SolrClientCert)
+}

apis/kubedb/v1alpha2/types.go

@@ -255,3 +255,10 @@ type ArchiverRecovery struct {
 	FullDBRepository    *kmapi.ObjectReference   `json:"fullDBRepository,omitempty"`
 	ReplicationStrategy *PITRReplicationStrategy `json:"replicationStrategy,omitempty"`
 }
+
+type DBBindInterface interface {
+	ServiceNames() (string, string) // (DBServiceName, UIServiceName)
+	Ports() (int, int)              // (DBPort, UIPort)
+	SecretName() string
+	CertSecretName() string
+}