csi

package
v0.1.0 Latest Latest
Warning

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

 Go to latest Published: Sep 10, 2017 License: Apache-2.0 Imports: 5 Imported by: 0

README

CSI Language Bindings for Go

This package contains the CSI language bindings for Go, generated using the protobuf compiler protoc. GoCSI references the CSI spec project in order to obtain the CSI specification.

Updating the Specification Version

In order to update the CSI specification version used by GoCSI, please follow the steps below starting from the root of the GoCSI project:

  1. Update Gopkg.toml with the desired CSI specification version.
  2. Run dep ensure to update the vendored dependencies. This requires the official Go dependency manager, Dep.
  3. Run make test to update the generated protobuf source and execute the test suite using the Mock plug-in.

If all of the above steps complete without error then commit and push the changes and use GitHub to create a pull request.

Documentation

Overview

Package csi is a generated protocol buffer package.

It is generated from these files: 

csi.proto

It has these top-level messages: 

GetSupportedVersionsRequest
GetSupportedVersionsResponse
Version
GetPluginInfoRequest
GetPluginInfoResponse
CreateVolumeRequest
CreateVolumeResponse
VolumeCapability
CapacityRange
VolumeInfo
VolumeID
VolumeMetadata
Credentials
DeleteVolumeRequest
DeleteVolumeResponse
ControllerPublishVolumeRequest
ControllerPublishVolumeResponse
NodeID
PublishVolumeInfo
ControllerUnpublishVolumeRequest
ControllerUnpublishVolumeResponse
ValidateVolumeCapabilitiesRequest
ValidateVolumeCapabilitiesResponse
ListVolumesRequest
ListVolumesResponse
GetCapacityRequest
GetCapacityResponse
ControllerGetCapabilitiesRequest
ControllerGetCapabilitiesResponse
ControllerServiceCapability
NodePublishVolumeRequest
NodePublishVolumeResponse
NodeUnpublishVolumeRequest
NodeUnpublishVolumeResponse
GetNodeIDRequest
GetNodeIDResponse
ProbeNodeRequest
ProbeNodeResponse
NodeGetCapabilitiesRequest
NodeGetCapabilitiesResponse
NodeServiceCapability
Error

Index

Constants

This section is empty.

Variables

View Source 
var ControllerServiceCapability_RPC_Type_name = map[int32]string{
	0: "UNKNOWN",
	1: "CREATE_DELETE_VOLUME",
	2: "PUBLISH_UNPUBLISH_VOLUME",
	3: "LIST_VOLUMES",
	4: "GET_CAPACITY",
}
View Source 
var ControllerServiceCapability_RPC_Type_value = map[string]int32{
	"UNKNOWN":                  0,
	"CREATE_DELETE_VOLUME":     1,
	"PUBLISH_UNPUBLISH_VOLUME": 2,
	"LIST_VOLUMES":             3,
	"GET_CAPACITY":             4,
}
View Source 
var Error_ControllerPublishVolumeError_ControllerPublishVolumeErrorCode_name = map[int32]string{
	0:  "UNKNOWN",
	1:  "CALL_NOT_IMPLEMENTED",
	2:  "OPERATION_PENDING_FOR_VOLUME",
	3:  "INVALID_VOLUME_ID",
	4:  "INVALID_VOLUME_METADATA",
	5:  "VOLUME_DOES_NOT_EXIST",
	6:  "VOLUME_ALREADY_PUBLISHED",
	7:  "NODE_DOES_NOT_EXIST",
	8:  "MAX_ATTACHED_NODES",
	10: "UNSUPPORTED_MOUNT_FLAGS",
	11: "UNSUPPORTED_VOLUME_TYPE",
	12: "UNSUPPORTED_FS_TYPE",
	9:  "INVALID_NODE_ID",
}
View Source 
var Error_ControllerPublishVolumeError_ControllerPublishVolumeErrorCode_value = map[string]int32{
	"UNKNOWN":                      0,
	"CALL_NOT_IMPLEMENTED":         1,
	"OPERATION_PENDING_FOR_VOLUME": 2,
	"INVALID_VOLUME_ID":            3,
	"INVALID_VOLUME_METADATA":      4,
	"VOLUME_DOES_NOT_EXIST":        5,
	"VOLUME_ALREADY_PUBLISHED":     6,
	"NODE_DOES_NOT_EXIST":          7,
	"MAX_ATTACHED_NODES":           8,
	"UNSUPPORTED_MOUNT_FLAGS":      10,
	"UNSUPPORTED_VOLUME_TYPE":      11,
	"UNSUPPORTED_FS_TYPE":          12,
	"INVALID_NODE_ID":              9,
}
View Source 
var Error_ControllerUnpublishVolumeError_ControllerUnpublishVolumeErrorCode_name = map[int32]string{
	0: "UNKNOWN",
	1: "CALL_NOT_IMPLEMENTED",
	2: "OPERATION_PENDING_FOR_VOLUME",
	3: "INVALID_VOLUME_ID",
	4: "INVALID_VOLUME_METADATA",
	5: "VOLUME_DOES_NOT_EXIST",
	6: "NODE_DOES_NOT_EXIST",
	7: "INVALID_NODE_ID",
	8: "VOLUME_NOT_ATTACHED_TO_SPECIFIED_NODE",
	9: "NODE_ID_REQUIRED",
}
View Source 
var Error_ControllerUnpublishVolumeError_ControllerUnpublishVolumeErrorCode_value = map[string]int32{
	"UNKNOWN":                               0,
	"CALL_NOT_IMPLEMENTED":                  1,
	"OPERATION_PENDING_FOR_VOLUME":          2,
	"INVALID_VOLUME_ID":                     3,
	"INVALID_VOLUME_METADATA":               4,
	"VOLUME_DOES_NOT_EXIST":                 5,
	"NODE_DOES_NOT_EXIST":                   6,
	"INVALID_NODE_ID":                       7,
	"VOLUME_NOT_ATTACHED_TO_SPECIFIED_NODE": 8,
	"NODE_ID_REQUIRED":                      9,
}
View Source 
var Error_CreateVolumeError_CreateVolumeErrorCode_name = map[int32]string{
	0: "UNKNOWN",
	1: "CALL_NOT_IMPLEMENTED",
	2: "OPERATION_PENDING_FOR_VOLUME",
	3: "INVALID_VOLUME_NAME",
	4: "UNSUPPORTED_CAPACITY_RANGE",
	5: "VOLUME_ALREADY_EXISTS",
	6: "UNSUPPORTED_PARAMETER_KEY",
	7: "INVALID_PARAMETER_VALUE",
}
View Source 
var Error_CreateVolumeError_CreateVolumeErrorCode_value = map[string]int32{
	"UNKNOWN":                      0,
	"CALL_NOT_IMPLEMENTED":         1,
	"OPERATION_PENDING_FOR_VOLUME": 2,
	"INVALID_VOLUME_NAME":          3,
	"UNSUPPORTED_CAPACITY_RANGE":   4,
	"VOLUME_ALREADY_EXISTS":        5,
	"UNSUPPORTED_PARAMETER_KEY":    6,
	"INVALID_PARAMETER_VALUE":      7,
}
View Source 
var Error_DeleteVolumeError_DeleteVolumeErrorCode_name = map[int32]string{
	0: "UNKNOWN",
	1: "CALL_NOT_IMPLEMENTED",
	2: "OPERATION_PENDING_FOR_VOLUME",
	3: "INVALID_VOLUME_ID",
	4: "INVALID_VOLUME_METADATA",
	5: "VOLUME_DOES_NOT_EXIST",
}
View Source 
var Error_DeleteVolumeError_DeleteVolumeErrorCode_value = map[string]int32{
	"UNKNOWN":                      0,
	"CALL_NOT_IMPLEMENTED":         1,
	"OPERATION_PENDING_FOR_VOLUME": 2,
	"INVALID_VOLUME_ID":            3,
	"INVALID_VOLUME_METADATA":      4,
	"VOLUME_DOES_NOT_EXIST":        5,
}
View Source 
var Error_GeneralError_GeneralErrorCode_name = map[int32]string{
	0: "UNKNOWN",
	1: "UNDEFINED",
	2: "UNSUPPORTED_REQUEST_VERSION",
	3: "MISSING_REQUIRED_FIELD",
}
View Source 
var Error_GeneralError_GeneralErrorCode_value = map[string]int32{
	"UNKNOWN":                     0,
	"UNDEFINED":                   1,
	"UNSUPPORTED_REQUEST_VERSION": 2,
	"MISSING_REQUIRED_FIELD":      3,
}
View Source 
var Error_GetNodeIDError_GetNodeIDErrorCode_name = map[int32]string{
	0: "UNKNOWN",
	1: "BAD_PLUGIN_CONFIG",
	2: "MISSING_REQUIRED_HOST_DEPENDENCY",
}
View Source 
var Error_GetNodeIDError_GetNodeIDErrorCode_value = map[string]int32{
	"UNKNOWN":                          0,
	"BAD_PLUGIN_CONFIG":                1,
	"MISSING_REQUIRED_HOST_DEPENDENCY": 2,
}
View Source 
var Error_NodePublishVolumeError_NodePublishVolumeErrorCode_name = map[int32]string{
	0: "UNKNOWN",
	1: "OPERATION_PENDING_FOR_VOLUME",
	2: "VOLUME_DOES_NOT_EXIST",
	3: "UNSUPPORTED_MOUNT_FLAGS",
	4: "UNSUPPORTED_VOLUME_TYPE",
	5: "UNSUPPORTED_FS_TYPE",
	6: "MOUNT_ERROR",
	7: "INVALID_VOLUME_ID",
}
View Source 
var Error_NodePublishVolumeError_NodePublishVolumeErrorCode_value = map[string]int32{
	"UNKNOWN":                      0,
	"OPERATION_PENDING_FOR_VOLUME": 1,
	"VOLUME_DOES_NOT_EXIST":        2,
	"UNSUPPORTED_MOUNT_FLAGS":      3,
	"UNSUPPORTED_VOLUME_TYPE":      4,
	"UNSUPPORTED_FS_TYPE":          5,
	"MOUNT_ERROR":                  6,
	"INVALID_VOLUME_ID":            7,
}
View Source 
var Error_NodeUnpublishVolumeError_NodeUnpublishVolumeErrorCode_name = map[int32]string{
	0: "UNKNOWN",
	1: "OPERATION_PENDING_FOR_VOLUME",
	2: "VOLUME_DOES_NOT_EXIST",
	3: "UNMOUNT_ERROR",
	4: "INVALID_VOLUME_ID",
}
View Source 
var Error_NodeUnpublishVolumeError_NodeUnpublishVolumeErrorCode_value = map[string]int32{
	"UNKNOWN":                      0,
	"OPERATION_PENDING_FOR_VOLUME": 1,
	"VOLUME_DOES_NOT_EXIST":        2,
	"UNMOUNT_ERROR":                3,
	"INVALID_VOLUME_ID":            4,
}
View Source 
var Error_ProbeNodeError_ProbeNodeErrorCode_name = map[int32]string{
	0: "UNKNOWN",
	1: "BAD_PLUGIN_CONFIG",
	2: "MISSING_REQUIRED_HOST_DEPENDENCY",
}
View Source 
var Error_ProbeNodeError_ProbeNodeErrorCode_value = map[string]int32{
	"UNKNOWN":                          0,
	"BAD_PLUGIN_CONFIG":                1,
	"MISSING_REQUIRED_HOST_DEPENDENCY": 2,
}
View Source 
var Error_ValidateVolumeCapabilitiesError_ValidateVolumeCapabilitiesErrorCode_name = map[int32]string{
	0: "UNKNOWN",
	1: "VOLUME_DOES_NOT_EXIST",
	2: "UNSUPPORTED_MOUNT_FLAGS",
	3: "UNSUPPORTED_VOLUME_TYPE",
	4: "UNSUPPORTED_FS_TYPE",
	5: "INVALID_VOLUME_INFO",
}
View Source 
var Error_ValidateVolumeCapabilitiesError_ValidateVolumeCapabilitiesErrorCode_value = map[string]int32{
	"UNKNOWN":                 0,
	"VOLUME_DOES_NOT_EXIST":   1,
	"UNSUPPORTED_MOUNT_FLAGS": 2,
	"UNSUPPORTED_VOLUME_TYPE": 3,
	"UNSUPPORTED_FS_TYPE":     4,
	"INVALID_VOLUME_INFO":     5,
}
View Source 
var NodeServiceCapability_RPC_Type_name = map[int32]string{
	0: "UNKNOWN",
}
View Source 
var NodeServiceCapability_RPC_Type_value = map[string]int32{
	"UNKNOWN": 0,
}
View Source 
var VolumeCapability_AccessMode_Mode_name = map[int32]string{
	0: "UNKNOWN",
	1: "SINGLE_NODE_WRITER",
	2: "SINGLE_NODE_READER_ONLY",
	3: "MULTI_NODE_READER_ONLY",
	4: "MULTI_NODE_SINGLE_WRITER",
	5: "MULTI_NODE_MULTI_WRITER",
}
View Source 
var VolumeCapability_AccessMode_Mode_value = map[string]int32{
	"UNKNOWN":                  0,
	"SINGLE_NODE_WRITER":       1,
	"SINGLE_NODE_READER_ONLY":  2,
	"MULTI_NODE_READER_ONLY":   3,
	"MULTI_NODE_SINGLE_WRITER": 4,
	"MULTI_NODE_MULTI_WRITER":  5,
}

Functions

func RegisterControllerServer 

func RegisterControllerServer(s *grpc.Server, srv ControllerServer)

func RegisterIdentityServer 

func RegisterIdentityServer(s *grpc.Server, srv IdentityServer)

func RegisterNodeServer 

func RegisterNodeServer(s *grpc.Server, srv NodeServer)

Types

type CapacityRange 

type CapacityRange struct {
	// Volume must be at least this big.
	RequiredBytes uint64 `protobuf:"varint,1,opt,name=required_bytes,json=requiredBytes" json:"required_bytes,omitempty"`
	// Volume must not be bigger than this.
	LimitBytes uint64 `protobuf:"varint,2,opt,name=limit_bytes,json=limitBytes" json:"limit_bytes,omitempty"`
}

The capacity of the storage space in bytes. To specify an exact size, `required_bytes` and `limit_bytes` can be set to the same value. At least one of the these fields MUST be specified.

func (*CapacityRange) Descriptor 

func (*CapacityRange) Descriptor() ([]byte, []int)

func (*CapacityRange) GetLimitBytes 

func (m *CapacityRange) GetLimitBytes() uint64

func (*CapacityRange) GetRequiredBytes 

func (m *CapacityRange) GetRequiredBytes() uint64

func (*CapacityRange) ProtoMessage 

func (*CapacityRange) ProtoMessage()

func (*CapacityRange) Reset 

func (m *CapacityRange) Reset()

func (*CapacityRange) String 

func (m *CapacityRange) String() string

type ControllerClient 

type ControllerClient interface {
	CreateVolume(ctx context.Context, in *CreateVolumeRequest, opts ...grpc.CallOption) (*CreateVolumeResponse, error)
	DeleteVolume(ctx context.Context, in *DeleteVolumeRequest, opts ...grpc.CallOption) (*DeleteVolumeResponse, error)
	ControllerPublishVolume(ctx context.Context, in *ControllerPublishVolumeRequest, opts ...grpc.CallOption) (*ControllerPublishVolumeResponse, error)
	ControllerUnpublishVolume(ctx context.Context, in *ControllerUnpublishVolumeRequest, opts ...grpc.CallOption) (*ControllerUnpublishVolumeResponse, error)
	ValidateVolumeCapabilities(ctx context.Context, in *ValidateVolumeCapabilitiesRequest, opts ...grpc.CallOption) (*ValidateVolumeCapabilitiesResponse, error)
	ListVolumes(ctx context.Context, in *ListVolumesRequest, opts ...grpc.CallOption) (*ListVolumesResponse, error)
	GetCapacity(ctx context.Context, in *GetCapacityRequest, opts ...grpc.CallOption) (*GetCapacityResponse, error)
	ControllerGetCapabilities(ctx context.Context, in *ControllerGetCapabilitiesRequest, opts ...grpc.CallOption) (*ControllerGetCapabilitiesResponse, error)
}

func NewControllerClient 

func NewControllerClient(cc *grpc.ClientConn) ControllerClient

type ControllerGetCapabilitiesRequest 

type ControllerGetCapabilitiesRequest struct {
	// The API version assumed by the CO. This is a REQUIRED field.
	Version *Version `protobuf:"bytes,1,opt,name=version" json:"version,omitempty"`
}

////// //////

func (*ControllerGetCapabilitiesRequest) Descriptor 

func (*ControllerGetCapabilitiesRequest) Descriptor() ([]byte, []int)

func (*ControllerGetCapabilitiesRequest) GetVersion 

func (m *ControllerGetCapabilitiesRequest) GetVersion() *Version

func (*ControllerGetCapabilitiesRequest) ProtoMessage 

func (*ControllerGetCapabilitiesRequest) ProtoMessage()

func (*ControllerGetCapabilitiesRequest) Reset 

func (m *ControllerGetCapabilitiesRequest) Reset()

func (*ControllerGetCapabilitiesRequest) String 

func (m *ControllerGetCapabilitiesRequest) String() string

type ControllerGetCapabilitiesResponse 

type ControllerGetCapabilitiesResponse struct {
	// One of the following fields MUST be specified.
	//
	// Types that are valid to be assigned to Reply:
	//	*ControllerGetCapabilitiesResponse_Result_
	//	*ControllerGetCapabilitiesResponse_Error
	Reply isControllerGetCapabilitiesResponse_Reply `protobuf_oneof:"reply"`
}

func (*ControllerGetCapabilitiesResponse) Descriptor 

func (*ControllerGetCapabilitiesResponse) Descriptor() ([]byte, []int)

func (*ControllerGetCapabilitiesResponse) GetError 

func (m *ControllerGetCapabilitiesResponse) GetError() *Error

func (*ControllerGetCapabilitiesResponse) GetReply 

func (m *ControllerGetCapabilitiesResponse) GetReply() isControllerGetCapabilitiesResponse_Reply

func (*ControllerGetCapabilitiesResponse) GetResult 

func (m *ControllerGetCapabilitiesResponse) GetResult() *ControllerGetCapabilitiesResponse_Result

func (*ControllerGetCapabilitiesResponse) ProtoMessage 

func (*ControllerGetCapabilitiesResponse) ProtoMessage()

func (*ControllerGetCapabilitiesResponse) Reset 

func (m *ControllerGetCapabilitiesResponse) Reset()

func (*ControllerGetCapabilitiesResponse) String 

func (m *ControllerGetCapabilitiesResponse) String() string

func (*ControllerGetCapabilitiesResponse) XXX_OneofFuncs 

func (*ControllerGetCapabilitiesResponse) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

type ControllerGetCapabilitiesResponse_Error 

type ControllerGetCapabilitiesResponse_Error struct {
	Error *Error `protobuf:"bytes,2,opt,name=error,oneof"`
}

type ControllerGetCapabilitiesResponse_Result 

type ControllerGetCapabilitiesResponse_Result struct {
	// All the capabilities that the controller service supports. This
	// field is OPTIONAL.
	Capabilities []*ControllerServiceCapability `protobuf:"bytes,2,rep,name=capabilities" json:"capabilities,omitempty"`
}

func (*ControllerGetCapabilitiesResponse_Result) Descriptor 

func (*ControllerGetCapabilitiesResponse_Result) Descriptor() ([]byte, []int)

func (*ControllerGetCapabilitiesResponse_Result) GetCapabilities 

func (m *ControllerGetCapabilitiesResponse_Result) GetCapabilities() []*ControllerServiceCapability

func (*ControllerGetCapabilitiesResponse_Result) ProtoMessage 

func (*ControllerGetCapabilitiesResponse_Result) ProtoMessage()

func (*ControllerGetCapabilitiesResponse_Result) Reset 

func (m *ControllerGetCapabilitiesResponse_Result) Reset()

func (*ControllerGetCapabilitiesResponse_Result) String 

func (m *ControllerGetCapabilitiesResponse_Result) String() string

type ControllerGetCapabilitiesResponse_Result_ 

