broker

Documentation

Index

• type Broker
  • func (b *Broker) Bind(request *osb.BindRequest, c *broker.RequestContext) (*broker.BindResponse, error)
  • func (b *Broker) Deprovision(request *osb.DeprovisionRequest, c *broker.RequestContext) (*broker.DeprovisionResponse, error)
  • func (b *Broker) GetCatalog(c *broker.RequestContext) (*broker.CatalogResponse, error)
  • func (b *Broker) LastOperation(request *osb.LastOperationRequest, c *broker.RequestContext) (*broker.LastOperationResponse, error)
  • func (b *Broker) Provision(request *osb.ProvisionRequest, c *broker.RequestContext) (*broker.ProvisionResponse, error)
  • func (b *Broker) Unbind(request *osb.UnbindRequest, c *broker.RequestContext) (*broker.UnbindResponse, error)
  • func (b *Broker) Update(request *osb.UpdateInstanceRequest, c *broker.RequestContext) (*broker.UpdateInstanceResponse, error)
  • func (b *Broker) ValidateBrokerAPIVersion(version string) error
• type Config
  • func NewConfig(clientConfig *rest.Config) *Config
  • func (c *Config) New() (*Broker, error)

Types

type Broker

type Broker struct {

	// Synchronize go routines.
	sync.RWMutex
	// contains filtered or unexported fields
}

Broker provides an implementation of broker.Interface

func (*Broker) Bind

func (b *Broker) Bind(request *osb.BindRequest, c *broker.RequestContext) (*broker.BindResponse, error)

func (*Broker) Deprovision

func (b *Broker) Deprovision(request *osb.DeprovisionRequest, c *broker.RequestContext) (*broker.DeprovisionResponse, error)

func (*Broker) GetCatalog

func (b *Broker) GetCatalog(c *broker.RequestContext) (*broker.CatalogResponse, error)

func (*Broker) LastOperation

func (b *Broker) LastOperation(request *osb.LastOperationRequest, c *broker.RequestContext) (*broker.LastOperationResponse, error)

func (*Broker) Provision

func (b *Broker) Provision(request *osb.ProvisionRequest, c *broker.RequestContext) (*broker.ProvisionResponse, error)

func (*Broker) Unbind

func (b *Broker) Unbind(request *osb.UnbindRequest, c *broker.RequestContext) (*broker.UnbindResponse, error)

func (*Broker) Update

func (b *Broker) Update(request *osb.UpdateInstanceRequest, c *broker.RequestContext) (*broker.UpdateInstanceResponse, error)

func (*Broker) ValidateBrokerAPIVersion

func (b *Broker) ValidateBrokerAPIVersion(version string) error

type Config

type Config struct {
	ClientConfig *rest.Config
	DBClient     *dbsvc.Client
	SvcCatClient svcat_cs.ServicecatalogV1beta1Interface
	// contains filtered or unexported fields
}

func NewConfig

func NewConfig(clientConfig *rest.Config) *Config

func (*Config) New

func (c *Config) New() (*Broker, error)