broker

package

v0.0.0-...-0c241e7 Latest Latest Go to latest Published: Sep 2, 2020 License: Apache-2.0 Imports: 12 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/cloudfoundry-incubator/eirini-persi-broker

Links

Open Source Insights

Documentation ¶

Index ¶

type KubeVolumeBroker

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

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

Source Files ¶

View all Source files

broker.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL