csibroker

package
v0.0.0-...-edc587e Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Nov 12, 2018 License: Apache-2.0 Imports: 18 Imported by: 4

Documentation

Index

Constants

View Source 
const (
	PermissionVolumeMount = brokerapi.RequiredPermission("volume_mount")
	DefaultContainerPath  = "/var/vcap/data"
)

Variables

View Source 
var ErrEmptySpecFile = errors.New("At least one service must be provided in specfile")

Functions

This section is empty.

Types

type Broker 

type Broker struct {
	// contains filtered or unexported fields
}

func New 

func New(
	logger lager.Logger,
	os osshim.Os,
	clock clock.Clock,
	store brokerstore.Store,
	servicesRegistry ServicesRegistry,
) (*Broker, error)

func (*Broker) Bind 

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

func (*Broker) Deprovision 

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

func (*Broker) LastOperation 

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

func (*Broker) Provision 

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

func (*Broker) Services 

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

func (*Broker) Unbind 

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

func (*Broker) Update 

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

type ErrInvalidService 

type ErrInvalidService struct {
	Index int
}

func (ErrInvalidService) Error 

func (e ErrInvalidService) Error() string

type ErrInvalidSpecFile 

type ErrInvalidSpecFile struct {
	// contains filtered or unexported fields
}

func (ErrInvalidSpecFile) Error 

func (e ErrInvalidSpecFile) Error() string

type ErrServiceNotFound 

type ErrServiceNotFound struct {
	ID string
}

func (ErrServiceNotFound) Error 

func (e ErrServiceNotFound) Error() string

type NoopControllerClient 

type NoopControllerClient struct{}

func (*NoopControllerClient) ControllerGetCapabilities 

func (c *NoopControllerClient) ControllerGetCapabilities(ctx context.Context, in *csi.ControllerGetCapabilitiesRequest, opts ...grpc.CallOption) (*csi.ControllerGetCapabilitiesResponse, error)

func (*NoopControllerClient) ControllerPublishVolume 

func (c *NoopControllerClient) ControllerPublishVolume(ctx context.Context, in *csi.ControllerPublishVolumeRequest, opts ...grpc.CallOption) (*csi.ControllerPublishVolumeResponse, error)

func (*NoopControllerClient) ControllerUnpublishVolume 

func (c *NoopControllerClient) ControllerUnpublishVolume(ctx context.Context, in *csi.ControllerUnpublishVolumeRequest, opts ...grpc.CallOption) (*csi.ControllerUnpublishVolumeResponse, error)

func (*NoopControllerClient) CreateSnapshot 

func (c *NoopControllerClient) CreateSnapshot(ctx context.Context, in *csi.CreateSnapshotRequest, opts ...grpc.CallOption) (*csi.CreateSnapshotResponse, error)

func (*NoopControllerClient) CreateVolume 

func (c *NoopControllerClient) CreateVolume(ctx context.Context, in *csi.CreateVolumeRequest, opts ...grpc.CallOption) (*csi.CreateVolumeResponse, error)

func (*NoopControllerClient) DeleteSnapshot 

func (c *NoopControllerClient) DeleteSnapshot(ctx context.Context, in *csi.DeleteSnapshotRequest, opts ...grpc.CallOption) (*csi.DeleteSnapshotResponse, error)

func (*NoopControllerClient) DeleteVolume 

func (c *NoopControllerClient) DeleteVolume(ctx context.Context, in *csi.DeleteVolumeRequest, opts ...grpc.CallOption) (*csi.DeleteVolumeResponse, error)

func (*NoopControllerClient) GetCapacity 

func (c *NoopControllerClient) GetCapacity(ctx context.Context, in *csi.GetCapacityRequest, opts ...grpc.CallOption) (*csi.GetCapacityResponse, error)

func (*NoopControllerClient) ListSnapshots 

func (c *NoopControllerClient) ListSnapshots(ctx context.Context, in *csi.ListSnapshotsRequest, opts ...grpc.CallOption) (*csi.ListSnapshotsResponse, error)

func (*NoopControllerClient) ListVolumes 

func (c *NoopControllerClient) ListVolumes(ctx context.Context, in *csi.ListVolumesRequest, opts ...grpc.CallOption) (*csi.ListVolumesResponse, error)

func (*NoopControllerClient) ValidateVolumeCapabilities 

func (c *NoopControllerClient) ValidateVolumeCapabilities(ctx context.Context, in *csi.ValidateVolumeCapabilitiesRequest, opts ...grpc.CallOption) (*csi.ValidateVolumeCapabilitiesResponse, error)

type NoopIdentityClient 

type NoopIdentityClient struct{}

func (*NoopIdentityClient) GetPluginCapabilities 

func (c *NoopIdentityClient) GetPluginCapabilities(ctx context.Context, in *csi.GetPluginCapabilitiesRequest, opts ...grpc.CallOption) (*csi.GetPluginCapabilitiesResponse, error)

func (*NoopIdentityClient) GetPluginInfo 

func (c *NoopIdentityClient) GetPluginInfo(ctx context.Context, in *csi.GetPluginInfoRequest, opts ...grpc.CallOption) (*csi.GetPluginInfoResponse, error)

func (*NoopIdentityClient) Probe 

func (c *NoopIdentityClient) Probe(ctx context.Context, in *csi.ProbeRequest, opts ...grpc.CallOption) (*csi.ProbeResponse, error)

type Service 

type Service struct {
	DriverName string `json:"driver_name"`
	ConnAddr   string `json:"connection_address"`

	brokerapi.Service
}

type ServiceFingerPrint 

type ServiceFingerPrint struct {
	Name   string
	Volume *csi.Volume
}

type ServicesRegistry 

type ServicesRegistry interface {
	IdentityClient(serviceID string) (csi.IdentityClient, error)
	ControllerClient(serviceID string) (csi.ControllerClient, error)
	BrokerServices() []brokerapi.Service
	DriverName(serviceID string) (string, error)
}

func NewServicesRegistry 

func NewServicesRegistry(
	csiShim csishim.Csi,
	grpcShim grpcshim.Grpc,
	serviceSpecPath string,
	logger lager.Logger,
) (ServicesRegistry, error)

Source Files

View all Source files

Directories

Path Synopsis
Code generated by counterfeiter.
 Code generated by counterfeiter.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.