topolvm: github.com/cybozu-go/topolvm/csi Index | Files

package csi

import "github.com/cybozu-go/topolvm/csi"

Index

Package Files

csi.pb.go

Variables

var ControllerServiceCapability_RPC_Type_name = map[int32]string{
    0:  "UNKNOWN",
    1:  "CREATE_DELETE_VOLUME",
    2:  "PUBLISH_UNPUBLISH_VOLUME",
    3:  "LIST_VOLUMES",
    4:  "GET_CAPACITY",
    5:  "CREATE_DELETE_SNAPSHOT",
    6:  "LIST_SNAPSHOTS",
    7:  "CLONE_VOLUME",
    8:  "PUBLISH_READONLY",
    9:  "EXPAND_VOLUME",
}
var ControllerServiceCapability_RPC_Type_value = map[string]int32{
    "UNKNOWN":                  0,
    "CREATE_DELETE_VOLUME":     1,
    "PUBLISH_UNPUBLISH_VOLUME": 2,
    "LIST_VOLUMES":             3,
    "GET_CAPACITY":             4,
    "CREATE_DELETE_SNAPSHOT":   5,
    "LIST_SNAPSHOTS":           6,
    "CLONE_VOLUME":             7,
    "PUBLISH_READONLY":         8,
    "EXPAND_VOLUME":            9,
}
var E_CsiSecret = &proto.ExtensionDesc{
    ExtendedType:  (*descriptor.FieldOptions)(nil),
    ExtensionType: (*bool)(nil),
    Field:         1059,
    Name:          "csi.v1.csi_secret",
    Tag:           "varint,1059,opt,name=csi_secret",
    Filename:      "csi.proto",
}
var NodeServiceCapability_RPC_Type_name = map[int32]string{
    0:  "UNKNOWN",
    1:  "STAGE_UNSTAGE_VOLUME",
    2:  "GET_VOLUME_STATS",
    3:  "EXPAND_VOLUME",
}
var NodeServiceCapability_RPC_Type_value = map[string]int32{
    "UNKNOWN":              0,
    "STAGE_UNSTAGE_VOLUME": 1,
    "GET_VOLUME_STATS":     2,
    "EXPAND_VOLUME":        3,
}
var PluginCapability_Service_Type_name = map[int32]string{
    0:  "UNKNOWN",
    1:  "CONTROLLER_SERVICE",
    2:  "VOLUME_ACCESSIBILITY_CONSTRAINTS",
}
var PluginCapability_Service_Type_value = map[string]int32{
    "UNKNOWN":                          0,
    "CONTROLLER_SERVICE":               1,
    "VOLUME_ACCESSIBILITY_CONSTRAINTS": 2,
}
var PluginCapability_VolumeExpansion_Type_name = map[int32]string{
    0:  "UNKNOWN",
    1:  "ONLINE",
    2:  "OFFLINE",
}
var PluginCapability_VolumeExpansion_Type_value = map[string]int32{
    "UNKNOWN": 0,
    "ONLINE":  1,
    "OFFLINE": 2,
}
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",
}
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,
}
var VolumeUsage_Unit_name = map[int32]string{
    0:  "UNKNOWN",
    1:  "BYTES",
    2:  "INODES",
}
var VolumeUsage_Unit_value = map[string]int32{
    "UNKNOWN": 0,
    "BYTES":   1,
    "INODES":  2,
}

func RegisterControllerServer Uses

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

func RegisterIdentityServer Uses

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

func RegisterNodeServer Uses

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

type CapacityRange Uses

type CapacityRange struct {
    // Volume MUST be at least this big. This field is OPTIONAL.
    // A value of 0 is equal to an unspecified field value.
    // The value of this field MUST NOT be negative.
    RequiredBytes int64 `protobuf:"varint,1,opt,name=required_bytes,json=requiredBytes,proto3" json:"required_bytes,omitempty"`
    // Volume MUST not be bigger than this. This field is OPTIONAL.
    // A value of 0 is equal to an unspecified field value.
    // The value of this field MUST NOT be negative.
    LimitBytes           int64    `protobuf:"varint,2,opt,name=limit_bytes,json=limitBytes,proto3" json:"limit_bytes,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

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

func (*CapacityRange) Descriptor Uses

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

func (*CapacityRange) GetLimitBytes Uses

func (m *CapacityRange) GetLimitBytes() int64

func (*CapacityRange) GetRequiredBytes Uses

func (m *CapacityRange) GetRequiredBytes() int64

func (*CapacityRange) ProtoMessage Uses

func (*CapacityRange) ProtoMessage()

func (*CapacityRange) Reset Uses

func (m *CapacityRange) Reset()

func (*CapacityRange) String Uses

func (m *CapacityRange) String() string

func (*CapacityRange) XXX_DiscardUnknown Uses

func (m *CapacityRange) XXX_DiscardUnknown()

func (*CapacityRange) XXX_Marshal Uses

func (m *CapacityRange) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CapacityRange) XXX_Merge Uses

func (m *CapacityRange) XXX_Merge(src proto.Message)

func (*CapacityRange) XXX_Size Uses

func (m *CapacityRange) XXX_Size() int

func (*CapacityRange) XXX_Unmarshal Uses

func (m *CapacityRange) XXX_Unmarshal(b []byte) error

type ControllerClient Uses

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)
    CreateSnapshot(ctx context.Context, in *CreateSnapshotRequest, opts ...grpc.CallOption) (*CreateSnapshotResponse, error)
    DeleteSnapshot(ctx context.Context, in *DeleteSnapshotRequest, opts ...grpc.CallOption) (*DeleteSnapshotResponse, error)
    ListSnapshots(ctx context.Context, in *ListSnapshotsRequest, opts ...grpc.CallOption) (*ListSnapshotsResponse, error)
    ControllerExpandVolume(ctx context.Context, in *ControllerExpandVolumeRequest, opts ...grpc.CallOption) (*ControllerExpandVolumeResponse, error)
}

ControllerClient is the client API for Controller service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewControllerClient Uses

func NewControllerClient(cc *grpc.ClientConn) ControllerClient

type ControllerExpandVolumeRequest Uses

type ControllerExpandVolumeRequest struct {
    // The ID of the volume to expand. This field is REQUIRED.
    VolumeId string `protobuf:"bytes,1,opt,name=volume_id,json=volumeId,proto3" json:"volume_id,omitempty"`
    // This allows CO to specify the capacity requirements of the volume
    // after expansion. This field is REQUIRED.
    CapacityRange *CapacityRange `protobuf:"bytes,2,opt,name=capacity_range,json=capacityRange,proto3" json:"capacity_range,omitempty"`
    // Secrets required by the plugin for expanding the volume.
    // This field is OPTIONAL.
    Secrets              map[string]string `protobuf:"bytes,3,rep,name=secrets,proto3" json:"secrets,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
    XXX_NoUnkeyedLiteral struct{}          `json:"-"`
    XXX_unrecognized     []byte            `json:"-"`
    XXX_sizecache        int32             `json:"-"`
}

func (*ControllerExpandVolumeRequest) Descriptor Uses

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

func (*ControllerExpandVolumeRequest) GetCapacityRange Uses

func (m *ControllerExpandVolumeRequest) GetCapacityRange() *CapacityRange

func (*ControllerExpandVolumeRequest) GetSecrets Uses

func (m *ControllerExpandVolumeRequest) GetSecrets() map[string]string

func (*ControllerExpandVolumeRequest) GetVolumeId Uses

func (m *ControllerExpandVolumeRequest) GetVolumeId() string

func (*ControllerExpandVolumeRequest) ProtoMessage Uses

func (*ControllerExpandVolumeRequest) ProtoMessage()

func (*ControllerExpandVolumeRequest) Reset Uses

func (m *ControllerExpandVolumeRequest) Reset()

func (*ControllerExpandVolumeRequest) String Uses

func (m *ControllerExpandVolumeRequest) String() string

func (*ControllerExpandVolumeRequest) XXX_DiscardUnknown Uses

func (m *ControllerExpandVolumeRequest) XXX_DiscardUnknown()

func (*ControllerExpandVolumeRequest) XXX_Marshal Uses

func (m *ControllerExpandVolumeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ControllerExpandVolumeRequest) XXX_Merge Uses

func (m *ControllerExpandVolumeRequest) XXX_Merge(src proto.Message)

func (*ControllerExpandVolumeRequest) XXX_Size Uses

func (m *ControllerExpandVolumeRequest) XXX_Size() int

func (*ControllerExpandVolumeRequest) XXX_Unmarshal Uses

func (m *ControllerExpandVolumeRequest) XXX_Unmarshal(b []byte) error

type ControllerExpandVolumeResponse Uses

type ControllerExpandVolumeResponse struct {
    // Capacity of volume after expansion. This field is REQUIRED.
    CapacityBytes int64 `protobuf:"varint,1,opt,name=capacity_bytes,json=capacityBytes,proto3" json:"capacity_bytes,omitempty"`
    // Whether node expansion is required for the volume. When true
    // the CO MUST make NodeExpandVolume RPC call on the node. This field
    // is REQUIRED.
    NodeExpansionRequired bool     `protobuf:"varint,2,opt,name=node_expansion_required,json=nodeExpansionRequired,proto3" json:"node_expansion_required,omitempty"`
    XXX_NoUnkeyedLiteral  struct{} `json:"-"`
    XXX_unrecognized      []byte   `json:"-"`
    XXX_sizecache         int32    `json:"-"`
}

func (*ControllerExpandVolumeResponse) Descriptor Uses

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

func (*ControllerExpandVolumeResponse) GetCapacityBytes Uses

func (m *ControllerExpandVolumeResponse) GetCapacityBytes() int64

func (*ControllerExpandVolumeResponse) GetNodeExpansionRequired Uses

func (m *ControllerExpandVolumeResponse) GetNodeExpansionRequired() bool

func (*ControllerExpandVolumeResponse) ProtoMessage Uses

func (*ControllerExpandVolumeResponse) ProtoMessage()

func (*ControllerExpandVolumeResponse) Reset Uses

func (m *ControllerExpandVolumeResponse) Reset()

func (*ControllerExpandVolumeResponse) String Uses

func (m *ControllerExpandVolumeResponse) String() string

func (*ControllerExpandVolumeResponse) XXX_DiscardUnknown Uses

func (m *ControllerExpandVolumeResponse) XXX_DiscardUnknown()

func (*ControllerExpandVolumeResponse) XXX_Marshal Uses

func (m *ControllerExpandVolumeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ControllerExpandVolumeResponse) XXX_Merge Uses

func (m *ControllerExpandVolumeResponse) XXX_Merge(src proto.Message)

func (*ControllerExpandVolumeResponse) XXX_Size Uses

func (m *ControllerExpandVolumeResponse) XXX_Size() int

func (*ControllerExpandVolumeResponse) XXX_Unmarshal Uses

func (m *ControllerExpandVolumeResponse) XXX_Unmarshal(b []byte) error

type ControllerGetCapabilitiesRequest Uses

type ControllerGetCapabilitiesRequest struct {
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*ControllerGetCapabilitiesRequest) Descriptor Uses

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

func (*ControllerGetCapabilitiesRequest) ProtoMessage Uses

func (*ControllerGetCapabilitiesRequest) ProtoMessage()

func (*ControllerGetCapabilitiesRequest) Reset Uses

func (m *ControllerGetCapabilitiesRequest) Reset()

func (*ControllerGetCapabilitiesRequest) String Uses

func (m *ControllerGetCapabilitiesRequest) String() string

func (*ControllerGetCapabilitiesRequest) XXX_DiscardUnknown Uses

func (m *ControllerGetCapabilitiesRequest) XXX_DiscardUnknown()

func (*ControllerGetCapabilitiesRequest) XXX_Marshal Uses

func (m *ControllerGetCapabilitiesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ControllerGetCapabilitiesRequest) XXX_Merge Uses

func (m *ControllerGetCapabilitiesRequest) XXX_Merge(src proto.Message)

func (*ControllerGetCapabilitiesRequest) XXX_Size Uses

func (m *ControllerGetCapabilitiesRequest) XXX_Size() int

func (*ControllerGetCapabilitiesRequest) XXX_Unmarshal Uses

func (m *ControllerGetCapabilitiesRequest) XXX_Unmarshal(b []byte) error

type ControllerGetCapabilitiesResponse Uses

type ControllerGetCapabilitiesResponse struct {
    // All the capabilities that the controller service supports. This
    // field is OPTIONAL.
    Capabilities         []*ControllerServiceCapability `protobuf:"bytes,1,rep,name=capabilities,proto3" json:"capabilities,omitempty"`
    XXX_NoUnkeyedLiteral struct{}                       `json:"-"`
    XXX_unrecognized     []byte                         `json:"-"`
    XXX_sizecache        int32                          `json:"-"`
}

func (*ControllerGetCapabilitiesResponse) Descriptor Uses

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

func (*ControllerGetCapabilitiesResponse) GetCapabilities Uses

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

func (*ControllerGetCapabilitiesResponse) ProtoMessage Uses

func (*ControllerGetCapabilitiesResponse) ProtoMessage()

func (*ControllerGetCapabilitiesResponse) Reset Uses

func (m *ControllerGetCapabilitiesResponse) Reset()

func (*ControllerGetCapabilitiesResponse) String Uses

func (m *ControllerGetCapabilitiesResponse) String() string

func (*ControllerGetCapabilitiesResponse) XXX_DiscardUnknown Uses

func (m *ControllerGetCapabilitiesResponse) XXX_DiscardUnknown()

func (*ControllerGetCapabilitiesResponse) XXX_Marshal Uses

func (m *ControllerGetCapabilitiesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ControllerGetCapabilitiesResponse) XXX_Merge Uses

func (m *ControllerGetCapabilitiesResponse) XXX_Merge(src proto.Message)

func (*ControllerGetCapabilitiesResponse) XXX_Size Uses

func (m *ControllerGetCapabilitiesResponse) XXX_Size() int

func (*ControllerGetCapabilitiesResponse) XXX_Unmarshal Uses

func (m *ControllerGetCapabilitiesResponse) XXX_Unmarshal(b []byte) error

type ControllerPublishVolumeRequest Uses

type ControllerPublishVolumeRequest struct {
    // The ID of the volume to be used on a node.
    // This field is REQUIRED.
    VolumeId string `protobuf:"bytes,1,opt,name=volume_id,json=volumeId,proto3" json:"volume_id,omitempty"`
    // The ID of the node. This field is REQUIRED. The CO SHALL set this
    // field to match the node ID returned by `NodeGetInfo`.
    NodeId string `protobuf:"bytes,2,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
    // Volume capability describing how the CO intends to use this volume.
    // SP MUST ensure the CO can use the published volume as described.
    // Otherwise SP MUST return the appropriate gRPC error code.
    // This is a REQUIRED field.
    VolumeCapability *VolumeCapability `protobuf:"bytes,3,opt,name=volume_capability,json=volumeCapability,proto3" json:"volume_capability,omitempty"`
    // Indicates SP MUST publish the volume in readonly mode.
    // CO MUST set this field to false if SP does not have the
    // PUBLISH_READONLY controller capability.
    // This is a REQUIRED field.
    Readonly bool `protobuf:"varint,4,opt,name=readonly,proto3" json:"readonly,omitempty"`
    // Secrets required by plugin to complete controller publish volume
    // request. This field is OPTIONAL. Refer to the
    // `Secrets Requirements` section on how to use this field.
    Secrets map[string]string `protobuf:"bytes,5,rep,name=secrets,proto3" json:"secrets,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
    // Volume context as returned by CO in CreateVolumeRequest. This field
    // is OPTIONAL and MUST match the volume_context of the volume
    // identified by `volume_id`.
    VolumeContext        map[string]string `protobuf:"bytes,6,rep,name=volume_context,json=volumeContext,proto3" json:"volume_context,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
    XXX_NoUnkeyedLiteral struct{}          `json:"-"`
    XXX_unrecognized     []byte            `json:"-"`
    XXX_sizecache        int32             `json:"-"`
}

func (*ControllerPublishVolumeRequest) Descriptor Uses

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

func (*ControllerPublishVolumeRequest) GetNodeId Uses

func (m *ControllerPublishVolumeRequest) GetNodeId() string

func (*ControllerPublishVolumeRequest) GetReadonly Uses

func (m *ControllerPublishVolumeRequest) GetReadonly() bool

func (*ControllerPublishVolumeRequest) GetSecrets Uses

func (m *ControllerPublishVolumeRequest) GetSecrets() map[string]string

func (*ControllerPublishVolumeRequest) GetVolumeCapability Uses

func (m *ControllerPublishVolumeRequest) GetVolumeCapability() *VolumeCapability

func (*ControllerPublishVolumeRequest) GetVolumeContext Uses

func (m *ControllerPublishVolumeRequest) GetVolumeContext() map[string]string

func (*ControllerPublishVolumeRequest) GetVolumeId Uses

func (m *ControllerPublishVolumeRequest) GetVolumeId() string

func (*ControllerPublishVolumeRequest) ProtoMessage Uses

func (*ControllerPublishVolumeRequest) ProtoMessage()

func (*ControllerPublishVolumeRequest) Reset Uses

func (m *ControllerPublishVolumeRequest) Reset()

func (*ControllerPublishVolumeRequest) String Uses

func (m *ControllerPublishVolumeRequest) String() string

func (*ControllerPublishVolumeRequest) XXX_DiscardUnknown Uses

func (m *ControllerPublishVolumeRequest) XXX_DiscardUnknown()

func (*ControllerPublishVolumeRequest) XXX_Marshal Uses

func (m *ControllerPublishVolumeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ControllerPublishVolumeRequest) XXX_Merge Uses

func (m *ControllerPublishVolumeRequest) XXX_Merge(src proto.Message)

func (*ControllerPublishVolumeRequest) XXX_Size Uses

func (m *ControllerPublishVolumeRequest) XXX_Size() int

func (*ControllerPublishVolumeRequest) XXX_Unmarshal Uses

func (m *ControllerPublishVolumeRequest) XXX_Unmarshal(b []byte) error

type ControllerPublishVolumeResponse Uses

type ControllerPublishVolumeResponse struct {
    // Opaque static publish properties of the volume. SP MAY use this
    // field to ensure subsequent `NodeStageVolume` or `NodePublishVolume`
    // calls calls have contextual information.
    // The contents of this field SHALL be opaque to a CO.
    // The contents of this field SHALL NOT be mutable.
    // The contents of this field SHALL be safe for the CO to cache.
    // The contents of this field SHOULD NOT contain sensitive
    // information.
    // The contents of this field SHOULD NOT be used for uniquely
    // identifying a volume. The `volume_id` alone SHOULD be sufficient to
    // identify the volume.
    // This field is OPTIONAL and when present MUST be passed to
    // subsequent `NodeStageVolume` or `NodePublishVolume` calls
    PublishContext       map[string]string `protobuf:"bytes,1,rep,name=publish_context,json=publishContext,proto3" json:"publish_context,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
    XXX_NoUnkeyedLiteral struct{}          `json:"-"`
    XXX_unrecognized     []byte            `json:"-"`
    XXX_sizecache        int32             `json:"-"`
}

func (*ControllerPublishVolumeResponse) Descriptor Uses

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

func (*ControllerPublishVolumeResponse) GetPublishContext Uses

func (m *ControllerPublishVolumeResponse) GetPublishContext() map[string]string

func (*ControllerPublishVolumeResponse) ProtoMessage Uses

func (*ControllerPublishVolumeResponse) ProtoMessage()

func (*ControllerPublishVolumeResponse) Reset Uses

func (m *ControllerPublishVolumeResponse) Reset()

func (*ControllerPublishVolumeResponse) String Uses

func (m *ControllerPublishVolumeResponse) String() string

func (*ControllerPublishVolumeResponse) XXX_DiscardUnknown Uses

func (m *ControllerPublishVolumeResponse) XXX_DiscardUnknown()

func (*ControllerPublishVolumeResponse) XXX_Marshal Uses

func (m *ControllerPublishVolumeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ControllerPublishVolumeResponse) XXX_Merge Uses

func (m *ControllerPublishVolumeResponse) XXX_Merge(src proto.Message)

func (*ControllerPublishVolumeResponse) XXX_Size Uses

func (m *ControllerPublishVolumeResponse) XXX_Size() int

func (*ControllerPublishVolumeResponse) XXX_Unmarshal Uses

func (m *ControllerPublishVolumeResponse) XXX_Unmarshal(b []byte) error

type ControllerServer Uses

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)
    CreateSnapshot(context.Context, *CreateSnapshotRequest) (*CreateSnapshotResponse, error)
    DeleteSnapshot(context.Context, *DeleteSnapshotRequest) (*DeleteSnapshotResponse, error)
    ListSnapshots(context.Context, *ListSnapshotsRequest) (*ListSnapshotsResponse, error)
    ControllerExpandVolume(context.Context, *ControllerExpandVolumeRequest) (*ControllerExpandVolumeResponse, error)
}

ControllerServer is the server API for Controller service.

type ControllerServiceCapability Uses

