broker

Documentation

Index

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

Types

type KubeVolumeBroker

type KubeVolumeBroker struct {
	KubeClient kubernetes.Interface
	Config     config.Config
	Context    context.Context
}

KubeVolumeBroker is a broker for Kubernetes Volumes

func (*KubeVolumeBroker) Bind

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

Bind adds an annotation to the service instance PVC

func (*KubeVolumeBroker) Deprovision

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

Deprovision deletes a Kubernetes PVC

func (*KubeVolumeBroker) GetBinding

func (b *KubeVolumeBroker) GetBinding(ctx context.Context, instanceID, bindingID string) (brokerapi.GetBindingSpec, error)

GetBinding finds the correct PVC and its binding annotation and reconstructs a binding spec

func (*KubeVolumeBroker) GetInstance

func (b *KubeVolumeBroker) GetInstance(ctx context.Context, instanceID string) (brokerapi.GetInstanceDetailsSpec, error)

GetInstance finds the correct PVC and reconstructs an instance spec

func (*KubeVolumeBroker) LastBindingOperation

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

LastBindingOperation is currently a noop

func (*KubeVolumeBroker) LastOperation

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

LastOperation is currently a noop

func (*KubeVolumeBroker) Provision

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

Provision creates a Kubernetes PVC

func (*KubeVolumeBroker) Services

func (b *KubeVolumeBroker) Services(ctx context.Context) ([]brokerapi.Service, error)

Services returns a list with one item, the service for provisioning kubernetes volumes

func (*KubeVolumeBroker) Unbind

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

Unbind removes the binding annotation from the appropriate PVC

func (*KubeVolumeBroker) Update

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

Update is currently a noop