broker

Documentation

Index

• Constants
• func MakeInstanceName(dbPrefix, instanceID string) (string, error)
• type Broker
  • func New(composeClient compose.Client, dbEngineProvider dbengine.Provider, ...) (*Broker, error)
  • func (b *Broker) Bind(context context.Context, instanceID, bindingID string, ...) (brokerapi.Binding, error)
  • func (b *Broker) Deprovision(context context.Context, instanceID string, ...) (brokerapi.DeprovisionServiceSpec, error)
  • func (b *Broker) LastOperation(context context.Context, instanceID, operationDataJson string) (brokerapi.LastOperation, error)
  • func (b *Broker) Provision(context context.Context, instanceID string, details brokerapi.ProvisionDetails, ...) (brokerapi.ProvisionedServiceSpec, error)
  • func (b *Broker) Services(context context.Context) []brokerapi.Service
  • func (b *Broker) Unbind(context context.Context, instanceID, bindingID string, ...) error
  • func (b *Broker) Update(context context.Context, instanceID string, details brokerapi.UpdateDetails, ...) (brokerapi.UpdateServiceSpec, error)
• type OperationData
• type ProvisionParameters
  • func ParseProvisionParameters(data []byte) (*ProvisionParameters, error)

Constants

const (
	ComposeDatacenter = "aws:eu-west-1"
)

Functions

func MakeInstanceName

func MakeInstanceName(dbPrefix, instanceID string) (string, error)

Types

type Broker

type Broker struct {
	Compose          compose.Client
	Config           *config.Config
	Catalog          *catalog.Catalog
	Logger           lager.Logger
	AccountID        string
	ClusterID        string
	DBEngineProvider dbengine.Provider
}

func New

func New(composeClient compose.Client, dbEngineProvider dbengine.Provider, config *config.Config, catalog *catalog.Catalog, logger lager.Logger) (*Broker, error)

func (*Broker) Bind

func (b *Broker) Bind(context context.Context, instanceID, bindingID string, details brokerapi.BindDetails) (brokerapi.Binding, error)

func (*Broker) Deprovision

func (b *Broker) Deprovision(context context.Context, instanceID string, details brokerapi.DeprovisionDetails, asyncAllowed bool) (brokerapi.DeprovisionServiceSpec, error)

func (*Broker) LastOperation

func (b *Broker) LastOperation(context context.Context, instanceID, operationDataJson string) (brokerapi.LastOperation, error)

func (*Broker) Provision

func (b *Broker) Provision(context context.Context, instanceID string, details brokerapi.ProvisionDetails, asyncAllowed bool) (brokerapi.ProvisionedServiceSpec, error)

func (*Broker) Services

func (b *Broker) Services(context context.Context) []brokerapi.Service

func (*Broker) Unbind

func (b *Broker) Unbind(context context.Context, instanceID, bindingID string, details brokerapi.UnbindDetails) error

func (*Broker) Update

func (b *Broker) Update(context context.Context, instanceID string, details brokerapi.UpdateDetails, asyncAllowed bool) (brokerapi.UpdateServiceSpec, error)

type OperationData

type OperationData struct {
	Type               string   `json:"type"`
	RecipeID           string   `json:"recipe_id"`
	WhitelistRecipeIDs []string `json:"whitelist_recipe_ids"`
}

type ProvisionParameters

type ProvisionParameters struct {
	RestoreFromLatestSnapshotOf *string `json:"restore_from_latest_snapshot_of"`
}

func ParseProvisionParameters

func ParseProvisionParameters(data []byte) (*ProvisionParameters, error)