type ControllerServiceCapability struct {
    // Types that are valid to be assigned to Type:
    //	*ControllerServiceCapability_Rpc
    Type                 isControllerServiceCapability_Type `protobuf_oneof:"type"`
    XXX_NoUnkeyedLiteral struct{}                           `json:"-"`
    XXX_unrecognized     []byte                             `json:"-"`
    XXX_sizecache        int32                              `json:"-"`
}

Specifies a capability of the controller service.

func (*ControllerServiceCapability) Descriptor Uses

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

func (*ControllerServiceCapability) GetRpc Uses

func (m *ControllerServiceCapability) GetRpc() *ControllerServiceCapability_RPC

func (*ControllerServiceCapability) GetType Uses

func (m *ControllerServiceCapability) GetType() isControllerServiceCapability_Type

func (*ControllerServiceCapability) ProtoMessage Uses

func (*ControllerServiceCapability) ProtoMessage()

func (*ControllerServiceCapability) Reset Uses

func (m *ControllerServiceCapability) Reset()

func (*ControllerServiceCapability) String Uses

func (m *ControllerServiceCapability) String() string

func (*ControllerServiceCapability) XXX_DiscardUnknown Uses

func (m *ControllerServiceCapability) XXX_DiscardUnknown()

func (*ControllerServiceCapability) XXX_Marshal Uses

func (m *ControllerServiceCapability) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ControllerServiceCapability) XXX_Merge Uses

func (m *ControllerServiceCapability) XXX_Merge(src proto.Message)

func (*ControllerServiceCapability) XXX_OneofWrappers Uses

func (*ControllerServiceCapability) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*ControllerServiceCapability) XXX_Size Uses

func (m *ControllerServiceCapability) XXX_Size() int

func (*ControllerServiceCapability) XXX_Unmarshal Uses

func (m *ControllerServiceCapability) XXX_Unmarshal(b []byte) error

type ControllerServiceCapability_RPC Uses

type ControllerServiceCapability_RPC struct {
    Type                 ControllerServiceCapability_RPC_Type `protobuf:"varint,1,opt,name=type,proto3,enum=csi.v1.ControllerServiceCapability_RPC_Type" json:"type,omitempty"`
    XXX_NoUnkeyedLiteral struct{}                             `json:"-"`
    XXX_unrecognized     []byte                               `json:"-"`
    XXX_sizecache        int32                                `json:"-"`
}

func (*ControllerServiceCapability_RPC) Descriptor Uses

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

func (*ControllerServiceCapability_RPC) GetType Uses

func (m *ControllerServiceCapability_RPC) GetType() ControllerServiceCapability_RPC_Type

func (*ControllerServiceCapability_RPC) ProtoMessage Uses

func (*ControllerServiceCapability_RPC) ProtoMessage()

func (*ControllerServiceCapability_RPC) Reset Uses

func (m *ControllerServiceCapability_RPC) Reset()

func (*ControllerServiceCapability_RPC) String Uses

func (m *ControllerServiceCapability_RPC) String() string

func (*ControllerServiceCapability_RPC) XXX_DiscardUnknown Uses

func (m *ControllerServiceCapability_RPC) XXX_DiscardUnknown()

func (*ControllerServiceCapability_RPC) XXX_Marshal Uses

func (m *ControllerServiceCapability_RPC) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ControllerServiceCapability_RPC) XXX_Merge Uses

func (m *ControllerServiceCapability_RPC) XXX_Merge(src proto.Message)

func (*ControllerServiceCapability_RPC) XXX_Size Uses

func (m *ControllerServiceCapability_RPC) XXX_Size() int

func (*ControllerServiceCapability_RPC) XXX_Unmarshal Uses

func (m *ControllerServiceCapability_RPC) XXX_Unmarshal(b []byte) error

type ControllerServiceCapability_RPC_Type Uses

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
    // Currently the only way to consume a snapshot is to create
    // a volume from it. Therefore plugins supporting
    // CREATE_DELETE_SNAPSHOT MUST support creating volume from
    // snapshot.
    ControllerServiceCapability_RPC_CREATE_DELETE_SNAPSHOT ControllerServiceCapability_RPC_Type = 5
    ControllerServiceCapability_RPC_LIST_SNAPSHOTS         ControllerServiceCapability_RPC_Type = 6
    // Plugins supporting volume cloning at the storage level MAY
    // report this capability. The source volume MUST be managed by
    // the same plugin. Not all volume sources and parameters
    // combinations MAY work.
    ControllerServiceCapability_RPC_CLONE_VOLUME ControllerServiceCapability_RPC_Type = 7
    // Indicates the SP supports ControllerPublishVolume.readonly
    // field.
    ControllerServiceCapability_RPC_PUBLISH_READONLY ControllerServiceCapability_RPC_Type = 8
    // See VolumeExpansion for details.
    ControllerServiceCapability_RPC_EXPAND_VOLUME ControllerServiceCapability_RPC_Type = 9
)

func (ControllerServiceCapability_RPC_Type) EnumDescriptor Uses

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

func (ControllerServiceCapability_RPC_Type) String Uses

func (x ControllerServiceCapability_RPC_Type) String() string

type ControllerServiceCapability_Rpc Uses

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

type ControllerUnpublishVolumeRequest Uses

type ControllerUnpublishVolumeRequest struct {
    // The ID of the volume. This field is REQUIRED.
    VolumeId string `protobuf:"bytes,1,opt,name=volume_id,json=volumeId,proto3" json:"volume_id,omitempty"`
    // The ID of the node. This field is OPTIONAL. The CO SHOULD set this
    // field to match the node ID returned by `NodeGetInfo` or leave it
    // unset. If the value is set, the SP MUST unpublish the volume from
    // the specified node. If the value is unset, the SP MUST unpublish
    // the volume from all nodes it is published to.
    NodeId string `protobuf:"bytes,2,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
    // Secrets required by plugin to complete controller unpublish volume
    // request. This SHOULD be the same secrets passed to the
    // ControllerPublishVolume call for the specified volume.
    // This field is OPTIONAL. Refer to the `Secrets Requirements`
    // section on how to use this field.
    Secrets              map[string]string `protobuf:"bytes,3,rep,name=secrets,proto3" json:"secrets,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
    XXX_NoUnkeyedLiteral struct{}          `json:"-"`
    XXX_unrecognized     []byte            `json:"-"`
    XXX_sizecache        int32             `json:"-"`
}

func (*ControllerUnpublishVolumeRequest) Descriptor Uses

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

func (*ControllerUnpublishVolumeRequest) GetNodeId Uses

func (m *ControllerUnpublishVolumeRequest) GetNodeId() string

func (*ControllerUnpublishVolumeRequest) GetSecrets Uses

func (m *ControllerUnpublishVolumeRequest) GetSecrets() map[string]string

func (*ControllerUnpublishVolumeRequest) GetVolumeId Uses

func (m *ControllerUnpublishVolumeRequest) GetVolumeId() string

func (*ControllerUnpublishVolumeRequest) ProtoMessage Uses

func (*ControllerUnpublishVolumeRequest) ProtoMessage()

func (*ControllerUnpublishVolumeRequest) Reset Uses

func (m *ControllerUnpublishVolumeRequest) Reset()

func (*ControllerUnpublishVolumeRequest) String Uses

func (m *ControllerUnpublishVolumeRequest) String() string

func (*ControllerUnpublishVolumeRequest) XXX_DiscardUnknown Uses

func (m *ControllerUnpublishVolumeRequest) XXX_DiscardUnknown()

func (*ControllerUnpublishVolumeRequest) XXX_Marshal Uses

func (m *ControllerUnpublishVolumeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ControllerUnpublishVolumeRequest) XXX_Merge Uses

func (m *ControllerUnpublishVolumeRequest) XXX_Merge(src proto.Message)

func (*ControllerUnpublishVolumeRequest) XXX_Size Uses

func (m *ControllerUnpublishVolumeRequest) XXX_Size() int

func (*ControllerUnpublishVolumeRequest) XXX_Unmarshal Uses

func (m *ControllerUnpublishVolumeRequest) XXX_Unmarshal(b []byte) error

type ControllerUnpublishVolumeResponse Uses

type ControllerUnpublishVolumeResponse struct {
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*ControllerUnpublishVolumeResponse) Descriptor Uses

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

func (*ControllerUnpublishVolumeResponse) ProtoMessage Uses

func (*ControllerUnpublishVolumeResponse) ProtoMessage()

func (*ControllerUnpublishVolumeResponse) Reset Uses

func (m *ControllerUnpublishVolumeResponse) Reset()

func (*ControllerUnpublishVolumeResponse) String Uses

func (m *ControllerUnpublishVolumeResponse) String() string

func (*ControllerUnpublishVolumeResponse) XXX_DiscardUnknown Uses

func (m *ControllerUnpublishVolumeResponse) XXX_DiscardUnknown()

func (*ControllerUnpublishVolumeResponse) XXX_Marshal Uses

func (m *ControllerUnpublishVolumeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ControllerUnpublishVolumeResponse) XXX_Merge Uses

func (m *ControllerUnpublishVolumeResponse) XXX_Merge(src proto.Message)

func (*ControllerUnpublishVolumeResponse) XXX_Size Uses

func (m *ControllerUnpublishVolumeResponse) XXX_Size() int

func (*ControllerUnpublishVolumeResponse) XXX_Unmarshal Uses

func (m *ControllerUnpublishVolumeResponse) XXX_Unmarshal(b []byte) error

type CreateSnapshotRequest Uses

type CreateSnapshotRequest struct {
    // The ID of the source volume to be snapshotted.
    // This field is REQUIRED.
    SourceVolumeId string `protobuf:"bytes,1,opt,name=source_volume_id,json=sourceVolumeId,proto3" json:"source_volume_id,omitempty"`
    // The suggested name for the snapshot. This field is REQUIRED for
    // idempotency.
    // Any Unicode string that conforms to the length limit is allowed
    // except those containing the following banned characters:
    // U+0000-U+0008, U+000B, U+000C, U+000E-U+001F, U+007F-U+009F.
    // (These are control characters other than commonly used whitespace.)
    Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
    // Secrets required by plugin to complete snapshot creation request.
    // This field is OPTIONAL. Refer to the `Secrets Requirements`
    // section on how to use this field.
    Secrets map[string]string `protobuf:"bytes,3,rep,name=secrets,proto3" json:"secrets,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
    // 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.
    // Use cases for opaque parameters:
    // - Specify a policy to automatically clean up the snapshot.
    // - Specify an expiration date for the snapshot.
    // - Specify whether the snapshot is readonly or read/write.
    // - Specify if the snapshot should be replicated to some place.
    // - Specify primary or secondary for replication systems that
    //   support snapshotting only on primary.
    Parameters           map[string]string `protobuf:"bytes,4,rep,name=parameters,proto3" json:"parameters,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
    XXX_NoUnkeyedLiteral struct{}          `json:"-"`
    XXX_unrecognized     []byte            `json:"-"`
    XXX_sizecache        int32             `json:"-"`
}

func (*CreateSnapshotRequest) Descriptor Uses

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

func (*CreateSnapshotRequest) GetName Uses

func (m *CreateSnapshotRequest) GetName() string

func (*CreateSnapshotRequest) GetParameters Uses

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

func (*CreateSnapshotRequest) GetSecrets Uses

func (m *CreateSnapshotRequest) GetSecrets() map[string]string

func (*CreateSnapshotRequest) GetSourceVolumeId Uses

func (m *CreateSnapshotRequest) GetSourceVolumeId() string

func (*CreateSnapshotRequest) ProtoMessage Uses

func (*CreateSnapshotRequest) ProtoMessage()

func (*CreateSnapshotRequest) Reset Uses

func (m *CreateSnapshotRequest) Reset()

func (*CreateSnapshotRequest) String Uses

func (m *CreateSnapshotRequest) String() string

func (*CreateSnapshotRequest) XXX_DiscardUnknown Uses

func (m *CreateSnapshotRequest) XXX_DiscardUnknown()

func (*CreateSnapshotRequest) XXX_Marshal Uses

func (m *CreateSnapshotRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateSnapshotRequest) XXX_Merge Uses

func (m *CreateSnapshotRequest) XXX_Merge(src proto.Message)

func (*CreateSnapshotRequest) XXX_Size Uses

func (m *CreateSnapshotRequest) XXX_Size() int

func (*CreateSnapshotRequest) XXX_Unmarshal Uses

func (m *CreateSnapshotRequest) XXX_Unmarshal(b []byte) error

type CreateSnapshotResponse Uses

type CreateSnapshotResponse struct {
    // Contains all attributes of the newly created snapshot that are
    // relevant to the CO along with information required by the Plugin
    // to uniquely identify the snapshot. This field is REQUIRED.
    Snapshot             *Snapshot `protobuf:"bytes,1,opt,name=snapshot,proto3" json:"snapshot,omitempty"`
    XXX_NoUnkeyedLiteral struct{}  `json:"-"`
    XXX_unrecognized     []byte    `json:"-"`
    XXX_sizecache        int32     `json:"-"`
}

func (*CreateSnapshotResponse) Descriptor Uses

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

func (*CreateSnapshotResponse) GetSnapshot Uses

func (m *CreateSnapshotResponse) GetSnapshot() *Snapshot

func (*CreateSnapshotResponse) ProtoMessage Uses

func (*CreateSnapshotResponse) ProtoMessage()

func (*CreateSnapshotResponse) Reset Uses

func (m *CreateSnapshotResponse) Reset()

func (*CreateSnapshotResponse) String Uses

func (m *CreateSnapshotResponse) String() string

func (*CreateSnapshotResponse) XXX_DiscardUnknown Uses

func (m *CreateSnapshotResponse) XXX_DiscardUnknown()

func (*CreateSnapshotResponse) XXX_Marshal Uses

func (m *CreateSnapshotResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateSnapshotResponse) XXX_Merge Uses

func (m *CreateSnapshotResponse) XXX_Merge(src proto.Message)

func (*CreateSnapshotResponse) XXX_Size Uses

func (m *CreateSnapshotResponse) XXX_Size() int

func (*CreateSnapshotResponse) XXX_Unmarshal Uses

func (m *CreateSnapshotResponse) XXX_Unmarshal(b []byte) error

type CreateVolumeRequest Uses

type CreateVolumeRequest struct {
    // 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.  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.
    //    In the case of error, the CO MUST handle the gRPC error codes
    //    per the recovery behavior defined in the "CreateVolume Errors"
    //    section below.
    //    The CO is responsible for cleaning up volumes it provisioned
    //    that it no longer needs. If the CO is uncertain whether a volume
    //    was provisioned or not when a `CreateVolume` call fails, the CO
    //    MAY call `CreateVolume` again, with the same name, to ensure the
    //    volume exists and to retrieve the volume's `volume_id` (unless
    //    otherwise prohibited by "CreateVolume Errors").
    // 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.
    // Any Unicode string that conforms to the length limit is allowed
    // except those containing the following banned characters:
    // U+0000-U+0008, U+000B, U+000C, U+000E-U+001F, U+007F-U+009F.
    // (These are control characters other than commonly used whitespace.)
    Name string `protobuf:"bytes,1,opt,name=name,proto3" 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. If
    // specified it MUST always be honored, even when creating volumes
    // from a source; which MAY force some backends to internally extend
    // the volume after creating it.
    CapacityRange *CapacityRange `protobuf:"bytes,2,opt,name=capacity_range,json=capacityRange,proto3" json:"capacity_range,omitempty"`
    // The capabilities that the provisioned volume MUST have. SP MUST
    // provision a volume that will satisfy ALL of the capabilities
    // specified in this list. Otherwise SP MUST return the appropriate
    // gRPC error code.
    // The Plugin MUST assume that the CO MAY use the provisioned volume
    // with ANY of the capabilities specified in this list.
    // For example, a CO MAY specify two volume capabilities: one with
    // access mode SINGLE_NODE_WRITER and another with access mode
    // MULTI_NODE_READER_ONLY. In this case, the SP MUST verify that the
    // provisioned volume can be used in either mode.
    // This also enables the CO to do early validation: If ANY of the
    // specified volume capabilities are not supported by the SP, the call
    // MUST return the appropriate gRPC error code.
    // This field is REQUIRED.
    VolumeCapabilities []*VolumeCapability `protobuf:"bytes,3,rep,name=volume_capabilities,json=volumeCapabilities,proto3" 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 `protobuf:"bytes,4,rep,name=parameters,proto3" json:"parameters,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
    // Secrets required by plugin to complete volume creation request.
    // This field is OPTIONAL. Refer to the `Secrets Requirements`
    // section on how to use this field.
    Secrets map[string]string `protobuf:"bytes,5,rep,name=secrets,proto3" json:"secrets,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
    // If specified, the new volume will be pre-populated with data from
    // this source. This field is OPTIONAL.
    VolumeContentSource *VolumeContentSource `protobuf:"bytes,6,opt,name=volume_content_source,json=volumeContentSource,proto3" json:"volume_content_source,omitempty"`
    // Specifies where (regions, zones, racks, etc.) the provisioned
    // volume MUST be accessible from.
    // An SP SHALL advertise the requirements for topological
    // accessibility information in documentation. COs SHALL only specify
    // topological accessibility information supported by the SP.
    // This field is OPTIONAL.
    // This field SHALL NOT be specified unless the SP has the
    // VOLUME_ACCESSIBILITY_CONSTRAINTS plugin capability.
    // If this field is not specified and the SP has the
    // VOLUME_ACCESSIBILITY_CONSTRAINTS plugin capability, the SP MAY
    // choose where the provisioned volume is accessible from.
    AccessibilityRequirements *TopologyRequirement `protobuf:"bytes,7,opt,name=accessibility_requirements,json=accessibilityRequirements,proto3" json:"accessibility_requirements,omitempty"`
    XXX_NoUnkeyedLiteral      struct{}             `json:"-"`
    XXX_unrecognized          []byte               `json:"-"`
    XXX_sizecache             int32                `json:"-"`
}

func (*CreateVolumeRequest) Descriptor Uses

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

func (*CreateVolumeRequest) GetAccessibilityRequirements Uses

func (m *CreateVolumeRequest) GetAccessibilityRequirements() *TopologyRequirement

func (*CreateVolumeRequest) GetCapacityRange Uses

func (m *CreateVolumeRequest) GetCapacityRange() *CapacityRange

func (*CreateVolumeRequest) GetName Uses

func (m *CreateVolumeRequest) GetName() string

func (*CreateVolumeRequest) GetParameters Uses

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

func (*CreateVolumeRequest) GetSecrets Uses

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

func (*CreateVolumeRequest) GetVolumeCapabilities Uses

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

func (*CreateVolumeRequest) GetVolumeContentSource Uses

func (m *CreateVolumeRequest) GetVolumeContentSource() *VolumeContentSource

func (*CreateVolumeRequest) ProtoMessage Uses

func (*CreateVolumeRequest) ProtoMessage()

func (*CreateVolumeRequest) Reset Uses

func (m *CreateVolumeRequest) Reset()

func (*CreateVolumeRequest) String Uses

func (m *CreateVolumeRequest) String() string

func (*CreateVolumeRequest) XXX_DiscardUnknown Uses

func (m *CreateVolumeRequest) XXX_DiscardUnknown()

func (*CreateVolumeRequest) XXX_Marshal Uses

func (m *CreateVolumeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateVolumeRequest) XXX_Merge Uses

func (m *CreateVolumeRequest) XXX_Merge(src proto.Message)

func (*CreateVolumeRequest) XXX_Size Uses

func (m *CreateVolumeRequest) XXX_Size() int

func (*CreateVolumeRequest) XXX_Unmarshal Uses

func (m *CreateVolumeRequest) XXX_Unmarshal(b []byte) error

type CreateVolumeResponse Uses

type CreateVolumeResponse struct {
    // Contains all attributes of the newly created volume that are
    // relevant to the CO along with information required by the Plugin
    // to uniquely identify the volume. This field is REQUIRED.
    Volume               *Volume  `protobuf:"bytes,1,opt,name=volume,proto3" json:"volume,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*CreateVolumeResponse) Descriptor Uses

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

func (*CreateVolumeResponse) GetVolume Uses

func (m *CreateVolumeResponse) GetVolume() *Volume

func (*CreateVolumeResponse) ProtoMessage Uses

func (*CreateVolumeResponse) ProtoMessage()

func (*CreateVolumeResponse) Reset Uses

func (m *CreateVolumeResponse) Reset()

func (*CreateVolumeResponse) String Uses

func (m *CreateVolumeResponse) String() string

func (*CreateVolumeResponse) XXX_DiscardUnknown Uses

func (m *CreateVolumeResponse) XXX_DiscardUnknown()

func (*CreateVolumeResponse) XXX_Marshal Uses

func (m *CreateVolumeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateVolumeResponse) XXX_Merge Uses

func (m *CreateVolumeResponse) XXX_Merge(src proto.Message)

func (*CreateVolumeResponse) XXX_Size Uses

func (m *CreateVolumeResponse) XXX_Size() int

func (*CreateVolumeResponse) XXX_Unmarshal Uses

func (m *CreateVolumeResponse) XXX_Unmarshal(b []byte) error

type DeleteSnapshotRequest Uses

type DeleteSnapshotRequest struct {
    // The ID of the snapshot to be deleted.
    // This field is REQUIRED.
    SnapshotId string `protobuf:"bytes,1,opt,name=snapshot_id,json=snapshotId,proto3" json:"snapshot_id,omitempty"`
    // Secrets required by plugin to complete snapshot deletion request.
    // This field is OPTIONAL. Refer to the `Secrets Requirements`
    // section on how to use this field.
    Secrets              map[string]string `protobuf:"bytes,2,rep,name=secrets,proto3" json:"secrets,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
    XXX_NoUnkeyedLiteral struct{}          `json:"-"`
    XXX_unrecognized     []byte            `json:"-"`
    XXX_sizecache        int32             `json:"-"`
}

