mssql.go

package mssql

import (
	sqlSDK "github.com/Azure/azure-sdk-for-go/services/preview/sql/mgmt/2017-03-01-preview/sql" // nolint: lll
	"github.com/Azure/go-autorest/autorest/azure"
	"github.com/Azure/open-service-broker-azure/pkg/azure/arm"
	"github.com/Azure/open-service-broker-azure/pkg/service"
)

const (
	// ConnectionPolicyDefault is the connection policy in effect on all servers
	// after creation.
	ConnectionPolicyDefault = string(sqlSDK.ServerConnectionTypeDefault)
	// ConnectionPolicyProxy -- all connections are proxied via the Azure
	// SQL Database gateways.
	ConnectionPolicyProxy = string(sqlSDK.ServerConnectionTypeProxy)
	// ConnectionPolicyRedirect -- clients establish connections directly
	// to the node hosting the database.
	ConnectionPolicyRedirect = string(sqlSDK.ServerConnectionTypeRedirect)
)

type module struct {
	allInOneServiceManager             *allInOneManager
	dbmsManager                        *dbmsManager
	databaseManager                    *databaseManager
	dbmsRegisteredManager              *dbmsRegisteredManager
	databaseManagerForExistingInstance *databaseManagerForExistingInstance
}

type allInOneManager struct {
	sqlDatabaseDNSSuffix           string
	armDeployer                    arm.Deployer
	serversClient                  sqlSDK.ServersClient
	databasesClient                sqlSDK.DatabasesClient
	serverConnectionPoliciesClient sqlSDK.ServerConnectionPoliciesClient
}

type dbmsManager struct {
	sqlDatabaseDNSSuffix           string
	armDeployer                    arm.Deployer
	serversClient                  sqlSDK.ServersClient
	serverConnectionPoliciesClient sqlSDK.ServerConnectionPoliciesClient
}

type databaseManager struct {
	armDeployer     arm.Deployer
	databasesClient sqlSDK.DatabasesClient
}

type dbmsRegisteredManager struct {
	dbmsManager
}

type databaseManagerForExistingInstance struct {
	databaseManager
}

// New returns a new instance of a type that fulfills the service.Module
// interface and is capable of provisioning MS SQL servers and databases
// using "Azure SQL Database"
func New(
	azureEnvironment azure.Environment,
	armDeployer arm.Deployer,
	serversClient sqlSDK.ServersClient,
	databasesClient sqlSDK.DatabasesClient,
	serverConnectionPoliciesClient sqlSDK.ServerConnectionPoliciesClient,
) service.Module {
	dbmsMgr := dbmsManager{
		sqlDatabaseDNSSuffix:           azureEnvironment.SQLDatabaseDNSSuffix,
		armDeployer:                    armDeployer,
		serversClient:                  serversClient,
		serverConnectionPoliciesClient: serverConnectionPoliciesClient,
	}
	databaseMgr := databaseManager{
		armDeployer:     armDeployer,
		databasesClient: databasesClient,
	}
	return &module{
		allInOneServiceManager: &allInOneManager{
			sqlDatabaseDNSSuffix:           azureEnvironment.SQLDatabaseDNSSuffix,
			armDeployer:                    armDeployer,
			serversClient:                  serversClient,
			databasesClient:                databasesClient,
			serverConnectionPoliciesClient: serverConnectionPoliciesClient,
		},
		dbmsManager:     &dbmsMgr,
		databaseManager: &databaseMgr,
		dbmsRegisteredManager: &dbmsRegisteredManager{
			dbmsMgr,
		},
		databaseManagerForExistingInstance: &databaseManagerForExistingInstance{
			databaseMgr,
		},
	}
}

func (m *module) GetName() string {
	return "mssql"
}