broker

Documentation

Index

• Constants
• type InstanceBinder
• type InstanceCreator
• type InstanceCredentials
• type RedisServiceBroker
  • func (redisServiceBroker *RedisServiceBroker) Bind(ctx context.Context, instanceID, bindingID string, ...) (brokerapi.Binding, error)
  • func (redisServiceBroker *RedisServiceBroker) Deprovision(ctx context.Context, instanceID string, details brokerapi.DeprovisionDetails, ...) (brokerapi.DeprovisionServiceSpec, error)
  • func (redisServiceBroker *RedisServiceBroker) GetBinding(ctx context.Context, instanceID string, bindingID string, ...) (brokerapi.GetBindingSpec, error)
  • func (redisServiceBroker *RedisServiceBroker) GetInstance(ctx context.Context, instanceID string, details brokerapi.FetchInstanceDetails) (brokerapi.GetInstanceDetailsSpec, error)
  • func (redisServiceBroker *RedisServiceBroker) LastBindingOperation(ctx context.Context, instanceID, bindingID string, ...) (brokerapi.LastOperation, error)
  • func (redisServiceBroker *RedisServiceBroker) LastOperation(ctx context.Context, instanceID string, details brokerapi.PollDetails) (brokerapi.LastOperation, error)
  • func (redisServiceBroker *RedisServiceBroker) Provision(ctx context.Context, instanceID string, ...) (spec brokerapi.ProvisionedServiceSpec, err error)
  • func (redisServiceBroker *RedisServiceBroker) Services(ctx context.Context) ([]brokerapi.Service, error)
  • func (redisServiceBroker *RedisServiceBroker) Unbind(ctx context.Context, instanceID, bindingID string, ...) (brokerapi.UnbindSpec, error)
  • func (redisServiceBroker *RedisServiceBroker) Update(cxt context.Context, instanceID string, details brokerapi.UpdateDetails, ...) (brokerapi.UpdateServiceSpec, error)

Constants

const (
	PlanNameShared = "shared-vm"
)

Types

type InstanceBinder

type InstanceBinder interface {
	Bind(instanceID string, bindingID string) (InstanceCredentials, error)
	Unbind(instanceID string, bindingID string) error
	InstanceExists(instanceID string) (bool, error)
}

type InstanceCreator

type InstanceCreator interface {
	Create(instanceID string) error
	Destroy(instanceID string) error
	InstanceExists(instanceID string) (bool, error)
}

type InstanceCredentials

type InstanceCredentials struct {
	Host     string
	Port     int
	Password string
}

type RedisServiceBroker

type RedisServiceBroker struct {
	InstanceCreators map[string]InstanceCreator
	InstanceBinders  map[string]InstanceBinder
	Config           brokerconfig.Config
}

func (*RedisServiceBroker) Bind

func (redisServiceBroker *RedisServiceBroker) Bind(ctx context.Context, instanceID, bindingID string, details brokerapi.BindDetails, asyncAllowed bool) (brokerapi.Binding, error)

func (*RedisServiceBroker) Deprovision

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

func (*RedisServiceBroker) GetBinding

func (redisServiceBroker *RedisServiceBroker) GetBinding(ctx context.Context, instanceID string, bindingID string, details brokerapi.FetchBindingDetails) (brokerapi.GetBindingSpec, error)

func (*RedisServiceBroker) GetInstance

func (redisServiceBroker *RedisServiceBroker) GetInstance(ctx context.Context, instanceID string, details brokerapi.FetchInstanceDetails) (brokerapi.GetInstanceDetailsSpec, error)

func (*RedisServiceBroker) LastBindingOperation

func (redisServiceBroker *RedisServiceBroker) LastBindingOperation(ctx context.Context, instanceID, bindingID string, details brokerapi.PollDetails) (brokerapi.LastOperation, error)

func (*RedisServiceBroker) LastOperation

func (redisServiceBroker *RedisServiceBroker) LastOperation(ctx context.Context, instanceID string, details brokerapi.PollDetails) (brokerapi.LastOperation, error)

LastOperation ... If the broker provisions asynchronously, the Cloud Controller will poll this endpoint for the status of the provisioning operation.

func (*RedisServiceBroker) Provision

func (redisServiceBroker *RedisServiceBroker) Provision(ctx context.Context, instanceID string, serviceDetails brokerapi.ProvisionDetails, asyncAllowed bool) (spec brokerapi.ProvisionedServiceSpec, err error)

Provision ...

func (*RedisServiceBroker) Services

func (redisServiceBroker *RedisServiceBroker) Services(ctx context.Context) ([]brokerapi.Service, error)

func (*RedisServiceBroker) Unbind

func (redisServiceBroker *RedisServiceBroker) Unbind(ctx context.Context, instanceID, bindingID string, details brokerapi.UnbindDetails, asyncAllowed bool) (brokerapi.UnbindSpec, error)

func (*RedisServiceBroker) Update

func (redisServiceBroker *RedisServiceBroker) Update(cxt context.Context, instanceID string, details brokerapi.UpdateDetails, asyncAllowed bool) (brokerapi.UpdateServiceSpec, error)