func (*DeleteSnapshotRequest) Descriptor Uses

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

func (*DeleteSnapshotRequest) GetSecrets Uses

func (m *DeleteSnapshotRequest) GetSecrets() map[string]string

func (*DeleteSnapshotRequest) GetSnapshotId Uses

func (m *DeleteSnapshotRequest) GetSnapshotId() string

func (*DeleteSnapshotRequest) ProtoMessage Uses

func (*DeleteSnapshotRequest) ProtoMessage()

func (*DeleteSnapshotRequest) Reset Uses

func (m *DeleteSnapshotRequest) Reset()

func (*DeleteSnapshotRequest) String Uses

func (m *DeleteSnapshotRequest) String() string

func (*DeleteSnapshotRequest) XXX_DiscardUnknown Uses

func (m *DeleteSnapshotRequest) XXX_DiscardUnknown()

func (*DeleteSnapshotRequest) XXX_Marshal Uses

func (m *DeleteSnapshotRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeleteSnapshotRequest) XXX_Merge Uses

func (m *DeleteSnapshotRequest) XXX_Merge(src proto.Message)

func (*DeleteSnapshotRequest) XXX_Size Uses

func (m *DeleteSnapshotRequest) XXX_Size() int

func (*DeleteSnapshotRequest) XXX_Unmarshal Uses

func (m *DeleteSnapshotRequest) XXX_Unmarshal(b []byte) error

type DeleteSnapshotResponse Uses

type DeleteSnapshotResponse struct {
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*DeleteSnapshotResponse) Descriptor Uses

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

func (*DeleteSnapshotResponse) ProtoMessage Uses

func (*DeleteSnapshotResponse) ProtoMessage()

func (*DeleteSnapshotResponse) Reset Uses

func (m *DeleteSnapshotResponse) Reset()

func (*DeleteSnapshotResponse) String Uses

func (m *DeleteSnapshotResponse) String() string

func (*DeleteSnapshotResponse) XXX_DiscardUnknown Uses

func (m *DeleteSnapshotResponse) XXX_DiscardUnknown()

func (*DeleteSnapshotResponse) XXX_Marshal Uses

func (m *DeleteSnapshotResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeleteSnapshotResponse) XXX_Merge Uses

func (m *DeleteSnapshotResponse) XXX_Merge(src proto.Message)

func (*DeleteSnapshotResponse) XXX_Size Uses

func (m *DeleteSnapshotResponse) XXX_Size() int

func (*DeleteSnapshotResponse) XXX_Unmarshal Uses

func (m *DeleteSnapshotResponse) XXX_Unmarshal(b []byte) error

type DeleteVolumeRequest Uses

type DeleteVolumeRequest struct {
    // The ID of the volume to be deprovisioned.
    // This field is REQUIRED.
    VolumeId string `protobuf:"bytes,1,opt,name=volume_id,json=volumeId,proto3" json:"volume_id,omitempty"`
    // Secrets required by plugin to complete volume deletion request.
    // This field is OPTIONAL. Refer to the `Secrets Requirements`
    // section on how to use this field.
    Secrets              map[string]string `protobuf:"bytes,2,rep,name=secrets,proto3" json:"secrets,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
    XXX_NoUnkeyedLiteral struct{}          `json:"-"`
    XXX_unrecognized     []byte            `json:"-"`
    XXX_sizecache        int32             `json:"-"`
}

func (*DeleteVolumeRequest) Descriptor Uses

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

func (*DeleteVolumeRequest) GetSecrets Uses

func (m *DeleteVolumeRequest) GetSecrets() map[string]string

func (*DeleteVolumeRequest) GetVolumeId Uses

func (m *DeleteVolumeRequest) GetVolumeId() string

func (*DeleteVolumeRequest) ProtoMessage Uses

func (*DeleteVolumeRequest) ProtoMessage()

func (*DeleteVolumeRequest) Reset Uses

func (m *DeleteVolumeRequest) Reset()

func (*DeleteVolumeRequest) String Uses

func (m *DeleteVolumeRequest) String() string

func (*DeleteVolumeRequest) XXX_DiscardUnknown Uses

func (m *DeleteVolumeRequest) XXX_DiscardUnknown()

func (*DeleteVolumeRequest) XXX_Marshal Uses

func (m *DeleteVolumeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeleteVolumeRequest) XXX_Merge Uses

func (m *DeleteVolumeRequest) XXX_Merge(src proto.Message)

func (*DeleteVolumeRequest) XXX_Size Uses

func (m *DeleteVolumeRequest) XXX_Size() int

func (*DeleteVolumeRequest) XXX_Unmarshal Uses

func (m *DeleteVolumeRequest) XXX_Unmarshal(b []byte) error

type DeleteVolumeResponse Uses

type DeleteVolumeResponse struct {
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*DeleteVolumeResponse) Descriptor Uses

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

func (*DeleteVolumeResponse) ProtoMessage Uses

func (*DeleteVolumeResponse) ProtoMessage()

func (*DeleteVolumeResponse) Reset Uses

func (m *DeleteVolumeResponse) Reset()

func (*DeleteVolumeResponse) String Uses

func (m *DeleteVolumeResponse) String() string

func (*DeleteVolumeResponse) XXX_DiscardUnknown Uses

func (m *DeleteVolumeResponse) XXX_DiscardUnknown()

func (*DeleteVolumeResponse) XXX_Marshal Uses

func (m *DeleteVolumeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeleteVolumeResponse) XXX_Merge Uses

func (m *DeleteVolumeResponse) XXX_Merge(src proto.Message)

func (*DeleteVolumeResponse) XXX_Size Uses

func (m *DeleteVolumeResponse) XXX_Size() int

func (*DeleteVolumeResponse) XXX_Unmarshal Uses

func (m *DeleteVolumeResponse) XXX_Unmarshal(b []byte) error

type GetCapacityRequest Uses

type GetCapacityRequest struct {
    // 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,1,rep,name=volume_capabilities,json=volumeCapabilities,proto3" 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 `protobuf:"bytes,2,rep,name=parameters,proto3" json:"parameters,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
    // If specified, the Plugin SHALL report the capacity of the storage
    // that can be used to provision volumes that in the specified
    // `accessible_topology`. This is the same as the
    // `accessible_topology` the CO returns in a `CreateVolumeResponse`.
    // This field is OPTIONAL. This field SHALL NOT be set unless the
    // plugin advertises the VOLUME_ACCESSIBILITY_CONSTRAINTS capability.
    AccessibleTopology   *Topology `protobuf:"bytes,3,opt,name=accessible_topology,json=accessibleTopology,proto3" json:"accessible_topology,omitempty"`
    XXX_NoUnkeyedLiteral struct{}  `json:"-"`
    XXX_unrecognized     []byte    `json:"-"`
    XXX_sizecache        int32     `json:"-"`
}

func (*GetCapacityRequest) Descriptor Uses

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

func (*GetCapacityRequest) GetAccessibleTopology Uses

func (m *GetCapacityRequest) GetAccessibleTopology() *Topology

func (*GetCapacityRequest) GetParameters Uses

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

func (*GetCapacityRequest) GetVolumeCapabilities Uses

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

func (*GetCapacityRequest) ProtoMessage Uses

func (*GetCapacityRequest) ProtoMessage()

func (*GetCapacityRequest) Reset Uses

func (m *GetCapacityRequest) Reset()

func (*GetCapacityRequest) String Uses

func (m *GetCapacityRequest) String() string

func (*GetCapacityRequest) XXX_DiscardUnknown Uses

func (m *GetCapacityRequest) XXX_DiscardUnknown()

func (*GetCapacityRequest) XXX_Marshal Uses

func (m *GetCapacityRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetCapacityRequest) XXX_Merge Uses

func (m *GetCapacityRequest) XXX_Merge(src proto.Message)

func (*GetCapacityRequest) XXX_Size Uses

func (m *GetCapacityRequest) XXX_Size() int

func (*GetCapacityRequest) XXX_Unmarshal Uses

func (m *GetCapacityRequest) XXX_Unmarshal(b []byte) error

type GetCapacityResponse Uses

