broker

Documentation

Index

• type CloudServiceBroker
  • func New(logger lager.Logger, config config.Config) (*CloudServiceBroker, error)
  • func (cloudBroker *CloudServiceBroker) Bind(ctx context.Context, instanceID string, bindingID string, ...) (brokerapi.Binding, error)
  • func (cloudBroker *CloudServiceBroker) Deprovision(ctx context.Context, instanceID string, details brokerapi.DeprovisionDetails, ...) (brokerapi.DeprovisionServiceSpec, error)
  • func (cloudBroker *CloudServiceBroker) LastOperation(ctx context.Context, instanceID string, operationData string) (brokerapi.LastOperation, error)
  • func (cloudBroker *CloudServiceBroker) Provision(ctx context.Context, instanceID string, details brokerapi.ProvisionDetails, ...) (brokerapi.ProvisionedServiceSpec, error)
  • func (cloudBroker *CloudServiceBroker) Services(ctx context.Context) ([]brokerapi.Service, error)
  • func (cloudBroker *CloudServiceBroker) Unbind(ctx context.Context, instanceID string, bindingID string, ...) error
  • func (cloudBroker *CloudServiceBroker) Update(ctx context.Context, instanceID string, details brokerapi.UpdateDetails, ...) (brokerapi.UpdateServiceSpec, error)

Types

type CloudServiceBroker

type CloudServiceBroker struct {
	CloudCredentials config.CloudCredentials
	Catalog          config.Catalog
	ServiceBrokerMap map[string]models.ServiceBrokerProxy
	Logger           lager.Logger
}

CloudServiceBroker define

func New

func New(logger lager.Logger, config config.Config) (*CloudServiceBroker, error)

New returns a composed service broker object

func (*CloudServiceBroker) Bind

func (cloudBroker *CloudServiceBroker) Bind(
	ctx context.Context,
	instanceID string,
	bindingID string,
	details brokerapi.BindDetails) (brokerapi.Binding, error)

Bind adds and returns the associated credentials

func (*CloudServiceBroker) Deprovision

func (cloudBroker *CloudServiceBroker) Deprovision(
	ctx context.Context,
	instanceID string,
	details brokerapi.DeprovisionDetails,
	asyncAllowed bool) (brokerapi.DeprovisionServiceSpec, error)

Deprovision deletes the given instance

func (*CloudServiceBroker) LastOperation

func (cloudBroker *CloudServiceBroker) LastOperation(
	ctx context.Context,
	instanceID string,
	operationData string) (brokerapi.LastOperation, error)

LastOperation is called until the attempt times out or success or failure is returned if a service is provisioned or deprovision or update asynchronously

func (*CloudServiceBroker) Provision

func (cloudBroker *CloudServiceBroker) Provision(
	ctx context.Context,
	instanceID string,
	details brokerapi.ProvisionDetails,
	asyncAllowed bool) (brokerapi.ProvisionedServiceSpec, error)

Provision creates a service instance

func (*CloudServiceBroker) Services

func (cloudBroker *CloudServiceBroker) Services(
	ctx context.Context) ([]brokerapi.Service, error)

Services lists services in this cloud broker

func (*CloudServiceBroker) Unbind

func (cloudBroker *CloudServiceBroker) Unbind(
	ctx context.Context,
	instanceID string,
	bindingID string,
	details brokerapi.UnbindDetails) error

Unbind removes the associated credentials

func (*CloudServiceBroker) Update

func (cloudBroker *CloudServiceBroker) Update(
	ctx context.Context,
	instanceID string,
	details brokerapi.UpdateDetails,
	asyncAllowed bool) (brokerapi.UpdateServiceSpec, error)

Update updates the given instance