type ControllerGetCapabilitiesResponse_Result_ struct {
	Result *ControllerGetCapabilitiesResponse_Result `protobuf:"bytes,1,opt,name=result,oneof"`
}

type ControllerPublishVolumeRequest 

type ControllerPublishVolumeRequest struct {
	// The API version assumed by the CO. This field is REQUIRED.
	Version *Version `protobuf:"bytes,1,opt,name=version" json:"version,omitempty"`
	// The ID of the volume to be used on a node. This field is REQUIRED.
	VolumeId *VolumeID `protobuf:"bytes,2,opt,name=volume_id,json=volumeId" json:"volume_id,omitempty"`
	// The metadata of the volume to be used on a node. This field is
	// OPTIONAL.
	VolumeMetadata *VolumeMetadata `protobuf:"bytes,3,opt,name=volume_metadata,json=volumeMetadata" json:"volume_metadata,omitempty"`
	// The ID of the node. This field is OPTIONAL. The CO SHALL set (or
	// clear) this field to match the `NodeID` returned by `GetNodeID`.
	// `GetNodeID` is allowed to omit `NodeID` from a successful `Result`;
	// in such cases the CO SHALL NOT specify this field.
	NodeId *NodeID `protobuf:"bytes,4,opt,name=node_id,json=nodeId" json:"node_id,omitempty"`
	// The capability of the volume the CO expects the volume to have.
	// This is a REQUIRED field.
	VolumeCapability *VolumeCapability `protobuf:"bytes,6,opt,name=volume_capability,json=volumeCapability" json:"volume_capability,omitempty"`
	// Whether to publish the volume in readonly mode. This field is
	// REQUIRED.
	Readonly bool `protobuf:"varint,5,opt,name=readonly" json:"readonly,omitempty"`
	// End user credentials used to authenticate/authorize controller publish
	// request.
	// This field is OPTIONAL.
	UserCredentials *Credentials `protobuf:"bytes,7,opt,name=user_credentials,json=userCredentials" json:"user_credentials,omitempty"`
}

////// //////

func (*ControllerPublishVolumeRequest) Descriptor 

func (*ControllerPublishVolumeRequest) Descriptor() ([]byte, []int)

func (*ControllerPublishVolumeRequest) GetNodeId 

func (m *ControllerPublishVolumeRequest) GetNodeId() *NodeID

func (*ControllerPublishVolumeRequest) GetReadonly 

func (m *ControllerPublishVolumeRequest) GetReadonly() bool

func (*ControllerPublishVolumeRequest) GetUserCredentials 

func (m *ControllerPublishVolumeRequest) GetUserCredentials() *Credentials

func (*ControllerPublishVolumeRequest) GetVersion 

func (m *ControllerPublishVolumeRequest) GetVersion() *Version

func (*ControllerPublishVolumeRequest) GetVolumeCapability 

func (m *ControllerPublishVolumeRequest) GetVolumeCapability() *VolumeCapability

func (*ControllerPublishVolumeRequest) GetVolumeId 

func (m *ControllerPublishVolumeRequest) GetVolumeId() *VolumeID

func (*ControllerPublishVolumeRequest) GetVolumeMetadata 

func (m *ControllerPublishVolumeRequest) GetVolumeMetadata() *VolumeMetadata

func (*ControllerPublishVolumeRequest) ProtoMessage 

func (*ControllerPublishVolumeRequest) ProtoMessage()

func (*ControllerPublishVolumeRequest) Reset 

func (m *ControllerPublishVolumeRequest) Reset()

func (*ControllerPublishVolumeRequest) String 

func (m *ControllerPublishVolumeRequest) String() string

type ControllerPublishVolumeResponse 

type ControllerPublishVolumeResponse struct {
	// One of the following fields MUST be specified.
	//
	// Types that are valid to be assigned to Reply:
	//	*ControllerPublishVolumeResponse_Result_
	//	*ControllerPublishVolumeResponse_Error
	Reply isControllerPublishVolumeResponse_Reply `protobuf_oneof:"reply"`
}

func (*ControllerPublishVolumeResponse) Descriptor 

func (*ControllerPublishVolumeResponse) Descriptor() ([]byte, []int)

func (*ControllerPublishVolumeResponse) GetError 

func (m *ControllerPublishVolumeResponse) GetError() *Error

func (*ControllerPublishVolumeResponse) GetReply 

func (m *ControllerPublishVolumeResponse) GetReply() isControllerPublishVolumeResponse_Reply

func (*ControllerPublishVolumeResponse) GetResult 

func (m *ControllerPublishVolumeResponse) GetResult() *ControllerPublishVolumeResponse_Result

func (*ControllerPublishVolumeResponse) ProtoMessage 

func (*ControllerPublishVolumeResponse) ProtoMessage()

func (*ControllerPublishVolumeResponse) Reset 

func (m *ControllerPublishVolumeResponse) Reset()

func (*ControllerPublishVolumeResponse) String 

func (m *ControllerPublishVolumeResponse) String() string

func (*ControllerPublishVolumeResponse) XXX_OneofFuncs 

func (*ControllerPublishVolumeResponse) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

type ControllerPublishVolumeResponse_Error 

type ControllerPublishVolumeResponse_Error struct {
	Error *Error `protobuf:"bytes,2,opt,name=error,oneof"`
}

type ControllerPublishVolumeResponse_Result 

type ControllerPublishVolumeResponse_Result struct {
	// The SP specific information that will be passed to the Plugin in
	// the subsequent `NodePublishVolume` call for the given volume.
	// This information is opaque to the CO. This field is OPTIONAL.
	PublishVolumeInfo *PublishVolumeInfo `protobuf:"bytes,1,opt,name=publish_volume_info,json=publishVolumeInfo" json:"publish_volume_info,omitempty"`
}

func (*ControllerPublishVolumeResponse_Result) Descriptor 

func (*ControllerPublishVolumeResponse_Result) Descriptor() ([]byte, []int)

func (*ControllerPublishVolumeResponse_Result) GetPublishVolumeInfo 

func (m *ControllerPublishVolumeResponse_Result) GetPublishVolumeInfo() *PublishVolumeInfo

func (*ControllerPublishVolumeResponse_Result) ProtoMessage 

func (*ControllerPublishVolumeResponse_Result) ProtoMessage()

func (*ControllerPublishVolumeResponse_Result) Reset 

func (m *ControllerPublishVolumeResponse_Result) Reset()

func (*ControllerPublishVolumeResponse_Result) String 

func (m *ControllerPublishVolumeResponse_Result) String() string

type ControllerPublishVolumeResponse_Result_ 

type ControllerPublishVolumeResponse_Result_ struct {
	Result *ControllerPublishVolumeResponse_Result `protobuf:"bytes,1,opt,name=result,oneof"`
}

type ControllerServer 

type ControllerServer interface {
	CreateVolume(context.Context, *CreateVolumeRequest) (*CreateVolumeResponse, error)
	DeleteVolume(context.Context, *DeleteVolumeRequest) (*DeleteVolumeResponse, error)
	ControllerPublishVolume(context.Context, *ControllerPublishVolumeRequest) (*ControllerPublishVolumeResponse, error)
	ControllerUnpublishVolume(context.Context, *ControllerUnpublishVolumeRequest) (*ControllerUnpublishVolumeResponse, error)
	ValidateVolumeCapabilities(context.Context, *ValidateVolumeCapabilitiesRequest) (*ValidateVolumeCapabilitiesResponse, error)
	ListVolumes(context.Context, *ListVolumesRequest) (*ListVolumesResponse, error)
	GetCapacity(context.Context, *GetCapacityRequest) (*GetCapacityResponse, error)
	ControllerGetCapabilities(context.Context, *ControllerGetCapabilitiesRequest) (*ControllerGetCapabilitiesResponse, error)
}

type ControllerServiceCapability 

type ControllerServiceCapability struct {
	// Types that are valid to be assigned to Type:
	//	*ControllerServiceCapability_Rpc
	Type isControllerServiceCapability_Type `protobuf_oneof:"type"`
}

Specifies a capability of the controller service.

func (*ControllerServiceCapability) Descriptor 

func (*ControllerServiceCapability) Descriptor() ([]byte, []int)

func (*ControllerServiceCapability) GetRpc 

func (m *ControllerServiceCapability) GetRpc() *ControllerServiceCapability_RPC

func (*ControllerServiceCapability) GetType 

func (m *ControllerServiceCapability) GetType() isControllerServiceCapability_Type

func (*ControllerServiceCapability) ProtoMessage 

func (*ControllerServiceCapability) ProtoMessage()

func (*ControllerServiceCapability) Reset 

func (m *ControllerServiceCapability) Reset()

func (*ControllerServiceCapability) String 

func (m *ControllerServiceCapability) String() string

func (*ControllerServiceCapability) XXX_OneofFuncs 

func (*ControllerServiceCapability) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

type ControllerServiceCapability_RPC 

type ControllerServiceCapability_RPC struct {
	Type ControllerServiceCapability_RPC_Type `protobuf:"varint,1,opt,name=type,enum=csi.ControllerServiceCapability_RPC_Type" json:"type,omitempty"`
}

func (*ControllerServiceCapability_RPC) Descriptor 

func (*ControllerServiceCapability_RPC) Descriptor() ([]byte, []int)

func (*ControllerServiceCapability_RPC) GetType 

func (m *ControllerServiceCapability_RPC) GetType() ControllerServiceCapability_RPC_Type

func (*ControllerServiceCapability_RPC) ProtoMessage 

func (*ControllerServiceCapability_RPC) ProtoMessage()

func (*ControllerServiceCapability_RPC) Reset 

func (m *ControllerServiceCapability_RPC) Reset()

func (*ControllerServiceCapability_RPC) String 

func (m *ControllerServiceCapability_RPC) String() string

type ControllerServiceCapability_RPC_Type 

type ControllerServiceCapability_RPC_Type int32
const (
	ControllerServiceCapability_RPC_UNKNOWN                  ControllerServiceCapability_RPC_Type = 0
	ControllerServiceCapability_RPC_CREATE_DELETE_VOLUME     ControllerServiceCapability_RPC_Type = 1
	ControllerServiceCapability_RPC_PUBLISH_UNPUBLISH_VOLUME ControllerServiceCapability_RPC_Type = 2
	ControllerServiceCapability_RPC_LIST_VOLUMES             ControllerServiceCapability_RPC_Type = 3
	ControllerServiceCapability_RPC_GET_CAPACITY             ControllerServiceCapability_RPC_Type = 4
)

func (ControllerServiceCapability_RPC_Type) EnumDescriptor 

func (ControllerServiceCapability_RPC_Type) EnumDescriptor() ([]byte, []int)

func (ControllerServiceCapability_RPC_Type) String 

func (x ControllerServiceCapability_RPC_Type) String() string

type ControllerServiceCapability_Rpc 

type ControllerServiceCapability_Rpc struct {
	Rpc *ControllerServiceCapability_RPC `protobuf:"bytes,1,opt,name=rpc,oneof"`
}

type ControllerUnpublishVolumeRequest 

type ControllerUnpublishVolumeRequest struct {
	// The API version assumed by the CO. This field is REQUIRED.
	Version *Version `protobuf:"bytes,1,opt,name=version" json:"version,omitempty"`
	// The ID of the volume. This field is REQUIRED.
	VolumeId *VolumeID `protobuf:"bytes,2,opt,name=volume_id,json=volumeId" json:"volume_id,omitempty"`
	// The metadata of the volume. This field is OPTIONAL.
	VolumeMetadata *VolumeMetadata `protobuf:"bytes,3,opt,name=volume_metadata,json=volumeMetadata" json:"volume_metadata,omitempty"`
	// The ID of the node. This field is OPTIONAL. The CO SHALL set (or
	// clear) this field to match the `NodeID` returned by `GetNodeID`.
	// `GetNodeID` is allowed to omit `NodeID` from a successful `Result`;
	// in such cases the CO SHALL NOT specify this field.
	//
	// If `GetNodeID` does not omit `NodeID` from a successful `Result`,
	// the CO MAY omit this field as well, indicating that it does not
	// know which node the volume was previously used. The Plugin SHOULD
	// return an Error if this is not supported.
	NodeId *NodeID `protobuf:"bytes,4,opt,name=node_id,json=nodeId" json:"node_id,omitempty"`
	// End user credentials used to authenticate/authorize controller unpublish
	// request.
	// This field is OPTIONAL.
	UserCredentials *Credentials `protobuf:"bytes,5,opt,name=user_credentials,json=userCredentials" json:"user_credentials,omitempty"`
}

////// //////

func (*ControllerUnpublishVolumeRequest) Descriptor 

func (*ControllerUnpublishVolumeRequest) Descriptor() ([]byte, []int)

func (*ControllerUnpublishVolumeRequest) GetNodeId 

func (m *ControllerUnpublishVolumeRequest) GetNodeId() *NodeID

func (*ControllerUnpublishVolumeRequest) GetUserCredentials 

func (m *ControllerUnpublishVolumeRequest) GetUserCredentials() *Credentials

func (*ControllerUnpublishVolumeRequest) GetVersion 

func (m *ControllerUnpublishVolumeRequest) GetVersion() *Version

func (*ControllerUnpublishVolumeRequest) GetVolumeId 

func (m *ControllerUnpublishVolumeRequest) GetVolumeId() *VolumeID

func (*ControllerUnpublishVolumeRequest) GetVolumeMetadata 

func (m *ControllerUnpublishVolumeRequest) GetVolumeMetadata() *VolumeMetadata

func (*ControllerUnpublishVolumeRequest) ProtoMessage 

func (*ControllerUnpublishVolumeRequest) ProtoMessage()

func (*ControllerUnpublishVolumeRequest) Reset 

func (m *ControllerUnpublishVolumeRequest) Reset()

func (*ControllerUnpublishVolumeRequest) String 

func (m *ControllerUnpublishVolumeRequest) String() string

type ControllerUnpublishVolumeResponse 

type ControllerUnpublishVolumeResponse struct {
	// One of the following fields MUST be specified.
	//
	// Types that are valid to be assigned to Reply:
	//	*ControllerUnpublishVolumeResponse_Result_
	//	*ControllerUnpublishVolumeResponse_Error
	Reply isControllerUnpublishVolumeResponse_Reply `protobuf_oneof:"reply"`
}

func (*ControllerUnpublishVolumeResponse) Descriptor 

func (*ControllerUnpublishVolumeResponse) Descriptor() ([]byte, []int)

func (*ControllerUnpublishVolumeResponse) GetError 

func (m *ControllerUnpublishVolumeResponse) GetError() *Error

func (*ControllerUnpublishVolumeResponse) GetReply 

func (m *ControllerUnpublishVolumeResponse) GetReply() isControllerUnpublishVolumeResponse_Reply

func (*ControllerUnpublishVolumeResponse) GetResult 

func (m *ControllerUnpublishVolumeResponse) GetResult() *ControllerUnpublishVolumeResponse_Result

func (*ControllerUnpublishVolumeResponse) ProtoMessage 

func (*ControllerUnpublishVolumeResponse) ProtoMessage()

func (*ControllerUnpublishVolumeResponse) Reset 

func (m *ControllerUnpublishVolumeResponse) Reset()

func (*ControllerUnpublishVolumeResponse) String 

func (m *ControllerUnpublishVolumeResponse) String() string

func (*ControllerUnpublishVolumeResponse) XXX_OneofFuncs 

func (*ControllerUnpublishVolumeResponse) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

type ControllerUnpublishVolumeResponse_Error 

type ControllerUnpublishVolumeResponse_Error struct {
	Error *Error `protobuf:"bytes,2,opt,name=error,oneof"`
}

type ControllerUnpublishVolumeResponse_Result 

type ControllerUnpublishVolumeResponse_Result struct {
}

func (*ControllerUnpublishVolumeResponse_Result) Descriptor 

func (*ControllerUnpublishVolumeResponse_Result) Descriptor() ([]byte, []int)

func (*ControllerUnpublishVolumeResponse_Result) ProtoMessage 

func (*ControllerUnpublishVolumeResponse_Result) ProtoMessage()

func (*ControllerUnpublishVolumeResponse_Result) Reset 

func (m *ControllerUnpublishVolumeResponse_Result) Reset()

func (*ControllerUnpublishVolumeResponse_Result) String 

func (m *ControllerUnpublishVolumeResponse_Result) String() string

type ControllerUnpublishVolumeResponse_Result_ 

type ControllerUnpublishVolumeResponse_Result_ struct {
	Result *ControllerUnpublishVolumeResponse_Result `protobuf:"bytes,1,opt,name=result,oneof"`
}

type CreateVolumeRequest 

type CreateVolumeRequest struct {
	// The API version assumed by the CO. This field is REQUIRED.
	Version *Version `protobuf:"bytes,1,opt,name=version" json:"version,omitempty"`
	// The suggested name for the storage space. This field is REQUIRED.
	// It serves two purposes:
	// 1) Idempotency - This name is generated by the CO to achieve
	//    idempotency. If `CreateVolume` fails, the volume may or may not
	//    be provisioned. In this case, the CO may call `CreateVolume`
	//    again, with the same name, to ensure the volume exists. The
	//    Plugin should ensure that multiple `CreateVolume` calls for the
	//    same name do not result in more than one piece of storage
	//    provisioned corresponding to that name. If a Plugin is unable to
	//    enforce idempotency, the CO’s error recovery logic could result
	//    in multiple (unused) volumes being provisioned.
	// 2) Suggested name - Some storage systems allow callers to specify
	//    an identifier by which to refer to the newly provisioned
	//    storage. If a storage system supports this, it can optionally
	//    use this name as the identifier for the new volume.
	Name string `protobuf:"bytes,2,opt,name=name" json:"name,omitempty"`
	// This field is OPTIONAL. This allows the CO to specify the capacity
	// requirement of the volume to be provisioned. If not specified, the
	// Plugin MAY choose an implementation-defined capacity range.
	CapacityRange *CapacityRange `protobuf:"bytes,3,opt,name=capacity_range,json=capacityRange" json:"capacity_range,omitempty"`
	// The capabilities that the provisioned volume MUST have: the Plugin
	// MUST provision a volume that could satisfy ALL of the
	// capabilities specified in this list. The Plugin MUST assume that
	// the CO MAY use the  provisioned volume later with ANY of the
	// capabilities specified in this list. This also enables the CO to do
	// early validation: if ANY of the specified volume capabilities are
	// not supported by the Plugin, the call SHALL fail. This field is
	// REQUIRED.
	VolumeCapabilities []*VolumeCapability `protobuf:"bytes,4,rep,name=volume_capabilities,json=volumeCapabilities" json:"volume_capabilities,omitempty"`
	// Plugin specific parameters passed in as opaque key-value pairs.
	// This field is OPTIONAL. The Plugin is responsible for parsing and
	// validating these parameters. COs will treat these as opaque.
	Parameters map[string]string `` /* 140-byte string literal not displayed */
	// End user credentials used to authenticate/authorize volume creation
	// request.
	// This field is OPTIONAL.
	UserCredentials *Credentials `protobuf:"bytes,6,opt,name=user_credentials,json=userCredentials" json:"user_credentials,omitempty"`
}

////// //////

func (*CreateVolumeRequest) Descriptor 

func (*CreateVolumeRequest) Descriptor() ([]byte, []int)

func (*CreateVolumeRequest) GetCapacityRange 

func (m *CreateVolumeRequest) GetCapacityRange() *CapacityRange

func (*CreateVolumeRequest) GetName 

func (m *CreateVolumeRequest) GetName() string

func (*CreateVolumeRequest) GetParameters 

func (m *CreateVolumeRequest) GetParameters() map[string]string

func (*CreateVolumeRequest) GetUserCredentials 

func (m *CreateVolumeRequest) GetUserCredentials() *Credentials

func (*CreateVolumeRequest) GetVersion 

func (m *CreateVolumeRequest) GetVersion() *Version

func (*CreateVolumeRequest) GetVolumeCapabilities 

func (m *CreateVolumeRequest) GetVolumeCapabilities() []*VolumeCapability

func (*CreateVolumeRequest) ProtoMessage 

func (*CreateVolumeRequest) ProtoMessage()

func (*CreateVolumeRequest) Reset 