type GetCapacityResponse struct {
    // The available capacity, in bytes, 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.
    // The value of this field MUST NOT be negative.
    AvailableCapacity    int64    `protobuf:"varint,1,opt,name=available_capacity,json=availableCapacity,proto3" json:"available_capacity,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*GetCapacityResponse) Descriptor Uses

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

func (*GetCapacityResponse) GetAvailableCapacity Uses

func (m *GetCapacityResponse) GetAvailableCapacity() int64

func (*GetCapacityResponse) ProtoMessage Uses

func (*GetCapacityResponse) ProtoMessage()

func (*GetCapacityResponse) Reset Uses

func (m *GetCapacityResponse) Reset()

func (*GetCapacityResponse) String Uses

func (m *GetCapacityResponse) String() string

func (*GetCapacityResponse) XXX_DiscardUnknown Uses

func (m *GetCapacityResponse) XXX_DiscardUnknown()

func (*GetCapacityResponse) XXX_Marshal Uses

func (m *GetCapacityResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetCapacityResponse) XXX_Merge Uses

func (m *GetCapacityResponse) XXX_Merge(src proto.Message)

func (*GetCapacityResponse) XXX_Size Uses

func (m *GetCapacityResponse) XXX_Size() int

func (*GetCapacityResponse) XXX_Unmarshal Uses

func (m *GetCapacityResponse) XXX_Unmarshal(b []byte) error

type GetPluginCapabilitiesRequest Uses

type GetPluginCapabilitiesRequest struct {
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*GetPluginCapabilitiesRequest) Descriptor Uses

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

func (*GetPluginCapabilitiesRequest) ProtoMessage Uses

func (*GetPluginCapabilitiesRequest) ProtoMessage()

func (*GetPluginCapabilitiesRequest) Reset Uses

func (m *GetPluginCapabilitiesRequest) Reset()

func (*GetPluginCapabilitiesRequest) String Uses

func (m *GetPluginCapabilitiesRequest) String() string

func (*GetPluginCapabilitiesRequest) XXX_DiscardUnknown Uses

func (m *GetPluginCapabilitiesRequest) XXX_DiscardUnknown()

func (*GetPluginCapabilitiesRequest) XXX_Marshal Uses

func (m *GetPluginCapabilitiesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetPluginCapabilitiesRequest) XXX_Merge Uses

func (m *GetPluginCapabilitiesRequest) XXX_Merge(src proto.Message)

func (*GetPluginCapabilitiesRequest) XXX_Size Uses

func (m *GetPluginCapabilitiesRequest) XXX_Size() int

func (*GetPluginCapabilitiesRequest) XXX_Unmarshal Uses

func (m *GetPluginCapabilitiesRequest) XXX_Unmarshal(b []byte) error

type GetPluginCapabilitiesResponse Uses

type GetPluginCapabilitiesResponse struct {
    // All the capabilities that the controller service supports. This
    // field is OPTIONAL.
    Capabilities         []*PluginCapability `protobuf:"bytes,1,rep,name=capabilities,proto3" json:"capabilities,omitempty"`
    XXX_NoUnkeyedLiteral struct{}            `json:"-"`
    XXX_unrecognized     []byte              `json:"-"`
    XXX_sizecache        int32               `json:"-"`
}

func (*GetPluginCapabilitiesResponse) Descriptor Uses

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

func (*GetPluginCapabilitiesResponse) GetCapabilities Uses

func (m *GetPluginCapabilitiesResponse) GetCapabilities() []*PluginCapability

func (*GetPluginCapabilitiesResponse) ProtoMessage Uses

func (*GetPluginCapabilitiesResponse) ProtoMessage()

func (*GetPluginCapabilitiesResponse) Reset Uses

func (m *GetPluginCapabilitiesResponse) Reset()

func (*GetPluginCapabilitiesResponse) String Uses

func (m *GetPluginCapabilitiesResponse) String() string

func (*GetPluginCapabilitiesResponse) XXX_DiscardUnknown Uses

func (m *GetPluginCapabilitiesResponse) XXX_DiscardUnknown()

func (*GetPluginCapabilitiesResponse) XXX_Marshal Uses

func (m *GetPluginCapabilitiesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetPluginCapabilitiesResponse) XXX_Merge Uses

func (m *GetPluginCapabilitiesResponse) XXX_Merge(src proto.Message)

func (*GetPluginCapabilitiesResponse) XXX_Size Uses

func (m *GetPluginCapabilitiesResponse) XXX_Size() int

func (*GetPluginCapabilitiesResponse) XXX_Unmarshal Uses

func (m *GetPluginCapabilitiesResponse) XXX_Unmarshal(b []byte) error

type GetPluginInfoRequest Uses

type GetPluginInfoRequest struct {
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*GetPluginInfoRequest) Descriptor Uses

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

func (*GetPluginInfoRequest) ProtoMessage Uses

func (*GetPluginInfoRequest) ProtoMessage()

func (*GetPluginInfoRequest) Reset Uses

func (m *GetPluginInfoRequest) Reset()

func (*GetPluginInfoRequest) String Uses

func (m *GetPluginInfoRequest) String() string

func (*GetPluginInfoRequest) XXX_DiscardUnknown Uses

func (m *GetPluginInfoRequest) XXX_DiscardUnknown()

func (*GetPluginInfoRequest) XXX_Marshal Uses

func (m *GetPluginInfoRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetPluginInfoRequest) XXX_Merge Uses

func (m *GetPluginInfoRequest) XXX_Merge(src proto.Message)

func (*GetPluginInfoRequest) XXX_Size Uses

func (m *GetPluginInfoRequest) XXX_Size() int

func (*GetPluginInfoRequest) XXX_Unmarshal Uses

func (m *GetPluginInfoRequest) XXX_Unmarshal(b []byte) error

type GetPluginInfoResponse Uses

type GetPluginInfoResponse struct {
    // The name MUST follow domain name notation format
    // (https://tools.ietf.org/html/rfc1035#section-2.3.1). It SHOULD
    // include the plugin's host company name and the plugin name,
    // to minimize the possibility of collisions. It MUST be 63
    // characters or less, beginning and ending with an alphanumeric
    // character ([a-z0-9A-Z]) with dashes (-), dots (.), and
    // alphanumerics between. This field is REQUIRED.
    Name string `protobuf:"bytes,1,opt,name=name,proto3" 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,proto3" json:"vendor_version,omitempty"`
    // This field is OPTIONAL. Values are opaque to the CO.
    Manifest             map[string]string `protobuf:"bytes,3,rep,name=manifest,proto3" json:"manifest,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
    XXX_NoUnkeyedLiteral struct{}          `json:"-"`
    XXX_unrecognized     []byte            `json:"-"`
    XXX_sizecache        int32             `json:"-"`
}

func (*GetPluginInfoResponse) Descriptor Uses

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

func (*GetPluginInfoResponse) GetManifest Uses

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

func (*GetPluginInfoResponse) GetName Uses

func (m *GetPluginInfoResponse) GetName() string

func (*GetPluginInfoResponse) GetVendorVersion Uses

func (m *GetPluginInfoResponse) GetVendorVersion() string

func (*GetPluginInfoResponse) ProtoMessage Uses

func (*GetPluginInfoResponse) ProtoMessage()

func (*GetPluginInfoResponse) Reset Uses

func (m *GetPluginInfoResponse) Reset()

func (*GetPluginInfoResponse) String Uses

func (m *GetPluginInfoResponse) String() string

func (*GetPluginInfoResponse) XXX_DiscardUnknown Uses

func (m *GetPluginInfoResponse) XXX_DiscardUnknown()

func (*GetPluginInfoResponse) XXX_Marshal Uses

func (m *GetPluginInfoResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetPluginInfoResponse) XXX_Merge Uses

func (m *GetPluginInfoResponse) XXX_Merge(src proto.Message)

func (*GetPluginInfoResponse) XXX_Size Uses

func (m *GetPluginInfoResponse) XXX_Size() int

func (*GetPluginInfoResponse) XXX_Unmarshal Uses

func (m *GetPluginInfoResponse) XXX_Unmarshal(b []byte) error

type IdentityClient Uses

type IdentityClient interface {
    GetPluginInfo(ctx context.Context, in *GetPluginInfoRequest, opts ...grpc.CallOption) (*GetPluginInfoResponse, error)
    GetPluginCapabilities(ctx context.Context, in *GetPluginCapabilitiesRequest, opts ...grpc.CallOption) (*GetPluginCapabilitiesResponse, error)
    Probe(ctx context.Context, in *ProbeRequest, opts ...grpc.CallOption) (*ProbeResponse, error)
}

IdentityClient is the client API for Identity service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewIdentityClient Uses

func NewIdentityClient(cc *grpc.ClientConn) IdentityClient

type IdentityServer Uses

type IdentityServer interface {
    GetPluginInfo(context.Context, *GetPluginInfoRequest) (*GetPluginInfoResponse, error)
    GetPluginCapabilities(context.Context, *GetPluginCapabilitiesRequest) (*GetPluginCapabilitiesResponse, error)
    Probe(context.Context, *ProbeRequest) (*ProbeResponse, error)
}

IdentityServer is the server API for Identity service.

type ListSnapshotsRequest Uses

type ListSnapshotsRequest struct {
    // If specified (non-zero value), 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 `ListSnapshots` call. This field is OPTIONAL. If
    // not specified (zero value), it means there is no restriction on the
    // number of entries that can be returned.
    // The value of this field MUST NOT be negative.
    MaxEntries int32 `protobuf:"varint,1,opt,name=max_entries,json=maxEntries,proto3" json:"max_entries,omitempty"`
    // A token to specify where to start paginating. Set this field to
    // `next_token` returned by a previous `ListSnapshots` call to get the
    // next page of entries. This field is OPTIONAL.
    // An empty string is equal to an unspecified field value.
    StartingToken string `protobuf:"bytes,2,opt,name=starting_token,json=startingToken,proto3" json:"starting_token,omitempty"`
    // Identity information for the source volume. This field is OPTIONAL.
    // It can be used to list snapshots by volume.
    SourceVolumeId string `protobuf:"bytes,3,opt,name=source_volume_id,json=sourceVolumeId,proto3" json:"source_volume_id,omitempty"`
    // Identity information for a specific snapshot. This field is
    // OPTIONAL. It can be used to list only a specific snapshot.
    // ListSnapshots will return with current snapshot information
    // and will not block if the snapshot is being processed after
    // it is cut.
    SnapshotId           string   `protobuf:"bytes,4,opt,name=snapshot_id,json=snapshotId,proto3" json:"snapshot_id,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

List all snapshots on the storage system regardless of how they were created.

func (*ListSnapshotsRequest) Descriptor Uses

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

func (*ListSnapshotsRequest) GetMaxEntries Uses

func (m *ListSnapshotsRequest) GetMaxEntries() int32

func (*ListSnapshotsRequest) GetSnapshotId Uses

func (m *ListSnapshotsRequest) GetSnapshotId() string

func (*ListSnapshotsRequest) GetSourceVolumeId Uses

func (m *ListSnapshotsRequest) GetSourceVolumeId() string

func (*ListSnapshotsRequest) GetStartingToken Uses

func (m *ListSnapshotsRequest) GetStartingToken() string

func (*ListSnapshotsRequest) ProtoMessage Uses

func (*ListSnapshotsRequest) ProtoMessage()

func (*ListSnapshotsRequest) Reset Uses

func (m *ListSnapshotsRequest) Reset()

func (*ListSnapshotsRequest) String Uses

func (m *ListSnapshotsRequest) String() string

func (*ListSnapshotsRequest) XXX_DiscardUnknown Uses

func (m *ListSnapshotsRequest) XXX_DiscardUnknown()

func (*ListSnapshotsRequest) XXX_Marshal Uses

func (m *ListSnapshotsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListSnapshotsRequest) XXX_Merge Uses

func (m *ListSnapshotsRequest) XXX_Merge(src proto.Message)

func (*ListSnapshotsRequest) XXX_Size Uses

func (m *ListSnapshotsRequest) XXX_Size() int

func (*ListSnapshotsRequest) XXX_Unmarshal Uses

func (m *ListSnapshotsRequest) XXX_Unmarshal(b []byte) error

type ListSnapshotsResponse Uses

type ListSnapshotsResponse struct {
    Entries []*ListSnapshotsResponse_Entry `protobuf:"bytes,1,rep,name=entries,proto3" json:"entries,omitempty"`
    // This token allows you to get the next page of entries for
    // `ListSnapshots` 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 `ListSnapshots` request. This
    // field is OPTIONAL.
    // An empty string is equal to an unspecified field value.
    NextToken            string   `protobuf:"bytes,2,opt,name=next_token,json=nextToken,proto3" json:"next_token,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*ListSnapshotsResponse) Descriptor Uses

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

func (*ListSnapshotsResponse) GetEntries Uses

func (m *ListSnapshotsResponse) GetEntries() []*ListSnapshotsResponse_Entry

func (*ListSnapshotsResponse) GetNextToken Uses

func (m *ListSnapshotsResponse) GetNextToken() string

func (*ListSnapshotsResponse) ProtoMessage Uses

func (*ListSnapshotsResponse) ProtoMessage()

func (*ListSnapshotsResponse) Reset Uses

func (m *ListSnapshotsResponse) Reset()

func (*ListSnapshotsResponse) String Uses

func (m *ListSnapshotsResponse) String() string

func (*ListSnapshotsResponse) XXX_DiscardUnknown Uses

func (m *ListSnapshotsResponse) XXX_DiscardUnknown()

func (*ListSnapshotsResponse) XXX_Marshal Uses

func (m *ListSnapshotsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListSnapshotsResponse) XXX_Merge Uses

func (m *ListSnapshotsResponse) XXX_Merge(src proto.Message)

func (*ListSnapshotsResponse) XXX_Size Uses

func (m *ListSnapshotsResponse) XXX_Size() int

func (*ListSnapshotsResponse) XXX_Unmarshal Uses

func (m *ListSnapshotsResponse) XXX_Unmarshal(b []byte) error

type ListSnapshotsResponse_Entry Uses

type ListSnapshotsResponse_Entry struct {
    Snapshot             *Snapshot `protobuf:"bytes,1,opt,name=snapshot,proto3" json:"snapshot,omitempty"`
    XXX_NoUnkeyedLiteral struct{}  `json:"-"`
    XXX_unrecognized     []byte    `json:"-"`
    XXX_sizecache        int32     `json:"-"`
}

func (*ListSnapshotsResponse_Entry) Descriptor Uses

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

func (*ListSnapshotsResponse_Entry) GetSnapshot Uses

func (m *ListSnapshotsResponse_Entry) GetSnapshot() *Snapshot

func (*ListSnapshotsResponse_Entry) ProtoMessage Uses

func (*ListSnapshotsResponse_Entry) ProtoMessage()

func (*ListSnapshotsResponse_Entry) Reset Uses

func (m *ListSnapshotsResponse_Entry) Reset()

func (*ListSnapshotsResponse_Entry) String Uses

func (m *ListSnapshotsResponse_Entry) String() string

func (*ListSnapshotsResponse_Entry) XXX_DiscardUnknown Uses

func (m *ListSnapshotsResponse_Entry) XXX_DiscardUnknown()

func (*ListSnapshotsResponse_Entry) XXX_Marshal Uses

func (m *ListSnapshotsResponse_Entry) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListSnapshotsResponse_Entry) XXX_Merge Uses

func (m *ListSnapshotsResponse_Entry) XXX_Merge(src proto.Message)

func (*ListSnapshotsResponse_Entry) XXX_Size Uses

func (m *ListSnapshotsResponse_Entry) XXX_Size() int

func (*ListSnapshotsResponse_Entry) XXX_Unmarshal Uses

func (m *ListSnapshotsResponse_Entry) XXX_Unmarshal(b []byte) error

type ListVolumesRequest Uses

type ListVolumesRequest struct {
    // If specified (non-zero value), 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 (zero value), it means there is no restriction on the
    // number of entries that can be returned.
    // The value of this field MUST NOT be negative.
    MaxEntries int32 `protobuf:"varint,1,opt,name=max_entries,json=maxEntries,proto3" 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.
    // An empty string is equal to an unspecified field value.
    StartingToken        string   `protobuf:"bytes,2,opt,name=starting_token,json=startingToken,proto3" json:"starting_token,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*ListVolumesRequest) Descriptor Uses

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

func (*ListVolumesRequest) GetMaxEntries Uses

func (m *ListVolumesRequest) GetMaxEntries() int32

func (*ListVolumesRequest) GetStartingToken Uses

func (m *ListVolumesRequest) GetStartingToken() string

func (*ListVolumesRequest) ProtoMessage Uses

func (*ListVolumesRequest) ProtoMessage()

func (*ListVolumesRequest) Reset Uses

func (m *ListVolumesRequest) Reset()

func (*ListVolumesRequest) String Uses

func (m *ListVolumesRequest) String() string

func (*ListVolumesRequest) XXX_DiscardUnknown Uses

func (m *ListVolumesRequest) XXX_DiscardUnknown()

func (*ListVolumesRequest) XXX_Marshal Uses

func (m *ListVolumesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListVolumesRequest) XXX_Merge Uses

func (m *ListVolumesRequest) XXX_Merge(src proto.Message)

func (*ListVolumesRequest) XXX_Size Uses

func (m *ListVolumesRequest) XXX_Size() int

func (*ListVolumesRequest) XXX_Unmarshal Uses

func (m *ListVolumesRequest) XXX_Unmarshal(b []byte) error

type ListVolumesResponse Uses

type ListVolumesResponse struct {
    Entries []*ListVolumesResponse_Entry `protobuf:"bytes,1,rep,name=entries,proto3" 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.
    // An empty string is equal to an unspecified field value.
    NextToken            string   `protobuf:"bytes,2,opt,name=next_token,json=nextToken,proto3" json:"next_token,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*ListVolumesResponse) Descriptor Uses

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

func (*ListVolumesResponse) GetEntries Uses

func (m *ListVolumesResponse) GetEntries() []*ListVolumesResponse_Entry

func (*ListVolumesResponse) GetNextToken Uses

func (m *ListVolumesResponse) GetNextToken() string

func (*ListVolumesResponse) ProtoMessage Uses

func (*ListVolumesResponse) ProtoMessage()

func (*ListVolumesResponse) Reset Uses

func (m *ListVolumesResponse) Reset()

func (*ListVolumesResponse) String Uses

func (m *ListVolumesResponse) String() string

func (*ListVolumesResponse) XXX_DiscardUnknown Uses

func (m *ListVolumesResponse) XXX_DiscardUnknown()

func (*ListVolumesResponse) XXX_Marshal Uses

func (m *ListVolumesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListVolumesResponse) XXX_Merge Uses

func (m *ListVolumesResponse) XXX_Merge(src proto.Message)

func (*ListVolumesResponse) XXX_Size Uses

func (m *ListVolumesResponse) XXX_Size() int

func (*ListVolumesResponse) XXX_Unmarshal Uses

func (m *ListVolumesResponse) XXX_Unmarshal(b []byte) error

type ListVolumesResponse_Entry Uses

type ListVolumesResponse_Entry struct {
    Volume               *Volume  `protobuf:"bytes,1,opt,name=volume,proto3" json:"volume,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*ListVolumesResponse_Entry) Descriptor Uses

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

func (*ListVolumesResponse_Entry) GetVolume Uses

func (m *ListVolumesResponse_Entry) GetVolume() *Volume

func (*ListVolumesResponse_Entry) ProtoMessage Uses

func (*ListVolumesResponse_Entry) ProtoMessage()

func (*ListVolumesResponse_Entry) Reset Uses

func (m *ListVolumesResponse_Entry) Reset()

func (*ListVolumesResponse_Entry) String Uses

func (m *ListVolumesResponse_Entry) String() string

func (*ListVolumesResponse_Entry) XXX_DiscardUnknown Uses

func (m *ListVolumesResponse_Entry) XXX_DiscardUnknown()

func (*ListVolumesResponse_Entry) XXX_Marshal Uses

func (m *ListVolumesResponse_Entry) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListVolumesResponse_Entry) XXX_Merge Uses

func (m *ListVolumesResponse_Entry) XXX_Merge(src proto.Message)

func (*ListVolumesResponse_Entry) XXX_Size Uses

func (m *ListVolumesResponse_Entry) XXX_Size() int

func (*ListVolumesResponse_Entry) XXX_Unmarshal Uses

func (m *ListVolumesResponse_Entry) XXX_Unmarshal(b []byte) error

type NodeClient Uses

type NodeClient interface {
    NodeStageVolume(ctx context.Context, in *NodeStageVolumeRequest, opts ...grpc.CallOption) (*NodeStageVolumeResponse, error)
    NodeUnstageVolume(ctx context.Context, in *NodeUnstageVolumeRequest, opts ...grpc.CallOption) (*NodeUnstageVolumeResponse, error)
    NodePublishVolume(ctx context.Context, in *NodePublishVolumeRequest, opts ...grpc.CallOption) (*NodePublishVolumeResponse, error)
    NodeUnpublishVolume(ctx context.Context, in *NodeUnpublishVolumeRequest, opts ...grpc.CallOption) (*NodeUnpublishVolumeResponse, error)
    NodeGetVolumeStats(ctx context.Context, in *NodeGetVolumeStatsRequest, opts ...grpc.CallOption) (*NodeGetVolumeStatsResponse, error)
    NodeExpandVolume(ctx context.Context, in *NodeExpandVolumeRequest, opts ...grpc.CallOption) (*NodeExpandVolumeResponse, error)
    NodeGetCapabilities(ctx context.Context, in *NodeGetCapabilitiesRequest, opts ...grpc.CallOption) (*NodeGetCapabilitiesResponse, error)
    NodeGetInfo(ctx context.Context, in *NodeGetInfoRequest, opts ...grpc.CallOption) (*NodeGetInfoResponse, error)
}

NodeClient is the client API for Node service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewNodeClient Uses

func NewNodeClient(cc *grpc.ClientConn) NodeClient

type NodeExpandVolumeRequest Uses

type NodeExpandVolumeRequest struct {
    // The ID of the volume. This field is REQUIRED.
    VolumeId string `protobuf:"bytes,1,opt,name=volume_id,json=volumeId,proto3" json:"volume_id,omitempty"`
    // The path on which volume is available. This field is REQUIRED.
    VolumePath string `protobuf:"bytes,2,opt,name=volume_path,json=volumePath,proto3" json:"volume_path,omitempty"`
    // This allows CO to specify the capacity requirements of the volume
    // after expansion. If capacity_range is omitted then a plugin MAY
    // inspect the file system of the volume to determine the maximum
    // capacity to which the volume can be expanded. In such cases a
    // plugin MAY expand the volume to its maximum capacity.
    // This field is OPTIONAL.
    CapacityRange        *CapacityRange `protobuf:"bytes,3,opt,name=capacity_range,json=capacityRange,proto3" json:"capacity_range,omitempty"`
    XXX_NoUnkeyedLiteral struct{}       `json:"-"`
    XXX_unrecognized     []byte         `json:"-"`
    XXX_sizecache        int32          `json:"-"`
}

func (*NodeExpandVolumeRequest) Descriptor Uses

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

func (*NodeExpandVolumeRequest) GetCapacityRange Uses

func (m *NodeExpandVolumeRequest) GetCapacityRange() *CapacityRange

func (*NodeExpandVolumeRequest) GetVolumeId Uses

func (m *NodeExpandVolumeRequest) GetVolumeId() string

func (*NodeExpandVolumeRequest) GetVolumePath Uses

func (m *NodeExpandVolumeRequest) GetVolumePath() string

func (*NodeExpandVolumeRequest) ProtoMessage Uses

func (*NodeExpandVolumeRequest) ProtoMessage()

func (*NodeExpandVolumeRequest) Reset Uses

func (m *NodeExpandVolumeRequest) Reset()

func (*NodeExpandVolumeRequest) String Uses

func (m *NodeExpandVolumeRequest) String() string

func (*NodeExpandVolumeRequest) XXX_DiscardUnknown Uses

func (m *NodeExpandVolumeRequest) XXX_DiscardUnknown()

func (*NodeExpandVolumeRequest) XXX_Marshal Uses

func (m *NodeExpandVolumeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NodeExpandVolumeRequest) XXX_Merge Uses

func (m *NodeExpandVolumeRequest) XXX_Merge(src proto.Message)

func (*NodeExpandVolumeRequest) XXX_Size Uses

func (m *NodeExpandVolumeRequest) XXX_Size() int

func (*NodeExpandVolumeRequest) XXX_Unmarshal Uses

func (m *NodeExpandVolumeRequest) XXX_Unmarshal(b []byte) error

type NodeExpandVolumeResponse Uses

type NodeExpandVolumeResponse struct {
    // The capacity of the volume in bytes. This field is OPTIONAL.
    CapacityBytes        int64    `protobuf:"varint,1,opt,name=capacity_bytes,json=capacityBytes,proto3" json:"capacity_bytes,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*NodeExpandVolumeResponse) Descriptor Uses

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

func (*NodeExpandVolumeResponse) GetCapacityBytes Uses

func (m *NodeExpandVolumeResponse) GetCapacityBytes() int64

func (*NodeExpandVolumeResponse) ProtoMessage Uses

func (*NodeExpandVolumeResponse) ProtoMessage()

func (*NodeExpandVolumeResponse) Reset Uses

func (m *NodeExpandVolumeResponse) Reset()

func (*NodeExpandVolumeResponse) String Uses

func (m *NodeExpandVolumeResponse) String() string

func (*NodeExpandVolumeResponse) XXX_DiscardUnknown Uses

func (m *NodeExpandVolumeResponse) XXX_DiscardUnknown()

func (*NodeExpandVolumeResponse) XXX_Marshal Uses

func (m *NodeExpandVolumeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NodeExpandVolumeResponse) XXX_Merge Uses

func (m *NodeExpandVolumeResponse) XXX_Merge(src proto.Message)

func (*NodeExpandVolumeResponse) XXX_Size Uses

func (m *NodeExpandVolumeResponse) XXX_Size() int

func (*NodeExpandVolumeResponse) XXX_Unmarshal Uses

func (m *NodeExpandVolumeResponse) XXX_Unmarshal(b []byte) error

type NodeGetCapabilitiesRequest Uses

type NodeGetCapabilitiesRequest struct {
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*NodeGetCapabilitiesRequest) Descriptor Uses

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

func (*NodeGetCapabilitiesRequest) ProtoMessage Uses

func (*NodeGetCapabilitiesRequest) ProtoMessage()

func (*NodeGetCapabilitiesRequest) Reset Uses

func (m *NodeGetCapabilitiesRequest) Reset()

func (*NodeGetCapabilitiesRequest) String Uses

func (m *NodeGetCapabilitiesRequest) String() string

func (*NodeGetCapabilitiesRequest) XXX_DiscardUnknown Uses

func (m *NodeGetCapabilitiesRequest) XXX_DiscardUnknown()

func (*NodeGetCapabilitiesRequest) XXX_Marshal Uses

func (m *NodeGetCapabilitiesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NodeGetCapabilitiesRequest) XXX_Merge Uses

func (m *NodeGetCapabilitiesRequest) XXX_Merge(src proto.Message)

func (*NodeGetCapabilitiesRequest) XXX_Size Uses

func (m *NodeGetCapabilitiesRequest) XXX_Size() int

func (*NodeGetCapabilitiesRequest) XXX_Unmarshal Uses

func (m *NodeGetCapabilitiesRequest) XXX_Unmarshal(b []byte) error

type NodeGetCapabilitiesResponse Uses

type NodeGetCapabilitiesResponse struct {
    // All the capabilities that the node service supports. This field
    // is OPTIONAL.
    Capabilities         []*NodeServiceCapability `protobuf:"bytes,1,rep,name=capabilities,proto3" json:"capabilities,omitempty"`
    XXX_NoUnkeyedLiteral struct{}                 `json:"-"`
    XXX_unrecognized     []byte                   `json:"-"`
    XXX_sizecache        int32                    `json:"-"`
}

func (*NodeGetCapabilitiesResponse) Descriptor Uses

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

func (*NodeGetCapabilitiesResponse) GetCapabilities Uses

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

func (*NodeGetCapabilitiesResponse) ProtoMessage Uses

func (*NodeGetCapabilitiesResponse) ProtoMessage()

func (*NodeGetCapabilitiesResponse) Reset Uses

func (m *NodeGetCapabilitiesResponse) Reset()

func (*NodeGetCapabilitiesResponse) String Uses

func (m *NodeGetCapabilitiesResponse) String() string

func (*NodeGetCapabilitiesResponse) XXX_DiscardUnknown Uses

func (m *NodeGetCapabilitiesResponse) XXX_DiscardUnknown()

func (*NodeGetCapabilitiesResponse) XXX_Marshal Uses

func (m *NodeGetCapabilitiesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NodeGetCapabilitiesResponse) XXX_Merge Uses

func (m *NodeGetCapabilitiesResponse) XXX_Merge(src proto.Message)

func (*NodeGetCapabilitiesResponse) XXX_Size Uses

func (m *NodeGetCapabilitiesResponse) XXX_Size() int

func (*NodeGetCapabilitiesResponse) XXX_Unmarshal Uses

func (m *NodeGetCapabilitiesResponse) XXX_Unmarshal(b []byte) error

type NodeGetInfoRequest Uses

type NodeGetInfoRequest struct {
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*NodeGetInfoRequest) Descriptor Uses

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

func (*NodeGetInfoRequest) ProtoMessage Uses

func (*NodeGetInfoRequest) ProtoMessage()

func (*NodeGetInfoRequest) Reset Uses

func (m *NodeGetInfoRequest) Reset()

func (*NodeGetInfoRequest) String Uses

func (m *NodeGetInfoRequest) String() string

func (*NodeGetInfoRequest) XXX_DiscardUnknown Uses

func (m *NodeGetInfoRequest) XXX_DiscardUnknown()

func (*NodeGetInfoRequest) XXX_Marshal Uses

func (m *NodeGetInfoRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NodeGetInfoRequest) XXX_Merge Uses

func (m *NodeGetInfoRequest) XXX_Merge(src proto.Message)

func (*NodeGetInfoRequest) XXX_Size Uses

func (m *NodeGetInfoRequest) XXX_Size() int

func (*NodeGetInfoRequest) XXX_Unmarshal Uses

func (m *NodeGetInfoRequest) XXX_Unmarshal(b []byte) error

type NodeGetInfoResponse Uses

type NodeGetInfoResponse struct {
    // The identifier of the node as understood by the SP.
    // This field is REQUIRED.
    // This field MUST contain enough information to uniquely identify
    // this specific node vs all other nodes supported by this plugin.
    // This field SHALL be used by the CO in subsequent calls, including
    // `ControllerPublishVolume`, to refer to this node.
    // The SP is NOT responsible for global uniqueness of node_id across
    // multiple SPs.
    NodeId string `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
    // Maximum number of volumes that controller can publish to the node.
    // If value is not set or zero CO SHALL decide how many volumes of
    // this type can be published by the controller to the node. The
    // plugin MUST NOT set negative values here.
    // This field is OPTIONAL.
    MaxVolumesPerNode int64 `protobuf:"varint,2,opt,name=max_volumes_per_node,json=maxVolumesPerNode,proto3" json:"max_volumes_per_node,omitempty"`
    // Specifies where (regions, zones, racks, etc.) the node is
    // accessible from.
    // A plugin that returns this field MUST also set the
    // VOLUME_ACCESSIBILITY_CONSTRAINTS plugin capability.
    // COs MAY use this information along with the topology information
    // returned in CreateVolumeResponse to ensure that a given volume is
    // accessible from a given node when scheduling workloads.
    // This field is OPTIONAL. If it is not specified, the CO MAY assume
    // the node is not subject to any topological constraint, and MAY
    // schedule workloads that reference any volume V, such that there are
    // no topological constraints declared for V.
    //
    // Example 1:
    //   accessible_topology =
    //     {"region": "R1", "zone": "Z2"}
    // Indicates the node exists within the "region" "R1" and the "zone"
    // "Z2".
    AccessibleTopology   *Topology `protobuf:"bytes,3,opt,name=accessible_topology,json=accessibleTopology,proto3" json:"accessible_topology,omitempty"`
    XXX_NoUnkeyedLiteral struct{}  `json:"-"`
    XXX_unrecognized     []byte    `json:"-"`
    XXX_sizecache        int32     `json:"-"`
}

func (*NodeGetInfoResponse) Descriptor Uses

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

func (*NodeGetInfoResponse) GetAccessibleTopology Uses

func (m *NodeGetInfoResponse) GetAccessibleTopology() *Topology

func (*NodeGetInfoResponse) GetMaxVolumesPerNode Uses

func (m *NodeGetInfoResponse) GetMaxVolumesPerNode() int64

func (*NodeGetInfoResponse) GetNodeId Uses

func (m *NodeGetInfoResponse) GetNodeId() string

func (*NodeGetInfoResponse) ProtoMessage Uses

func (*NodeGetInfoResponse) ProtoMessage()

func (*NodeGetInfoResponse) Reset Uses

func (m *NodeGetInfoResponse) Reset()

func (*NodeGetInfoResponse) String Uses

func (m *NodeGetInfoResponse) String() string

func (*NodeGetInfoResponse) XXX_DiscardUnknown Uses

func (m *NodeGetInfoResponse) XXX_DiscardUnknown()

func (*NodeGetInfoResponse) XXX_Marshal Uses

func (m *NodeGetInfoResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NodeGetInfoResponse) XXX_Merge Uses

func (m *NodeGetInfoResponse) XXX_Merge(src proto.Message)

func (*NodeGetInfoResponse) XXX_Size Uses

func (m *NodeGetInfoResponse) XXX_Size() int

func (*NodeGetInfoResponse) XXX_Unmarshal Uses

func (m *NodeGetInfoResponse) XXX_Unmarshal(b []byte) error

type NodeGetVolumeStatsRequest Uses

type NodeGetVolumeStatsRequest struct {
    // The ID of the volume. This field is REQUIRED.
    VolumeId string `protobuf:"bytes,1,opt,name=volume_id,json=volumeId,proto3" json:"volume_id,omitempty"`
    // It can be any valid path where volume was previously
    // staged or published.
    // It MUST be an absolute path in the root filesystem of
    // the process serving this request.
    // This is a REQUIRED field.
    VolumePath           string   `protobuf:"bytes,2,opt,name=volume_path,json=volumePath,proto3" json:"volume_path,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*NodeGetVolumeStatsRequest) Descriptor Uses

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

func (*NodeGetVolumeStatsRequest) GetVolumeId Uses

func (m *NodeGetVolumeStatsRequest) GetVolumeId() string

func (*NodeGetVolumeStatsRequest) GetVolumePath Uses

func (m *NodeGetVolumeStatsRequest) GetVolumePath() string

func (*NodeGetVolumeStatsRequest) ProtoMessage Uses

func (*NodeGetVolumeStatsRequest) ProtoMessage()

func (*NodeGetVolumeStatsRequest) Reset Uses

func (m *NodeGetVolumeStatsRequest) Reset()

func (*NodeGetVolumeStatsRequest) String Uses

func (m *NodeGetVolumeStatsRequest) String() string

func (*NodeGetVolumeStatsRequest) XXX_DiscardUnknown Uses

func (m *NodeGetVolumeStatsRequest) XXX_DiscardUnknown()

func (*NodeGetVolumeStatsRequest) XXX_Marshal Uses

func (m *NodeGetVolumeStatsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NodeGetVolumeStatsRequest) XXX_Merge Uses

func (m *NodeGetVolumeStatsRequest) XXX_Merge(src proto.Message)

func (*NodeGetVolumeStatsRequest) XXX_Size Uses

func (m *NodeGetVolumeStatsRequest) XXX_Size() int

func (*NodeGetVolumeStatsRequest) XXX_Unmarshal Uses

func (m *NodeGetVolumeStatsRequest) XXX_Unmarshal(b []byte) error

type NodeGetVolumeStatsResponse Uses

type NodeGetVolumeStatsResponse struct {
    // This field is OPTIONAL.
    Usage                []*VolumeUsage `protobuf:"bytes,1,rep,name=usage,proto3" json:"usage,omitempty"`
    XXX_NoUnkeyedLiteral struct{}       `json:"-"`
    XXX_unrecognized     []byte         `json:"-"`
    XXX_sizecache        int32          `json:"-"`
}

func (*NodeGetVolumeStatsResponse) Descriptor Uses

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

func (*NodeGetVolumeStatsResponse) GetUsage Uses

func (m *NodeGetVolumeStatsResponse) GetUsage() []*VolumeUsage

func (*NodeGetVolumeStatsResponse) ProtoMessage Uses

func (*NodeGetVolumeStatsResponse) ProtoMessage()

func (*NodeGetVolumeStatsResponse) Reset Uses

func (m *NodeGetVolumeStatsResponse) Reset()

func (*NodeGetVolumeStatsResponse) String Uses

func (m *NodeGetVolumeStatsResponse) String() string

func (*NodeGetVolumeStatsResponse) XXX_DiscardUnknown Uses

func (m *NodeGetVolumeStatsResponse) XXX_DiscardUnknown()

func (*NodeGetVolumeStatsResponse) XXX_Marshal Uses

func (m *NodeGetVolumeStatsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NodeGetVolumeStatsResponse) XXX_Merge Uses

func (m *NodeGetVolumeStatsResponse) XXX_Merge(src proto.Message)

func (*NodeGetVolumeStatsResponse) XXX_Size Uses

func (m *NodeGetVolumeStatsResponse) XXX_Size() int

func (*NodeGetVolumeStatsResponse) XXX_Unmarshal Uses

func (m *NodeGetVolumeStatsResponse) XXX_Unmarshal(b []byte) error

type NodePublishVolumeRequest Uses

type NodePublishVolumeRequest struct {
    // The ID of the volume to publish. This field is REQUIRED.
    VolumeId string `protobuf:"bytes,1,opt,name=volume_id,json=volumeId,proto3" json:"volume_id,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.
    PublishContext map[string]string `protobuf:"bytes,2,rep,name=publish_context,json=publishContext,proto3" json:"publish_context,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
    // The path to which the volume was staged by `NodeStageVolume`.
    // It MUST be an absolute path in the root filesystem of the process
    // serving this request.
    // It MUST be set if the Node Plugin implements the
    // `STAGE_UNSTAGE_VOLUME` node capability.
    // This is an OPTIONAL field.
    StagingTargetPath string `protobuf:"bytes,3,opt,name=staging_target_path,json=stagingTargetPath,proto3" json:"staging_target_path,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.
    // The CO SHALL ensure that the parent directory of this path exists
    // and that the process serving the request has `read` and `write`
    // permissions to that parent directory.
    // For volumes with an access type of block, the SP SHALL place the
    // block device at target_path.
    // For volumes with an access type of mount, the SP SHALL place the
    // mounted directory at target_path.
    // Creation of target_path is the responsibility of the SP.
    // This is a REQUIRED field.
    TargetPath string `protobuf:"bytes,4,opt,name=target_path,json=targetPath,proto3" json:"target_path,omitempty"`
    // Volume capability describing how the CO intends to use this volume.
    // SP MUST ensure the CO can use the published volume as described.
    // Otherwise SP MUST return the appropriate gRPC error code.
    // This is a REQUIRED field.
    VolumeCapability *VolumeCapability `protobuf:"bytes,5,opt,name=volume_capability,json=volumeCapability,proto3" json:"volume_capability,omitempty"`
    // Indicates SP MUST publish the volume in readonly mode.
    // This field is REQUIRED.
    Readonly bool `protobuf:"varint,6,opt,name=readonly,proto3" json:"readonly,omitempty"`
    // Secrets required by plugin to complete node publish volume request.
    // This field is OPTIONAL. Refer to the `Secrets Requirements`
    // section on how to use this field.
    Secrets map[string]string `protobuf:"bytes,7,rep,name=secrets,proto3" json:"secrets,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
    // Volume context as returned by CO in CreateVolumeRequest. This field
    // is OPTIONAL and MUST match the volume_context of the volume
    // identified by `volume_id`.
    VolumeContext        map[string]string `protobuf:"bytes,8,rep,name=volume_context,json=volumeContext,proto3" json:"volume_context,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
    XXX_NoUnkeyedLiteral struct{}          `json:"-"`
    XXX_unrecognized     []byte            `json:"-"`
    XXX_sizecache        int32             `json:"-"`
}

func (*NodePublishVolumeRequest) Descriptor Uses

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

func (*NodePublishVolumeRequest) GetPublishContext Uses

func (m *NodePublishVolumeRequest) GetPublishContext() map[string]string

func (*NodePublishVolumeRequest) GetReadonly Uses

func (m *NodePublishVolumeRequest) GetReadonly() bool

func (*NodePublishVolumeRequest) GetSecrets Uses

func (m *NodePublishVolumeRequest) GetSecrets() map[string]string

func (*NodePublishVolumeRequest) GetStagingTargetPath Uses

func (m *NodePublishVolumeRequest) GetStagingTargetPath() string

func (*NodePublishVolumeRequest) GetTargetPath Uses

func (m *NodePublishVolumeRequest) GetTargetPath() string

func (*NodePublishVolumeRequest) GetVolumeCapability Uses

func (m *NodePublishVolumeRequest) GetVolumeCapability() *VolumeCapability

func (*NodePublishVolumeRequest) GetVolumeContext Uses

func (m *NodePublishVolumeRequest) GetVolumeContext() map[string]string

func (*NodePublishVolumeRequest) GetVolumeId Uses

func (m *NodePublishVolumeRequest) GetVolumeId() string

func (*NodePublishVolumeRequest) ProtoMessage Uses

func (*NodePublishVolumeRequest) ProtoMessage()

func (*NodePublishVolumeRequest) Reset Uses

func (m *NodePublishVolumeRequest) Reset()

func (*NodePublishVolumeRequest) String Uses

func (m *NodePublishVolumeRequest) String() string

func (*NodePublishVolumeRequest) XXX_DiscardUnknown Uses

func (m *NodePublishVolumeRequest) XXX_DiscardUnknown()

func (*NodePublishVolumeRequest) XXX_Marshal Uses

func (m *NodePublishVolumeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NodePublishVolumeRequest) XXX_Merge Uses

func (m *NodePublishVolumeRequest) XXX_Merge(src proto.Message)

func (*NodePublishVolumeRequest) XXX_Size Uses

func (m *NodePublishVolumeRequest) XXX_Size() int

func (*NodePublishVolumeRequest) XXX_Unmarshal Uses

func (m *NodePublishVolumeRequest) XXX_Unmarshal(b []byte) error

type NodePublishVolumeResponse Uses

type NodePublishVolumeResponse struct {
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*NodePublishVolumeResponse) Descriptor Uses

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

func (*NodePublishVolumeResponse) ProtoMessage Uses

func (*NodePublishVolumeResponse) ProtoMessage()

func (*NodePublishVolumeResponse) Reset Uses

func (m *NodePublishVolumeResponse) Reset()

func (*NodePublishVolumeResponse) String Uses

func (m *NodePublishVolumeResponse) String() string

func (*NodePublishVolumeResponse) XXX_DiscardUnknown Uses

func (m *NodePublishVolumeResponse) XXX_DiscardUnknown()

func (*NodePublishVolumeResponse) XXX_Marshal Uses

func (m *NodePublishVolumeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NodePublishVolumeResponse) XXX_Merge Uses

func (m *NodePublishVolumeResponse) XXX_Merge(src proto.Message)

func (*NodePublishVolumeResponse) XXX_Size Uses

func (m *NodePublishVolumeResponse) XXX_Size() int

func (*NodePublishVolumeResponse) XXX_Unmarshal Uses

func (m *NodePublishVolumeResponse) XXX_Unmarshal(b []byte) error

type NodeServer Uses

type NodeServer interface {
    NodeStageVolume(context.Context, *NodeStageVolumeRequest) (*NodeStageVolumeResponse, error)
    NodeUnstageVolume(context.Context, *NodeUnstageVolumeRequest) (*NodeUnstageVolumeResponse, error)
    NodePublishVolume(context.Context, *NodePublishVolumeRequest) (*NodePublishVolumeResponse, error)
    NodeUnpublishVolume(context.Context, *NodeUnpublishVolumeRequest) (*NodeUnpublishVolumeResponse, error)
    NodeGetVolumeStats(context.Context, *NodeGetVolumeStatsRequest) (*NodeGetVolumeStatsResponse, error)
    NodeExpandVolume(context.Context, *NodeExpandVolumeRequest) (*NodeExpandVolumeResponse, error)
    NodeGetCapabilities(context.Context, *NodeGetCapabilitiesRequest) (*NodeGetCapabilitiesResponse, error)
    NodeGetInfo(context.Context, *NodeGetInfoRequest) (*NodeGetInfoResponse, error)
}

NodeServer is the server API for Node service.

type NodeServiceCapability Uses

type NodeServiceCapability struct {
    // Types that are valid to be assigned to Type:
    //	*NodeServiceCapability_Rpc
    Type                 isNodeServiceCapability_Type `protobuf_oneof:"type"`
    XXX_NoUnkeyedLiteral struct{}                     `json:"-"`
    XXX_unrecognized     []byte                       `json:"-"`
    XXX_sizecache        int32                        `json:"-"`
}

Specifies a capability of the node service.

func (*NodeServiceCapability) Descriptor Uses

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

func (*NodeServiceCapability) GetRpc Uses

func (m *NodeServiceCapability) GetRpc() *NodeServiceCapability_RPC

func (*NodeServiceCapability) GetType Uses

func (m *NodeServiceCapability) GetType() isNodeServiceCapability_Type

func (*NodeServiceCapability) ProtoMessage Uses

func (*NodeServiceCapability) ProtoMessage()

func (*NodeServiceCapability) Reset Uses

func (m *NodeServiceCapability) Reset()

func (*NodeServiceCapability) String Uses

func (m *NodeServiceCapability) String() string

func (*NodeServiceCapability) XXX_DiscardUnknown Uses

func (m *NodeServiceCapability) XXX_DiscardUnknown()

func (*NodeServiceCapability) XXX_Marshal Uses

func (m *NodeServiceCapability) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NodeServiceCapability) XXX_Merge Uses

