helpers

Documentation

Index

• func BodyBytes(resp *http.Response) ([]byte, error)
• func CreateSecurityGroup(prefix string, session *session.Session) (*string, error)
• func CreateSubnetGroup(prefix string, session *session.Session) (*string, error)
• func DestroyParameterGroup(name *string, session *session.Session) error
• func DestroySecurityGroup(id *string, session *session.Session) error
• func DestroySubnetGroup(name *string, session *session.Session) error
• func ReplicationGroupARN(session *session.Session, replicationGroupID string) (string, error)
• func WriteCustomConfig(config broker.Config, brokerName string, elastiCacheSubnetGroupName string, ...) (broker.Config, string, error)
• type BindingResponse
• type BrokerAPIClient
  • func NewBrokerAPIClient(url string, username string, password string, defaultOrganizationID string, ...) *BrokerAPIClient
  • func (b *BrokerAPIClient) Bind(instanceID, serviceID, planID, appGUID, bindingID string) (int, *BindingResponse, error)
  • func (b *BrokerAPIClient) DeprovisionInstance(instanceID, serviceID, planID string) (responseCode int, operation string, err error)
  • func (b *BrokerAPIClient) DoBindRequest(instanceID, serviceID, planID, appGUID, bindingID string) (*http.Response, error)
  • func (b *BrokerAPIClient) DoDeprovisionRequest(instanceID, serviceID, planID string) (*http.Response, error)
  • func (b *BrokerAPIClient) DoGetInstanceRequest(instanceID string) (*http.Response, error)
  • func (b *BrokerAPIClient) DoLastOperationRequest(instanceID, serviceID, planID, operation string) (*http.Response, error)
  • func (b *BrokerAPIClient) DoProvisionRequest(instanceID, serviceID, planID string, paramJSON string) (*http.Response, error)
  • func (b *BrokerAPIClient) DoUnbindRequest(instanceID, serviceID, planID, bindingID string) (*http.Response, error)
  • func (b *BrokerAPIClient) DoUpdateRequest(...) (*http.Response, error)
  • func (b *BrokerAPIClient) GetCatalog() (brokerapi.CatalogResponse, error)
  • func (b *BrokerAPIClient) GetLastOperationState(instanceID, serviceID, planID, operation string) (string, error)
  • func (b *BrokerAPIClient) GetServiceParams(instanceID string) (serviceParams providers.InstanceParameters, err error)
  • func (b *BrokerAPIClient) ProvisionInstance(instanceID, serviceID, planID string, paramJSON string) (responseCode int, operation string, err error)
  • func (b *BrokerAPIClient) Unbind(instanceID, serviceID, planID, bindingID string) (int, error)
  • func (b *BrokerAPIClient) UpdateInstance(...) (responseCode int, operation string, responseBody string, err error)
• type ByServiceID
  • func (a ByServiceID) Len() int
  • func (a ByServiceID) Less(i, j int) bool
  • func (a ByServiceID) Swap(i, j int)
• type LastOperationResponse
• type ProvisioningResponse

Functions

func BodyBytes

func BodyBytes(resp *http.Response) ([]byte, error)

func CreateSecurityGroup

func CreateSecurityGroup(prefix string, session *session.Session) (*string, error)

func CreateSubnetGroup

func CreateSubnetGroup(prefix string, session *session.Session) (*string, error)

func DestroyParameterGroup

func DestroyParameterGroup(name *string, session *session.Session) error

func DestroySecurityGroup

func DestroySecurityGroup(id *string, session *session.Session) error

func DestroySubnetGroup

func DestroySubnetGroup(name *string, session *session.Session) error

func ReplicationGroupARN

func ReplicationGroupARN(session *session.Session, replicationGroupID string) (string, error)

func WriteCustomConfig

func WriteCustomConfig(
	config broker.Config,
	brokerName string,
	elastiCacheSubnetGroupName string,
	ec2SecurityGroupID string,
) (broker.Config, string, error)

Types

type BindingResponse

