helpers

package
v0.36.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 31, 2019 License: Apache-2.0 Imports: 17 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func BodyBytes 

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

func CleanUpParameterGroups added in v0.27.0 

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

func CleanUpTestDatabaseInstances added in v0.27.0 

func CleanUpTestDatabaseInstances(prefix string, awsSession *session.Session) error

func CreateSecurityGroup 

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

func CreateSubnetGroup 

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

func DestroySecurityGroup 

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

func DestroySubnetGroup 

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

Types

type BrokerAPIClient 

type BrokerAPIClient struct {
	Url               string
	Username          string
	Password          string
	AcceptsIncomplete bool
}

func NewBrokerAPIClient 

func NewBrokerAPIClient(Url string, Username string, Password string) *BrokerAPIClient

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) 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 string, newPlanID string, 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) ProvisionInstance 

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

func (*BrokerAPIClient) UpdateInstance 

func (b *BrokerAPIClient) UpdateInstance(instanceID, serviceID, planID string, newPlanID string, paramJSON string) (responseCode int, operation 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 CleanFunc added in v0.22.0 

type CleanFunc func()

type LastOperationResponse 

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

type ProvisionFunc added in v0.22.0 

type ProvisionFunc func() (WaitFunc, CleanFunc)

type ProvisionManager added in v0.22.0 

type ProvisionManager struct {
	Provisioner ProvisionFunc
	// contains filtered or unexported fields
}

ProvisionManager performs the provisioning. It gets a Provisioner function that should do the creationg and returns:

  • a function that would synchronously wait for the thing to finish
  • a function that would clean up whatever is created

It allows to optionally wait for the creation to finish or cleanup only once.

func (*ProvisionManager) CleanUp added in v0.22.0 

func (p *ProvisionManager) CleanUp()

func (*ProvisionManager) Provision added in v0.22.0 

func (p *ProvisionManager) Provision()

func (*ProvisionManager) Wait added in v0.22.0 

func (p *ProvisionManager) Wait()

type ProvisioningResponse 

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

type RDSClient 

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

func NewRDSClient 

func NewRDSClient(region string, dbPrefix string) (*RDSClient, error)

func (*RDSClient) CreateDBSnapshot added in v0.22.0 

func (r *RDSClient) CreateDBSnapshot(ID string) (string, error)

func (*RDSClient) DBInstanceFinalSnapshotIdentifier added in v0.22.0 

func (b *RDSClient) DBInstanceFinalSnapshotIdentifier(instanceID string) string

func (*RDSClient) DeleteDBSnapshot added in v0.22.0 

func (r *RDSClient) DeleteDBSnapshot(snapshotID string) (*rds.DeleteDBSnapshotOutput, error)

func (*RDSClient) GetDBInstanceDetails added in v0.20.0 

func (r *RDSClient) GetDBInstanceDetails(ID string) (*rds.DescribeDBInstancesOutput, error)

func (*RDSClient) GetDBSnapshot added in v0.22.0 

func (r *RDSClient) GetDBSnapshot(snapshotID string) (*rds.DescribeDBSnapshotsOutput, error)

func (*RDSClient) Ping 

func (r *RDSClient) Ping() (bool, error)

type WaitFunc added in v0.22.0 

type WaitFunc func()

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.