func (m *CreateVolumeRequest) Reset()

func (*CreateVolumeRequest) String 

func (m *CreateVolumeRequest) String() string

type CreateVolumeResponse 

type CreateVolumeResponse struct {
	// One of the following fields MUST be specified.
	//
	// Types that are valid to be assigned to Reply:
	//	*CreateVolumeResponse_Result_
	//	*CreateVolumeResponse_Error
	Reply isCreateVolumeResponse_Reply `protobuf_oneof:"reply"`
}

func (*CreateVolumeResponse) Descriptor 

func (*CreateVolumeResponse) Descriptor() ([]byte, []int)

func (*CreateVolumeResponse) GetError 

func (m *CreateVolumeResponse) GetError() *Error

func (*CreateVolumeResponse) GetReply 

func (m *CreateVolumeResponse) GetReply() isCreateVolumeResponse_Reply

func (*CreateVolumeResponse) GetResult 

func (m *CreateVolumeResponse) GetResult() *CreateVolumeResponse_Result

func (*CreateVolumeResponse) ProtoMessage 

func (*CreateVolumeResponse) ProtoMessage()

func (*CreateVolumeResponse) Reset 

func (m *CreateVolumeResponse) Reset()

func (*CreateVolumeResponse) String 

func (m *CreateVolumeResponse) String() string

func (*CreateVolumeResponse) XXX_OneofFuncs 

func (*CreateVolumeResponse) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

type CreateVolumeResponse_Error 

type CreateVolumeResponse_Error struct {
	Error *Error `protobuf:"bytes,2,opt,name=error,oneof"`
}

type CreateVolumeResponse_Result 

type CreateVolumeResponse_Result struct {
	// Contains all attributes of the newly created volume that are
	// relevant to the CO along with information required by the Plugin
	// to uniquely identifying the volume. This field is REQUIRED.
	VolumeInfo *VolumeInfo `protobuf:"bytes,1,opt,name=volume_info,json=volumeInfo" json:"volume_info,omitempty"`
}

func (*CreateVolumeResponse_Result) Descriptor 

func (*CreateVolumeResponse_Result) Descriptor() ([]byte, []int)

func (*CreateVolumeResponse_Result) GetVolumeInfo 

func (m *CreateVolumeResponse_Result) GetVolumeInfo() *VolumeInfo

func (*CreateVolumeResponse_Result) ProtoMessage 

func (*CreateVolumeResponse_Result) ProtoMessage()

func (*CreateVolumeResponse_Result) Reset 

func (m *CreateVolumeResponse_Result) Reset()

func (*CreateVolumeResponse_Result) String 

func (m *CreateVolumeResponse_Result) String() string

type CreateVolumeResponse_Result_ 

type CreateVolumeResponse_Result_ struct {
	Result *CreateVolumeResponse_Result `protobuf:"bytes,1,opt,name=result,oneof"`
}

type Credentials 

type Credentials struct {
	// Data contains the credential data, for example username and password.
	// Each key must consist of alphanumeric characters, '-', '_' or '.'.
	// Each value MUST contain a valid string. An SP MAY choose to accept binary
	// (non-string) data by using a binary-to-text encoding scheme, like base64.
	// An SP SHALL advertise the requirements for credentials in documentation.
	// COs SHALL permit users to pass through the required credentials.
	// This information is sensitive and MUST be treated as such (not logged,
	// etc.) by the CO.
	// This field is REQUIRED.
	Data map[string]string `` /* 128-byte string literal not displayed */
}

A standard way to encode credential data. The total bytes of the values in the Data field must be less than 1 Mebibyte.

func (*Credentials) Descriptor 

func (*Credentials) Descriptor() ([]byte, []int)

func (*Credentials) GetData 

func (m *Credentials) GetData() map[string]string

func (*Credentials) ProtoMessage 

func (*Credentials) ProtoMessage()

func (*Credentials) Reset 

func (m *Credentials) Reset()

func (*Credentials) String 

func (m *Credentials) String() string

type DeleteVolumeRequest 

type DeleteVolumeRequest struct {
	// The API version assumed by the CO. This field is REQUIRED.
	Version *Version `protobuf:"bytes,1,opt,name=version" json:"version,omitempty"`
	// The ID of the volume to be deprovisioned. This field is REQUIRED.
	VolumeId *VolumeID `protobuf:"bytes,2,opt,name=volume_id,json=volumeId" json:"volume_id,omitempty"`
	// The metadata of the volume to be deprovisioned. This field is
	// OPTIONAL.
	VolumeMetadata *VolumeMetadata `protobuf:"bytes,3,opt,name=volume_metadata,json=volumeMetadata" json:"volume_metadata,omitempty"`
	// End user credentials used to authenticate/authorize volume deletion
	// request.
	// This field is OPTIONAL.
	UserCredentials *Credentials `protobuf:"bytes,4,opt,name=user_credentials,json=userCredentials" json:"user_credentials,omitempty"`
}

////// //////

func (*DeleteVolumeRequest) Descriptor 

func (*DeleteVolumeRequest) Descriptor() ([]byte, []int)

func (*DeleteVolumeRequest) GetUserCredentials 

func (m *DeleteVolumeRequest) GetUserCredentials() *Credentials

func (*DeleteVolumeRequest) GetVersion 

func (m *DeleteVolumeRequest) GetVersion() *Version

func (*DeleteVolumeRequest) GetVolumeId 

func (m *DeleteVolumeRequest) GetVolumeId() *VolumeID

func (*DeleteVolumeRequest) GetVolumeMetadata 

func (m *DeleteVolumeRequest) GetVolumeMetadata() *VolumeMetadata

func (*DeleteVolumeRequest) ProtoMessage 

func (*DeleteVolumeRequest) ProtoMessage()

func (*DeleteVolumeRequest) Reset 

func (m *DeleteVolumeRequest) Reset()

func (*DeleteVolumeRequest) String 

func (m *DeleteVolumeRequest) String() string

type DeleteVolumeResponse 

type DeleteVolumeResponse struct {
	// One of the following fields MUST be specified.
	//
	// Types that are valid to be assigned to Reply:
	//	*DeleteVolumeResponse_Result_
	//	*DeleteVolumeResponse_Error
	Reply isDeleteVolumeResponse_Reply `protobuf_oneof:"reply"`
}

func (*DeleteVolumeResponse) Descriptor 

func (*DeleteVolumeResponse) Descriptor() ([]byte, []int)

func (*DeleteVolumeResponse) GetError 

func (m *DeleteVolumeResponse) GetError() *Error

func (*DeleteVolumeResponse) GetReply 

func (m *DeleteVolumeResponse) GetReply() isDeleteVolumeResponse_Reply

func (*DeleteVolumeResponse) GetResult 

func (m *DeleteVolumeResponse) GetResult() *DeleteVolumeResponse_Result

func (*DeleteVolumeResponse) ProtoMessage 

func (*DeleteVolumeResponse) ProtoMessage()

func (*DeleteVolumeResponse) Reset 

func (m *DeleteVolumeResponse) Reset()

func (*DeleteVolumeResponse) String 

func (m *DeleteVolumeResponse) String() string

func (*DeleteVolumeResponse) XXX_OneofFuncs 

func (*DeleteVolumeResponse) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

type DeleteVolumeResponse_Error 

type DeleteVolumeResponse_Error struct {
	Error *Error `protobuf:"bytes,2,opt,name=error,oneof"`
}

type DeleteVolumeResponse_Result 

type DeleteVolumeResponse_Result struct {
}

func (*DeleteVolumeResponse_Result) Descriptor 

func (*DeleteVolumeResponse_Result) Descriptor() ([]byte, []int)

func (*DeleteVolumeResponse_Result) ProtoMessage 

func (*DeleteVolumeResponse_Result) ProtoMessage()

func (*DeleteVolumeResponse_Result) Reset 

func (m *DeleteVolumeResponse_Result) Reset()

func (*DeleteVolumeResponse_Result) String 

func (m *DeleteVolumeResponse_Result) String() string

type DeleteVolumeResponse_Result_ 

type DeleteVolumeResponse_Result_ struct {
	Result *DeleteVolumeResponse_Result `protobuf:"bytes,1,opt,name=result,oneof"`
}

type Error 

type Error struct {
	// One of the following fields MUST be specified.
	//
	// Types that are valid to be assigned to Value:
	//	*Error_GeneralError_
	//	*Error_CreateVolumeError_
	//	*Error_DeleteVolumeError_
	//	*Error_ControllerPublishVolumeError_
	//	*Error_ControllerUnpublishVolumeError_
	//	*Error_ValidateVolumeCapabilitiesError_
	//	*Error_NodePublishVolumeError_
	//	*Error_NodeUnpublishVolumeError_
	//	*Error_ProbeNodeError_
	//	*Error_GetNodeIdError
	Value isError_Value `protobuf_oneof:"value"`
}

////// //////

func (*Error) Descriptor 

func (*Error) Descriptor() ([]byte, []int)

func (*Error) GetControllerPublishVolumeError 

func (m *Error) GetControllerPublishVolumeError() *Error_ControllerPublishVolumeError

func (*Error) GetControllerUnpublishVolumeError 

func (m *Error) GetControllerUnpublishVolumeError() *Error_ControllerUnpublishVolumeError

func (*Error) GetCreateVolumeError 

func (m *Error) GetCreateVolumeError() *Error_CreateVolumeError

func (*Error) GetDeleteVolumeError 

func (m *Error) GetDeleteVolumeError() *Error_DeleteVolumeError

func (*Error) GetGeneralError 

func (m *Error) GetGeneralError() *Error_GeneralError

func (*Error) GetGetNodeIdError 

func (m *Error) GetGetNodeIdError() *Error_GetNodeIDError

func (*Error) GetNodePublishVolumeError 

func (m *Error) GetNodePublishVolumeError() *Error_NodePublishVolumeError

func (*Error) GetNodeUnpublishVolumeError 

func (m *Error) GetNodeUnpublishVolumeError() *Error_NodeUnpublishVolumeError

func (*Error) GetProbeNodeError 

func (m *Error) GetProbeNodeError() *Error_ProbeNodeError

func (*Error) GetValidateVolumeCapabilitiesError 

func (m *Error) GetValidateVolumeCapabilitiesError() *Error_ValidateVolumeCapabilitiesError

func (*Error) GetValue 

func (m *Error) GetValue() isError_Value

func (*Error) ProtoMessage 

func (*Error) ProtoMessage()

func (*Error) Reset 

func (m *Error) Reset()

func (*Error) String 

func (m *Error) String() string

func (*Error) XXX_OneofFuncs 

func (*Error) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

type Error_ControllerPublishVolumeError 

type Error_ControllerPublishVolumeError struct {
	// Machine parsable error code.
	ErrorCode Error_ControllerPublishVolumeError_ControllerPublishVolumeErrorCode `` /* 159-byte string literal not displayed */
	// Human readable description of error, possibly with additional
	// information. This string maybe surfaced by CO to end users.
	ErrorDescription string `protobuf:"bytes,2,opt,name=error_description,json=errorDescription" json:"error_description,omitempty"`
	// On `VOLUME_ALREADY_ATTACHED` and `MAX_ATTACHED_NODES` errors,
	// this field contains the node(s) that the specified volume is
	// already attached to.
	NodeIds []*NodeID `protobuf:"bytes,3,rep,name=node_ids,json=nodeIds" json:"node_ids,omitempty"`
}

`ControllerPublishVolume` specific error.

func (*Error_ControllerPublishVolumeError) Descriptor 

func (*Error_ControllerPublishVolumeError) Descriptor() ([]byte, []int)

func (*Error_ControllerPublishVolumeError) GetErrorCode 

func (m *Error_ControllerPublishVolumeError) GetErrorCode() Error_ControllerPublishVolumeError_ControllerPublishVolumeErrorCode

func (*Error_ControllerPublishVolumeError) GetErrorDescription 

func (m *Error_ControllerPublishVolumeError) GetErrorDescription() string

func (*Error_ControllerPublishVolumeError) GetNodeIds 

func (m *Error_ControllerPublishVolumeError) GetNodeIds() []*NodeID

func (*Error_ControllerPublishVolumeError) ProtoMessage 

func (*Error_ControllerPublishVolumeError) ProtoMessage()

func (*Error_ControllerPublishVolumeError) Reset 

func (m *Error_ControllerPublishVolumeError) Reset()

func (*Error_ControllerPublishVolumeError) String 

func (m *Error_ControllerPublishVolumeError) String() string

type Error_ControllerPublishVolumeError_ 

type Error_ControllerPublishVolumeError_ struct {
	ControllerPublishVolumeError *Error_ControllerPublishVolumeError `protobuf:"bytes,4,opt,name=controller_publish_volume_error,json=controllerPublishVolumeError,oneof"`
}

type Error_ControllerPublishVolumeError_ControllerPublishVolumeErrorCode 

type Error_ControllerPublishVolumeError_ControllerPublishVolumeErrorCode int32
const (
	// Default value for backwards compatibility. SHOULD NOT be
	// returned by Plugins. However, if a Plugin returns a
	// `ControllerPublishVolumeErrorCode` code that an older CSI
	// client is not aware of, the client will see this code (the
	// default fallback).
	//
	// Recovery behavior: Caller SHOULD consider updating CSI client
	// to match Plugin CSI version.
	Error_ControllerPublishVolumeError_UNKNOWN Error_ControllerPublishVolumeError_ControllerPublishVolumeErrorCode = 0
	// Indicates that the call is either not implemented by the Plugin
	// or disabled in the Plugin’s current mode of operation.
	//
	// Recovery behavior: Caller MUST not retry; caller MAY call
	// `ControllerGetCapabilities` or `NodeGetCapabilities` to discover
	// Plugin capabilities.
	Error_ControllerPublishVolumeError_CALL_NOT_IMPLEMENTED Error_ControllerPublishVolumeError_ControllerPublishVolumeErrorCode = 1
	// Indicates that there is a already an operation pending for the
	// specified volume. In general the Cluster Orchestrator (CO) is
	// responsible for ensuring that there is no more than one call
	// “in-flight” per volume at a given time. However, in some
	// circumstances, the CO MAY lose state (for example when the CO
	// crashes and restarts), and MAY issue multiple calls
	// simultaneously for the same volume. The Plugin, SHOULD handle
	// this as gracefully as possible, and MAY return this error code
	// to reject secondary calls.
	//
	// Recovery behavior: Caller SHOULD ensure that there are no other
	// calls pending for the specified volume, and then retry with
	// exponential back off.
	Error_ControllerPublishVolumeError_OPERATION_PENDING_FOR_VOLUME Error_ControllerPublishVolumeError_ControllerPublishVolumeErrorCode = 2
	// Indicates that the specified `VolumeID` is not allowed or
	// understood by the Plugin. More human-readable information MAY
	// be provided in the `error_description` field.
	//
	// Recovery behavior: Caller MUST fix the `VolumeID` before
	// retrying.
	Error_ControllerPublishVolumeError_INVALID_VOLUME_ID Error_ControllerPublishVolumeError_ControllerPublishVolumeErrorCode = 3
	// Indicates that the specified `VolumeMetadata` is not allowed or
	// understood by the Plugin. More human-readable information MAY
	// be provided in the `error_description` field.
	//
	// Recovery behavior: Caller MUST fix the `VolumeMetadata` before
	// retrying.
	Error_ControllerPublishVolumeError_INVALID_VOLUME_METADATA Error_ControllerPublishVolumeError_ControllerPublishVolumeErrorCode = 4
	// Indicates that a volume corresponding to the specified
	// `VolumeID` does not exist.
	//
	// Recovery behavior: Caller SHOULD verify that the `VolumeID` is
	// correct and that the volume is accessible and has not been
	// deleted before retrying with exponential back off.
	Error_ControllerPublishVolumeError_VOLUME_DOES_NOT_EXIST Error_ControllerPublishVolumeError_ControllerPublishVolumeErrorCode = 5
	// Indicates that a volume corresponding to the specified
	// `VolumeID` is already attached to another node and does not
	// support multi-node attach. If this error code is returned, the
	// Plugin MUST also specify the `node_id` of the node the volume
	// is already attached to.
	//
	// Recovery behavior: Caller MAY use the provided `node_ids`
	// information to detach the volume from the other node. Caller
	// SHOULD ensure the specified volume is not attached to any other
	// node before retrying with exponential back off.
	Error_ControllerPublishVolumeError_VOLUME_ALREADY_PUBLISHED Error_ControllerPublishVolumeError_ControllerPublishVolumeErrorCode = 6
	// Indicates that a node corresponding to the specified `NodeID`
	// does not exist.
	//
	// Recovery behavior: Caller SHOULD verify that the `NodeID` is
	// correct and that the node is available and has not been
	// terminated or deleted before retrying with exponential backoff.
	Error_ControllerPublishVolumeError_NODE_DOES_NOT_EXIST Error_ControllerPublishVolumeError_ControllerPublishVolumeErrorCode = 7
	// Indicates that a volume corresponding to the specified
	// `VolumeID` is already attached to the maximum supported number
	// of nodes and therefore this operation can not be completed
	// until the volume is detached from at least one of the existing
	// nodes. When this error code is returned, the Plugin MUST also
	// specify the `NodeId` of all the nodes the volume is attached
	// to.
	//
	// Recovery behavior: Caller MAY use the provided `node_ids`
	// information to detach the volume from one other node before
	// retrying with exponential backoff.
	Error_ControllerPublishVolumeError_MAX_ATTACHED_NODES      Error_ControllerPublishVolumeError_ControllerPublishVolumeErrorCode = 8
	Error_ControllerPublishVolumeError_UNSUPPORTED_MOUNT_FLAGS Error_ControllerPublishVolumeError_ControllerPublishVolumeErrorCode = 10
	Error_ControllerPublishVolumeError_UNSUPPORTED_VOLUME_TYPE Error_ControllerPublishVolumeError_ControllerPublishVolumeErrorCode = 11
	Error_ControllerPublishVolumeError_UNSUPPORTED_FS_TYPE     Error_ControllerPublishVolumeError_ControllerPublishVolumeErrorCode = 12
	// Indicates that the specified `NodeID` is not allowed or
	// understood by the Plugin, or the Plugin does not support the
	// operation without a `NodeID`. More human-readable information
	// MAY be provided in the `error_description` field.
	//
	// Recovery behavior: Caller MUST fix the `NodeID` before
	// retrying.
	Error_ControllerPublishVolumeError_INVALID_NODE_ID Error_ControllerPublishVolumeError_ControllerPublishVolumeErrorCode = 9
)

func (Error_ControllerPublishVolumeError_ControllerPublishVolumeErrorCode) EnumDescriptor 

func (Error_ControllerPublishVolumeError_ControllerPublishVolumeErrorCode) EnumDescriptor() ([]byte, []int)

func (Error_ControllerPublishVolumeError_ControllerPublishVolumeErrorCode) String 

func (x Error_ControllerPublishVolumeError_ControllerPublishVolumeErrorCode) String() string

type Error_ControllerUnpublishVolumeError 

type Error_ControllerUnpublishVolumeError struct {
	ErrorCode        Error_ControllerUnpublishVolumeError_ControllerUnpublishVolumeErrorCode `` /* 163-byte string literal not displayed */
	ErrorDescription string                                                                  `protobuf:"bytes,2,opt,name=error_description,json=errorDescription" json:"error_description,omitempty"`
}

`ControllerUnpublishVolume` specific error.

func (*Error_ControllerUnpublishVolumeError) Descriptor 

func (*Error_ControllerUnpublishVolumeError) Descriptor() ([]byte, []int)

func (*Error_ControllerUnpublishVolumeError) GetErrorCode 

func (m *Error_ControllerUnpublishVolumeError) GetErrorCode() Error_ControllerUnpublishVolumeError_ControllerUnpublishVolumeErrorCode

func (*Error_ControllerUnpublishVolumeError) GetErrorDescription 

func (m *Error_ControllerUnpublishVolumeError) GetErrorDescription() string

func (*Error_ControllerUnpublishVolumeError) ProtoMessage 

func (*Error_ControllerUnpublishVolumeError) ProtoMessage()

func (*Error_ControllerUnpublishVolumeError) Reset 

func (m *Error_ControllerUnpublishVolumeError) Reset()

