Function getRwServiceObject

tests/utils/services/service.go:55–71

getRwServiceObject return read write service object

(
	ctx context.Context,
	crudClient client.Client,
	namespace, clusterName string,
)

// getRwServiceObject return read write service object
func getRwServiceObject(
	ctx context.Context,
	crudClient client.Client,
	namespace, clusterName string,
) (*corev1.Service, error) {
	svcName := GetReadWriteServiceName(clusterName)
	service := &corev1.Service{}
	namespacedName := types.NamespacedName{
		Namespace: namespace,
		Name:      svcName,
	}
	err := crudClient.Get(ctx, namespacedName, service)
	if err != nil {
		return service, err
	}
	return service, nil
}

// CreateDSN return DSN name
func CreateDSN(host, user, dbname, password string, sslmode SSLMode, port int) string {