func (m *NodeServiceCapability) XXX_Merge(src proto.Message)

func (*NodeServiceCapability) XXX_OneofWrappers Uses

func (*NodeServiceCapability) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*NodeServiceCapability) XXX_Size Uses

func (m *NodeServiceCapability) XXX_Size() int

func (*NodeServiceCapability) XXX_Unmarshal Uses

func (m *NodeServiceCapability) XXX_Unmarshal(b []byte) error

type NodeServiceCapability_RPC Uses

type NodeServiceCapability_RPC struct {
    Type                 NodeServiceCapability_RPC_Type `protobuf:"varint,1,opt,name=type,proto3,enum=csi.v1.NodeServiceCapability_RPC_Type" json:"type,omitempty"`
    XXX_NoUnkeyedLiteral struct{}                       `json:"-"`
    XXX_unrecognized     []byte                         `json:"-"`
    XXX_sizecache        int32                          `json:"-"`
}

func (*NodeServiceCapability_RPC) Descriptor Uses

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

func (*NodeServiceCapability_RPC) GetType Uses

func (m *NodeServiceCapability_RPC) GetType() NodeServiceCapability_RPC_Type

func (*NodeServiceCapability_RPC) ProtoMessage Uses

func (*NodeServiceCapability_RPC) ProtoMessage()

func (*NodeServiceCapability_RPC) Reset Uses

func (m *NodeServiceCapability_RPC) Reset()

func (*NodeServiceCapability_RPC) String Uses

func (m *NodeServiceCapability_RPC) String() string

func (*NodeServiceCapability_RPC) XXX_DiscardUnknown Uses

func (m *NodeServiceCapability_RPC) XXX_DiscardUnknown()

func (*NodeServiceCapability_RPC) XXX_Marshal Uses

func (m *NodeServiceCapability_RPC) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NodeServiceCapability_RPC) XXX_Merge Uses

func (m *NodeServiceCapability_RPC) XXX_Merge(src proto.Message)

func (*NodeServiceCapability_RPC) XXX_Size Uses

func (m *NodeServiceCapability_RPC) XXX_Size() int

func (*NodeServiceCapability_RPC) XXX_Unmarshal Uses

func (m *NodeServiceCapability_RPC) XXX_Unmarshal(b []byte) error

type NodeServiceCapability_RPC_Type Uses

type NodeServiceCapability_RPC_Type int32
const (
    NodeServiceCapability_RPC_UNKNOWN              NodeServiceCapability_RPC_Type = 0
    NodeServiceCapability_RPC_STAGE_UNSTAGE_VOLUME NodeServiceCapability_RPC_Type = 1
    // If Plugin implements GET_VOLUME_STATS capability
    // then it MUST implement NodeGetVolumeStats RPC
    // call for fetching volume statistics.
    NodeServiceCapability_RPC_GET_VOLUME_STATS NodeServiceCapability_RPC_Type = 2
    // See VolumeExpansion for details.
    NodeServiceCapability_RPC_EXPAND_VOLUME NodeServiceCapability_RPC_Type = 3
)

func (NodeServiceCapability_RPC_Type) EnumDescriptor Uses

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

func (NodeServiceCapability_RPC_Type) String Uses

func (x NodeServiceCapability_RPC_Type) String() string

type NodeServiceCapability_Rpc Uses

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

type NodeStageVolumeRequest Uses

type NodeStageVolumeRequest struct {
    // The ID of the volume to publish. This field is REQUIRED.
    VolumeId string `protobuf:"bytes,1,opt,name=volume_id,json=volumeId,proto3" json:"volume_id,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.
    PublishContext map[string]string `protobuf:"bytes,2,rep,name=publish_context,json=publishContext,proto3" json:"publish_context,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
    // The path to which the volume MAY be staged. It MUST be an
    // absolute path in the root filesystem of the process serving this
    // request, and MUST be a directory. The CO SHALL ensure that there
    // is only one `staging_target_path` per volume. The CO SHALL ensure
    // that the path is directory and that the process serving the
    // request has `read` and `write` permission to that directory. The
    // CO SHALL be responsible for creating the directory if it does not
    // exist.
    // This is a REQUIRED field.
    StagingTargetPath string `protobuf:"bytes,3,opt,name=staging_target_path,json=stagingTargetPath,proto3" json:"staging_target_path,omitempty"`
    // Volume capability describing how the CO intends to use this volume.
    // SP MUST ensure the CO can use the staged volume as described.
    // Otherwise SP MUST return the appropriate gRPC error code.
    // This is a REQUIRED field.
    VolumeCapability *VolumeCapability `protobuf:"bytes,4,opt,name=volume_capability,json=volumeCapability,proto3" json:"volume_capability,omitempty"`
    // Secrets required by plugin to complete node stage volume request.
    // This field is OPTIONAL. Refer to the `Secrets Requirements`
    // section on how to use this field.
    Secrets map[string]string `protobuf:"bytes,5,rep,name=secrets,proto3" json:"secrets,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
    // Volume context as returned by CO in CreateVolumeRequest. This field
    // is OPTIONAL and MUST match the volume_context of the volume
    // identified by `volume_id`.
    VolumeContext        map[string]string `protobuf:"bytes,6,rep,name=volume_context,json=volumeContext,proto3" json:"volume_context,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
    XXX_NoUnkeyedLiteral struct{}          `json:"-"`
    XXX_unrecognized     []byte            `json:"-"`
    XXX_sizecache        int32             `json:"-"`
}

func (*NodeStageVolumeRequest) Descriptor Uses

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

func (*NodeStageVolumeRequest) GetPublishContext Uses

func (m *NodeStageVolumeRequest) GetPublishContext() map[string]string

func (*NodeStageVolumeRequest) GetSecrets Uses

func (m *NodeStageVolumeRequest) GetSecrets() map[string]string

func (*NodeStageVolumeRequest) GetStagingTargetPath Uses

func (m *NodeStageVolumeRequest) GetStagingTargetPath() string

func (*NodeStageVolumeRequest) GetVolumeCapability Uses

func (m *NodeStageVolumeRequest) GetVolumeCapability() *VolumeCapability

func (*NodeStageVolumeRequest) GetVolumeContext Uses

func (m *NodeStageVolumeRequest) GetVolumeContext() map[string]string

func (*NodeStageVolumeRequest) GetVolumeId Uses

func (m *NodeStageVolumeRequest) GetVolumeId() string

func (*NodeStageVolumeRequest) ProtoMessage Uses

func (*NodeStageVolumeRequest) ProtoMessage()

func (*NodeStageVolumeRequest) Reset Uses

func (m *NodeStageVolumeRequest) Reset()

func (*NodeStageVolumeRequest) String Uses

func (m *NodeStageVolumeRequest) String() string

func (*NodeStageVolumeRequest) XXX_DiscardUnknown Uses

func (m *NodeStageVolumeRequest) XXX_DiscardUnknown()

func (*NodeStageVolumeRequest) XXX_Marshal Uses

func (m *NodeStageVolumeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NodeStageVolumeRequest) XXX_Merge Uses

func (m *NodeStageVolumeRequest) XXX_Merge(src proto.Message)

func (*NodeStageVolumeRequest) XXX_Size Uses

func (m *NodeStageVolumeRequest) XXX_Size() int

func (*NodeStageVolumeRequest) XXX_Unmarshal Uses

func (m *NodeStageVolumeRequest) XXX_Unmarshal(b []byte) error

type NodeStageVolumeResponse Uses

type NodeStageVolumeResponse struct {
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*NodeStageVolumeResponse) Descriptor Uses

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

func (*NodeStageVolumeResponse) ProtoMessage Uses

func (*NodeStageVolumeResponse) ProtoMessage()

func (*NodeStageVolumeResponse) Reset Uses

func (m *NodeStageVolumeResponse) Reset()

func (*NodeStageVolumeResponse) String Uses

func (m *NodeStageVolumeResponse) String() string

func (*NodeStageVolumeResponse) XXX_DiscardUnknown Uses

func (m *NodeStageVolumeResponse) XXX_DiscardUnknown()

func (*NodeStageVolumeResponse) XXX_Marshal Uses

func (m *NodeStageVolumeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NodeStageVolumeResponse) XXX_Merge Uses

func (m *NodeStageVolumeResponse) XXX_Merge(src proto.Message)