func (*Error_ControllerUnpublishVolumeError) String 

func (m *Error_ControllerUnpublishVolumeError) String() string

type Error_ControllerUnpublishVolumeError_ 

type Error_ControllerUnpublishVolumeError_ struct {
	ControllerUnpublishVolumeError *Error_ControllerUnpublishVolumeError `protobuf:"bytes,5,opt,name=controller_unpublish_volume_error,json=controllerUnpublishVolumeError,oneof"`
}

type Error_ControllerUnpublishVolumeError_ControllerUnpublishVolumeErrorCode 

type Error_ControllerUnpublishVolumeError_ControllerUnpublishVolumeErrorCode int32
const (
	// Default value for backwards compatibility. SHOULD NOT be
	// returned by Plugins. However, if a Plugin returns a
	// `ControllerUnpublishVolumeErrorCode` code that an older CSI
	// client is not aware of, the client will see this code (the
	// default fallback).
	//
	// Recovery behavior: Caller SHOULD consider updating CSI client
	// to match Plugin CSI version.
	Error_ControllerUnpublishVolumeError_UNKNOWN Error_ControllerUnpublishVolumeError_ControllerUnpublishVolumeErrorCode = 0
	// Indicates that the call is either not implemented by the Plugin
	// or disabled in the Plugin’s current mode of operation.
	//
	// Recovery behavior: Caller MUST not retry; caller MAY call
	// `ControllerGetCapabilities` or `NodeGetCapabilities` to
	// discover Plugin capabilities.
	Error_ControllerUnpublishVolumeError_CALL_NOT_IMPLEMENTED Error_ControllerUnpublishVolumeError_ControllerUnpublishVolumeErrorCode = 1
	// Indicates that there is a already an operation pending for the
	// specified volume. In general the Cluster Orchestrator (CO) is
	// responsible for ensuring that there is no more than one call
	// “in-flight” per volume at a given time. However, in some
	// circumstances, the CO MAY lose state (for example when the CO
	// crashes and restarts), and MAY issue multiple calls
	// simultaneously for the same volume. The Plugin, SHOULD handle
	// this as gracefully as possible, and MAY return this error code
	// to reject secondary calls.
	//
	// Recovery behavior: Caller SHOULD ensure that there are no other
	// calls pending for the specified volume, and then retry with
	// exponential back off.
	Error_ControllerUnpublishVolumeError_OPERATION_PENDING_FOR_VOLUME Error_ControllerUnpublishVolumeError_ControllerUnpublishVolumeErrorCode = 2
	// Indicates that the specified `VolumeID` is not allowed or
	// understood by the Plugin. More human-readable information MAY
	// be provided in the `error_description` field.
	//
	// Recovery behavior: Caller MUST fix the `VolumeID` before
	// retrying.
	Error_ControllerUnpublishVolumeError_INVALID_VOLUME_ID Error_ControllerUnpublishVolumeError_ControllerUnpublishVolumeErrorCode = 3
	// Indicates that the specified `VolumeMetadata` is not allowed or
	// understood by the Plugin. More human-readable information MAY
	// be provided in the `error_description` field.
	//
	// Recovery behavior: Caller MUST fix the `VolumeMetadata` before
	// retrying.
	Error_ControllerUnpublishVolumeError_INVALID_VOLUME_METADATA Error_ControllerUnpublishVolumeError_ControllerUnpublishVolumeErrorCode = 4
	// Indicates that a volume corresponding to the specified
	// `VolumeID` does not exist.
	//
	// Recovery behavior: Caller SHOULD verify that the `VolumeID` is
	// correct and that the volume is accessible and has not been
	// deleted before retrying with exponential back off.
	Error_ControllerUnpublishVolumeError_VOLUME_DOES_NOT_EXIST Error_ControllerUnpublishVolumeError_ControllerUnpublishVolumeErrorCode = 5
	// Indicates that a node corresponding to the specified `NodeID`
	// does not exist.
	//
	// Recovery behavior: Caller SHOULD verify that the `NodeID` is
	// correct and that the node is available and has not been
	// terminated or deleted before retrying.
	Error_ControllerUnpublishVolumeError_NODE_DOES_NOT_EXIST Error_ControllerUnpublishVolumeError_ControllerUnpublishVolumeErrorCode = 6
	// Indicates that the specified `NodeID` is not allowed or
	// understood by the Plugin. More human-readable information MAY
	// be provided in the `error_description` field.
	//
	// Recovery behavior: Caller MUST fix the `NodeID` before
	// retrying.
	Error_ControllerUnpublishVolumeError_INVALID_NODE_ID                       Error_ControllerUnpublishVolumeError_ControllerUnpublishVolumeErrorCode = 7
	Error_ControllerUnpublishVolumeError_VOLUME_NOT_ATTACHED_TO_SPECIFIED_NODE Error_ControllerUnpublishVolumeError_ControllerUnpublishVolumeErrorCode = 8
	// Indicates that the Plugin does not support the operation
	// without a `NodeID`.
	//
	// Recovery behavior: Caller MUST specify the `NodeID` before
	// retrying.
	Error_ControllerUnpublishVolumeError_NODE_ID_REQUIRED Error_ControllerUnpublishVolumeError_ControllerUnpublishVolumeErrorCode = 9
)

func (Error_ControllerUnpublishVolumeError_ControllerUnpublishVolumeErrorCode) EnumDescriptor 

func (Error_ControllerUnpublishVolumeError_ControllerUnpublishVolumeErrorCode) EnumDescriptor() ([]byte, []int)

func (Error_ControllerUnpublishVolumeError_ControllerUnpublishVolumeErrorCode) String 

func (x Error_ControllerUnpublishVolumeError_ControllerUnpublishVolumeErrorCode) String() string

type Error_CreateVolumeError 

type Error_CreateVolumeError struct {
	// Machine parsable error code.
	ErrorCode Error_CreateVolumeError_CreateVolumeErrorCode `` /* 137-byte string literal not displayed */
	// Human readable description of error, possibly with additional
	// information. This string maybe surfaced by CO to end users.
	ErrorDescription string `protobuf:"bytes,2,opt,name=error_description,json=errorDescription" json:"error_description,omitempty"`
}

`CreateVolume` specific error.

func (*Error_CreateVolumeError) Descriptor 

func (*Error_CreateVolumeError) Descriptor() ([]byte, []int)

func (*Error_CreateVolumeError) GetErrorCode 

func (m *Error_CreateVolumeError) GetErrorCode() Error_CreateVolumeError_CreateVolumeErrorCode

func (*Error_CreateVolumeError) GetErrorDescription 

func (m *Error_CreateVolumeError) GetErrorDescription() string

func (*Error_CreateVolumeError) ProtoMessage 

func (*Error_CreateVolumeError) ProtoMessage()

func (*Error_CreateVolumeError) Reset 

func (m *Error_CreateVolumeError) Reset()

func (*Error_CreateVolumeError) String 

func (m *Error_CreateVolumeError) String() string

type Error_CreateVolumeError_ 

type Error_CreateVolumeError_ struct {
	CreateVolumeError *Error_CreateVolumeError `protobuf:"bytes,2,opt,name=create_volume_error,json=createVolumeError,oneof"`
}

type Error_CreateVolumeError_CreateVolumeErrorCode 

type Error_CreateVolumeError_CreateVolumeErrorCode int32
const (
	// Default value for backwards compatibility. SHOULD NOT be
	// returned by Plugins. However, if a Plugin returns a
	// `CreateVolumeErrorCode` code that an older CSI client is not
	// aware of, the client will see this code (the default fallback).
	//
	// Recovery behavior: Caller SHOULD consider updating CSI client
	// to match Plugin CSI version.
	Error_CreateVolumeError_UNKNOWN Error_CreateVolumeError_CreateVolumeErrorCode = 0
	// Indicates that the call is either not implemented by the Plugin
	// or disabled in the Plugin’s current mode of operation.
	//
	// Recovery behavior: Caller MUST not retry; caller MAY call
	// `ControllerGetCapabilities` or `NodeGetCapabilities` to discover
	// Plugin capabilities.
	Error_CreateVolumeError_CALL_NOT_IMPLEMENTED Error_CreateVolumeError_CreateVolumeErrorCode = 1
	// Indicates that there is a already an operation pending for the
	// specified volume. In general the Cluster Orchestrator (CO) is
	// responsible for ensuring that there is no more than one call
	// “in-flight” per volume at a given time. However, in some
	// circumstances, the CO MAY lose state (for example when the CO
	// crashes and restarts), and MAY issue multiple calls
	// simultaneously for the same volume. The Plugin, SHOULD handle
	// this as gracefully as possible, and MAY return this error code
	// to reject secondary calls.
	//
	// Recovery behavior: Caller SHOULD ensure that there are no other
	// calls pending for the specified volume, and then retry with
	// exponential back off.
	Error_CreateVolumeError_OPERATION_PENDING_FOR_VOLUME Error_CreateVolumeError_CreateVolumeErrorCode = 2
	// Indicates that the specified volume name is not allowed by the
	// Plugin. More human-readable information MAY be provided in the
	// `error_description` field.
	//
	// Recovery behavior: Caller MUST fix the name before retrying.
	Error_CreateVolumeError_INVALID_VOLUME_NAME Error_CreateVolumeError_CreateVolumeErrorCode = 3
	// Indicates that the capacity range is not allowed by the Plugin.
	// More human-readable information MAY be provided in the
	// `error_description` field.
	//
	// Recovery behavior: Caller MUST fix the capacity range before //
	// retrying.
	Error_CreateVolumeError_UNSUPPORTED_CAPACITY_RANGE Error_CreateVolumeError_CreateVolumeErrorCode = 4
	// Indicates that a volume corresponding to the specified volume
	// name already exists.
	//
	// Recovery behavior: Caller MAY assume the `CreateVolume`
	// call succeeded.
	Error_CreateVolumeError_VOLUME_ALREADY_EXISTS Error_CreateVolumeError_CreateVolumeErrorCode = 5
	// Indicates that a key in the opaque key/value parameters field
	// is not supported by the Plugin. More human-readable information
	// MAY be provided in the `error_description` field. This MAY
	// occur, for example, due to caller error, Plugin version skew, etc.
	//
	// Recovery behavior: Caller MUST remove the unsupported key/value
	// pair from the list of parameters before retrying.
	Error_CreateVolumeError_UNSUPPORTED_PARAMETER_KEY Error_CreateVolumeError_CreateVolumeErrorCode = 6
	// Indicates that a value in one of the opaque key/value pairs
	// parameter contains invalid data. More human-readable
	// information (such as the corresponding key) MAY be provided in
	// the `error_description` field.
	//
	// Recovery behavior: Caller MUST fix the invalid value before
	// retrying.
	Error_CreateVolumeError_INVALID_PARAMETER_VALUE Error_CreateVolumeError_CreateVolumeErrorCode = 7
)

func (Error_CreateVolumeError_CreateVolumeErrorCode) EnumDescriptor 

func (Error_CreateVolumeError_CreateVolumeErrorCode) EnumDescriptor() ([]byte, []int)

func (Error_CreateVolumeError_CreateVolumeErrorCode) String 

func (x Error_CreateVolumeError_CreateVolumeErrorCode) String() string

type Error_DeleteVolumeError 

type Error_DeleteVolumeError struct {
	// Machine parsable error code.
	ErrorCode Error_DeleteVolumeError_DeleteVolumeErrorCode `` /* 137-byte string literal not displayed */
	// Human readable description of error, possibly with additional
	// information. This string maybe surfaced by CO to end users.
	ErrorDescription string `protobuf:"bytes,2,opt,name=error_description,json=errorDescription" json:"error_description,omitempty"`
}

`DeleteVolume` specific error.

func (*Error_DeleteVolumeError) Descriptor 

func (*Error_DeleteVolumeError) Descriptor() ([]byte, []int)

func (*Error_DeleteVolumeError) GetErrorCode 

func (m *Error_DeleteVolumeError) GetErrorCode() Error_DeleteVolumeError_DeleteVolumeErrorCode

func (*Error_DeleteVolumeError) GetErrorDescription 

func (m *Error_DeleteVolumeError) GetErrorDescription() string

func (*Error_DeleteVolumeError) ProtoMessage 

func (*Error_DeleteVolumeError) ProtoMessage()

func (*Error_DeleteVolumeError) Reset 

func (m *Error_DeleteVolumeError) Reset()

func (*Error_DeleteVolumeError) String 

func (m *Error_DeleteVolumeError) String() string

type Error_DeleteVolumeError_ 

type Error_DeleteVolumeError_ struct {
	DeleteVolumeError *Error_DeleteVolumeError `protobuf:"bytes,3,opt,name=delete_volume_error,json=deleteVolumeError,oneof"`
}

type Error_DeleteVolumeError_DeleteVolumeErrorCode 

type Error_DeleteVolumeError_DeleteVolumeErrorCode int32
const (
	// Default value for backwards compatibility. SHOULD NOT be
	// returned by Plugins. However, if a Plugin returns a
	// `DeleteVolumeErrorCode` code that an older CSI client is not
	// aware of, the client will see this code (the default fallback).
	//
	// Recovery behavior: Caller SHOULD consider updating CSI client
	// to match Plugin CSI version.
	Error_DeleteVolumeError_UNKNOWN Error_DeleteVolumeError_DeleteVolumeErrorCode = 0
	// Indicates that the call is either not implemented by the Plugin
	// or disabled in the Plugin’s current mode of operation.
	//
	// Recovery behavior: Caller MUST not retry; caller MAY call
	// `ControllerGetCapabilities` or `NodeGetCapabilities` to
	// discover Plugin capabilities.
	Error_DeleteVolumeError_CALL_NOT_IMPLEMENTED Error_DeleteVolumeError_DeleteVolumeErrorCode = 1
	// Indicates that there is a already an operation pending for the
	// specified volume. In general the Cluster Orchestrator (CO) is
	// responsible for ensuring that there is no more than one call
	// “in-flight” per volume at a given time. However, in some
	// circumstances, the CO MAY lose state (for example when the CO
	// crashes and restarts), and MAY issue multiple calls
	// simultaneously for the same volume. The Plugin, SHOULD handle
	// this as gracefully as possible, and MAY return this error code
	// to reject secondary calls.
	//
	// Recovery behavior: Caller SHOULD ensure that there are no other
	// calls pending for the specified volume, and then retry with
	// exponential back off.
	Error_DeleteVolumeError_OPERATION_PENDING_FOR_VOLUME Error_DeleteVolumeError_DeleteVolumeErrorCode = 2
	// Indicates that the specified `VolumeID` is not allowed or
	// understood by the Plugin. More human-readable information MAY
	// be provided in the `error_description` field.
	//
	// Recovery behavior: Caller MUST fix the `VolumeID` before
	// retrying.
	Error_DeleteVolumeError_INVALID_VOLUME_ID Error_DeleteVolumeError_DeleteVolumeErrorCode = 3
	// Indicates that the specified `VolumeMetadata` is not allowed or
	// understood by the Plugin. More human-readable information MAY
	// be provided in the `error_description` field.
	//
	// Recovery behavior: Caller MUST fix the `VolumeMetadata` before
	// retrying.
	Error_DeleteVolumeError_INVALID_VOLUME_METADATA Error_DeleteVolumeError_DeleteVolumeErrorCode = 4
	// Indicates that a volume corresponding to the specified
	// `VolumeID` does not exist.
	//
	// Recovery behavior: Caller SHOULD assume the `DeleteVolume` call
	// succeeded.
	Error_DeleteVolumeError_VOLUME_DOES_NOT_EXIST Error_DeleteVolumeError_DeleteVolumeErrorCode = 5
)

func (Error_DeleteVolumeError_DeleteVolumeErrorCode) EnumDescriptor 

func (Error_DeleteVolumeError_DeleteVolumeErrorCode) EnumDescriptor() ([]byte, []int)

func (Error_DeleteVolumeError_DeleteVolumeErrorCode) String 

func (x Error_DeleteVolumeError_DeleteVolumeErrorCode) String() string

type Error_GeneralError 

type Error_GeneralError struct {
	// Machine parsable error code.
	ErrorCode Error_GeneralError_GeneralErrorCode `` /* 127-byte string literal not displayed */
	// When set to true, `caller_must_not_retry` indicates that the
	// caller MUST not retry the same call again. This MAY be because
	// the call is deemed invalid by the Plugin and no amount of retries
	// will cause it to succeed. If this value is false, the caller MAY
	// reissue the same call, but SHOULD implement exponential backoff
	// on retires.
	CallerMustNotRetry bool `protobuf:"varint,2,opt,name=caller_must_not_retry,json=callerMustNotRetry" json:"caller_must_not_retry,omitempty"`
	// Human readable description of error, possibly with additional
	// information. This string MAY be surfaced by CO to end users.
	ErrorDescription string `protobuf:"bytes,3,opt,name=error_description,json=errorDescription" json:"error_description,omitempty"`
}

General Error that MAY be returned by any RPC.

func (*Error_GeneralError) Descriptor 

func (*Error_GeneralError) Descriptor() ([]byte, []int)

func (*Error_GeneralError) GetCallerMustNotRetry 

func (m *Error_GeneralError) GetCallerMustNotRetry() bool

func (*Error_GeneralError) GetErrorCode 

func (m *Error_GeneralError) GetErrorCode() Error_GeneralError_GeneralErrorCode

func (*Error_GeneralError) GetErrorDescription 

func (m *Error_GeneralError) GetErrorDescription() string

func (*Error_GeneralError) ProtoMessage 

func (*Error_GeneralError) ProtoMessage()

func (*Error_GeneralError) Reset 

func (m *Error_GeneralError) Reset()

func (*Error_GeneralError) String 

func (m *Error_GeneralError) String() string

type Error_GeneralError_ 

type Error_GeneralError_ struct {
	GeneralError *Error_GeneralError `protobuf:"bytes,1,opt,name=general_error,json=generalError,oneof"`
}

type Error_GeneralError_GeneralErrorCode 

type Error_GeneralError_GeneralErrorCode int32
const (
	// Default value for backwards compatibility. SHOULD NOT be
	// returned by Plugins. However, if a Plugin returns a
	// `GeneralErrorCode` code that an older CSI client is not aware
	// of, the client will see this code (the default fallback).
	//
	// Recovery behavior: Caller SHOULD consider updating CSI client
	// to match Plugin CSI version.
	Error_GeneralError_UNKNOWN Error_GeneralError_GeneralErrorCode = 0
	// Indicates that an undefined error occurred. More human-readable
	// information MAY be provided in the `error_description` field.
	// The `caller_must_not_retry` field MUST be set appropriately by
	// the Plugin to provide callers expected recovery behavior.
	//
	// Recovery behavior: Caller MAY retry (with exponential backoff),
	// if `caller_must_not_retry` is set to false. Otherwise, the
	// caller MUST not reissue the same request.
	Error_GeneralError_UNDEFINED Error_GeneralError_GeneralErrorCode = 1
	// Indicates that the version specified in the request is not
	// supported by the Plugin. The `caller_must_not_retry` field MUST
	// be set to true.
	//
	// Recovery behavior: Caller MUST NOT retry; caller SHOULD call
	// `GetSupportedVersions` to discover which CSI versions the Plugin
	// supports.
	Error_GeneralError_UNSUPPORTED_REQUEST_VERSION Error_GeneralError_GeneralErrorCode = 2
	// Indicates that a required field is missing from the request.
	// More human-readable information MAY be provided in the
	// `error_description` field. The `caller_must_not_retry` field
	// MUST be set to true.
	//
	// Recovery behavior: Caller MUST fix the request by adding the
	// missing required field before retrying.
	Error_GeneralError_MISSING_REQUIRED_FIELD Error_GeneralError_GeneralErrorCode = 3
)

func (Error_GeneralError_GeneralErrorCode) EnumDescriptor 

func (Error_GeneralError_GeneralErrorCode) EnumDescriptor() ([]byte, []int)

func (Error_GeneralError_GeneralErrorCode) String 

func (x Error_GeneralError_GeneralErrorCode) String() string

type Error_GetNodeIDError 

