oss

Documentation

Index

• Constants
• func CheckOssInstanceStatus(instanceID, region, accessKeyId, accessKeySecret string) (bool, error)
• func CheckRamForInstance(instanceId, region, accessKeyId, accessKeySecret string) bool
• func CreateBroker() brokerapi.ServiceBroker
• func CreateOssBucket(instanceId, region, accessKeyId, accessKeySecret, acl, storageClass string) (string, error)
• func CreateRamForInstance(instanceId, region, accessKeyId, accessKeySecret string) error
• func CreateRamNewClient(region, accessKeyId, accessKeySecret string) (*ram.Client, error)
• func CreateRamUserForBinding(bindingId, instanceID, region, accessKeyId, accessKeySecret string) (*ram.User, *ram.AccessKey, error)
• func DeleteOssBucket(instanceId, region, accessKeyId, accessKeySecret string) error
• func DeleteRamForInstance(instanceId, region, accessKeyId, accessKeySecret string) error
• func DeleteRamUserForBinding(...) error
• func GetAccessInfoFromInstanceParameters(parameterIn map[string]interface{}) (accessKeyId, accessKeySecret, region, acl, storageClass string, err error)
• func GetBucketNameForInstance(instanceId string) string
• func GetOSSEndPoint(region string) string
• func GetOssRamPolicy(instanceID string) string
• func GetRamUserForBinding(bindingId, instanceID, region, accessKeyId, accessKeySecret string) error
• type ConnectionInfo
• type OSSBroker
  • func (c *OSSBroker) Bind(instanceID, serviceID, planID, bindingID string, ...) (map[string]interface{}, brokerapi.Credential, error)
  • func (c *OSSBroker) Catalog() (*brokerapi.Catalog, error)
  • func (c *OSSBroker) Deprovision(instanceID, serviceID, planID string, parameterIn map[string]interface{}) error
  • func (c *OSSBroker) GetBindingStatus(instanceID, serviceID, planID, bindingID string, ...) (bool, error)
  • func (c *OSSBroker) GetInstanceStatus(instanceID, serviceID, planID string, parameterIn map[string]interface{}) (bool, error)
  • func (c *OSSBroker) GetServiceInstance(id string) (string, error)
  • func (c *OSSBroker) Provision(instanceID, serviceID, planID string, parameterIn map[string]interface{}) (map[string]interface{}, error)
  • func (c *OSSBroker) UnBind(instanceID, serviceID, planID, bindingID string, ...) error
• type ServicePlanMetadata
• type UserMetaData
  • func GetCloudServiceMetaData() (*UserMetaData, error)

Constants

const (
	SelfDefineServicePlan = "oss-edc2badc-d93b-4d9c-9d8e-da2f1c8c2222"
)

Functions

func CheckOssInstanceStatus

func CheckOssInstanceStatus(instanceID, region, accessKeyId, accessKeySecret string) (bool, error)

func CheckRamForInstance

func CheckRamForInstance(instanceId, region, accessKeyId, accessKeySecret string) bool

func CreateBroker

func CreateBroker() brokerapi.ServiceBroker

func CreateOssBucket

func CreateOssBucket(instanceId, region, accessKeyId, accessKeySecret, acl, storageClass string) (string, error)

func CreateRamForInstance

func CreateRamForInstance(instanceId, region, accessKeyId, accessKeySecret string) error

func CreateRamNewClient

func CreateRamNewClient(region, accessKeyId, accessKeySecret string) (*ram.Client, error)

func CreateRamUserForBinding

func CreateRamUserForBinding(bindingId, instanceID, region, accessKeyId, accessKeySecret string) (*ram.User, *ram.AccessKey, error)

func DeleteOssBucket

func DeleteOssBucket(instanceId, region, accessKeyId, accessKeySecret string) error

func DeleteRamForInstance

func DeleteRamForInstance(instanceId, region, accessKeyId, accessKeySecret string) error

func DeleteRamUserForBinding

func DeleteRamUserForBinding(bindingId, instanceID, region, userAccessKeyId, accessKeyId, accessKeySecret string) error

func GetAccessInfoFromInstanceParameters

func GetAccessInfoFromInstanceParameters(parameterIn map[string]interface{}) (
	accessKeyId, accessKeySecret, region, acl, storageClass string, err error)

func GetBucketNameForInstance

func GetBucketNameForInstance(instanceId string) string

func GetOSSEndPoint

func GetOSSEndPoint(region string) string

func GetOssRamPolicy

func GetOssRamPolicy(instanceID string) string

func GetRamUserForBinding

func GetRamUserForBinding(bindingId, instanceID, region, accessKeyId, accessKeySecret string) error

Types

type ConnectionInfo

type ConnectionInfo struct {
	ConnectionString string
	Port             string
}

type OSSBroker

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

func (*OSSBroker) Bind

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

func (*OSSBroker) Catalog

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

func (*OSSBroker) Deprovision

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

func (*OSSBroker) GetBindingStatus

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

func (*OSSBroker) GetInstanceStatus

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

func (*OSSBroker) GetServiceInstance

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

func (*OSSBroker) Provision

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

func (*OSSBroker) UnBind

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

type ServicePlanMetadata

type ServicePlanMetadata struct {
	Engine           string `json:"engine"`
	EngineVersion    string `json:"engine_version"`
	Class            string `json:"class"`
	CPU              string `json:"cpu"`
	Memory           string `json:"memory"`
	Storage          string `json:"storage"`
	HighAvailability string `json:"high_availability"`
	Type             string `json:"type"`
	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)