func (*NodeStageVolumeResponse) XXX_Size Uses

func (m *NodeStageVolumeResponse) XXX_Size() int

func (*NodeStageVolumeResponse) XXX_Unmarshal Uses

func (m *NodeStageVolumeResponse) XXX_Unmarshal(b []byte) error

type NodeUnpublishVolumeRequest Uses

type NodeUnpublishVolumeRequest struct {
    // The ID of the volume. This field is REQUIRED.
    VolumeId string `protobuf:"bytes,1,opt,name=volume_id,json=volumeId,proto3" json:"volume_id,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.
    // The SP MUST delete the file or directory it created at this path.
    // This is a REQUIRED field.
    TargetPath           string   `protobuf:"bytes,2,opt,name=target_path,json=targetPath,proto3" json:"target_path,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*NodeUnpublishVolumeRequest) Descriptor Uses

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

func (*NodeUnpublishVolumeRequest) GetTargetPath Uses

func (m *NodeUnpublishVolumeRequest) GetTargetPath() string

func (*NodeUnpublishVolumeRequest) GetVolumeId Uses

func (m *NodeUnpublishVolumeRequest) GetVolumeId() string

func (*NodeUnpublishVolumeRequest) ProtoMessage Uses

func (*NodeUnpublishVolumeRequest) ProtoMessage()

func (*NodeUnpublishVolumeRequest) Reset Uses

func (m *NodeUnpublishVolumeRequest) Reset()

func (*NodeUnpublishVolumeRequest) String Uses

func (m *NodeUnpublishVolumeRequest) String() string

func (*NodeUnpublishVolumeRequest) XXX_DiscardUnknown Uses

func (m *NodeUnpublishVolumeRequest) XXX_DiscardUnknown()

func (*NodeUnpublishVolumeRequest) XXX_Marshal Uses

func (m *NodeUnpublishVolumeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NodeUnpublishVolumeRequest) XXX_Merge Uses

func (m *NodeUnpublishVolumeRequest) XXX_Merge(src proto.Message)

func (*NodeUnpublishVolumeRequest) XXX_Size Uses

func (m *NodeUnpublishVolumeRequest) XXX_Size() int

func (*NodeUnpublishVolumeRequest) XXX_Unmarshal Uses

func (m *NodeUnpublishVolumeRequest) XXX_Unmarshal(b []byte) error

type NodeUnpublishVolumeResponse Uses

type NodeUnpublishVolumeResponse struct {
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*NodeUnpublishVolumeResponse) Descriptor Uses

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

func (*NodeUnpublishVolumeResponse) ProtoMessage Uses

func (*NodeUnpublishVolumeResponse) ProtoMessage()

func (*NodeUnpublishVolumeResponse) Reset Uses

func (m *NodeUnpublishVolumeResponse) Reset()

func (*NodeUnpublishVolumeResponse) String Uses

func (m *NodeUnpublishVolumeResponse) String() string

func (*NodeUnpublishVolumeResponse) XXX_DiscardUnknown Uses

func (m *NodeUnpublishVolumeResponse) XXX_DiscardUnknown()

func (*NodeUnpublishVolumeResponse) XXX_Marshal Uses

func (m *NodeUnpublishVolumeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NodeUnpublishVolumeResponse) XXX_Merge Uses

func (m *NodeUnpublishVolumeResponse) XXX_Merge(src proto.Message)

func (*NodeUnpublishVolumeResponse) XXX_Size Uses

func (m *NodeUnpublishVolumeResponse) XXX_Size() int

func (*NodeUnpublishVolumeResponse) XXX_Unmarshal Uses

func (m *NodeUnpublishVolumeResponse) XXX_Unmarshal(b []byte) error

type NodeUnstageVolumeRequest Uses

type NodeUnstageVolumeRequest struct {
    // The ID of the volume. This field is REQUIRED.
    VolumeId string `protobuf:"bytes,1,opt,name=volume_id,json=volumeId,proto3" json:"volume_id,omitempty"`
    // The path at which the volume was staged. It MUST be an absolute
    // path in the root filesystem of the process serving this request.
    // This is a REQUIRED field.
    StagingTargetPath    string   `protobuf:"bytes,2,opt,name=staging_target_path,json=stagingTargetPath,proto3" json:"staging_target_path,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*NodeUnstageVolumeRequest) Descriptor Uses

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

func (*NodeUnstageVolumeRequest) GetStagingTargetPath Uses

func (m *NodeUnstageVolumeRequest) GetStagingTargetPath() string

func (*NodeUnstageVolumeRequest) GetVolumeId Uses

func (m *NodeUnstageVolumeRequest) GetVolumeId() string

func (*NodeUnstageVolumeRequest) ProtoMessage Uses

func (*NodeUnstageVolumeRequest) ProtoMessage()

func (*NodeUnstageVolumeRequest) Reset Uses

func (m *NodeUnstageVolumeRequest) Reset()

func (*NodeUnstageVolumeRequest) String Uses

func (m *NodeUnstageVolumeRequest) String() string

func (*NodeUnstageVolumeRequest) XXX_DiscardUnknown Uses

func (m *NodeUnstageVolumeRequest) XXX_DiscardUnknown()

func (*NodeUnstageVolumeRequest) XXX_Marshal Uses

func (m *NodeUnstageVolumeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NodeUnstageVolumeRequest) XXX_Merge Uses

func (m *NodeUnstageVolumeRequest) XXX_Merge(src proto.Message)

func (*NodeUnstageVolumeRequest) XXX_Size Uses

func (m *NodeUnstageVolumeRequest) XXX_Size() int

func (*NodeUnstageVolumeRequest) XXX_Unmarshal Uses

func (m *NodeUnstageVolumeRequest) XXX_Unmarshal(b []byte) error

type NodeUnstageVolumeResponse Uses

type NodeUnstageVolumeResponse struct {
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*NodeUnstageVolumeResponse) Descriptor Uses

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

func (*NodeUnstageVolumeResponse) ProtoMessage Uses

func (*NodeUnstageVolumeResponse) ProtoMessage()

func (*NodeUnstageVolumeResponse) Reset Uses

func (m *NodeUnstageVolumeResponse) Reset()

func (*NodeUnstageVolumeResponse) String Uses

func (m *NodeUnstageVolumeResponse) String() string

func (*NodeUnstageVolumeResponse) XXX_DiscardUnknown Uses

func (m *NodeUnstageVolumeResponse) XXX_DiscardUnknown()

func (*NodeUnstageVolumeResponse) XXX_Marshal Uses

func (m *NodeUnstageVolumeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NodeUnstageVolumeResponse) XXX_Merge Uses

func (m *NodeUnstageVolumeResponse) XXX_Merge(src proto.Message)

func (*NodeUnstageVolumeResponse) XXX_Size Uses

func (m *NodeUnstageVolumeResponse) XXX_Size() int

func (*NodeUnstageVolumeResponse) XXX_Unmarshal Uses

func (m *NodeUnstageVolumeResponse) XXX_Unmarshal(b []byte) error

type PluginCapability Uses

type PluginCapability struct {
    // Types that are valid to be assigned to Type:
    //	*PluginCapability_Service_
    //	*PluginCapability_VolumeExpansion_
    Type                 isPluginCapability_Type `protobuf_oneof:"type"`
    XXX_NoUnkeyedLiteral struct{}                `json:"-"`
    XXX_unrecognized     []byte                  `json:"-"`
    XXX_sizecache        int32                   `json:"-"`
}

Specifies a capability of the plugin.

func (*PluginCapability) Descriptor Uses

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

func (*PluginCapability) GetService Uses

func (m *PluginCapability) GetService() *PluginCapability_Service

func (*PluginCapability) GetType Uses

func (m *PluginCapability) GetType() isPluginCapability_Type

func (*PluginCapability) GetVolumeExpansion Uses

func (m *PluginCapability) GetVolumeExpansion() *PluginCapability_VolumeExpansion

func (*PluginCapability) ProtoMessage Uses

func (*PluginCapability) ProtoMessage()

func (*PluginCapability) Reset Uses

func (m *PluginCapability) Reset()

func (*PluginCapability) String Uses

func (m *PluginCapability) String() string

func (*PluginCapability) XXX_DiscardUnknown Uses

func (m *PluginCapability) XXX_DiscardUnknown()

func (*PluginCapability) XXX_Marshal Uses

func (m *PluginCapability) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PluginCapability) XXX_Merge Uses

func (m *PluginCapability) XXX_Merge(src proto.Message)

func (*PluginCapability) XXX_OneofWrappers Uses

func (*PluginCapability) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*PluginCapability) XXX_Size Uses

func (m *PluginCapability) XXX_Size() int

func (*PluginCapability) XXX_Unmarshal Uses

func (m *PluginCapability) XXX_Unmarshal(b []byte) error

type PluginCapability_Service Uses

type PluginCapability_Service struct {
    Type                 PluginCapability_Service_Type `protobuf:"varint,1,opt,name=type,proto3,enum=csi.v1.PluginCapability_Service_Type" json:"type,omitempty"`
    XXX_NoUnkeyedLiteral struct{}                      `json:"-"`
    XXX_unrecognized     []byte                        `json:"-"`
    XXX_sizecache        int32                         `json:"-"`
}

func (*PluginCapability_Service) Descriptor Uses

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

func (*PluginCapability_Service) GetType Uses

func (m *PluginCapability_Service) GetType() PluginCapability_Service_Type

func (*PluginCapability_Service) ProtoMessage Uses

func (*PluginCapability_Service) ProtoMessage()

func (*PluginCapability_Service) Reset Uses

func (m *PluginCapability_Service) Reset()

func (*PluginCapability_Service) String Uses

func (m *PluginCapability_Service) String() string

func (*PluginCapability_Service) XXX_DiscardUnknown Uses

func (m *PluginCapability_Service) XXX_DiscardUnknown()

func (*PluginCapability_Service) XXX_Marshal Uses

func (m *PluginCapability_Service) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PluginCapability_Service) XXX_Merge Uses

func (m *PluginCapability_Service) XXX_Merge(src proto.Message)

func (*PluginCapability_Service) XXX_Size Uses

func (m *PluginCapability_Service) XXX_Size() int

func (*PluginCapability_Service) XXX_Unmarshal Uses

func (m *PluginCapability_Service) XXX_Unmarshal(b []byte) error

type PluginCapability_Service_ Uses

type PluginCapability_Service_ struct {
    Service *PluginCapability_Service `protobuf:"bytes,1,opt,name=service,proto3,oneof"`
}

type PluginCapability_Service_Type Uses

type PluginCapability_Service_Type int32
const (
    PluginCapability_Service_UNKNOWN PluginCapability_Service_Type = 0
    // CONTROLLER_SERVICE indicates that the Plugin provides RPCs for
    // the ControllerService. Plugins SHOULD provide this capability.
    // In rare cases certain plugins MAY wish to omit the
    // ControllerService entirely from their implementation, but such
    // SHOULD NOT be the common case.
    // The presence of this capability determines whether the CO will
    // attempt to invoke the REQUIRED ControllerService RPCs, as well
    // as specific RPCs as indicated by ControllerGetCapabilities.
    PluginCapability_Service_CONTROLLER_SERVICE PluginCapability_Service_Type = 1
    // VOLUME_ACCESSIBILITY_CONSTRAINTS indicates that the volumes for
    // this plugin MAY NOT be equally accessible by all nodes in the
    // cluster. The CO MUST use the topology information returned by
    // CreateVolumeRequest along with the topology information
    // returned by NodeGetInfo to ensure that a given volume is
    // accessible from a given node when scheduling workloads.
    PluginCapability_Service_VOLUME_ACCESSIBILITY_CONSTRAINTS PluginCapability_Service_Type = 2
)

func (PluginCapability_Service_Type) EnumDescriptor Uses

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

func (PluginCapability_Service_Type) String Uses

func (x PluginCapability_Service_Type) String() string

type PluginCapability_VolumeExpansion Uses

type PluginCapability_VolumeExpansion struct {
    Type                 PluginCapability_VolumeExpansion_Type `protobuf:"varint,1,opt,name=type,proto3,enum=csi.v1.PluginCapability_VolumeExpansion_Type" json:"type,omitempty"`
    XXX_NoUnkeyedLiteral struct{}                              `json:"-"`
    XXX_unrecognized     []byte                                `json:"-"`
    XXX_sizecache        int32                                 `json:"-"`
}

func (*PluginCapability_VolumeExpansion) Descriptor Uses

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

func (*PluginCapability_VolumeExpansion) GetType Uses

func (m *PluginCapability_VolumeExpansion) GetType() PluginCapability_VolumeExpansion_Type

func (*PluginCapability_VolumeExpansion) ProtoMessage Uses

func (*PluginCapability_VolumeExpansion) ProtoMessage()

func (*PluginCapability_VolumeExpansion) Reset Uses

func (m *PluginCapability_VolumeExpansion) Reset()

func (*PluginCapability_VolumeExpansion) String Uses

func (m *PluginCapability_VolumeExpansion) String() string

func (*PluginCapability_VolumeExpansion) XXX_DiscardUnknown Uses

func (m *PluginCapability_VolumeExpansion) XXX_DiscardUnknown()

func (*PluginCapability_VolumeExpansion) XXX_Marshal Uses

func (m *PluginCapability_VolumeExpansion) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PluginCapability_VolumeExpansion) XXX_Merge Uses

func (m *PluginCapability_VolumeExpansion) XXX_Merge(src proto.Message)

func (*PluginCapability_VolumeExpansion) XXX_Size Uses

func (m *PluginCapability_VolumeExpansion) XXX_Size() int

func (*PluginCapability_VolumeExpansion) XXX_Unmarshal Uses

func (m *PluginCapability_VolumeExpansion) XXX_Unmarshal(b []byte) error

type PluginCapability_VolumeExpansion_ Uses

type PluginCapability_VolumeExpansion_ struct {
    VolumeExpansion *PluginCapability_VolumeExpansion `protobuf:"bytes,2,opt,name=volume_expansion,json=volumeExpansion,proto3,oneof"`
}

type PluginCapability_VolumeExpansion_Type Uses

type PluginCapability_VolumeExpansion_Type int32
const (
    PluginCapability_VolumeExpansion_UNKNOWN PluginCapability_VolumeExpansion_Type = 0
    // ONLINE indicates that volumes may be expanded when published to
    // a node. When a Plugin implements this capability it MUST
    // implement either the EXPAND_VOLUME controller capability or the
    // EXPAND_VOLUME node capability or both. When a plugin supports
    // ONLINE volume expansion and also has the EXPAND_VOLUME
    // controller capability then the plugin MUST support expansion of
    // volumes currently published and available on a node. When a
    // plugin supports ONLINE volume expansion and also has the
    // EXPAND_VOLUME node capability then the plugin MAY support
    // expansion of node-published volume via NodeExpandVolume.
    //
    // Example 1: Given a shared filesystem volume (e.g. GlusterFs),
    //   the Plugin may set the ONLINE volume expansion capability and
    //   implement ControllerExpandVolume but not NodeExpandVolume.
    //
    // Example 2: Given a block storage volume type (e.g. EBS), the
    //   Plugin may set the ONLINE volume expansion capability and
    //   implement both ControllerExpandVolume and NodeExpandVolume.
    //
    // Example 3: Given a Plugin that supports volume expansion only
    //   upon a node, the Plugin may set the ONLINE volume
    //   expansion capability and implement NodeExpandVolume but not
    //   ControllerExpandVolume.
    PluginCapability_VolumeExpansion_ONLINE PluginCapability_VolumeExpansion_Type = 1
    // OFFLINE indicates that volumes currently published and
    // available on a node SHALL NOT be expanded via
    // ControllerExpandVolume. When a plugin supports OFFLINE volume
    // expansion it MUST implement either the EXPAND_VOLUME controller
    // capability or both the EXPAND_VOLUME controller capability and
    // the EXPAND_VOLUME node capability.
    //
    // Example 1: Given a block storage volume type (e.g. Azure Disk)
    //   that does not support expansion of "node-attached" (i.e.
    //   controller-published) volumes, the Plugin may indicate
    //   OFFLINE volume expansion support and implement both
    //   ControllerExpandVolume and NodeExpandVolume.
    PluginCapability_VolumeExpansion_OFFLINE PluginCapability_VolumeExpansion_Type = 2
)

func (PluginCapability_VolumeExpansion_Type) EnumDescriptor Uses

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

func (PluginCapability_VolumeExpansion_Type) String Uses

func (x PluginCapability_VolumeExpansion_Type) String() string

type ProbeRequest Uses

type ProbeRequest struct {
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*ProbeRequest) Descriptor Uses

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

func (*ProbeRequest) ProtoMessage Uses

func (*ProbeRequest) ProtoMessage()

func (*ProbeRequest) Reset Uses

func (m *ProbeRequest) Reset()

func (*ProbeRequest) String Uses

func (m *ProbeRequest) String() string

func (*ProbeRequest) XXX_DiscardUnknown Uses

func (m *ProbeRequest) XXX_DiscardUnknown()

func (*ProbeRequest) XXX_Marshal Uses

func (m *ProbeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ProbeRequest) XXX_Merge Uses

func (m *ProbeRequest) XXX_Merge(src proto.Message)

func (*ProbeRequest) XXX_Size Uses

func (m *ProbeRequest) XXX_Size() int

func (*ProbeRequest) XXX_Unmarshal Uses

func (m *ProbeRequest) XXX_Unmarshal(b []byte) error

type ProbeResponse Uses

type ProbeResponse struct {
    // Readiness allows a plugin to report its initialization status back
    // to the CO. Initialization for some plugins MAY be time consuming
    // and it is important for a CO to distinguish between the following
    // cases:
    //
    // 1) The plugin is in an unhealthy state and MAY need restarting. In
    //    this case a gRPC error code SHALL be returned.
    // 2) The plugin is still initializing, but is otherwise perfectly
    //    healthy. In this case a successful response SHALL be returned
    //    with a readiness value of `false`. Calls to the plugin's
    //    Controller and/or Node services MAY fail due to an incomplete
    //    initialization state.
    // 3) The plugin has finished initializing and is ready to service
    //    calls to its Controller and/or Node services. A successful
    //    response is returned with a readiness value of `true`.
    //
    // This field is OPTIONAL. If not present, the caller SHALL assume
    // that the plugin is in a ready state and is accepting calls to its
    // Controller and/or Node services (according to the plugin's reported
    // capabilities).
    Ready                *wrappers.BoolValue `protobuf:"bytes,1,opt,name=ready,proto3" json:"ready,omitempty"`
    XXX_NoUnkeyedLiteral struct{}            `json:"-"`
    XXX_unrecognized     []byte              `json:"-"`
    XXX_sizecache        int32               `json:"-"`
}

func (*ProbeResponse) Descriptor Uses

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

func (*ProbeResponse) GetReady Uses

func (m *ProbeResponse) GetReady() *wrappers.BoolValue

func (*ProbeResponse) ProtoMessage Uses

func (*ProbeResponse) ProtoMessage()

func (*ProbeResponse) Reset Uses

func (m *ProbeResponse) Reset()

func (*ProbeResponse) String Uses

func (m *ProbeResponse) String() string

func (*ProbeResponse) XXX_DiscardUnknown Uses

func (m *ProbeResponse) XXX_DiscardUnknown()

func (*ProbeResponse) XXX_Marshal Uses

func (m *ProbeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ProbeResponse) XXX_Merge Uses

func (m *ProbeResponse) XXX_Merge(src proto.Message)

func (*ProbeResponse) XXX_Size Uses

func (m *ProbeResponse) XXX_Size() int

func (*ProbeResponse) XXX_Unmarshal Uses

func (m *ProbeResponse) XXX_Unmarshal(b []byte) error

type Snapshot Uses

type Snapshot struct {
    // This is the complete size of the snapshot in bytes. The purpose of
    // this field is to give CO guidance on how much space is needed to
    // create a volume from this snapshot. The size of the volume MUST NOT
    // be less than the size of the source snapshot. This field is
    // OPTIONAL. If this field is not set, it indicates that this size is
    // unknown. The value of this field MUST NOT be negative and a size of
    // zero means it is unspecified.
    SizeBytes int64 `protobuf:"varint,1,opt,name=size_bytes,json=sizeBytes,proto3" json:"size_bytes,omitempty"`
    // The identifier for this snapshot, generated by the plugin.
    // This field is REQUIRED.
    // This field MUST contain enough information to uniquely identify
    // this specific snapshot vs all other snapshots supported by this
    // plugin.
    // This field SHALL be used by the CO in subsequent calls to refer to
    // this snapshot.
    // The SP is NOT responsible for global uniqueness of snapshot_id
    // across multiple SPs.
    SnapshotId string `protobuf:"bytes,2,opt,name=snapshot_id,json=snapshotId,proto3" json:"snapshot_id,omitempty"`
    // Identity information for the source volume. Note that creating a
    // snapshot from a snapshot is not supported here so the source has to
    // be a volume. This field is REQUIRED.
    SourceVolumeId string `protobuf:"bytes,3,opt,name=source_volume_id,json=sourceVolumeId,proto3" json:"source_volume_id,omitempty"`
    // Timestamp when the point-in-time snapshot is taken on the storage
    // system. This field is REQUIRED.
    CreationTime *timestamp.Timestamp `protobuf:"bytes,4,opt,name=creation_time,json=creationTime,proto3" json:"creation_time,omitempty"`
    // Indicates if a snapshot is ready to use as a
    // `volume_content_source` in a `CreateVolumeRequest`. The default
    // value is false. This field is REQUIRED.
    ReadyToUse           bool     `protobuf:"varint,5,opt,name=ready_to_use,json=readyToUse,proto3" json:"ready_to_use,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

Information about a specific snapshot.

func (*Snapshot) Descriptor Uses

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

func (*Snapshot) GetCreationTime Uses

func (m *Snapshot) GetCreationTime() *timestamp.Timestamp

func (*Snapshot) GetReadyToUse Uses

func (m *Snapshot) GetReadyToUse() bool

func (*Snapshot) GetSizeBytes Uses

func (m *Snapshot) GetSizeBytes() int64

func (*Snapshot) GetSnapshotId Uses

func (m *Snapshot) GetSnapshotId() string

func (*Snapshot) GetSourceVolumeId Uses

func (m *Snapshot) GetSourceVolumeId() string

func (*Snapshot) ProtoMessage Uses

func (*Snapshot) ProtoMessage()

func (*Snapshot) Reset Uses

func (m *Snapshot) Reset()

func (*Snapshot) String Uses

func (m *Snapshot) String() string

func (*Snapshot) XXX_DiscardUnknown Uses

func (m *Snapshot) XXX_DiscardUnknown()

func (*Snapshot) XXX_Marshal Uses

func (m *Snapshot) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Snapshot) XXX_Merge Uses

func (m *Snapshot) XXX_Merge(src proto.Message)

func (*Snapshot) XXX_Size Uses

func (m *Snapshot) XXX_Size() int

func (*Snapshot) XXX_Unmarshal Uses

func (m *Snapshot) XXX_Unmarshal(b []byte) error

type Topology Uses

type Topology struct {
    Segments             map[string]string `protobuf:"bytes,1,rep,name=segments,proto3" json:"segments,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
    XXX_NoUnkeyedLiteral struct{}          `json:"-"`
    XXX_unrecognized     []byte            `json:"-"`
    XXX_sizecache        int32             `json:"-"`
}

Topology is a map of topological domains to topological segments. A topological domain is a sub-division of a cluster, like "region", "zone", "rack", etc. A topological segment is a specific instance of a topological domain, like "zone3", "rack3", etc. For example {"com.company/zone": "Z1", "com.company/rack": "R3"} Valid keys have two segments: an OPTIONAL prefix and name, separated by a slash (/), for example: "com.company.example/zone". The key name segment is REQUIRED. The prefix is OPTIONAL. The key name MUST be 63 characters or less, begin and end with an alphanumeric character ([a-z0-9A-Z]), and contain only dashes (-), underscores (_), dots (.), or alphanumerics in between, for example "zone". The key prefix MUST be 63 characters or less, begin and end with a lower-case alphanumeric character ([a-z0-9]), contain only dashes (-), dots (.), or lower-case alphanumerics in between, and follow domain name notation format (https://tools.ietf.org/html/rfc1035#section-2.3.1). The key prefix SHOULD include the plugin's host company name and/or the plugin name, to minimize the possibility of collisions with keys from other plugins. If a key prefix is specified, it MUST be identical across all topology keys returned by the SP (across all RPCs). Keys MUST be case-insensitive. Meaning the keys "Zone" and "zone" MUST not both exist. Each value (topological segment) MUST contain 1 or more strings. Each string MUST be 63 characters or less and begin and end with an alphanumeric character with '-', '_', '.', or alphanumerics in between.

func (*Topology) Descriptor Uses

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

func (*Topology) GetSegments Uses

func (m *Topology) GetSegments() map[string]string

func (*Topology) ProtoMessage Uses

func (*Topology) ProtoMessage()

func (*Topology) Reset Uses

func (m *Topology) Reset()

func (*Topology) String Uses

func (m *Topology) String() string

func (*Topology) XXX_DiscardUnknown Uses

func (m *Topology) XXX_DiscardUnknown()

func (*Topology) XXX_Marshal Uses

func (m *Topology) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Topology) XXX_Merge Uses

func (m *Topology) XXX_Merge(src proto.Message)

func (*Topology) XXX_Size Uses

func (m *Topology) XXX_Size() int

func (*Topology) XXX_Unmarshal Uses

func (m *Topology) XXX_Unmarshal(b []byte) error

type TopologyRequirement Uses

type TopologyRequirement struct {
    // Specifies the list of topologies the provisioned volume MUST be
    // accessible from.
    // This field is OPTIONAL. If TopologyRequirement is specified either
    // requisite or preferred or both MUST be specified.
    //
    // If requisite is specified, the provisioned volume MUST be
    // accessible from at least one of the requisite topologies.
    //
    // Given
    //   x = number of topologies provisioned volume is accessible from
    //   n = number of requisite topologies
    // The CO MUST ensure n >= 1. The SP MUST ensure x >= 1
    // If x==n, then the SP MUST make the provisioned volume available to
    // all topologies from the list of requisite topologies. If it is
    // unable to do so, the SP MUST fail the CreateVolume call.
    // For example, if a volume should be accessible from a single zone,
    // and requisite =
    //   {"region": "R1", "zone": "Z2"}
    // then the provisioned volume MUST be accessible from the "region"
    // "R1" and the "zone" "Z2".
    // Similarly, if a volume should be accessible from two zones, and
    // requisite =
    //   {"region": "R1", "zone": "Z2"},
    //   {"region": "R1", "zone": "Z3"}
    // then the provisioned volume MUST be accessible from the "region"
    // "R1" and both "zone" "Z2" and "zone" "Z3".
    //
    // If x<n, then the SP SHALL choose x unique topologies from the list
    // of requisite topologies. If it is unable to do so, the SP MUST fail
    // the CreateVolume call.
    // For example, if a volume should be accessible from a single zone,
    // and requisite =
    //   {"region": "R1", "zone": "Z2"},
    //   {"region": "R1", "zone": "Z3"}
    // then the SP may choose to make the provisioned volume available in
    // either the "zone" "Z2" or the "zone" "Z3" in the "region" "R1".
    // Similarly, if a volume should be accessible from two zones, and
    // requisite =
    //   {"region": "R1", "zone": "Z2"},
    //   {"region": "R1", "zone": "Z3"},
    //   {"region": "R1", "zone": "Z4"}
    // then the provisioned volume MUST be accessible from any combination
    // of two unique topologies: e.g. "R1/Z2" and "R1/Z3", or "R1/Z2" and
    //  "R1/Z4", or "R1/Z3" and "R1/Z4".
    //
    // If x>n, then the SP MUST make the provisioned volume available from
    // all topologies from the list of requisite topologies and MAY choose
    // the remaining x-n unique topologies from the list of all possible
    // topologies. If it is unable to do so, the SP MUST fail the
    // CreateVolume call.
    // For example, if a volume should be accessible from two zones, and
    // requisite =
    //   {"region": "R1", "zone": "Z2"}
    // then the provisioned volume MUST be accessible from the "region"
    // "R1" and the "zone" "Z2" and the SP may select the second zone
    // independently, e.g. "R1/Z4".
    Requisite []*Topology `protobuf:"bytes,1,rep,name=requisite,proto3" json:"requisite,omitempty"`
    // Specifies the list of topologies the CO would prefer the volume to
    // be provisioned in.
    //
    // This field is OPTIONAL. If TopologyRequirement is specified either
    // requisite or preferred or both MUST be specified.
    //
    // An SP MUST attempt to make the provisioned volume available using
    // the preferred topologies in order from first to last.
    //
    // If requisite is specified, all topologies in preferred list MUST
    // also be present in the list of requisite topologies.
    //
    // If the SP is unable to to make the provisioned volume available
    // from any of the preferred topologies, the SP MAY choose a topology
    // from the list of requisite topologies.
    // If the list of requisite topologies is not specified, then the SP
    // MAY choose from the list of all possible topologies.
    // If the list of requisite topologies is specified and the SP is
    // unable to to make the provisioned volume available from any of the
    // requisite topologies it MUST fail the CreateVolume call.
    //
    // Example 1:
    // Given a volume should be accessible from a single zone, and
    // requisite =
    //   {"region": "R1", "zone": "Z2"},
    //   {"region": "R1", "zone": "Z3"}
    // preferred =
    //   {"region": "R1", "zone": "Z3"}
    // then the the SP SHOULD first attempt to make the provisioned volume
    // available from "zone" "Z3" in the "region" "R1" and fall back to
    // "zone" "Z2" in the "region" "R1" if that is not possible.
    //
    // Example 2:
    // Given a volume should be accessible from a single zone, and
    // requisite =
    //   {"region": "R1", "zone": "Z2"},
    //   {"region": "R1", "zone": "Z3"},
    //   {"region": "R1", "zone": "Z4"},
    //   {"region": "R1", "zone": "Z5"}
    // preferred =
    //   {"region": "R1", "zone": "Z4"},
    //   {"region": "R1", "zone": "Z2"}
    // then the the SP SHOULD first attempt to make the provisioned volume
    // accessible from "zone" "Z4" in the "region" "R1" and fall back to
    // "zone" "Z2" in the "region" "R1" if that is not possible. If that
    // is not possible, the SP may choose between either the "zone"
    // "Z3" or "Z5" in the "region" "R1".
    //
    // Example 3:
    // Given a volume should be accessible from TWO zones (because an
    // opaque parameter in CreateVolumeRequest, for example, specifies
    // the volume is accessible from two zones, aka synchronously
    // replicated), and
    // requisite =
    //   {"region": "R1", "zone": "Z2"},
    //   {"region": "R1", "zone": "Z3"},
    //   {"region": "R1", "zone": "Z4"},
    //   {"region": "R1", "zone": "Z5"}
    // preferred =
    //   {"region": "R1", "zone": "Z5"},
    //   {"region": "R1", "zone": "Z3"}
    // then the the SP SHOULD first attempt to make the provisioned volume
    // accessible from the combination of the two "zones" "Z5" and "Z3" in
    // the "region" "R1". If that's not possible, it should fall back to
    // a combination of "Z5" and other possibilities from the list of
    // requisite. If that's not possible, it should fall back  to a
    // combination of "Z3" and other possibilities from the list of
    // requisite. If that's not possible, it should fall back  to a
    // combination of other possibilities from the list of requisite.
    Preferred            []*Topology `protobuf:"bytes,2,rep,name=preferred,proto3" json:"preferred,omitempty"`
    XXX_NoUnkeyedLiteral struct{}    `json:"-"`
    XXX_unrecognized     []byte      `json:"-"`
    XXX_sizecache        int32       `json:"-"`
}

func (*TopologyRequirement) Descriptor Uses

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

func (*TopologyRequirement) GetPreferred Uses

func (m *TopologyRequirement) GetPreferred() []*Topology

func (*TopologyRequirement) GetRequisite Uses

func (m *TopologyRequirement) GetRequisite() []*Topology

func (*TopologyRequirement) ProtoMessage Uses

func (*TopologyRequirement) ProtoMessage()

func (*TopologyRequirement) Reset Uses

func (m *TopologyRequirement) Reset()

func (*TopologyRequirement) String Uses

func (m *TopologyRequirement) String() string

func (*TopologyRequirement) XXX_DiscardUnknown Uses

func (m *TopologyRequirement) XXX_DiscardUnknown()

func (*TopologyRequirement) XXX_Marshal Uses

func (m *TopologyRequirement) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TopologyRequirement) XXX_Merge Uses

func (m *TopologyRequirement) XXX_Merge(src proto.Message)

func (*TopologyRequirement) XXX_Size Uses

func (m *TopologyRequirement) XXX_Size() int

func (*TopologyRequirement) XXX_Unmarshal Uses

func (m *TopologyRequirement) XXX_Unmarshal(b []byte) error

type ValidateVolumeCapabilitiesRequest Uses

type ValidateVolumeCapabilitiesRequest struct {
    // The ID of the volume to check. This field is REQUIRED.
    VolumeId string `protobuf:"bytes,1,opt,name=volume_id,json=volumeId,proto3" json:"volume_id,omitempty"`
    // Volume context as returned by CO in CreateVolumeRequest. This field
    // is OPTIONAL and MUST match the volume_context of the volume
    // identified by `volume_id`.
    VolumeContext map[string]string `protobuf:"bytes,2,rep,name=volume_context,json=volumeContext,proto3" json:"volume_context,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
    // The capabilities that the CO wants to check for the volume. This
    // call SHALL return "confirmed" 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,proto3" json:"volume_capabilities,omitempty"`
    // See CreateVolumeRequest.parameters.
    // This field is OPTIONAL.
    Parameters map[string]string `protobuf:"bytes,4,rep,name=parameters,proto3" json:"parameters,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
    // Secrets required by plugin to complete volume validation request.
    // This field is OPTIONAL. Refer to the `Secrets Requirements`
    // section on how to use this field.
    Secrets              map[string]string `protobuf:"bytes,5,rep,name=secrets,proto3" json:"secrets,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
    XXX_NoUnkeyedLiteral struct{}          `json:"-"`
    XXX_unrecognized     []byte            `json:"-"`
    XXX_sizecache        int32             `json:"-"`
}

func (*ValidateVolumeCapabilitiesRequest) Descriptor Uses

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

func (*ValidateVolumeCapabilitiesRequest) GetParameters Uses

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

func (*ValidateVolumeCapabilitiesRequest) GetSecrets Uses

func (m *ValidateVolumeCapabilitiesRequest) GetSecrets() map[string]string

func (*ValidateVolumeCapabilitiesRequest) GetVolumeCapabilities Uses

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

func (*ValidateVolumeCapabilitiesRequest) GetVolumeContext Uses

func (m *ValidateVolumeCapabilitiesRequest) GetVolumeContext() map[string]string

func (*ValidateVolumeCapabilitiesRequest) GetVolumeId Uses

func (m *ValidateVolumeCapabilitiesRequest) GetVolumeId() string

func (*ValidateVolumeCapabilitiesRequest) ProtoMessage Uses

func (*ValidateVolumeCapabilitiesRequest) ProtoMessage()

func (*ValidateVolumeCapabilitiesRequest) Reset Uses

func (m *ValidateVolumeCapabilitiesRequest) Reset()

func (*ValidateVolumeCapabilitiesRequest) String Uses

func (m *ValidateVolumeCapabilitiesRequest) String() string

func (*ValidateVolumeCapabilitiesRequest) XXX_DiscardUnknown Uses

func (m *ValidateVolumeCapabilitiesRequest) XXX_DiscardUnknown()

func (*ValidateVolumeCapabilitiesRequest) XXX_Marshal Uses

func (m *ValidateVolumeCapabilitiesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ValidateVolumeCapabilitiesRequest) XXX_Merge Uses

func (m *ValidateVolumeCapabilitiesRequest) XXX_Merge(src proto.Message)

func (*ValidateVolumeCapabilitiesRequest) XXX_Size Uses

func (m *ValidateVolumeCapabilitiesRequest) XXX_Size() int

func (*ValidateVolumeCapabilitiesRequest) XXX_Unmarshal Uses

func (m *ValidateVolumeCapabilitiesRequest) XXX_Unmarshal(b []byte) error

type ValidateVolumeCapabilitiesResponse Uses

type ValidateVolumeCapabilitiesResponse struct {
    // Confirmed indicates to the CO the set of capabilities that the
    // plugin has validated. This field SHALL only be set to a non-empty
    // value for successful validation responses.
    // For successful validation responses, the CO SHALL compare the
    // fields of this message to the originally requested capabilities in
    // order to guard against an older plugin reporting "valid" for newer
    // capability fields that it does not yet understand.
    // This field is OPTIONAL.
    Confirmed *ValidateVolumeCapabilitiesResponse_Confirmed `protobuf:"bytes,1,opt,name=confirmed,proto3" json:"confirmed,omitempty"`
    // Message to the CO if `confirmed` above is empty. This field is
    // OPTIONAL.
    // An empty string is equal to an unspecified field value.
    Message              string   `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*ValidateVolumeCapabilitiesResponse) Descriptor Uses

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

func (*ValidateVolumeCapabilitiesResponse) GetConfirmed Uses

func (m *ValidateVolumeCapabilitiesResponse) GetConfirmed() *ValidateVolumeCapabilitiesResponse_Confirmed

func (*ValidateVolumeCapabilitiesResponse) GetMessage Uses

func (m *ValidateVolumeCapabilitiesResponse) GetMessage() string

func (*ValidateVolumeCapabilitiesResponse) ProtoMessage Uses

func (*ValidateVolumeCapabilitiesResponse) ProtoMessage()

func (*ValidateVolumeCapabilitiesResponse) Reset Uses

func (m *ValidateVolumeCapabilitiesResponse) Reset()

func (*ValidateVolumeCapabilitiesResponse) String Uses

func (m *ValidateVolumeCapabilitiesResponse) String() string

func (*ValidateVolumeCapabilitiesResponse) XXX_DiscardUnknown Uses

func (m *ValidateVolumeCapabilitiesResponse) XXX_DiscardUnknown()

func (*ValidateVolumeCapabilitiesResponse) XXX_Marshal Uses

func (m *ValidateVolumeCapabilitiesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ValidateVolumeCapabilitiesResponse) XXX_Merge Uses

func (m *ValidateVolumeCapabilitiesResponse) XXX_Merge(src proto.Message)

func (*ValidateVolumeCapabilitiesResponse) XXX_Size Uses

func (m *ValidateVolumeCapabilitiesResponse) XXX_Size() int

func (*ValidateVolumeCapabilitiesResponse) XXX_Unmarshal Uses

func (m *ValidateVolumeCapabilitiesResponse) XXX_Unmarshal(b []byte) error

type ValidateVolumeCapabilitiesResponse_Confirmed Uses

type ValidateVolumeCapabilitiesResponse_Confirmed struct {
    // Volume context validated by the plugin.
    // This field is OPTIONAL.
    VolumeContext map[string]string `protobuf:"bytes,1,rep,name=volume_context,json=volumeContext,proto3" json:"volume_context,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
    // Volume capabilities supported by the plugin.
    // This field is REQUIRED.
    VolumeCapabilities []*VolumeCapability `protobuf:"bytes,2,rep,name=volume_capabilities,json=volumeCapabilities,proto3" json:"volume_capabilities,omitempty"`
    // The volume creation parameters validated by the plugin.
    // This field is OPTIONAL.
    Parameters           map[string]string `protobuf:"bytes,3,rep,name=parameters,proto3" json:"parameters,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
    XXX_NoUnkeyedLiteral struct{}          `json:"-"`
    XXX_unrecognized     []byte            `json:"-"`
    XXX_sizecache        int32             `json:"-"`
}

func (*ValidateVolumeCapabilitiesResponse_Confirmed) Descriptor Uses

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

func (*ValidateVolumeCapabilitiesResponse_Confirmed) GetParameters Uses

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

func (*ValidateVolumeCapabilitiesResponse_Confirmed) GetVolumeCapabilities Uses

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

func (*ValidateVolumeCapabilitiesResponse_Confirmed) GetVolumeContext Uses

func (m *ValidateVolumeCapabilitiesResponse_Confirmed) GetVolumeContext() map[string]string

func (*ValidateVolumeCapabilitiesResponse_Confirmed) ProtoMessage Uses

func (*ValidateVolumeCapabilitiesResponse_Confirmed) ProtoMessage()

func (*ValidateVolumeCapabilitiesResponse_Confirmed) Reset Uses

func (m *ValidateVolumeCapabilitiesResponse_Confirmed) Reset()

func (*ValidateVolumeCapabilitiesResponse_Confirmed) String Uses

func (m *ValidateVolumeCapabilitiesResponse_Confirmed) String() string

func (*ValidateVolumeCapabilitiesResponse_Confirmed) XXX_DiscardUnknown Uses

func (m *ValidateVolumeCapabilitiesResponse_Confirmed) XXX_DiscardUnknown()

func (*ValidateVolumeCapabilitiesResponse_Confirmed) XXX_Marshal Uses

func (m *ValidateVolumeCapabilitiesResponse_Confirmed) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ValidateVolumeCapabilitiesResponse_Confirmed) XXX_Merge Uses

func (m *ValidateVolumeCapabilitiesResponse_Confirmed) XXX_Merge(src proto.Message)

func (*ValidateVolumeCapabilitiesResponse_Confirmed) XXX_Size Uses

func (m *ValidateVolumeCapabilitiesResponse_Confirmed) XXX_Size() int

func (*ValidateVolumeCapabilitiesResponse_Confirmed) XXX_Unmarshal Uses

func (m *ValidateVolumeCapabilitiesResponse_Confirmed) XXX_Unmarshal(b []byte) error

type Volume Uses

type Volume struct {
    // The capacity of the volume in bytes. This field is OPTIONAL. If not
    // set (value of 0), it indicates that the capacity of the volume is
    // unknown (e.g., NFS share).
    // The value of this field MUST NOT be negative.
    CapacityBytes int64 `protobuf:"varint,1,opt,name=capacity_bytes,json=capacityBytes,proto3" json:"capacity_bytes,omitempty"`
    // The identifier for this volume, generated by the plugin.
    // This field is REQUIRED.
    // This field MUST contain enough information to uniquely identify
    // this specific volume vs all other volumes supported by this plugin.
    // This field SHALL be used by the CO in subsequent calls to refer to
    // this volume.
    // The SP is NOT responsible for global uniqueness of volume_id across
    // multiple SPs.
    VolumeId string `protobuf:"bytes,2,opt,name=volume_id,json=volumeId,proto3" json:"volume_id,omitempty"`
    // Opaque static properties of the volume. SP MAY use this field to
    // ensure subsequent volume validation and publishing calls have
    // contextual information.
    // The contents of this field SHALL be opaque to a CO.
    // The contents of this field SHALL NOT be mutable.
    // The contents of this field SHALL be safe for the CO to cache.
    // The contents of this field SHOULD NOT contain sensitive
    // information.
    // The contents of this field SHOULD NOT be used for uniquely
    // identifying a volume. The `volume_id` alone SHOULD be sufficient to
    // identify the volume.
    // A volume uniquely identified by `volume_id` SHALL always report the
    // same volume_context.
    // This field is OPTIONAL and when present MUST be passed to volume
    // validation and publishing calls.
    VolumeContext map[string]string `protobuf:"bytes,3,rep,name=volume_context,json=volumeContext,proto3" json:"volume_context,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
    // If specified, indicates that the volume is not empty and is
    // pre-populated with data from the specified source.
    // This field is OPTIONAL.
    ContentSource *VolumeContentSource `protobuf:"bytes,4,opt,name=content_source,json=contentSource,proto3" json:"content_source,omitempty"`
    // Specifies where (regions, zones, racks, etc.) the provisioned
    // volume is accessible from.
    // A plugin that returns this field MUST also set the
    // VOLUME_ACCESSIBILITY_CONSTRAINTS plugin capability.
    // An SP MAY specify multiple topologies to indicate the volume is
    // accessible from multiple locations.
    // COs MAY use this information along with the topology information
    // returned by NodeGetInfo to ensure that a given volume is accessible
    // from a given node when scheduling workloads.
    // This field is OPTIONAL. If it is not specified, the CO MAY assume
    // the volume is equally accessible from all nodes in the cluster and
    // MAY schedule workloads referencing the volume on any available
    // node.
    //
    // Example 1:
    //   accessible_topology = {"region": "R1", "zone": "Z2"}
    // Indicates a volume accessible only from the "region" "R1" and the
    // "zone" "Z2".
    //
    // Example 2:
    //   accessible_topology =
    //     {"region": "R1", "zone": "Z2"},
    //     {"region": "R1", "zone": "Z3"}
    // Indicates a volume accessible from both "zone" "Z2" and "zone" "Z3"
    // in the "region" "R1".
    AccessibleTopology   []*Topology `protobuf:"bytes,5,rep,name=accessible_topology,json=accessibleTopology,proto3" json:"accessible_topology,omitempty"`
    XXX_NoUnkeyedLiteral struct{}    `json:"-"`
    XXX_unrecognized     []byte      `json:"-"`
    XXX_sizecache        int32       `json:"-"`
}

Information about a specific volume.

func (*Volume) Descriptor Uses

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

func (*Volume) GetAccessibleTopology Uses

func (m *Volume) GetAccessibleTopology() []*Topology

func (*Volume) GetCapacityBytes Uses

func (m *Volume) GetCapacityBytes() int64

func (*Volume) GetContentSource Uses

func (m *Volume) GetContentSource() *VolumeContentSource

func (*Volume) GetVolumeContext Uses

func (m *Volume) GetVolumeContext() map[string]string

func (*Volume) GetVolumeId Uses

func (m *Volume) GetVolumeId() string

func (*Volume) ProtoMessage Uses

func (*Volume) ProtoMessage()

func (*Volume) Reset Uses

func (m *Volume) Reset()

func (*Volume) String Uses

func (m *Volume) String() string

func (*Volume) XXX_DiscardUnknown Uses

func (m *Volume) XXX_DiscardUnknown()

func (*Volume) XXX_Marshal Uses

func (m *Volume) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Volume) XXX_Merge Uses