type Error_GetNodeIDError struct {
	ErrorCode        Error_GetNodeIDError_GetNodeIDErrorCode `` /* 131-byte string literal not displayed */
	ErrorDescription string                                  `protobuf:"bytes,2,opt,name=error_description,json=errorDescription" json:"error_description,omitempty"`
}

`GetNodeID` specific error.

func (*Error_GetNodeIDError) Descriptor 

func (*Error_GetNodeIDError) Descriptor() ([]byte, []int)

func (*Error_GetNodeIDError) GetErrorCode 

func (m *Error_GetNodeIDError) GetErrorCode() Error_GetNodeIDError_GetNodeIDErrorCode

func (*Error_GetNodeIDError) GetErrorDescription 

func (m *Error_GetNodeIDError) GetErrorDescription() string

func (*Error_GetNodeIDError) ProtoMessage 

func (*Error_GetNodeIDError) ProtoMessage()

func (*Error_GetNodeIDError) Reset 

func (m *Error_GetNodeIDError) Reset()

func (*Error_GetNodeIDError) String 

func (m *Error_GetNodeIDError) String() string

type Error_GetNodeIDError_GetNodeIDErrorCode 

type Error_GetNodeIDError_GetNodeIDErrorCode int32
const (
	// Default value for backwards compatibility. SHOULD NOT be
	// returned by Plugins. However, if a Plugin returns a
	// `GetNodeIDErrorCode` code that an older CSI client is not aware
	// of, the client will see this code (the default fallback).
	//
	// Recovery behavior: Caller SHOULD consider updating CSI client
	// to match Plugin CSI version.
	Error_GetNodeIDError_UNKNOWN                          Error_GetNodeIDError_GetNodeIDErrorCode = 0
	Error_GetNodeIDError_BAD_PLUGIN_CONFIG                Error_GetNodeIDError_GetNodeIDErrorCode = 1
	Error_GetNodeIDError_MISSING_REQUIRED_HOST_DEPENDENCY Error_GetNodeIDError_GetNodeIDErrorCode = 2
)

func (Error_GetNodeIDError_GetNodeIDErrorCode) EnumDescriptor 

func (Error_GetNodeIDError_GetNodeIDErrorCode) EnumDescriptor() ([]byte, []int)

func (Error_GetNodeIDError_GetNodeIDErrorCode) String 

func (x Error_GetNodeIDError_GetNodeIDErrorCode) String() string

type Error_GetNodeIdError 

type Error_GetNodeIdError struct {
	GetNodeIdError *Error_GetNodeIDError `protobuf:"bytes,10,opt,name=get_node_id_error,json=getNodeIdError,oneof"`
}

type Error_NodePublishVolumeError 

type Error_NodePublishVolumeError struct {
	ErrorCode        Error_NodePublishVolumeError_NodePublishVolumeErrorCode `` /* 147-byte string literal not displayed */
	ErrorDescription string                                                  `protobuf:"bytes,2,opt,name=error_description,json=errorDescription" json:"error_description,omitempty"`
}

`NodePublishVolume` specific error.

func (*Error_NodePublishVolumeError) Descriptor 

func (*Error_NodePublishVolumeError) Descriptor() ([]byte, []int)

func (*Error_NodePublishVolumeError) GetErrorCode 

func (m *Error_NodePublishVolumeError) GetErrorCode() Error_NodePublishVolumeError_NodePublishVolumeErrorCode

func (*Error_NodePublishVolumeError) GetErrorDescription 

func (m *Error_NodePublishVolumeError) GetErrorDescription() string

func (*Error_NodePublishVolumeError) ProtoMessage 

func (*Error_NodePublishVolumeError) ProtoMessage()

func (*Error_NodePublishVolumeError) Reset 

func (m *Error_NodePublishVolumeError) Reset()

func (*Error_NodePublishVolumeError) String 

func (m *Error_NodePublishVolumeError) String() string

type Error_NodePublishVolumeError_ 

type Error_NodePublishVolumeError_ struct {
	NodePublishVolumeError *Error_NodePublishVolumeError `protobuf:"bytes,7,opt,name=node_publish_volume_error,json=nodePublishVolumeError,oneof"`
}

type Error_NodePublishVolumeError_NodePublishVolumeErrorCode 

type Error_NodePublishVolumeError_NodePublishVolumeErrorCode int32
const (
	// Default value for backwards compatibility. SHOULD NOT be
	// returned by Plugins. However, if a Plugin returns a
	// `NodePublishVolumeErrorCode` code that an older CSI
	// client is not aware of, the client will see this code (the
	// default fallback).
	//
	// Recovery behavior: Caller SHOULD consider updating CSI client
	// to match Plugin CSI version.
	Error_NodePublishVolumeError_UNKNOWN Error_NodePublishVolumeError_NodePublishVolumeErrorCode = 0
	// Indicates that there is a already an operation pending for the
	// specified volume. In general the Cluster Orchestrator (CO) is
	// responsible for ensuring that there is no more than one call
	// “in-flight” per volume at a given time. However, in some
	// circumstances, the CO MAY lose state (for example when the CO
	// crashes and restarts), and MAY issue multiple calls
	// simultaneously for the same volume. The Plugin, SHOULD handle
	// this as gracefully as possible, and MAY return this error code
	// to reject secondary calls.
	//
	// Recovery behavior: Caller SHOULD ensure that there are no other
	// calls pending for the specified volume, and then retry with
	// exponential back off.
	Error_NodePublishVolumeError_OPERATION_PENDING_FOR_VOLUME Error_NodePublishVolumeError_NodePublishVolumeErrorCode = 1
	// Indicates that a volume corresponding to the specified
	// `VolumeID` does not exist.
	//
	// Recovery behavior: Caller SHOULD verify that the `VolumeID` is
	// correct and that the volume is accessible and has not been
	// deleted before retrying with exponential back off.
	Error_NodePublishVolumeError_VOLUME_DOES_NOT_EXIST   Error_NodePublishVolumeError_NodePublishVolumeErrorCode = 2
	Error_NodePublishVolumeError_UNSUPPORTED_MOUNT_FLAGS Error_NodePublishVolumeError_NodePublishVolumeErrorCode = 3
	Error_NodePublishVolumeError_UNSUPPORTED_VOLUME_TYPE Error_NodePublishVolumeError_NodePublishVolumeErrorCode = 4
	Error_NodePublishVolumeError_UNSUPPORTED_FS_TYPE     Error_NodePublishVolumeError_NodePublishVolumeErrorCode = 5
	Error_NodePublishVolumeError_MOUNT_ERROR             Error_NodePublishVolumeError_NodePublishVolumeErrorCode = 6
	// Indicates that the specified `VolumeID` is not allowed or
	// understood by the Plugin. More human-readable information MAY
	// be provided in the `error_description` field.
	//
	// Recovery behavior: Caller MUST fix the `VolumeID` before
	// retrying.
	Error_NodePublishVolumeError_INVALID_VOLUME_ID Error_NodePublishVolumeError_NodePublishVolumeErrorCode = 7
)

func (Error_NodePublishVolumeError_NodePublishVolumeErrorCode) EnumDescriptor 

func (Error_NodePublishVolumeError_NodePublishVolumeErrorCode) EnumDescriptor() ([]byte, []int)

func (Error_NodePublishVolumeError_NodePublishVolumeErrorCode) String 

func (x Error_NodePublishVolumeError_NodePublishVolumeErrorCode) String() string

type Error_NodeUnpublishVolumeError 

type Error_NodeUnpublishVolumeError struct {
	ErrorCode        Error_NodeUnpublishVolumeError_NodeUnpublishVolumeErrorCode `` /* 151-byte string literal not displayed */
	ErrorDescription string                                                      `protobuf:"bytes,2,opt,name=error_description,json=errorDescription" json:"error_description,omitempty"`
}

`NodeUnpublishVolume` specific error.

func (*Error_NodeUnpublishVolumeError) Descriptor 

func (*Error_NodeUnpublishVolumeError) Descriptor() ([]byte, []int)

func (*Error_NodeUnpublishVolumeError) GetErrorCode 

func (m *Error_NodeUnpublishVolumeError) GetErrorCode() Error_NodeUnpublishVolumeError_NodeUnpublishVolumeErrorCode

func (*Error_NodeUnpublishVolumeError) GetErrorDescription 

func (m *Error_NodeUnpublishVolumeError) GetErrorDescription() string

func (*Error_NodeUnpublishVolumeError) ProtoMessage 

func (*Error_NodeUnpublishVolumeError) ProtoMessage()

func (*Error_NodeUnpublishVolumeError) Reset 

func (m *Error_NodeUnpublishVolumeError) Reset()

func (*Error_NodeUnpublishVolumeError) String 

func (m *Error_NodeUnpublishVolumeError) String() string

type Error_NodeUnpublishVolumeError_ 

type Error_NodeUnpublishVolumeError_ struct {
	NodeUnpublishVolumeError *Error_NodeUnpublishVolumeError `protobuf:"bytes,8,opt,name=node_unpublish_volume_error,json=nodeUnpublishVolumeError,oneof"`
}

type Error_NodeUnpublishVolumeError_NodeUnpublishVolumeErrorCode 

type Error_NodeUnpublishVolumeError_NodeUnpublishVolumeErrorCode int32
const (
	// Default value for backwards compatibility. SHOULD NOT be
	// returned by Plugins. However, if a Plugin returns a
	// `NodeUnpublishVolumeErrorCode` code that an older CSI
	// client is not aware of, the client will see this code (the
	// default fallback).
	//
	// Recovery behavior: Caller SHOULD consider updating CSI client
	// to match Plugin CSI version.
	Error_NodeUnpublishVolumeError_UNKNOWN Error_NodeUnpublishVolumeError_NodeUnpublishVolumeErrorCode = 0
	// Indicates that there is a already an operation pending for the
	// specified volume. In general the Cluster Orchestrator (CO) is
	// responsible for ensuring that there is no more than one call
	// “in-flight” per volume at a given time. However, in some
	// circumstances, the CO MAY lose state (for example when the CO
	// crashes and restarts), and MAY issue multiple calls
	// simultaneously for the same volume. The Plugin, SHOULD handle
	// this as gracefully as possible, and MAY return this error code
	// to reject secondary calls.
	//
	// Recovery behavior: Caller SHOULD ensure that there are no other
	// calls pending for the specified volume, and then retry with
	// exponential back off.
	Error_NodeUnpublishVolumeError_OPERATION_PENDING_FOR_VOLUME Error_NodeUnpublishVolumeError_NodeUnpublishVolumeErrorCode = 1
	// Indicates that a volume corresponding to the specified
	// `VolumeID` does not exist.
	//
	// Recovery behavior: Caller SHOULD verify that the `VolumeID` is
	// correct and that the volume is accessible and has not been
	// deleted before retrying with exponential back off.
	Error_NodeUnpublishVolumeError_VOLUME_DOES_NOT_EXIST Error_NodeUnpublishVolumeError_NodeUnpublishVolumeErrorCode = 2
	Error_NodeUnpublishVolumeError_UNMOUNT_ERROR         Error_NodeUnpublishVolumeError_NodeUnpublishVolumeErrorCode = 3
	// Indicates that the specified `VolumeID` is not allowed or
	// understood by the Plugin. More human-readable information MAY
	// be provided in the `error_description` field.
	//
	// Recovery behavior: Caller MUST fix the `VolumeID` before
	// retrying.
	Error_NodeUnpublishVolumeError_INVALID_VOLUME_ID Error_NodeUnpublishVolumeError_NodeUnpublishVolumeErrorCode = 4
)

func (Error_NodeUnpublishVolumeError_NodeUnpublishVolumeErrorCode) EnumDescriptor 

func (Error_NodeUnpublishVolumeError_NodeUnpublishVolumeErrorCode) EnumDescriptor() ([]byte, []int)

func (Error_NodeUnpublishVolumeError_NodeUnpublishVolumeErrorCode) String 

func (x Error_NodeUnpublishVolumeError_NodeUnpublishVolumeErrorCode) String() string

type Error_ProbeNodeError 

type Error_ProbeNodeError struct {
	ErrorCode        Error_ProbeNodeError_ProbeNodeErrorCode `` /* 131-byte string literal not displayed */
	ErrorDescription string                                  `protobuf:"bytes,2,opt,name=error_description,json=errorDescription" json:"error_description,omitempty"`
}

`ProbeNode` specific error.

func (*Error_ProbeNodeError) Descriptor 

func (*Error_ProbeNodeError) Descriptor() ([]byte, []int)

func (*Error_ProbeNodeError) GetErrorCode 

func (m *Error_ProbeNodeError) GetErrorCode() Error_ProbeNodeError_ProbeNodeErrorCode

func (*Error_ProbeNodeError) GetErrorDescription 

func (m *Error_ProbeNodeError) GetErrorDescription() string

func (*Error_ProbeNodeError) ProtoMessage 

func (*Error_ProbeNodeError) ProtoMessage()

func (*Error_ProbeNodeError) Reset 

func (m *Error_ProbeNodeError) Reset()

func (*Error_ProbeNodeError) String 

func (m *Error_ProbeNodeError) String() string

type Error_ProbeNodeError_ 

type Error_ProbeNodeError_ struct {
	ProbeNodeError *Error_ProbeNodeError `protobuf:"bytes,9,opt,name=probe_node_error,json=probeNodeError,oneof"`
}

type Error_ProbeNodeError_ProbeNodeErrorCode 

type Error_ProbeNodeError_ProbeNodeErrorCode int32
const (
	// Default value for backwards compatibility. SHOULD NOT be
	// returned by Plugins. However, if a Plugin returns a
	// `ProbeNodeErrorCode` code that an older CSI
	// client is not aware of, the client will see this code (the
	// default fallback).
	//
	// Recovery behavior: Caller SHOULD consider updating CSI client
	// to match Plugin CSI version.
	Error_ProbeNodeError_UNKNOWN                          Error_ProbeNodeError_ProbeNodeErrorCode = 0
	Error_ProbeNodeError_BAD_PLUGIN_CONFIG                Error_ProbeNodeError_ProbeNodeErrorCode = 1
	Error_ProbeNodeError_MISSING_REQUIRED_HOST_DEPENDENCY Error_ProbeNodeError_ProbeNodeErrorCode = 2
)

func (Error_ProbeNodeError_ProbeNodeErrorCode) EnumDescriptor 

func (Error_ProbeNodeError_ProbeNodeErrorCode) EnumDescriptor() ([]byte, []int)

func (Error_ProbeNodeError_ProbeNodeErrorCode) String 

func (x Error_ProbeNodeError_ProbeNodeErrorCode) String() string

type Error_ValidateVolumeCapabilitiesError 

type Error_ValidateVolumeCapabilitiesError struct {
	ErrorCode        Error_ValidateVolumeCapabilitiesError_ValidateVolumeCapabilitiesErrorCode `` /* 165-byte string literal not displayed */
	ErrorDescription string                                                                    `protobuf:"bytes,2,opt,name=error_description,json=errorDescription" json:"error_description,omitempty"`
}

`ValidateVolumeCapabilities` specific error.

func (*Error_ValidateVolumeCapabilitiesError) Descriptor 

func (*Error_ValidateVolumeCapabilitiesError) Descriptor() ([]byte, []int)

func (*Error_ValidateVolumeCapabilitiesError) GetErrorCode 

func (m *Error_ValidateVolumeCapabilitiesError) GetErrorCode() Error_ValidateVolumeCapabilitiesError_ValidateVolumeCapabilitiesErrorCode

func (*Error_ValidateVolumeCapabilitiesError) GetErrorDescription 

func (m *Error_ValidateVolumeCapabilitiesError) GetErrorDescription() string

func (*Error_ValidateVolumeCapabilitiesError) ProtoMessage 

func (*Error_ValidateVolumeCapabilitiesError) ProtoMessage()

func (*Error_ValidateVolumeCapabilitiesError) Reset 

func (m *Error_ValidateVolumeCapabilitiesError) Reset()

func (*Error_ValidateVolumeCapabilitiesError) String 

func (m *Error_ValidateVolumeCapabilitiesError) String() string

type Error_ValidateVolumeCapabilitiesError_ 

type Error_ValidateVolumeCapabilitiesError_ struct {
	ValidateVolumeCapabilitiesError *Error_ValidateVolumeCapabilitiesError `protobuf:"bytes,6,opt,name=validate_volume_capabilities_error,json=validateVolumeCapabilitiesError,oneof"`
}

type Error_ValidateVolumeCapabilitiesError_ValidateVolumeCapabilitiesErrorCode 

type Error_ValidateVolumeCapabilitiesError_ValidateVolumeCapabilitiesErrorCode int32
const (
	// Default value for backwards compatibility. SHOULD NOT be
	// returned by Plugins. However, if a Plugin returns a
	// `ValidateVolumeCapabilitiesErrorCode` code that an older CSI
	// client is not aware of, the client will see this code (the
	// default fallback).
	//
	// Recovery behavior: Caller SHOULD consider updating CSI client
	// to match Plugin CSI version.
	Error_ValidateVolumeCapabilitiesError_UNKNOWN Error_ValidateVolumeCapabilitiesError_ValidateVolumeCapabilitiesErrorCode = 0
	// Indicates that a volume corresponding to the specified
	// `VolumeInfo` does not exist.
	//
	// Recovery behavior: Caller SHOULD verify that the `VolumeInfo`
	// is correct and that the volume is accessable and has not been
	// deleted before retrying.
	Error_ValidateVolumeCapabilitiesError_VOLUME_DOES_NOT_EXIST   Error_ValidateVolumeCapabilitiesError_ValidateVolumeCapabilitiesErrorCode = 1
	Error_ValidateVolumeCapabilitiesError_UNSUPPORTED_MOUNT_FLAGS Error_ValidateVolumeCapabilitiesError_ValidateVolumeCapabilitiesErrorCode = 2
	Error_ValidateVolumeCapabilitiesError_UNSUPPORTED_VOLUME_TYPE Error_ValidateVolumeCapabilitiesError_ValidateVolumeCapabilitiesErrorCode = 3
	Error_ValidateVolumeCapabilitiesError_UNSUPPORTED_FS_TYPE     Error_ValidateVolumeCapabilitiesError_ValidateVolumeCapabilitiesErrorCode = 4
	// Indicates that the specified `VolumeInfo` is not allowed or
	// understood by the Plugin. More human-readable information MAY
	// be provided in the `error_description` field.
	//
	// Recovery behavior: Caller MUST fix the `VolumeInfo` before
	// retrying.
	Error_ValidateVolumeCapabilitiesError_INVALID_VOLUME_INFO Error_ValidateVolumeCapabilitiesError_ValidateVolumeCapabilitiesErrorCode = 5
)

func (Error_ValidateVolumeCapabilitiesError_ValidateVolumeCapabilitiesErrorCode) EnumDescriptor 

func (Error_ValidateVolumeCapabilitiesError_ValidateVolumeCapabilitiesErrorCode) EnumDescriptor() ([]byte, []int)

func (Error_ValidateVolumeCapabilitiesError_ValidateVolumeCapabilitiesErrorCode) String 

func (x Error_ValidateVolumeCapabilitiesError_ValidateVolumeCapabilitiesErrorCode) String() string

type GetCapacityRequest 

type GetCapacityRequest struct {
	// The API version assumed by the CO. This is a REQUIRED field.
	Version *Version `protobuf:"bytes,1,opt,name=version" json:"version,omitempty"`
	// If specified, the Plugin SHALL report the capacity of the storage
	// that can be used to provision volumes that satisfy ALL of the
	// specified `volume_capabilities`. These are the same
	// `volume_capabilities` the CO will use in `CreateVolumeRequest`.
	// This field is OPTIONAL.
	VolumeCapabilities []*VolumeCapability `protobuf:"bytes,2,rep,name=volume_capabilities,json=volumeCapabilities" json:"volume_capabilities,omitempty"`
	// If specified, the Plugin SHALL report the capacity of the storage
	// that can be used to provision volumes with the given Plugin
	// specific `parameters`. These are the same `parameters` the CO will
	// use in `CreateVolumeRequest`. This field is OPTIONAL.
	Parameters map[string]string `` /* 140-byte string literal not displayed */
}

////// //////

func (*GetCapacityRequest) Descriptor 

func (*GetCapacityRequest) Descriptor() ([]byte, []int)

func (*GetCapacityRequest) GetParameters 