type BindingResponse struct {
	Credentials map[string]interface{} `json:"credentials,omitempty"`
}

type BrokerAPIClient

type BrokerAPIClient struct {
	URL                   string
	Username              string
	Password              string
	DefaultOrganizationID string
	DefaultSpaceID        string
	AcceptsIncomplete     bool
	CaPEM                 []byte
}

func NewBrokerAPIClient

func NewBrokerAPIClient(url string, username string, password string, defaultOrganizationID string, defaultSpaceID string, caPEM []byte) *BrokerAPIClient

func (*BrokerAPIClient) Bind

func (b *BrokerAPIClient) Bind(instanceID, serviceID, planID, appGUID, bindingID string) (int, *BindingResponse, error)

func (*BrokerAPIClient) DeprovisionInstance

func (b *BrokerAPIClient) DeprovisionInstance(instanceID, serviceID, planID string) (responseCode int, operation string, err error)

func (*BrokerAPIClient) DoBindRequest

func (b *BrokerAPIClient) DoBindRequest(instanceID, serviceID, planID, appGUID, bindingID string) (*http.Response, error)

func (*BrokerAPIClient) DoDeprovisionRequest

func (b *BrokerAPIClient) DoDeprovisionRequest(instanceID, serviceID, planID string) (*http.Response, error)

func (*BrokerAPIClient) DoGetInstanceRequest

func (b *BrokerAPIClient) DoGetInstanceRequest(instanceID string) (*http.Response, error)

func (*BrokerAPIClient) DoLastOperationRequest

func (b *BrokerAPIClient) DoLastOperationRequest(instanceID, serviceID, planID, operation string) (*http.Response, error)

func (*BrokerAPIClient) DoProvisionRequest

func (b *BrokerAPIClient) DoProvisionRequest(instanceID, serviceID, planID string, paramJSON string) (*http.Response, error)

func (*BrokerAPIClient) DoUnbindRequest

func (b *BrokerAPIClient) DoUnbindRequest(instanceID, serviceID, planID, bindingID string) (*http.Response, error)

func (*BrokerAPIClient) DoUpdateRequest

func (b *BrokerAPIClient) DoUpdateRequest(instanceID, serviceID, planID, oldPlanID, oldServiceID, orgID, spaceID, paramJSON string) (*http.Response, error)

func (*BrokerAPIClient) GetCatalog

func (b *BrokerAPIClient) GetCatalog() (brokerapi.CatalogResponse, error)

func (*BrokerAPIClient) GetLastOperationState

func (b *BrokerAPIClient) GetLastOperationState(instanceID, serviceID, planID, operation string) (string, error)

func (*BrokerAPIClient) GetServiceParams

func (b *BrokerAPIClient) GetServiceParams(instanceID string) (serviceParams providers.InstanceParameters, err error)

func (*BrokerAPIClient) ProvisionInstance

func (b *BrokerAPIClient) ProvisionInstance(instanceID, serviceID, planID string, paramJSON string) (responseCode int, operation string, err error)

func (*BrokerAPIClient) Unbind

func (b *BrokerAPIClient) Unbind(instanceID, serviceID, planID, bindingID string) (int, error)

func (*BrokerAPIClient) UpdateInstance

func (b *BrokerAPIClient) UpdateInstance(instanceID, serviceID, planID, oldPlanID, oldServiceID, orgID, spaceID, paramJSON string) (responseCode int, operation string, responseBody string, err error)

type ByServiceID

type ByServiceID []brokerapi.Service

func (ByServiceID) Len

func (a ByServiceID) Len() int

func (ByServiceID) Less

func (a ByServiceID) Less(i, j int) bool

func (ByServiceID) Swap

func (a ByServiceID) Swap(i, j int)

type LastOperationResponse

type LastOperationResponse struct {
	State       string `json:"state,omitempty"`
	Description string `json:"description,omitempty"`
}

type ProvisioningResponse

type ProvisioningResponse struct {
	DashboardURL string `json:"dashboard_url,omitempty"`
	Operation    string `json:"operation,omitempty"`
}