func (m *Volume) XXX_Merge(src proto.Message)

func (*Volume) XXX_Size Uses

func (m *Volume) XXX_Size() int

func (*Volume) XXX_Unmarshal Uses

func (m *Volume) XXX_Unmarshal(b []byte) error

type VolumeCapability Uses

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,proto3" json:"access_mode,omitempty"`
    XXX_NoUnkeyedLiteral struct{}                     `json:"-"`
    XXX_unrecognized     []byte                       `json:"-"`
    XXX_sizecache        int32                        `json:"-"`
}

Specify a capability of a volume.

func (*VolumeCapability) Descriptor Uses

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

func (*VolumeCapability) GetAccessMode Uses

func (m *VolumeCapability) GetAccessMode() *VolumeCapability_AccessMode

func (*VolumeCapability) GetAccessType Uses

func (m *VolumeCapability) GetAccessType() isVolumeCapability_AccessType

func (*VolumeCapability) GetBlock Uses

func (m *VolumeCapability) GetBlock() *VolumeCapability_BlockVolume

func (*VolumeCapability) GetMount Uses

func (m *VolumeCapability) GetMount() *VolumeCapability_MountVolume

func (*VolumeCapability) ProtoMessage Uses

func (*VolumeCapability) ProtoMessage()

func (*VolumeCapability) Reset Uses