func (m *GetCapacityRequest) GetParameters() map[string]string

func (*GetCapacityRequest) GetVersion 

func (m *GetCapacityRequest) GetVersion() *Version

func (*GetCapacityRequest) GetVolumeCapabilities 

func (m *GetCapacityRequest) GetVolumeCapabilities() []*VolumeCapability

func (*GetCapacityRequest) ProtoMessage 

func (*GetCapacityRequest) ProtoMessage()

func (*GetCapacityRequest) Reset 

func (m *GetCapacityRequest) Reset()

func (*GetCapacityRequest) String 

func (m *GetCapacityRequest) String() string

type GetCapacityResponse 

type GetCapacityResponse struct {
	// One of the following fields MUST be specified.
	//
	// Types that are valid to be assigned to Reply:
	//	*GetCapacityResponse_Result_
	//	*GetCapacityResponse_Error
	Reply isGetCapacityResponse_Reply `protobuf_oneof:"reply"`
}

func (*GetCapacityResponse) Descriptor 

func (*GetCapacityResponse) Descriptor() ([]byte, []int)

func (*GetCapacityResponse) GetError 

func (m *GetCapacityResponse) GetError() *Error

func (*GetCapacityResponse) GetReply 

func (m *GetCapacityResponse) GetReply() isGetCapacityResponse_Reply

func (*GetCapacityResponse) GetResult 

func (m *GetCapacityResponse) GetResult() *GetCapacityResponse_Result

func (*GetCapacityResponse) ProtoMessage 

func (*GetCapacityResponse) ProtoMessage()

func (*GetCapacityResponse) Reset 

func (m *GetCapacityResponse) Reset()

func (*GetCapacityResponse) String 

func (m *GetCapacityResponse) String() string

func (*GetCapacityResponse) XXX_OneofFuncs 

func (*GetCapacityResponse) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

type GetCapacityResponse_Error 

type GetCapacityResponse_Error struct {
	Error *Error `protobuf:"bytes,2,opt,name=error,oneof"`
}

type GetCapacityResponse_Result 

type GetCapacityResponse_Result struct {
	// The available capacity of the storage that can be used to
	// provision volumes. If `volume_capabilities` or `parameters` is
	// specified in the request, the Plugin SHALL take those into
	// consideration when calculating the available capacity of the
	// storage. This field is REQUIRED.
	AvailableCapacity uint64 `protobuf:"varint,1,opt,name=available_capacity,json=availableCapacity" json:"available_capacity,omitempty"`
}

func (*GetCapacityResponse_Result) Descriptor 

func (*GetCapacityResponse_Result) Descriptor() ([]byte, []int)

func (*GetCapacityResponse_Result) GetAvailableCapacity 

func (m *GetCapacityResponse_Result) GetAvailableCapacity() uint64

func (*GetCapacityResponse_Result) ProtoMessage 

func (*GetCapacityResponse_Result) ProtoMessage()

func (*GetCapacityResponse_Result) Reset 

func (m *GetCapacityResponse_Result) Reset()

func (*GetCapacityResponse_Result) String 

func (m *GetCapacityResponse_Result) String() string

type GetCapacityResponse_Result_ 

type GetCapacityResponse_Result_ struct {
	Result *GetCapacityResponse_Result `protobuf:"bytes,1,opt,name=result,oneof"`
}

type GetNodeIDRequest 

type GetNodeIDRequest struct {
	// The API version assumed by the CO. This is a REQUIRED field.
	Version *Version `protobuf:"bytes,1,opt,name=version" json:"version,omitempty"`
}

////// //////

func (*GetNodeIDRequest) Descriptor 

func (*GetNodeIDRequest) Descriptor() ([]byte, []int)

func (*GetNodeIDRequest) GetVersion 

func (m *GetNodeIDRequest) GetVersion() *Version

func (*GetNodeIDRequest) ProtoMessage 

func (*GetNodeIDRequest) ProtoMessage()

func (*GetNodeIDRequest) Reset 

func (m *GetNodeIDRequest) Reset()

func (*GetNodeIDRequest) String 

func (m *GetNodeIDRequest) String() string

type GetNodeIDResponse 

type GetNodeIDResponse struct {
	// One of the following fields MUST be specified.
	//
	// Types that are valid to be assigned to Reply:
	//	*GetNodeIDResponse_Result_
	//	*GetNodeIDResponse_Error
	Reply isGetNodeIDResponse_Reply `protobuf_oneof:"reply"`
}

func (*GetNodeIDResponse) Descriptor 

func (*GetNodeIDResponse) Descriptor() ([]byte, []int)

func (*GetNodeIDResponse) GetError 

func (m *GetNodeIDResponse) GetError() *Error

func (*GetNodeIDResponse) GetReply 

func (m *GetNodeIDResponse) GetReply() isGetNodeIDResponse_Reply

func (*GetNodeIDResponse) GetResult 

func (m *GetNodeIDResponse) GetResult() *GetNodeIDResponse_Result

func (*GetNodeIDResponse) ProtoMessage 

func (*GetNodeIDResponse) ProtoMessage()

func (*GetNodeIDResponse) Reset 

func (m *GetNodeIDResponse) Reset()

func (*GetNodeIDResponse) String 

func (m *GetNodeIDResponse) String() string

func (*GetNodeIDResponse) XXX_OneofFuncs 

func (*GetNodeIDResponse) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

type GetNodeIDResponse_Error 

type GetNodeIDResponse_Error struct {
	Error *Error `protobuf:"bytes,2,opt,name=error,oneof"`
}

type GetNodeIDResponse_Result 

type GetNodeIDResponse_Result struct {
	// The ID of the node which SHALL be used by CO in
	// `ControllerPublishVolume`. This is an OPTIONAL field. If unset,
	// the CO SHALL leave the `node_id` field unset in
	// `ControllerPublishVolume`.
	NodeId *NodeID `protobuf:"bytes,1,opt,name=node_id,json=nodeId" json:"node_id,omitempty"`
}

func (*GetNodeIDResponse_Result) Descriptor 

func (*GetNodeIDResponse_Result) Descriptor() ([]byte, []int)

func (*GetNodeIDResponse_Result) GetNodeId 

func (m *GetNodeIDResponse_Result) GetNodeId() *NodeID

func (*GetNodeIDResponse_Result) ProtoMessage 

func (*GetNodeIDResponse_Result) ProtoMessage()

func (*GetNodeIDResponse_Result) Reset 

func (m *GetNodeIDResponse_Result) Reset()

func (*GetNodeIDResponse_Result) String 

func (m *GetNodeIDResponse_Result) String() string

type GetNodeIDResponse_Result_ 

type GetNodeIDResponse_Result_ struct {
	Result *GetNodeIDResponse_Result `protobuf:"bytes,1,opt,name=result,oneof"`
}

type GetPluginInfoRequest 

type GetPluginInfoRequest struct {
	// The API version assumed by the CO. This is a REQUIRED field.
	Version *Version `protobuf:"bytes,1,opt,name=version" json:"version,omitempty"`
}

////// //////

func (*GetPluginInfoRequest) Descriptor 

func (*GetPluginInfoRequest) Descriptor() ([]byte, []int)

func (*GetPluginInfoRequest) GetVersion 

func (m *GetPluginInfoRequest) GetVersion() *Version

func (*GetPluginInfoRequest) ProtoMessage 

func (*GetPluginInfoRequest) ProtoMessage()

func (*GetPluginInfoRequest) Reset 

func (m *GetPluginInfoRequest) Reset()

func (*GetPluginInfoRequest) String 

func (m *GetPluginInfoRequest) String() string

type GetPluginInfoResponse 

type GetPluginInfoResponse struct {
	// One of the following fields MUST be specified.
	//
	// Types that are valid to be assigned to Reply:
	//	*GetPluginInfoResponse_Result_
	//	*GetPluginInfoResponse_Error
	Reply isGetPluginInfoResponse_Reply `protobuf_oneof:"reply"`
}

func (*GetPluginInfoResponse) Descriptor 

func (*GetPluginInfoResponse) Descriptor() ([]byte, []int)

func (*GetPluginInfoResponse) GetError 

func (m *GetPluginInfoResponse) GetError() *Error

func (*GetPluginInfoResponse) GetReply 

func (m *GetPluginInfoResponse) GetReply() isGetPluginInfoResponse_Reply

func (*GetPluginInfoResponse) GetResult 

func (m *GetPluginInfoResponse) GetResult() *GetPluginInfoResponse_Result

func (*GetPluginInfoResponse) ProtoMessage 

func (*GetPluginInfoResponse) ProtoMessage()

func (*GetPluginInfoResponse) Reset 

func (m *GetPluginInfoResponse) Reset()

func (*GetPluginInfoResponse) String 

func (m *GetPluginInfoResponse) String() string

func (*GetPluginInfoResponse) XXX_OneofFuncs 

func (*GetPluginInfoResponse) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

type GetPluginInfoResponse_Error 

type GetPluginInfoResponse_Error struct {
	Error *Error `protobuf:"bytes,2,opt,name=error,oneof"`
}

type GetPluginInfoResponse_Result 

