rds

Documentation

Index

• Constants
• func CreateBroker() brokerapi.ServiceBroker
• func GetAccountInfoFromBindingParameters(parameter map[string]interface{}) (string, string)
• type ConnectionInfo
• type RDSBroker
  • func (c *RDSBroker) Bind(instanceID, serviceID, planID, bindingID string, ...) (map[string]interface{}, brokerapi.Credential, error)
  • func (c *RDSBroker) Catalog() (*brokerapi.Catalog, error)
  • func (c *RDSBroker) CheckAccountStatus(instanceID string, accountName string, status string) (bool, error)
  • func (c *RDSBroker) CheckDBInstanceStatus(instanceID, status string) (bool, error)
  • func (c *RDSBroker) CreateDatabaseAccount(instanceID, dbInstanceID, accountName, accountPassword string) error
  • func (c *RDSBroker) CreateNewClientFromStsToken() error
  • func (c *RDSBroker) CreateVpcClientFromStsToken() (*vpc.Client, error)
  • func (c *RDSBroker) Deprovision(instanceID, serviceID, planID string, parameterIn map[string]interface{}) error
  • func (c *RDSBroker) GetBindingStatus(instanceID, serviceID, planID, bindingID string, ...) (bool, error)
  • func (c *RDSBroker) GetEcsVpcIps() (ips string, err error)
  • func (c *RDSBroker) GetInstanceStatus(instanceID, serviceID, planID string, parameterIn map[string]interface{}) (bool, error)
  • func (c *RDSBroker) GetServiceInstance(id string) (string, error)
  • func (c *RDSBroker) Provision(instanceID, serviceID, planID string, parameterIn map[string]interface{}) (map[string]interface{}, error)
  • func (c *RDSBroker) ResetDatabaseAccount(instanceID, dbInstanceID, accountName, password string) error
  • func (c *RDSBroker) SetRdsIpsForEcs(instanceID, dbInstanceID string) error
  • func (c *RDSBroker) SetRdsSecurityIps(ips, dbInstanceID string) error
  • func (c *RDSBroker) UnBind(instanceID, serviceID, planID, bindingID string, ...) error
• type ServiceInstanceBasicMetadata
• type ServiceInstanceMetadata
• type UserMetaData
  • func GetCloudServiceMetaData() (*UserMetaData, error)

Constants

const DEFAULT_PAGE_SIZE = 50

const SERVICE_CATALOG_TAG_KEY = "service_catalog"

const SERVICE_CATALOG_TAG_VALUE = "true"

const (
	SelfDefineServicePlan = "rds-edc2badc-d93b-4d9c-9d8e-da2f1c8c3e1e"
)

Functions

func CreateBroker

func CreateBroker() brokerapi.ServiceBroker

func GetAccountInfoFromBindingParameters

func GetAccountInfoFromBindingParameters(parameter map[string]interface{}) (string, string)

Types

type ConnectionInfo

type ConnectionInfo struct {
	ConnectionString string
	Port             string
}

type RDSBroker

type RDSBroker struct {
	// contains filtered or unexported fields
}

func (*RDSBroker) Bind

func (c *RDSBroker) Bind(instanceID, serviceID, planID, bindingID string,
	parameterInstance, parameterIn map[string]interface{}) (map[string]interface{}, brokerapi.Credential, error)

func (*RDSBroker) Catalog

func (c *RDSBroker) Catalog() (*brokerapi.Catalog, error)

func (*RDSBroker) CheckAccountStatus

func (c *RDSBroker) CheckAccountStatus(instanceID string, accountName string, status string) (bool, error)

func (*RDSBroker) CheckDBInstanceStatus

func (c *RDSBroker) CheckDBInstanceStatus(instanceID, status string) (bool, error)

func (*RDSBroker) CreateDatabaseAccount

func (c *RDSBroker) CreateDatabaseAccount(instanceID, dbInstanceID, accountName, accountPassword string) error

func (*RDSBroker) CreateNewClientFromStsToken

func (c *RDSBroker) CreateNewClientFromStsToken() error

func (*RDSBroker) CreateVpcClientFromStsToken

func (c *RDSBroker) CreateVpcClientFromStsToken() (*vpc.Client, error)

func (*RDSBroker) Deprovision

func (c *RDSBroker) Deprovision(instanceID, serviceID, planID string, parameterIn map[string]interface{}) error

func (*RDSBroker) GetBindingStatus

func (c *RDSBroker) GetBindingStatus(instanceID, serviceID, planID, bindingID string,
	parameterInstance, parameterIn map[string]interface{}) (bool, error)

func (*RDSBroker) GetEcsVpcIps

func (c *RDSBroker) GetEcsVpcIps() (ips string, err error)

func (*RDSBroker) GetInstanceStatus

func (c *RDSBroker) GetInstanceStatus(instanceID, serviceID, planID string,
	parameterIn map[string]interface{}) (bool, error)

func (*RDSBroker) GetServiceInstance

func (c *RDSBroker) GetServiceInstance(id string) (string, error)

func (*RDSBroker) Provision

func (c *RDSBroker) Provision(instanceID, serviceID, planID string, parameterIn map[string]interface{}) (map[string]interface{}, error)

func (*RDSBroker) ResetDatabaseAccount

func (c *RDSBroker) ResetDatabaseAccount(instanceID, dbInstanceID, accountName, password string) error

func (*RDSBroker) SetRdsIpsForEcs

func (c *RDSBroker) SetRdsIpsForEcs(instanceID, dbInstanceID string) error

func (*RDSBroker) SetRdsSecurityIps

func (c *RDSBroker) SetRdsSecurityIps(ips, dbInstanceID string) error

func (*RDSBroker) UnBind

func (c *RDSBroker) UnBind(instanceID, serviceID, planID, bindingID string,
	parameterInstance, parameterIn map[string]interface{}) error

type ServiceInstanceBasicMetadata

type ServiceInstanceBasicMetadata struct {
	Engine        string `json:"engine"`
	EngineVersion string `json:"engine_version"`
	Class         string `json:"class"`
	Storage       string `json:"storage"`
}

type ServiceInstanceMetadata

type ServiceInstanceMetadata struct {
	Engine        string `json:"engine"`
	EngineVersion string `json:"engine_version"`
	Class         string `json:"class"`
	Storage       string `json:"storage"`
	ZoneId        string `json:"zoneId"`
	NetworkType   string `json:"networktype"`
	VpcID         string `json:"vpcID"`
	VSwitchID     string `json:"vswitchID"`
}

type UserMetaData

type UserMetaData struct {
	AccessKeyId     string
	AccessKeySecret string
	SecurityToken   string
	Region          string
	ZoneID          string
	VpcID           string
	VSwitchID       string
}

func GetCloudServiceMetaData

func GetCloudServiceMetaData() (*UserMetaData, error)