func (m *VolumeCapability) Reset()

func (*VolumeCapability) String Uses

func (m *VolumeCapability) String() string

func (*VolumeCapability) XXX_DiscardUnknown Uses

func (m *VolumeCapability) XXX_DiscardUnknown()

func (*VolumeCapability) XXX_Marshal Uses

func (m *VolumeCapability) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*VolumeCapability) XXX_Merge Uses

func (m *VolumeCapability) XXX_Merge(src proto.Message)

func (*VolumeCapability) XXX_OneofWrappers Uses

func (*VolumeCapability) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*VolumeCapability) XXX_Size Uses

func (m *VolumeCapability) XXX_Size() int

func (*VolumeCapability) XXX_Unmarshal Uses

func (m *VolumeCapability) XXX_Unmarshal(b []byte) error

type VolumeCapability_AccessMode Uses

type VolumeCapability_AccessMode struct {
    // This field is REQUIRED.
    Mode                 VolumeCapability_AccessMode_Mode `protobuf:"varint,1,opt,name=mode,proto3,enum=csi.v1.VolumeCapability_AccessMode_Mode" json:"mode,omitempty"`
    XXX_NoUnkeyedLiteral struct{}                         `json:"-"`
    XXX_unrecognized     []byte                           `json:"-"`
    XXX_sizecache        int32                            `json:"-"`
}

Specify how a volume can be accessed.

func (*VolumeCapability_AccessMode) Descriptor Uses

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

func (*VolumeCapability_AccessMode) GetMode Uses

func (m *VolumeCapability_AccessMode) GetMode() VolumeCapability_AccessMode_Mode

func (*VolumeCapability_AccessMode) ProtoMessage Uses

func (*VolumeCapability_AccessMode) ProtoMessage()

func (*VolumeCapability_AccessMode) Reset Uses

func (m *VolumeCapability_AccessMode) Reset()

func (*VolumeCapability_AccessMode) String Uses

func (m *VolumeCapability_AccessMode) String() string

func (*VolumeCapability_AccessMode) XXX_DiscardUnknown Uses

func (m *VolumeCapability_AccessMode) XXX_DiscardUnknown()

func (*VolumeCapability_AccessMode) XXX_Marshal Uses

func (m *VolumeCapability_AccessMode) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*VolumeCapability_AccessMode) XXX_Merge Uses

func (m *VolumeCapability_AccessMode) XXX_Merge(src proto.Message)

func (*VolumeCapability_AccessMode) XXX_Size Uses

func (m *VolumeCapability_AccessMode) XXX_Size() int

func (*VolumeCapability_AccessMode) XXX_Unmarshal Uses

func (m *VolumeCapability_AccessMode) XXX_Unmarshal(b []byte) error

type VolumeCapability_AccessMode_Mode Uses

type VolumeCapability_AccessMode_Mode int32
const (
    VolumeCapability_AccessMode_UNKNOWN VolumeCapability_AccessMode_Mode = 0
    // Can only be published once as read/write on a single node, at
    // any given time.
    VolumeCapability_AccessMode_SINGLE_NODE_WRITER VolumeCapability_AccessMode_Mode = 1
    // Can only be published once as readonly on a single node, at
    // any given 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 Uses

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

func (VolumeCapability_AccessMode_Mode) String Uses

func (x VolumeCapability_AccessMode_Mode) String() string

type VolumeCapability_Block Uses

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

type VolumeCapability_BlockVolume Uses

type VolumeCapability_BlockVolume struct {
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

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

func (*VolumeCapability_BlockVolume) Descriptor Uses

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

func (*VolumeCapability_BlockVolume) ProtoMessage Uses

func (*VolumeCapability_BlockVolume) ProtoMessage()

func (*VolumeCapability_BlockVolume) Reset Uses

func (m *VolumeCapability_BlockVolume) Reset()

func (*VolumeCapability_BlockVolume) String Uses

func (m *VolumeCapability_BlockVolume) String() string

func (*VolumeCapability_BlockVolume) XXX_DiscardUnknown Uses

func (m *VolumeCapability_BlockVolume) XXX_DiscardUnknown()

func (*VolumeCapability_BlockVolume) XXX_Marshal Uses

func (m *VolumeCapability_BlockVolume) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*VolumeCapability_BlockVolume) XXX_Merge Uses

func (m *VolumeCapability_BlockVolume) XXX_Merge(src proto.Message)

func (*VolumeCapability_BlockVolume) XXX_Size Uses

func (m *VolumeCapability_BlockVolume) XXX_Size() int

func (*VolumeCapability_BlockVolume) XXX_Unmarshal Uses

func (m *VolumeCapability_BlockVolume) XXX_Unmarshal(b []byte) error

type VolumeCapability_Mount Uses

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

type VolumeCapability_MountVolume Uses

type VolumeCapability_MountVolume struct {
    // The filesystem type. This field is OPTIONAL.
    // An empty string is equal to an unspecified field value.
    FsType string `protobuf:"bytes,1,opt,name=fs_type,json=fsType,proto3" 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. The total size of this repeated field
    // SHALL NOT exceed 4 KiB.
    MountFlags           []string `protobuf:"bytes,2,rep,name=mount_flags,json=mountFlags,proto3" json:"mount_flags,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

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

func (*VolumeCapability_MountVolume) Descriptor Uses

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

func (*VolumeCapability_MountVolume) GetFsType Uses

func (m *VolumeCapability_MountVolume) GetFsType() string

func (*VolumeCapability_MountVolume) GetMountFlags Uses

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

func (*VolumeCapability_MountVolume) ProtoMessage Uses

func (*VolumeCapability_MountVolume) ProtoMessage()

func (*VolumeCapability_MountVolume) Reset Uses

func (m *VolumeCapability_MountVolume) Reset()

func (*VolumeCapability_MountVolume) String Uses

func (m *VolumeCapability_MountVolume) String() string

func (*VolumeCapability_MountVolume) XXX_DiscardUnknown Uses

func (m *VolumeCapability_MountVolume) XXX_DiscardUnknown()

func (*VolumeCapability_MountVolume) XXX_Marshal Uses

func (m *VolumeCapability_MountVolume) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*VolumeCapability_MountVolume) XXX_Merge Uses

func (m *VolumeCapability_MountVolume) XXX_Merge(src proto.Message)

func (*VolumeCapability_MountVolume) XXX_Size Uses

func (m *VolumeCapability_MountVolume) XXX_Size() int

func (*VolumeCapability_MountVolume) XXX_Unmarshal Uses

func (m *VolumeCapability_MountVolume) XXX_Unmarshal(b []byte) error

type VolumeContentSource Uses

type VolumeContentSource struct {
    // Types that are valid to be assigned to Type:
    //	*VolumeContentSource_Snapshot
    //	*VolumeContentSource_Volume
    Type                 isVolumeContentSource_Type `protobuf_oneof:"type"`
    XXX_NoUnkeyedLiteral struct{}                   `json:"-"`
    XXX_unrecognized     []byte                     `json:"-"`
    XXX_sizecache        int32                      `json:"-"`
}

Specifies what source the volume will be created from. One of the type fields MUST be specified.

func (*VolumeContentSource) Descriptor Uses

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

func (*VolumeContentSource) GetSnapshot Uses

func (m *VolumeContentSource) GetSnapshot() *VolumeContentSource_SnapshotSource

func (*VolumeContentSource) GetType Uses

func (m *VolumeContentSource) GetType() isVolumeContentSource_Type

func (*VolumeContentSource) GetVolume Uses

func (m *VolumeContentSource) GetVolume() *VolumeContentSource_VolumeSource

func (*VolumeContentSource) ProtoMessage Uses

func (*VolumeContentSource) ProtoMessage()

func (*VolumeContentSource) Reset Uses

func (m *VolumeContentSource) Reset()

func (*VolumeContentSource) String Uses

func (m *VolumeContentSource) String() string

func (*VolumeContentSource) XXX_DiscardUnknown Uses

func (m *VolumeContentSource) XXX_DiscardUnknown()

func (*VolumeContentSource) XXX_Marshal Uses

func (m *VolumeContentSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*VolumeContentSource) XXX_Merge Uses

func (m *VolumeContentSource) XXX_Merge(src proto.Message)

func (*VolumeContentSource) XXX_OneofWrappers Uses

func (*VolumeContentSource) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*VolumeContentSource) XXX_Size Uses

func (m *VolumeContentSource) XXX_Size() int

func (*VolumeContentSource) XXX_Unmarshal Uses

func (m *VolumeContentSource) XXX_Unmarshal(b []byte) error

type VolumeContentSource_Snapshot Uses

type VolumeContentSource_Snapshot struct {
    Snapshot *VolumeContentSource_SnapshotSource `protobuf:"bytes,1,opt,name=snapshot,proto3,oneof"`
}

type VolumeContentSource_SnapshotSource Uses

type VolumeContentSource_SnapshotSource struct {
    // Contains identity information for the existing source snapshot.
    // This field is REQUIRED. Plugin is REQUIRED to support creating
    // volume from snapshot if it supports the capability
    // CREATE_DELETE_SNAPSHOT.
    SnapshotId           string   `protobuf:"bytes,1,opt,name=snapshot_id,json=snapshotId,proto3" json:"snapshot_id,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*VolumeContentSource_SnapshotSource) Descriptor Uses

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

func (*VolumeContentSource_SnapshotSource) GetSnapshotId Uses

func (m *VolumeContentSource_SnapshotSource) GetSnapshotId() string

func (*VolumeContentSource_SnapshotSource) ProtoMessage Uses

func (*VolumeContentSource_SnapshotSource) ProtoMessage()

func (*VolumeContentSource_SnapshotSource) Reset Uses

func (m *VolumeContentSource_SnapshotSource) Reset()

func (*VolumeContentSource_SnapshotSource) String Uses

func (m *VolumeContentSource_SnapshotSource) String() string

func (*VolumeContentSource_SnapshotSource) XXX_DiscardUnknown Uses

func (m *VolumeContentSource_SnapshotSource) XXX_DiscardUnknown()

func (*VolumeContentSource_SnapshotSource) XXX_Marshal Uses

func (m *VolumeContentSource_SnapshotSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*VolumeContentSource_SnapshotSource) XXX_Merge Uses

func (m *VolumeContentSource_SnapshotSource) XXX_Merge(src proto.Message)

func (*VolumeContentSource_SnapshotSource) XXX_Size Uses

func (m *VolumeContentSource_SnapshotSource) XXX_Size() int

func (*VolumeContentSource_SnapshotSource) XXX_Unmarshal Uses

func (m *VolumeContentSource_SnapshotSource) XXX_Unmarshal(b []byte) error

type VolumeContentSource_Volume Uses

type VolumeContentSource_Volume struct {
    Volume *VolumeContentSource_VolumeSource `protobuf:"bytes,2,opt,name=volume,proto3,oneof"`
}

type VolumeContentSource_VolumeSource Uses

type VolumeContentSource_VolumeSource struct {
    // Contains identity information for the existing source volume.
    // This field is REQUIRED. Plugins reporting CLONE_VOLUME
    // capability MUST support creating a volume from another volume.
    VolumeId             string   `protobuf:"bytes,1,opt,name=volume_id,json=volumeId,proto3" json:"volume_id,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*VolumeContentSource_VolumeSource) Descriptor Uses

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

func (*VolumeContentSource_VolumeSource) GetVolumeId Uses

func (m *VolumeContentSource_VolumeSource) GetVolumeId() string

func (*VolumeContentSource_VolumeSource) ProtoMessage Uses

func (*VolumeContentSource_VolumeSource) ProtoMessage()

func (*VolumeContentSource_VolumeSource) Reset Uses

func (m *VolumeContentSource_VolumeSource) Reset()

func (*VolumeContentSource_VolumeSource) String Uses

func (m *VolumeContentSource_VolumeSource) String() string

func (*VolumeContentSource_VolumeSource) XXX_DiscardUnknown Uses

func (m *VolumeContentSource_VolumeSource) XXX_DiscardUnknown()

func (*VolumeContentSource_VolumeSource) XXX_Marshal Uses

func (m *VolumeContentSource_VolumeSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*VolumeContentSource_VolumeSource) XXX_Merge Uses

func (m *VolumeContentSource_VolumeSource) XXX_Merge(src proto.Message)

func (*VolumeContentSource_VolumeSource) XXX_Size Uses

func (m *VolumeContentSource_VolumeSource) XXX_Size() int

func (*VolumeContentSource_VolumeSource) XXX_Unmarshal Uses

func (m *VolumeContentSource_VolumeSource) XXX_Unmarshal(b []byte) error

type VolumeUsage Uses

type VolumeUsage struct {
    // The available capacity in specified Unit. This field is OPTIONAL.
    // The value of this field MUST NOT be negative.
    Available int64 `protobuf:"varint,1,opt,name=available,proto3" json:"available,omitempty"`
    // The total capacity in specified Unit. This field is REQUIRED.
    // The value of this field MUST NOT be negative.
    Total int64 `protobuf:"varint,2,opt,name=total,proto3" json:"total,omitempty"`
    // The used capacity in specified Unit. This field is OPTIONAL.
    // The value of this field MUST NOT be negative.
    Used int64 `protobuf:"varint,3,opt,name=used,proto3" json:"used,omitempty"`
    // Units by which values are measured. This field is REQUIRED.
    Unit                 VolumeUsage_Unit `protobuf:"varint,4,opt,name=unit,proto3,enum=csi.v1.VolumeUsage_Unit" json:"unit,omitempty"`
    XXX_NoUnkeyedLiteral struct{}         `json:"-"`
    XXX_unrecognized     []byte           `json:"-"`
    XXX_sizecache        int32            `json:"-"`
}

func (*VolumeUsage) Descriptor Uses

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

func (*VolumeUsage) GetAvailable Uses

func (m *VolumeUsage) GetAvailable() int64

func (*VolumeUsage) GetTotal Uses

func (m *VolumeUsage) GetTotal() int64

func (*VolumeUsage) GetUnit Uses

func (m *VolumeUsage) GetUnit() VolumeUsage_Unit

func (*VolumeUsage) GetUsed Uses

func (m *VolumeUsage) GetUsed() int64

func (*VolumeUsage) ProtoMessage Uses

func (*VolumeUsage) ProtoMessage()

func (*VolumeUsage) Reset Uses

func (m *VolumeUsage) Reset()

func (*VolumeUsage) String Uses

func (m *VolumeUsage) String() string

func (*VolumeUsage) XXX_DiscardUnknown Uses

func (m *VolumeUsage) XXX_DiscardUnknown()

func (*VolumeUsage) XXX_Marshal Uses

func (m *VolumeUsage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*VolumeUsage) XXX_Merge Uses

func (m *VolumeUsage) XXX_Merge(src proto.Message)

func (*VolumeUsage) XXX_Size Uses

func (m *VolumeUsage) XXX_Size() int

func (*VolumeUsage) XXX_Unmarshal Uses

func (m *VolumeUsage) XXX_Unmarshal(b []byte) error

type VolumeUsage_Unit Uses

type VolumeUsage_Unit int32
const (
    VolumeUsage_UNKNOWN VolumeUsage_Unit = 0
    VolumeUsage_BYTES   VolumeUsage_Unit = 1
    VolumeUsage_INODES  VolumeUsage_Unit = 2
)

func (VolumeUsage_Unit) EnumDescriptor Uses

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

func (VolumeUsage_Unit) String Uses

func (x VolumeUsage_Unit) String() string

Package csi imports 8 packages (graph) and is imported by 3 packages. Updated 2019-08-12. Refresh now. Tools for package owners.