type GetPluginInfoResponse_Result struct {
	// This field is REQUIRED.
	Name string `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
	// This field is REQUIRED. Value of this field is opaque to the CO.
	VendorVersion string `protobuf:"bytes,2,opt,name=vendor_version,json=vendorVersion" json:"vendor_version,omitempty"`
	// This field is OPTIONAL. Values are opaque to the CO.
	Manifest map[string]string `` /* 136-byte string literal not displayed */
}

func (*GetPluginInfoResponse_Result) Descriptor 

func (*GetPluginInfoResponse_Result) Descriptor() ([]byte, []int)

func (*GetPluginInfoResponse_Result) GetManifest 

func (m *GetPluginInfoResponse_Result) GetManifest() map[string]string

func (*GetPluginInfoResponse_Result) GetName 

func (m *GetPluginInfoResponse_Result) GetName() string

func (*GetPluginInfoResponse_Result) GetVendorVersion 

func (m *GetPluginInfoResponse_Result) GetVendorVersion() string

func (*GetPluginInfoResponse_Result) ProtoMessage 

func (*GetPluginInfoResponse_Result) ProtoMessage()

func (*GetPluginInfoResponse_Result) Reset 

func (m *GetPluginInfoResponse_Result) Reset()

func (*GetPluginInfoResponse_Result) String 

func (m *GetPluginInfoResponse_Result) String() string

type GetPluginInfoResponse_Result_ 

type GetPluginInfoResponse_Result_ struct {
	Result *GetPluginInfoResponse_Result `protobuf:"bytes,1,opt,name=result,oneof"`
}

type GetSupportedVersionsRequest 

type GetSupportedVersionsRequest struct {
}

////// //////

func (*GetSupportedVersionsRequest) Descriptor 

func (*GetSupportedVersionsRequest) Descriptor() ([]byte, []int)

func (*GetSupportedVersionsRequest) ProtoMessage 

func (*GetSupportedVersionsRequest) ProtoMessage()

func (*GetSupportedVersionsRequest) Reset 

func (m *GetSupportedVersionsRequest) Reset()

func (*GetSupportedVersionsRequest) String 

func (m *GetSupportedVersionsRequest) String() string

type GetSupportedVersionsResponse 

type GetSupportedVersionsResponse struct {
	// One of the following fields MUST be specified.
	//
	// Types that are valid to be assigned to Reply:
	//	*GetSupportedVersionsResponse_Result_
	//	*GetSupportedVersionsResponse_Error
	Reply isGetSupportedVersionsResponse_Reply `protobuf_oneof:"reply"`
}

func (*GetSupportedVersionsResponse) Descriptor 

func (*GetSupportedVersionsResponse) Descriptor() ([]byte, []int)

func (*GetSupportedVersionsResponse) GetError 

func (m *GetSupportedVersionsResponse) GetError() *Error

func (*GetSupportedVersionsResponse) GetReply 

func (m *GetSupportedVersionsResponse) GetReply() isGetSupportedVersionsResponse_Reply

func (*GetSupportedVersionsResponse) GetResult 

func (m *GetSupportedVersionsResponse) GetResult() *GetSupportedVersionsResponse_Result

func (*GetSupportedVersionsResponse) ProtoMessage 

func (*GetSupportedVersionsResponse) ProtoMessage()

func (*GetSupportedVersionsResponse) Reset 

func (m *GetSupportedVersionsResponse) Reset()

func (*GetSupportedVersionsResponse) String 

func (m *GetSupportedVersionsResponse) String() string

func (*GetSupportedVersionsResponse) XXX_OneofFuncs 

func (*GetSupportedVersionsResponse) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

type GetSupportedVersionsResponse_Error 

type GetSupportedVersionsResponse_Error struct {
	Error *Error `protobuf:"bytes,2,opt,name=error,oneof"`
}

type GetSupportedVersionsResponse_Result 

type GetSupportedVersionsResponse_Result struct {
	// All the CSI versions that the Plugin supports. This field is
	// REQUIRED.
	SupportedVersions []*Version `protobuf:"bytes,1,rep,name=supported_versions,json=supportedVersions" json:"supported_versions,omitempty"`
}

func (*GetSupportedVersionsResponse_Result) Descriptor 

func (*GetSupportedVersionsResponse_Result) Descriptor() ([]byte, []int)

func (*GetSupportedVersionsResponse_Result) GetSupportedVersions 

func (m *GetSupportedVersionsResponse_Result) GetSupportedVersions() []*Version

func (*GetSupportedVersionsResponse_Result) ProtoMessage 

func (*GetSupportedVersionsResponse_Result) ProtoMessage()

func (*GetSupportedVersionsResponse_Result) Reset 

func (m *GetSupportedVersionsResponse_Result) Reset()

func (*GetSupportedVersionsResponse_Result) String 

func (m *GetSupportedVersionsResponse_Result) String() string

type GetSupportedVersionsResponse_Result_ 

type GetSupportedVersionsResponse_Result_ struct {
	Result *GetSupportedVersionsResponse_Result `protobuf:"bytes,1,opt,name=result,oneof"`
}

type IdentityClient 

type IdentityClient interface {
	GetSupportedVersions(ctx context.Context, in *GetSupportedVersionsRequest, opts ...grpc.CallOption) (*GetSupportedVersionsResponse, error)
	GetPluginInfo(ctx context.Context, in *GetPluginInfoRequest, opts ...grpc.CallOption) (*GetPluginInfoResponse, error)
}

func NewIdentityClient 

func NewIdentityClient(cc *grpc.ClientConn) IdentityClient

type IdentityServer 

type IdentityServer interface {
	GetSupportedVersions(context.Context, *GetSupportedVersionsRequest) (*GetSupportedVersionsResponse, error)
	GetPluginInfo(context.Context, *GetPluginInfoRequest) (*GetPluginInfoResponse, error)
}

type ListVolumesRequest 

type ListVolumesRequest struct {
	// The API version assumed by the CO. This field is REQUIRED.
	Version *Version `protobuf:"bytes,1,opt,name=version" json:"version,omitempty"`
	// If specified, the Plugin MUST NOT return more entries than this
	// number in the response. If the actual number of entries is more
	// than this number, the Plugin MUST set `next_token` in the response
	// which can be used to get the next page of entries in the subsequent
	// `ListVolumes` call. This field is OPTIONAL. If not specified, it
	// means there is no restriction on the number of entries that can be
	// returned.
	MaxEntries uint32 `protobuf:"varint,2,opt,name=max_entries,json=maxEntries" json:"max_entries,omitempty"`
	// A token to specify where to start paginating. Set this field to
	// `next_token` returned by a previous `ListVolumes` call to get the
	// next page of entries. This field is OPTIONAL.
	StartingToken string `protobuf:"bytes,3,opt,name=starting_token,json=startingToken" json:"starting_token,omitempty"`
}

////// //////

func (*ListVolumesRequest) Descriptor 

func (*ListVolumesRequest) Descriptor() ([]byte, []int)

func (*ListVolumesRequest) GetMaxEntries 

func (m *ListVolumesRequest) GetMaxEntries() uint32

func (*ListVolumesRequest) GetStartingToken 

func (m *ListVolumesRequest) GetStartingToken() string

func (*ListVolumesRequest) GetVersion 

func (m *ListVolumesRequest) GetVersion() *Version

func (*ListVolumesRequest) ProtoMessage 

func (*ListVolumesRequest) ProtoMessage()

func (*ListVolumesRequest) Reset 

func (m *ListVolumesRequest) Reset()

func (*ListVolumesRequest) String 

func (m *ListVolumesRequest) String() string

type ListVolumesResponse 

type ListVolumesResponse struct {
	// One of the following fields MUST be specified.
	//
	// Types that are valid to be assigned to Reply:
	//	*ListVolumesResponse_Result_
	//	*ListVolumesResponse_Error
	Reply isListVolumesResponse_Reply `protobuf_oneof:"reply"`
}

func (*ListVolumesResponse) Descriptor 

func (*ListVolumesResponse) Descriptor() ([]byte, []int)

func (*ListVolumesResponse) GetError 

func (m *ListVolumesResponse) GetError() *Error

func (*ListVolumesResponse) GetReply 

func (m *ListVolumesResponse) GetReply() isListVolumesResponse_Reply

func (*ListVolumesResponse) GetResult 

func (m *ListVolumesResponse) GetResult() *ListVolumesResponse_Result

func (*ListVolumesResponse) ProtoMessage 

func (*ListVolumesResponse) ProtoMessage()

func (*ListVolumesResponse) Reset 

func (m *ListVolumesResponse) Reset()

func (*ListVolumesResponse) String 

func (m *ListVolumesResponse) String() string

func (*ListVolumesResponse) XXX_OneofFuncs 

func (*ListVolumesResponse) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

type ListVolumesResponse_Error 

type ListVolumesResponse_Error struct {
	Error *Error `protobuf:"bytes,2,opt,name=error,oneof"`
}

type ListVolumesResponse_Result 

type ListVolumesResponse_Result struct {
	Entries []*ListVolumesResponse_Result_Entry `protobuf:"bytes,1,rep,name=entries" json:"entries,omitempty"`
	// This token allows you to get the next page of entries for
	// `ListVolumes` request. If the number of entries is larger than
	// `max_entries`, use the `next_token` as a value for the
	// `starting_token` field in the next `ListVolumes` request. This
	// field is OPTIONAL.
	NextToken string `protobuf:"bytes,2,opt,name=next_token,json=nextToken" json:"next_token,omitempty"`
}

func (*ListVolumesResponse_Result) Descriptor 

func (*ListVolumesResponse_Result) Descriptor() ([]byte, []int)

func (*ListVolumesResponse_Result) GetEntries 

func (m *ListVolumesResponse_Result) GetEntries() []*ListVolumesResponse_Result_Entry

func (*ListVolumesResponse_Result) GetNextToken 

func (m *ListVolumesResponse_Result) GetNextToken() string

func (*ListVolumesResponse_Result) ProtoMessage 

func (*ListVolumesResponse_Result) ProtoMessage()

func (*ListVolumesResponse_Result) Reset 

func (m *ListVolumesResponse_Result) Reset()

func (*ListVolumesResponse_Result) String 

func (m *ListVolumesResponse_Result) String() string

type ListVolumesResponse_Result_ 

type ListVolumesResponse_Result_ struct {
	Result *ListVolumesResponse_Result `protobuf:"bytes,1,opt,name=result,oneof"`
}

type ListVolumesResponse_Result_Entry 

type ListVolumesResponse_Result_Entry struct {
	VolumeInfo *VolumeInfo `protobuf:"bytes,1,opt,name=volume_info,json=volumeInfo" json:"volume_info,omitempty"`
}

func (*ListVolumesResponse_Result_Entry) Descriptor 

func (*ListVolumesResponse_Result_Entry) Descriptor() ([]byte, []int)

func (*ListVolumesResponse_Result_Entry) GetVolumeInfo 

func (m *ListVolumesResponse_Result_Entry) GetVolumeInfo() *VolumeInfo

func (*ListVolumesResponse_Result_Entry) ProtoMessage 

func (*ListVolumesResponse_Result_Entry) ProtoMessage()

func (*ListVolumesResponse_Result_Entry) Reset 

func (m *ListVolumesResponse_Result_Entry) Reset()

func (*ListVolumesResponse_Result_Entry) String 

func (m *ListVolumesResponse_Result_Entry) String() string

type NodeClient 

type NodeClient interface {
	NodePublishVolume(ctx context.Context, in *NodePublishVolumeRequest, opts ...grpc.CallOption) (*NodePublishVolumeResponse, error)
	NodeUnpublishVolume(ctx context.Context, in *NodeUnpublishVolumeRequest, opts ...grpc.CallOption) (*NodeUnpublishVolumeResponse, error)
	GetNodeID(ctx context.Context, in *GetNodeIDRequest, opts ...grpc.CallOption) (*GetNodeIDResponse, error)
	ProbeNode(ctx context.Context, in *ProbeNodeRequest, opts ...grpc.CallOption) (*ProbeNodeResponse, error)
	NodeGetCapabilities(ctx context.Context, in *NodeGetCapabilitiesRequest, opts ...grpc.CallOption) (*NodeGetCapabilitiesResponse, error)
}

func NewNodeClient 

func NewNodeClient(cc *grpc.ClientConn) NodeClient

type NodeGetCapabilitiesRequest 

type NodeGetCapabilitiesRequest struct {
	// The API version assumed by the CO. This is a REQUIRED field.
	Version *Version `protobuf:"bytes,1,opt,name=version" json:"version,omitempty"`
}

////// //////

func (*NodeGetCapabilitiesRequest) Descriptor 

func (*NodeGetCapabilitiesRequest) Descriptor() ([]byte, []int)

func (*NodeGetCapabilitiesRequest) GetVersion 

func (m *NodeGetCapabilitiesRequest) GetVersion() *Version

func (*NodeGetCapabilitiesRequest) ProtoMessage 

func (*NodeGetCapabilitiesRequest) ProtoMessage()

func (*NodeGetCapabilitiesRequest) Reset 

func (m *NodeGetCapabilitiesRequest) Reset()

func (*NodeGetCapabilitiesRequest) String 

func (m *NodeGetCapabilitiesRequest) String() string

type NodeGetCapabilitiesResponse 

type NodeGetCapabilitiesResponse struct {
	// One of the following fields MUST be specified.
	//
	// Types that are valid to be assigned to Reply:
	//	*NodeGetCapabilitiesResponse_Result_
	//	*NodeGetCapabilitiesResponse_Error
	Reply isNodeGetCapabilitiesResponse_Reply `protobuf_oneof:"reply"`
}

func (*NodeGetCapabilitiesResponse) Descriptor 

func (*NodeGetCapabilitiesResponse) Descriptor() ([]byte, []int)

func (*NodeGetCapabilitiesResponse) GetError 

func (m *NodeGetCapabilitiesResponse) GetError() *Error

func (*NodeGetCapabilitiesResponse) GetReply 

func (m *NodeGetCapabilitiesResponse) GetReply() isNodeGetCapabilitiesResponse_Reply

func (*NodeGetCapabilitiesResponse) GetResult 

func (m *NodeGetCapabilitiesResponse) GetResult() *NodeGetCapabilitiesResponse_Result

func (*NodeGetCapabilitiesResponse) ProtoMessage 

func (*NodeGetCapabilitiesResponse) ProtoMessage()

func (*NodeGetCapabilitiesResponse) Reset 

func (m *NodeGetCapabilitiesResponse) Reset()

func (*NodeGetCapabilitiesResponse) String 

func (m *NodeGetCapabilitiesResponse) String() string

func (*NodeGetCapabilitiesResponse) XXX_OneofFuncs 

func (*NodeGetCapabilitiesResponse) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

type NodeGetCapabilitiesResponse_Error 

type NodeGetCapabilitiesResponse_Error struct {
	Error *Error `protobuf:"bytes,2,opt,name=error,oneof"`
}

type NodeGetCapabilitiesResponse_Result 

type NodeGetCapabilitiesResponse_Result struct {
	// All the capabilities that the node service supports. This field
	// is OPTIONAL.
	Capabilities []*NodeServiceCapability `protobuf:"bytes,2,rep,name=capabilities" json:"capabilities,omitempty"`
}

func (*NodeGetCapabilitiesResponse_Result) Descriptor 

func (*NodeGetCapabilitiesResponse_Result) Descriptor() ([]byte, []int)

func (*NodeGetCapabilitiesResponse_Result) GetCapabilities 

func (m *NodeGetCapabilitiesResponse_Result) GetCapabilities() []*NodeServiceCapability

func (*NodeGetCapabilitiesResponse_Result) ProtoMessage 

func (*NodeGetCapabilitiesResponse_Result) ProtoMessage()

func (*NodeGetCapabilitiesResponse_Result) Reset 

func (m *NodeGetCapabilitiesResponse_Result) Reset()

func (*NodeGetCapabilitiesResponse_Result) String 

func (m *NodeGetCapabilitiesResponse_Result) String() string

type NodeGetCapabilitiesResponse_Result_ 

type NodeGetCapabilitiesResponse_Result_ struct {
	Result *NodeGetCapabilitiesResponse_Result `protobuf:"bytes,1,opt,name=result,oneof"`
}

type NodeID 

type NodeID struct {
	// Information about a node in the form of key-value pairs. This
	// information is opaque to the CO. Given this information will be
	// passed around by the CO, it is RECOMMENDED that each Plugin keeps
	// this information as small as possible. This field is REQUIRED.
	Values map[string]string `` /* 132-byte string literal not displayed */
}

func (*NodeID) Descriptor 

func (*NodeID) Descriptor() ([]byte, []int)

func (*NodeID) GetValues 

func (m *NodeID) GetValues() map[string]string

func (*NodeID) ProtoMessage 

func (*NodeID) ProtoMessage()

func (*NodeID) Reset 

func (m *NodeID) Reset()

func (*NodeID) String 

func (m *NodeID) String() string

type NodePublishVolumeRequest 

type NodePublishVolumeRequest struct {
	// The API version assumed by the CO. This is a REQUIRED field.
	Version *Version `protobuf:"bytes,1,opt,name=version" json:"version,omitempty"`
	// The ID of the volume to publish. This field is REQUIRED.
	VolumeId *VolumeID `protobuf:"bytes,2,opt,name=volume_id,json=volumeId" json:"volume_id,omitempty"`
	// The metadata of the volume to publish. This field is OPTIONAL.
	VolumeMetadata *VolumeMetadata `protobuf:"bytes,3,opt,name=volume_metadata,json=volumeMetadata" json:"volume_metadata,omitempty"`
	// The CO SHALL set this field to the value returned by
	// `ControllerPublishVolume` if the corresponding Controller Plugin
	// has `PUBLISH_UNPUBLISH_VOLUME` controller capability, and SHALL be
	// left unset if the corresponding Controller Plugin does not have
	// this capability. This is an OPTIONAL field.
	PublishVolumeInfo *PublishVolumeInfo `protobuf:"bytes,4,opt,name=publish_volume_info,json=publishVolumeInfo" json:"publish_volume_info,omitempty"`
	// The path to which the volume will be published. It MUST be an
	// absolute path in the root filesystem of the process serving this
	// request. The CO SHALL ensure uniqueness of target_path per volume.
	// This is a REQUIRED field.
	TargetPath string `protobuf:"bytes,5,opt,name=target_path,json=targetPath" json:"target_path,omitempty"`
	// The capability of the volume the CO expects the volume to have.
	// This is a REQUIRED field.
	VolumeCapability *VolumeCapability `protobuf:"bytes,6,opt,name=volume_capability,json=volumeCapability" json:"volume_capability,omitempty"`
	// Whether to publish the volume in readonly mode. This field is
	// REQUIRED.
	Readonly bool `protobuf:"varint,7,opt,name=readonly" json:"readonly,omitempty"`
	// End user credentials used to authenticate/authorize node publish request.
	// This field is OPTIONAL.
	UserCredentials *Credentials `protobuf:"bytes,8,opt,name=user_credentials,json=userCredentials" json:"user_credentials,omitempty"`
}

////// //////

func (*NodePublishVolumeRequest) Descriptor 

func (*NodePublishVolumeRequest) Descriptor() ([]byte, []int)

func (*NodePublishVolumeRequest) GetPublishVolumeInfo 

func (m *NodePublishVolumeRequest) GetPublishVolumeInfo() *PublishVolumeInfo

func (*NodePublishVolumeRequest) GetReadonly 

func (m *NodePublishVolumeRequest) GetReadonly() bool

func (*NodePublishVolumeRequest) GetTargetPath 

func (m *NodePublishVolumeRequest) GetTargetPath() string

func (*NodePublishVolumeRequest) GetUserCredentials 

func (m *NodePublishVolumeRequest) GetUserCredentials() *Credentials

func (*NodePublishVolumeRequest) GetVersion 

func (m *NodePublishVolumeRequest) GetVersion() *Version

func (*NodePublishVolumeRequest) GetVolumeCapability 

func (m *NodePublishVolumeRequest) GetVolumeCapability() *VolumeCapability

func (*NodePublishVolumeRequest) GetVolumeId 

func (m *NodePublishVolumeRequest) GetVolumeId() *VolumeID

func (*NodePublishVolumeRequest) GetVolumeMetadata 

func (m *NodePublishVolumeRequest) GetVolumeMetadata() *VolumeMetadata

func (*NodePublishVolumeRequest) ProtoMessage 

func (*NodePublishVolumeRequest) ProtoMessage()

func (*NodePublishVolumeRequest) Reset 

func (m *NodePublishVolumeRequest) Reset()

func (*NodePublishVolumeRequest) String 

func (m *NodePublishVolumeRequest) String() string

type NodePublishVolumeResponse 

type NodePublishVolumeResponse struct {
	// One of the following fields MUST be specified.
	//
	// Types that are valid to be assigned to Reply:
	//	*NodePublishVolumeResponse_Result_
	//	*NodePublishVolumeResponse_Error
	Reply isNodePublishVolumeResponse_Reply `protobuf_oneof:"reply"`
}

func (*NodePublishVolumeResponse) Descriptor 

func (*NodePublishVolumeResponse) Descriptor() ([]byte, []int)

func (*NodePublishVolumeResponse) GetError 

func (m *NodePublishVolumeResponse) GetError() *Error

func (*NodePublishVolumeResponse) GetReply 

func (m *NodePublishVolumeResponse) GetReply() isNodePublishVolumeResponse_Reply

func (*NodePublishVolumeResponse) GetResult 

func (m *NodePublishVolumeResponse) GetResult() *NodePublishVolumeResponse_Result

func (*NodePublishVolumeResponse) ProtoMessage 

func (*NodePublishVolumeResponse) ProtoMessage()

func (*NodePublishVolumeResponse) Reset 

func (m *NodePublishVolumeResponse) Reset()

func (*NodePublishVolumeResponse) String 

func (m *NodePublishVolumeResponse) String() string

func (*NodePublishVolumeResponse) XXX_OneofFuncs 

func (*NodePublishVolumeResponse) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

type NodePublishVolumeResponse_Error 

type NodePublishVolumeResponse_Error struct {
	Error *Error `protobuf:"bytes,2,opt,name=error,oneof"`
}

type NodePublishVolumeResponse_Result 

type NodePublishVolumeResponse_Result struct {
}

func (*NodePublishVolumeResponse_Result) Descriptor 

func (*NodePublishVolumeResponse_Result) Descriptor() ([]byte, []int)

func (*NodePublishVolumeResponse_Result) ProtoMessage 

func (*NodePublishVolumeResponse_Result) ProtoMessage()

func (*NodePublishVolumeResponse_Result) Reset 

func (m *NodePublishVolumeResponse_Result) Reset()

func (*NodePublishVolumeResponse_Result) String 

func (m *NodePublishVolumeResponse_Result) String() string

type NodePublishVolumeResponse_Result_ 

type NodePublishVolumeResponse_Result_ struct {
	Result *NodePublishVolumeResponse_Result `protobuf:"bytes,1,opt,name=result,oneof"`
}

type NodeServer 

type NodeServer interface {
	NodePublishVolume(context.Context, *NodePublishVolumeRequest) (*NodePublishVolumeResponse, error)
	NodeUnpublishVolume(context.Context, *NodeUnpublishVolumeRequest) (*NodeUnpublishVolumeResponse, error)
	GetNodeID(context.Context, *GetNodeIDRequest) (*GetNodeIDResponse, error)
	ProbeNode(context.Context, *ProbeNodeRequest) (*ProbeNodeResponse, error)
	NodeGetCapabilities(context.Context, *NodeGetCapabilitiesRequest) (*NodeGetCapabilitiesResponse, error)
}

type NodeServiceCapability 

type NodeServiceCapability struct {
	// Types that are valid to be assigned to Type:
	//	*NodeServiceCapability_Rpc
	Type isNodeServiceCapability_Type `protobuf_oneof:"type"`
}

Specifies a capability of the node service.

func (*NodeServiceCapability) Descriptor 

func (*NodeServiceCapability) Descriptor() ([]byte, []int)

func (*NodeServiceCapability) GetRpc 

func (m *NodeServiceCapability) GetRpc() *NodeServiceCapability_RPC

func (*NodeServiceCapability) GetType 

func (m *NodeServiceCapability) GetType() isNodeServiceCapability_Type

func (*NodeServiceCapability) ProtoMessage 

func (*NodeServiceCapability) ProtoMessage()

func (*NodeServiceCapability) Reset 

func (m *NodeServiceCapability) Reset()

func (*NodeServiceCapability) String 

func (m *NodeServiceCapability) String() string

func (*NodeServiceCapability) XXX_OneofFuncs 

func (*NodeServiceCapability) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

type NodeServiceCapability_RPC 

type NodeServiceCapability_RPC struct {
	Type NodeServiceCapability_RPC_Type `protobuf:"varint,1,opt,name=type,enum=csi.NodeServiceCapability_RPC_Type" json:"type,omitempty"`
}

func (*NodeServiceCapability_RPC) Descriptor 

func (*NodeServiceCapability_RPC) Descriptor() ([]byte, []int)

func (*NodeServiceCapability_RPC) GetType 

func (m *NodeServiceCapability_RPC) GetType() NodeServiceCapability_RPC_Type

func (*NodeServiceCapability_RPC) ProtoMessage 

func (*NodeServiceCapability_RPC) ProtoMessage()

func (*NodeServiceCapability_RPC) Reset 

func (m *NodeServiceCapability_RPC) Reset()

func (*NodeServiceCapability_RPC) String 

func (m *NodeServiceCapability_RPC) String() string

type NodeServiceCapability_RPC_Type 

type NodeServiceCapability_RPC_Type int32
const (
	NodeServiceCapability_RPC_UNKNOWN NodeServiceCapability_RPC_Type = 0
)

func (NodeServiceCapability_RPC_Type) EnumDescriptor 

func (NodeServiceCapability_RPC_Type) EnumDescriptor() ([]byte, []int)

func (NodeServiceCapability_RPC_Type) String 

func (x NodeServiceCapability_RPC_Type) String() string

type NodeServiceCapability_Rpc 

type NodeServiceCapability_Rpc struct {
	Rpc *NodeServiceCapability_RPC `protobuf:"bytes,1,opt,name=rpc,oneof"`
}

type NodeUnpublishVolumeRequest 

type NodeUnpublishVolumeRequest struct {
	// The API version assumed by the CO. This is a REQUIRED field.
	Version *Version `protobuf:"bytes,1,opt,name=version" json:"version,omitempty"`
	// The ID of the volume. This field is REQUIRED.
	VolumeId *VolumeID `protobuf:"bytes,2,opt,name=volume_id,json=volumeId" json:"volume_id,omitempty"`
	// The metadata of the volume. This field is OPTIONAL.
	VolumeMetadata *VolumeMetadata `protobuf:"bytes,3,opt,name=volume_metadata,json=volumeMetadata" json:"volume_metadata,omitempty"`
	// The path at which the volume was published. It MUST be an absolute
	// path in the root filesystem of the process serving this request.
	// This is a REQUIRED field.
	TargetPath string `protobuf:"bytes,4,opt,name=target_path,json=targetPath" json:"target_path,omitempty"`
	// End user credentials used to authenticate/authorize node unpublish request.
	// This field is OPTIONAL.
	UserCredentials *Credentials `protobuf:"bytes,5,opt,name=user_credentials,json=userCredentials" json:"user_credentials,omitempty"`
}

////// //////

func (*NodeUnpublishVolumeRequest) Descriptor 

func (*NodeUnpublishVolumeRequest) Descriptor() ([]byte, []int)

func (*NodeUnpublishVolumeRequest) GetTargetPath 

func (m *NodeUnpublishVolumeRequest) GetTargetPath() string

func (*NodeUnpublishVolumeRequest) GetUserCredentials 

func (m *NodeUnpublishVolumeRequest) GetUserCredentials() *Credentials

func (*NodeUnpublishVolumeRequest) GetVersion 

func (m *NodeUnpublishVolumeRequest) GetVersion() *Version

func (*NodeUnpublishVolumeRequest) GetVolumeId 

func (m *NodeUnpublishVolumeRequest) GetVolumeId() *VolumeID

func (*NodeUnpublishVolumeRequest) GetVolumeMetadata 

func (m *NodeUnpublishVolumeRequest) GetVolumeMetadata() *VolumeMetadata

func (*NodeUnpublishVolumeRequest) ProtoMessage 

func (*NodeUnpublishVolumeRequest) ProtoMessage()

func (*NodeUnpublishVolumeRequest) Reset 

func (m *NodeUnpublishVolumeRequest) Reset()

func (*NodeUnpublishVolumeRequest) String 

func (m *NodeUnpublishVolumeRequest) String() string

type NodeUnpublishVolumeResponse 

type NodeUnpublishVolumeResponse struct {
	// One of the following fields MUST be specified.
	//
	// Types that are valid to be assigned to Reply:
	//	*NodeUnpublishVolumeResponse_Result_
	//	*NodeUnpublishVolumeResponse_Error
	Reply isNodeUnpublishVolumeResponse_Reply `protobuf_oneof:"reply"`
}

func (*NodeUnpublishVolumeResponse) Descriptor 

func (*NodeUnpublishVolumeResponse) Descriptor() ([]byte, []int)

func (*NodeUnpublishVolumeResponse) GetError 

func (m *NodeUnpublishVolumeResponse) GetError() *Error

func (*NodeUnpublishVolumeResponse) GetReply 

func (m *NodeUnpublishVolumeResponse) GetReply() isNodeUnpublishVolumeResponse_Reply

func (*NodeUnpublishVolumeResponse) GetResult 

func (m *NodeUnpublishVolumeResponse) GetResult() *NodeUnpublishVolumeResponse_Result

func (*NodeUnpublishVolumeResponse) ProtoMessage 

func (*NodeUnpublishVolumeResponse) ProtoMessage()

func (*NodeUnpublishVolumeResponse) Reset 

func (m *NodeUnpublishVolumeResponse) Reset()

func (*NodeUnpublishVolumeResponse) String 

func (m *NodeUnpublishVolumeResponse) String() string

func (*NodeUnpublishVolumeResponse) XXX_OneofFuncs 

func (*NodeUnpublishVolumeResponse) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

type NodeUnpublishVolumeResponse_Error 

type NodeUnpublishVolumeResponse_Error struct {
	Error *Error `protobuf:"bytes,2,opt,name=error,oneof"`
}

type NodeUnpublishVolumeResponse_Result 

type NodeUnpublishVolumeResponse_Result struct {
}

func (*NodeUnpublishVolumeResponse_Result) Descriptor 

func (*NodeUnpublishVolumeResponse_Result) Descriptor() ([]byte, []int)

func (*NodeUnpublishVolumeResponse_Result) ProtoMessage 

func (*NodeUnpublishVolumeResponse_Result) ProtoMessage()

func (*NodeUnpublishVolumeResponse_Result) Reset 

func (m *NodeUnpublishVolumeResponse_Result) Reset()

func (*NodeUnpublishVolumeResponse_Result) String 

func (m *NodeUnpublishVolumeResponse_Result) String() string

type NodeUnpublishVolumeResponse_Result_ 

type NodeUnpublishVolumeResponse_Result_ struct {
	Result *NodeUnpublishVolumeResponse_Result `protobuf:"bytes,1,opt,name=result,oneof"`
}

type ProbeNodeRequest 

type ProbeNodeRequest struct {
	// The API version assumed by the CO. This is a REQUIRED field.
	Version *Version `protobuf:"bytes,1,opt,name=version" json:"version,omitempty"`
}

////// //////

func (*ProbeNodeRequest) Descriptor 

func (*ProbeNodeRequest) Descriptor() ([]byte, []int)

func (*ProbeNodeRequest) GetVersion 

func (m *ProbeNodeRequest) GetVersion() *Version

func (*ProbeNodeRequest) ProtoMessage 

func (*ProbeNodeRequest) ProtoMessage()

func (*ProbeNodeRequest) Reset 

func (m *ProbeNodeRequest) Reset()

func (*ProbeNodeRequest) String 

func (m *ProbeNodeRequest) String() string

type ProbeNodeResponse 

type ProbeNodeResponse struct {
	// One of the following fields MUST be specified.
	//
	// Types that are valid to be assigned to Reply:
	//	*ProbeNodeResponse_Result_
	//	*ProbeNodeResponse_Error
	Reply isProbeNodeResponse_Reply `protobuf_oneof:"reply"`
}

func (*ProbeNodeResponse) Descriptor 

func (*ProbeNodeResponse) Descriptor() ([]byte, []int)

func (*ProbeNodeResponse) GetError 

func (m *ProbeNodeResponse) GetError() *Error

func (*ProbeNodeResponse) GetReply 

func (m *ProbeNodeResponse) GetReply() isProbeNodeResponse_Reply

func (*ProbeNodeResponse) GetResult 

func (m *ProbeNodeResponse) GetResult() *ProbeNodeResponse_Result

func (*ProbeNodeResponse) ProtoMessage 

func (*ProbeNodeResponse) ProtoMessage()

func (*ProbeNodeResponse) Reset 

func (m *ProbeNodeResponse) Reset()

func (*ProbeNodeResponse) String 

func (m *ProbeNodeResponse) String() string

func (*ProbeNodeResponse) XXX_OneofFuncs 

func (*ProbeNodeResponse) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

type ProbeNodeResponse_Error 

type ProbeNodeResponse_Error struct {
	Error *Error `protobuf:"bytes,2,opt,name=error,oneof"`
}

type ProbeNodeResponse_Result 

type ProbeNodeResponse_Result struct {
}

func (*ProbeNodeResponse_Result) Descriptor 

func (*ProbeNodeResponse_Result) Descriptor() ([]byte, []int)

func (*ProbeNodeResponse_Result) ProtoMessage 

func (*ProbeNodeResponse_Result) ProtoMessage()

func (*ProbeNodeResponse_Result) Reset 

func (m *ProbeNodeResponse_Result) Reset()

func (*ProbeNodeResponse_Result) String 

func (m *ProbeNodeResponse_Result) String() string

type ProbeNodeResponse_Result_ 

type ProbeNodeResponse_Result_ struct {
	Result *ProbeNodeResponse_Result `protobuf:"bytes,1,opt,name=result,oneof"`
}

type PublishVolumeInfo 

type PublishVolumeInfo struct {
	// Information returned by the Plugin in `ControllerPublishVolume`
	// call. It is in the form of key-value pairs, and is opaque to the
	// CO. Given this information will be passed around by the CO, it is
	// RECOMMENDED that each Plugin keeps this information as small as
	// possible. This field is OPTIONAL.
	Values map[string]string `` /* 132-byte string literal not displayed */
}

func (*PublishVolumeInfo) Descriptor 

func (*PublishVolumeInfo) Descriptor() ([]byte, []int)

func (*PublishVolumeInfo) GetValues 

func (m *PublishVolumeInfo) GetValues() map[string]string

func (*PublishVolumeInfo) ProtoMessage 

func (*PublishVolumeInfo) ProtoMessage()

func (*PublishVolumeInfo) Reset 

func (m *PublishVolumeInfo) Reset()

func (*PublishVolumeInfo) String 

func (m *PublishVolumeInfo) String() string

type ValidateVolumeCapabilitiesRequest 

type ValidateVolumeCapabilitiesRequest struct {
	// The API version assumed by the CO. This is a REQUIRED field.
	Version *Version `protobuf:"bytes,1,opt,name=version" json:"version,omitempty"`
	// The information about the volume to check. This is a REQUIRED
	// field.
	VolumeInfo *VolumeInfo `protobuf:"bytes,2,opt,name=volume_info,json=volumeInfo" json:"volume_info,omitempty"`
	// The capabilities that the CO wants to check for the volume. This
	// call SHALL return “supported” only if all the volume capabilities
	// specified below are supported. This field is REQUIRED.
	VolumeCapabilities []*VolumeCapability `protobuf:"bytes,3,rep,name=volume_capabilities,json=volumeCapabilities" json:"volume_capabilities,omitempty"`
}

////// //////

func (*ValidateVolumeCapabilitiesRequest) Descriptor 

func (*ValidateVolumeCapabilitiesRequest) Descriptor() ([]byte, []int)

func (*ValidateVolumeCapabilitiesRequest) GetVersion 

func (m *ValidateVolumeCapabilitiesRequest) GetVersion() *Version

func (*ValidateVolumeCapabilitiesRequest) GetVolumeCapabilities 

func (m *ValidateVolumeCapabilitiesRequest) GetVolumeCapabilities() []*VolumeCapability

func (*ValidateVolumeCapabilitiesRequest) GetVolumeInfo 

func (m *ValidateVolumeCapabilitiesRequest) GetVolumeInfo() *VolumeInfo

func (*ValidateVolumeCapabilitiesRequest) ProtoMessage 

func (*ValidateVolumeCapabilitiesRequest) ProtoMessage()

func (*ValidateVolumeCapabilitiesRequest) Reset 

func (m *ValidateVolumeCapabilitiesRequest) Reset()

func (*ValidateVolumeCapabilitiesRequest) String 

func (m *ValidateVolumeCapabilitiesRequest) String() string

type ValidateVolumeCapabilitiesResponse 

type ValidateVolumeCapabilitiesResponse struct {
	// One of the following fields MUST be specified.
	//
	// Types that are valid to be assigned to Reply:
	//	*ValidateVolumeCapabilitiesResponse_Result_
	//	*ValidateVolumeCapabilitiesResponse_Error
	Reply isValidateVolumeCapabilitiesResponse_Reply `protobuf_oneof:"reply"`
}

func (*ValidateVolumeCapabilitiesResponse) Descriptor 

func (*ValidateVolumeCapabilitiesResponse) Descriptor() ([]byte, []int)

func (*ValidateVolumeCapabilitiesResponse) GetError 

func (m *ValidateVolumeCapabilitiesResponse) GetError() *Error

func (*ValidateVolumeCapabilitiesResponse) GetReply 

func (m *ValidateVolumeCapabilitiesResponse) GetReply() isValidateVolumeCapabilitiesResponse_Reply

func (*ValidateVolumeCapabilitiesResponse) GetResult 

func (m *ValidateVolumeCapabilitiesResponse) GetResult() *ValidateVolumeCapabilitiesResponse_Result

func (*ValidateVolumeCapabilitiesResponse) ProtoMessage 

func (*ValidateVolumeCapabilitiesResponse) ProtoMessage()

func (*ValidateVolumeCapabilitiesResponse) Reset 

func (m *ValidateVolumeCapabilitiesResponse) Reset()

func (*ValidateVolumeCapabilitiesResponse) String 

func (m *ValidateVolumeCapabilitiesResponse) String() string

func (*ValidateVolumeCapabilitiesResponse) XXX_OneofFuncs 

func (*ValidateVolumeCapabilitiesResponse) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

type ValidateVolumeCapabilitiesResponse_Error 

type ValidateVolumeCapabilitiesResponse_Error struct {
	Error *Error `protobuf:"bytes,2,opt,name=error,oneof"`
}

type ValidateVolumeCapabilitiesResponse_Result 

type ValidateVolumeCapabilitiesResponse_Result struct {
	// True if the Plugin supports the specified capabilities for the
	// given volume. This field is REQUIRED.
	Supported bool `protobuf:"varint,1,opt,name=supported" json:"supported,omitempty"`
	// Message to the CO if `supported` above is false. This field is
	// OPTIONAL.
	Message string `protobuf:"bytes,2,opt,name=message" json:"message,omitempty"`
}

func (*ValidateVolumeCapabilitiesResponse_Result) Descriptor 

func (*ValidateVolumeCapabilitiesResponse_Result) Descriptor() ([]byte, []int)

func (*ValidateVolumeCapabilitiesResponse_Result) GetMessage 

func (m *ValidateVolumeCapabilitiesResponse_Result) GetMessage() string

func (*ValidateVolumeCapabilitiesResponse_Result) GetSupported 

func (m *ValidateVolumeCapabilitiesResponse_Result) GetSupported() bool

func (*ValidateVolumeCapabilitiesResponse_Result) ProtoMessage 

func (*ValidateVolumeCapabilitiesResponse_Result) ProtoMessage()

func (*ValidateVolumeCapabilitiesResponse_Result) Reset 

func (m *ValidateVolumeCapabilitiesResponse_Result) Reset()

func (*ValidateVolumeCapabilitiesResponse_Result) String 

func (m *ValidateVolumeCapabilitiesResponse_Result) String() string

type ValidateVolumeCapabilitiesResponse_Result_ 

type ValidateVolumeCapabilitiesResponse_Result_ struct {
	Result *ValidateVolumeCapabilitiesResponse_Result `protobuf:"bytes,1,opt,name=result,oneof"`
}

type Version 

type Version struct {
	Major uint32 `protobuf:"varint,1,opt,name=major" json:"major,omitempty"`
	Minor uint32 `protobuf:"varint,2,opt,name=minor" json:"minor,omitempty"`
	Patch uint32 `protobuf:"varint,3,opt,name=patch" json:"patch,omitempty"`
}

Specifies a version in Semantic Version 2.0 format. (http://semver.org/spec/v2.0.0.html)

func (*Version) Descriptor 

func (*Version) Descriptor() ([]byte, []int)

func (*Version) GetMajor 

func (m *Version) GetMajor() uint32

func (*Version) GetMinor 

func (m *Version) GetMinor() uint32

func (*Version) GetPatch 

func (m *Version) GetPatch() uint32

func (*Version) ProtoMessage 

func (*Version) ProtoMessage()

func (*Version) Reset 

func (m *Version) Reset()

func (*Version) String 

func (m *Version) String() string

type VolumeCapability 

type VolumeCapability struct {
	// Specifies what API the volume will be accessed using. One of the
	// following fields MUST be specified.
	//
	// Types that are valid to be assigned to AccessType:
	//	*VolumeCapability_Block
	//	*VolumeCapability_Mount
	AccessType isVolumeCapability_AccessType `protobuf_oneof:"access_type"`
	// This is a REQUIRED field.
	AccessMode *VolumeCapability_AccessMode `protobuf:"bytes,3,opt,name=access_mode,json=accessMode" json:"access_mode,omitempty"`
}

Specify a capability of a volume.

func (*VolumeCapability) Descriptor 

func (*VolumeCapability) Descriptor() ([]byte, []int)

func (*VolumeCapability) GetAccessMode 

func (m *VolumeCapability) GetAccessMode() *VolumeCapability_AccessMode

func (*VolumeCapability) GetAccessType 

func (m *VolumeCapability) GetAccessType() isVolumeCapability_AccessType

func (*VolumeCapability) GetBlock 

func (m *VolumeCapability) GetBlock() *VolumeCapability_BlockVolume

func (*VolumeCapability) GetMount 

func (m *VolumeCapability) GetMount() *VolumeCapability_MountVolume

func (*VolumeCapability) ProtoMessage 

func (*VolumeCapability) ProtoMessage()

func (*VolumeCapability) Reset 

func (m *VolumeCapability) Reset()

func (*VolumeCapability) String 

func (m *VolumeCapability) String() string

func (*VolumeCapability) XXX_OneofFuncs 

func (*VolumeCapability) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

type VolumeCapability_AccessMode 

type VolumeCapability_AccessMode struct {
	// This field is REQUIRED.
	Mode VolumeCapability_AccessMode_Mode `protobuf:"varint,1,opt,name=mode,enum=csi.VolumeCapability_AccessMode_Mode" json:"mode,omitempty"`
}

Specify how a volume can be accessed.

func (*VolumeCapability_AccessMode) Descriptor 

func (*VolumeCapability_AccessMode) Descriptor() ([]byte, []int)

func (*VolumeCapability_AccessMode) GetMode 

func (m *VolumeCapability_AccessMode) GetMode() VolumeCapability_AccessMode_Mode

func (*VolumeCapability_AccessMode) ProtoMessage 

func (*VolumeCapability_AccessMode) ProtoMessage()

func (*VolumeCapability_AccessMode) Reset 

func (m *VolumeCapability_AccessMode) Reset()

func (*VolumeCapability_AccessMode) String 

func (m *VolumeCapability_AccessMode) String() string

type VolumeCapability_AccessMode_Mode 

type VolumeCapability_AccessMode_Mode int32
const (
	VolumeCapability_AccessMode_UNKNOWN VolumeCapability_AccessMode_Mode = 0
	// Can be published as read/write at one node at a time.
	VolumeCapability_AccessMode_SINGLE_NODE_WRITER VolumeCapability_AccessMode_Mode = 1
	// Can be published as readonly at one node at a time.
	VolumeCapability_AccessMode_SINGLE_NODE_READER_ONLY VolumeCapability_AccessMode_Mode = 2
	// Can be published as readonly at multiple nodes simultaneously.
	VolumeCapability_AccessMode_MULTI_NODE_READER_ONLY VolumeCapability_AccessMode_Mode = 3
	// Can be published at multiple nodes simultaneously. Only one of
	// the node can be used as read/write. The rest will be readonly.
	VolumeCapability_AccessMode_MULTI_NODE_SINGLE_WRITER VolumeCapability_AccessMode_Mode = 4
	// Can be published as read/write at multiple nodes simultaneously.
	VolumeCapability_AccessMode_MULTI_NODE_MULTI_WRITER VolumeCapability_AccessMode_Mode = 5
)

func (VolumeCapability_AccessMode_Mode) EnumDescriptor 

func (VolumeCapability_AccessMode_Mode) EnumDescriptor() ([]byte, []int)

func (VolumeCapability_AccessMode_Mode) String 

func (x VolumeCapability_AccessMode_Mode) String() string

type VolumeCapability_Block 

type VolumeCapability_Block struct {
	Block *VolumeCapability_BlockVolume `protobuf:"bytes,1,opt,name=block,oneof"`
}

type VolumeCapability_BlockVolume 

type VolumeCapability_BlockVolume struct {
}

Indicate that the volume will be accessed via the block device API.

func (*VolumeCapability_BlockVolume) Descriptor 

func (*VolumeCapability_BlockVolume) Descriptor() ([]byte, []int)

func (*VolumeCapability_BlockVolume) ProtoMessage 

func (*VolumeCapability_BlockVolume) ProtoMessage()

func (*VolumeCapability_BlockVolume) Reset 

func (m *VolumeCapability_BlockVolume) Reset()

func (*VolumeCapability_BlockVolume) String 

func (m *VolumeCapability_BlockVolume) String() string

type VolumeCapability_Mount 

type VolumeCapability_Mount struct {
	Mount *VolumeCapability_MountVolume `protobuf:"bytes,2,opt,name=mount,oneof"`
}

type VolumeCapability_MountVolume 

type VolumeCapability_MountVolume struct {
	// The filesystem type. This field is OPTIONAL.
	FsType string `protobuf:"bytes,1,opt,name=fs_type,json=fsType" json:"fs_type,omitempty"`
	// The mount options that can be used for the volume. This field is
	// OPTIONAL. `mount_flags` MAY contain sensitive information.
	// Therefore, the CO and the Plugin MUST NOT leak this information
	// to untrusted entities.
	MountFlags []string `protobuf:"bytes,2,rep,name=mount_flags,json=mountFlags" json:"mount_flags,omitempty"`
}

Indicate that the volume will be accessed via the filesystem API.

func (*VolumeCapability_MountVolume) Descriptor 

func (*VolumeCapability_MountVolume) Descriptor() ([]byte, []int)

func (*VolumeCapability_MountVolume) GetFsType 

func (m *VolumeCapability_MountVolume) GetFsType() string

func (*VolumeCapability_MountVolume) GetMountFlags 

func (m *VolumeCapability_MountVolume) GetMountFlags() []string

func (*VolumeCapability_MountVolume) ProtoMessage 

func (*VolumeCapability_MountVolume) ProtoMessage()

func (*VolumeCapability_MountVolume) Reset 

func (m *VolumeCapability_MountVolume) Reset()

func (*VolumeCapability_MountVolume) String 

func (m *VolumeCapability_MountVolume) String() string

type VolumeID 

type VolumeID struct {
	// The identity of the provisioned volume specified by the Plugin in
	// the form of key-value pairs. This field is REQUIRED. Given this
	// information will be passed around by the CO, it is RECOMMENDED that
	// each Plugin keeps this information as small as possible.
	Values map[string]string `` /* 132-byte string literal not displayed */
}

The identity of the volume.

func (*VolumeID) Descriptor 

func (*VolumeID) Descriptor() ([]byte, []int)

func (*VolumeID) GetValues 

func (m *VolumeID) GetValues() map[string]string

func (*VolumeID) ProtoMessage 

func (*VolumeID) ProtoMessage()

func (*VolumeID) Reset 

func (m *VolumeID) Reset()

func (*VolumeID) String 

func (m *VolumeID) String() string

type VolumeInfo 

type VolumeInfo struct {
	// The capacity of the volume in bytes. This field is OPTIONAL. If not
	// set, it indicates that the capacity of the volume is unknown (e.g.,
	// NFS share). If set, it MUST be non-zero.
	CapacityBytes uint64 `protobuf:"varint,1,opt,name=capacity_bytes,json=capacityBytes" json:"capacity_bytes,omitempty"`
	// Contains identity information for the created volume. This field is
	// REQUIRED. The identity information will be used by the CO in
	// subsequent calls to refer to the provisioned volume.
	Id *VolumeID `protobuf:"bytes,4,opt,name=id" json:"id,omitempty"`
	// Metadata of the created volume. This field is OPTIONAL. If set, the
	// CO SHALL pass this information along with the `id` to subsequent
	// calls.
	Metadata *VolumeMetadata `protobuf:"bytes,5,opt,name=metadata" json:"metadata,omitempty"`
}

The information about a provisioned volume.

func (*VolumeInfo) Descriptor 

func (*VolumeInfo) Descriptor() ([]byte, []int)

func (*VolumeInfo) GetCapacityBytes 

func (m *VolumeInfo) GetCapacityBytes() uint64

func (*VolumeInfo) GetId 

func (m *VolumeInfo) GetId() *VolumeID

func (*VolumeInfo) GetMetadata 

func (m *VolumeInfo) GetMetadata() *VolumeMetadata

func (*VolumeInfo) ProtoMessage 

func (*VolumeInfo) ProtoMessage()

func (*VolumeInfo) Reset 

func (m *VolumeInfo) Reset()

func (*VolumeInfo) String 

func (m *VolumeInfo) String() string

type VolumeMetadata 

type VolumeMetadata struct {
	// The metadata information about the provisioned volume specified by
	// the Plugin in the form of key-value pairs. This field is OPTIONAL.
	// This field MAY contain sensitive information. Therefore, the CO
	// MUST NOT leak this information to untrusted entities. Given this
	// information will be passed around by the CO, it is RECOMMENDED that
	// each Plugin keeps this information as small as possible.
	Values map[string]string `` /* 132-byte string literal not displayed */
}

The metadata information about the volume.

func (*VolumeMetadata) Descriptor 

func (*VolumeMetadata) Descriptor() ([]byte, []int)

func (*VolumeMetadata) GetValues 

func (m *VolumeMetadata) GetValues() map[string]string

func (*VolumeMetadata) ProtoMessage 

func (*VolumeMetadata) ProtoMessage()

func (*VolumeMetadata) Reset 

func (m *VolumeMetadata) Reset()

func (*VolumeMetadata) String 

func (m *VolumeMetadata) String() string

Source Files

View all Source files

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.