Versions in this module Expand all Collapse all v0 v0.1.1 Apr 11, 2023 Changes in this version + type EncryptionSpec struct + SecretData map[string][]byte + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + func (*EncryptionSpec) Descriptor() ([]byte, []int) + func (*EncryptionSpec) ProtoMessage() + func (m *EncryptionSpec) GetSecretData() map[string][]byte + func (m *EncryptionSpec) Marshal() (dAtA []byte, err error) + func (m *EncryptionSpec) MarshalTo(dAtA []byte) (int, error) + func (m *EncryptionSpec) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *EncryptionSpec) Reset() + func (m *EncryptionSpec) Size() (n int) + func (m *EncryptionSpec) Unmarshal(dAtA []byte) error + func (m *EncryptionSpec) XXX_DiscardUnknown() + func (m *EncryptionSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *EncryptionSpec) XXX_Merge(src proto.Message) + func (m *EncryptionSpec) XXX_Size() int + func (m *EncryptionSpec) XXX_Unmarshal(b []byte) error + func (this *EncryptionSpec) String() string type VolumeSpec + Encryption *EncryptionSpec + func (m *VolumeSpec) GetEncryption() *EncryptionSpec v0.1.0 Mar 27, 2023 Changes in this version + var ErrIntOverflowApi = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthApi = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrUnexpectedEndOfGroupApi = fmt.Errorf("proto: unexpected end of group") + var VolumeState_name = map[int32]string + var VolumeState_value = map[string]int32 + func RegisterVolumeRuntimeServer(s *grpc.Server, srv VolumeRuntimeServer) + type CreateVolumeRequest struct + Volume *Volume + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + func (*CreateVolumeRequest) Descriptor() ([]byte, []int) + func (*CreateVolumeRequest) ProtoMessage() + func (m *CreateVolumeRequest) GetVolume() *Volume + func (m *CreateVolumeRequest) Marshal() (dAtA []byte, err error) + func (m *CreateVolumeRequest) MarshalTo(dAtA []byte) (int, error) + func (m *CreateVolumeRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *CreateVolumeRequest) Reset() + func (m *CreateVolumeRequest) Size() (n int) + func (m *CreateVolumeRequest) Unmarshal(dAtA []byte) error + func (m *CreateVolumeRequest) XXX_DiscardUnknown() + func (m *CreateVolumeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CreateVolumeRequest) XXX_Merge(src proto.Message) + func (m *CreateVolumeRequest) XXX_Size() int + func (m *CreateVolumeRequest) XXX_Unmarshal(b []byte) error + func (this *CreateVolumeRequest) String() string + type CreateVolumeResponse struct + Volume *Volume + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + func (*CreateVolumeResponse) Descriptor() ([]byte, []int) + func (*CreateVolumeResponse) ProtoMessage() + func (m *CreateVolumeResponse) GetVolume() *Volume + func (m *CreateVolumeResponse) Marshal() (dAtA []byte, err error) + func (m *CreateVolumeResponse) MarshalTo(dAtA []byte) (int, error) + func (m *CreateVolumeResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *CreateVolumeResponse) Reset() + func (m *CreateVolumeResponse) Size() (n int) + func (m *CreateVolumeResponse) Unmarshal(dAtA []byte) error + func (m *CreateVolumeResponse) XXX_DiscardUnknown() + func (m *CreateVolumeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CreateVolumeResponse) XXX_Merge(src proto.Message) + func (m *CreateVolumeResponse) XXX_Size() int + func (m *CreateVolumeResponse) XXX_Unmarshal(b []byte) error + func (this *CreateVolumeResponse) String() string + type DeleteVolumeRequest struct + VolumeId string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + func (*DeleteVolumeRequest) Descriptor() ([]byte, []int) + func (*DeleteVolumeRequest) ProtoMessage() + func (m *DeleteVolumeRequest) GetVolumeId() string + func (m *DeleteVolumeRequest) Marshal() (dAtA []byte, err error) + func (m *DeleteVolumeRequest) MarshalTo(dAtA []byte) (int, error) + func (m *DeleteVolumeRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *DeleteVolumeRequest) Reset() + func (m *DeleteVolumeRequest) Size() (n int) + func (m *DeleteVolumeRequest) Unmarshal(dAtA []byte) error + func (m *DeleteVolumeRequest) XXX_DiscardUnknown() + func (m *DeleteVolumeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DeleteVolumeRequest) XXX_Merge(src proto.Message) + func (m *DeleteVolumeRequest) XXX_Size() int + func (m *DeleteVolumeRequest) XXX_Unmarshal(b []byte) error + func (this *DeleteVolumeRequest) String() string + type DeleteVolumeResponse struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + func (*DeleteVolumeResponse) Descriptor() ([]byte, []int) + func (*DeleteVolumeResponse) ProtoMessage() + func (m *DeleteVolumeResponse) Marshal() (dAtA []byte, err error) + func (m *DeleteVolumeResponse) MarshalTo(dAtA []byte) (int, error) + func (m *DeleteVolumeResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *DeleteVolumeResponse) Reset() + func (m *DeleteVolumeResponse) Size() (n int) + func (m *DeleteVolumeResponse) Unmarshal(dAtA []byte) error + func (m *DeleteVolumeResponse) XXX_DiscardUnknown() + func (m *DeleteVolumeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DeleteVolumeResponse) XXX_Merge(src proto.Message) + func (m *DeleteVolumeResponse) XXX_Size() int + func (m *DeleteVolumeResponse) XXX_Unmarshal(b []byte) error + func (this *DeleteVolumeResponse) String() string + type ListVolumeClassesRequest struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + func (*ListVolumeClassesRequest) Descriptor() ([]byte, []int) + func (*ListVolumeClassesRequest) ProtoMessage() + func (m *ListVolumeClassesRequest) Marshal() (dAtA []byte, err error) + func (m *ListVolumeClassesRequest) MarshalTo(dAtA []byte) (int, error) + func (m *ListVolumeClassesRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ListVolumeClassesRequest) Reset() + func (m *ListVolumeClassesRequest) Size() (n int) + func (m *ListVolumeClassesRequest) Unmarshal(dAtA []byte) error + func (m *ListVolumeClassesRequest) XXX_DiscardUnknown() + func (m *ListVolumeClassesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ListVolumeClassesRequest) XXX_Merge(src proto.Message) + func (m *ListVolumeClassesRequest) XXX_Size() int + func (m *ListVolumeClassesRequest) XXX_Unmarshal(b []byte) error + func (this *ListVolumeClassesRequest) String() string + type ListVolumeClassesResponse struct + VolumeClasses []*VolumeClass + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + func (*ListVolumeClassesResponse) Descriptor() ([]byte, []int) + func (*ListVolumeClassesResponse) ProtoMessage() + func (m *ListVolumeClassesResponse) GetVolumeClasses() []*VolumeClass + func (m *ListVolumeClassesResponse) Marshal() (dAtA []byte, err error) + func (m *ListVolumeClassesResponse) MarshalTo(dAtA []byte) (int, error) + func (m *ListVolumeClassesResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ListVolumeClassesResponse) Reset() + func (m *ListVolumeClassesResponse) Size() (n int) + func (m *ListVolumeClassesResponse) Unmarshal(dAtA []byte) error + func (m *ListVolumeClassesResponse) XXX_DiscardUnknown() + func (m *ListVolumeClassesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ListVolumeClassesResponse) XXX_Merge(src proto.Message) + func (m *ListVolumeClassesResponse) XXX_Size() int + func (m *ListVolumeClassesResponse) XXX_Unmarshal(b []byte) error + func (this *ListVolumeClassesResponse) String() string + type ListVolumesRequest struct + Filter *VolumeFilter + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + func (*ListVolumesRequest) Descriptor() ([]byte, []int) + func (*ListVolumesRequest) ProtoMessage() + func (m *ListVolumesRequest) GetFilter() *VolumeFilter + func (m *ListVolumesRequest) Marshal() (dAtA []byte, err error) + func (m *ListVolumesRequest) MarshalTo(dAtA []byte) (int, error) + func (m *ListVolumesRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ListVolumesRequest) Reset() + func (m *ListVolumesRequest) Size() (n int) + func (m *ListVolumesRequest) Unmarshal(dAtA []byte) error + func (m *ListVolumesRequest) XXX_DiscardUnknown() + func (m *ListVolumesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ListVolumesRequest) XXX_Merge(src proto.Message) + func (m *ListVolumesRequest) XXX_Size() int + func (m *ListVolumesRequest) XXX_Unmarshal(b []byte) error + func (this *ListVolumesRequest) String() string + type ListVolumesResponse struct + Volumes []*Volume + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + func (*ListVolumesResponse) Descriptor() ([]byte, []int) + func (*ListVolumesResponse) ProtoMessage() + func (m *ListVolumesResponse) GetVolumes() []*Volume + func (m *ListVolumesResponse) Marshal() (dAtA []byte, err error) + func (m *ListVolumesResponse) MarshalTo(dAtA []byte) (int, error) + func (m *ListVolumesResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ListVolumesResponse) Reset() + func (m *ListVolumesResponse) Size() (n int) + func (m *ListVolumesResponse) Unmarshal(dAtA []byte) error + func (m *ListVolumesResponse) XXX_DiscardUnknown() + func (m *ListVolumesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ListVolumesResponse) XXX_Merge(src proto.Message) + func (m *ListVolumesResponse) XXX_Size() int + func (m *ListVolumesResponse) XXX_Unmarshal(b []byte) error + func (this *ListVolumesResponse) String() string + type UnimplementedVolumeRuntimeServer struct + func (*UnimplementedVolumeRuntimeServer) CreateVolume(ctx context.Context, req *CreateVolumeRequest) (*CreateVolumeResponse, error) + func (*UnimplementedVolumeRuntimeServer) DeleteVolume(ctx context.Context, req *DeleteVolumeRequest) (*DeleteVolumeResponse, error) + func (*UnimplementedVolumeRuntimeServer) ListVolumeClasses(ctx context.Context, req *ListVolumeClassesRequest) (*ListVolumeClassesResponse, error) + func (*UnimplementedVolumeRuntimeServer) ListVolumes(ctx context.Context, req *ListVolumesRequest) (*ListVolumesResponse, error) + type Volume struct + Metadata *v1alpha1.ObjectMetadata + Spec *VolumeSpec + Status *VolumeStatus + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + func (*Volume) Descriptor() ([]byte, []int) + func (*Volume) ProtoMessage() + func (m *Volume) GetMetadata() *v1alpha1.ObjectMetadata + func (m *Volume) GetSpec() *VolumeSpec + func (m *Volume) GetStatus() *VolumeStatus + func (m *Volume) Marshal() (dAtA []byte, err error) + func (m *Volume) MarshalTo(dAtA []byte) (int, error) + func (m *Volume) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Volume) Reset() + func (m *Volume) Size() (n int) + func (m *Volume) Unmarshal(dAtA []byte) error + func (m *Volume) XXX_DiscardUnknown() + func (m *Volume) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Volume) XXX_Merge(src proto.Message) + func (m *Volume) XXX_Size() int + func (m *Volume) XXX_Unmarshal(b []byte) error + func (this *Volume) String() string + type VolumeAccess struct + Attributes map[string]string + Driver string + Handle string + SecretData map[string][]byte + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + func (*VolumeAccess) Descriptor() ([]byte, []int) + func (*VolumeAccess) ProtoMessage() + func (m *VolumeAccess) GetAttributes() map[string]string + func (m *VolumeAccess) GetDriver() string + func (m *VolumeAccess) GetHandle() string + func (m *VolumeAccess) GetSecretData() map[string][]byte + func (m *VolumeAccess) Marshal() (dAtA []byte, err error) + func (m *VolumeAccess) MarshalTo(dAtA []byte) (int, error) + func (m *VolumeAccess) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *VolumeAccess) Reset() + func (m *VolumeAccess) Size() (n int) + func (m *VolumeAccess) Unmarshal(dAtA []byte) error + func (m *VolumeAccess) XXX_DiscardUnknown() + func (m *VolumeAccess) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *VolumeAccess) XXX_Merge(src proto.Message) + func (m *VolumeAccess) XXX_Size() int + func (m *VolumeAccess) XXX_Unmarshal(b []byte) error + func (this *VolumeAccess) String() string + type VolumeClass struct + Capabilities *VolumeClassCapabilities + Name string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + func (*VolumeClass) Descriptor() ([]byte, []int) + func (*VolumeClass) ProtoMessage() + func (m *VolumeClass) GetCapabilities() *VolumeClassCapabilities + func (m *VolumeClass) GetName() string + func (m *VolumeClass) Marshal() (dAtA []byte, err error) + func (m *VolumeClass) MarshalTo(dAtA []byte) (int, error) + func (m *VolumeClass) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *VolumeClass) Reset() + func (m *VolumeClass) Size() (n int) + func (m *VolumeClass) Unmarshal(dAtA []byte) error + func (m *VolumeClass) XXX_DiscardUnknown() + func (m *VolumeClass) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *VolumeClass) XXX_Merge(src proto.Message) + func (m *VolumeClass) XXX_Size() int + func (m *VolumeClass) XXX_Unmarshal(b []byte) error + func (this *VolumeClass) String() string + type VolumeClassCapabilities struct + Iops int64 + Tps int64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + func (*VolumeClassCapabilities) Descriptor() ([]byte, []int) + func (*VolumeClassCapabilities) ProtoMessage() + func (m *VolumeClassCapabilities) GetIops() int64 + func (m *VolumeClassCapabilities) GetTps() int64 + func (m *VolumeClassCapabilities) Marshal() (dAtA []byte, err error) + func (m *VolumeClassCapabilities) MarshalTo(dAtA []byte) (int, error) + func (m *VolumeClassCapabilities) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *VolumeClassCapabilities) Reset() + func (m *VolumeClassCapabilities) Size() (n int) + func (m *VolumeClassCapabilities) Unmarshal(dAtA []byte) error + func (m *VolumeClassCapabilities) XXX_DiscardUnknown() + func (m *VolumeClassCapabilities) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *VolumeClassCapabilities) XXX_Merge(src proto.Message) + func (m *VolumeClassCapabilities) XXX_Size() int + func (m *VolumeClassCapabilities) XXX_Unmarshal(b []byte) error + func (this *VolumeClassCapabilities) String() string + type VolumeFilter struct + Id string + LabelSelector map[string]string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + func (*VolumeFilter) Descriptor() ([]byte, []int) + func (*VolumeFilter) ProtoMessage() + func (m *VolumeFilter) GetId() string + func (m *VolumeFilter) GetLabelSelector() map[string]string + func (m *VolumeFilter) Marshal() (dAtA []byte, err error) + func (m *VolumeFilter) MarshalTo(dAtA []byte) (int, error) + func (m *VolumeFilter) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *VolumeFilter) Reset() + func (m *VolumeFilter) Size() (n int) + func (m *VolumeFilter) Unmarshal(dAtA []byte) error + func (m *VolumeFilter) XXX_DiscardUnknown() + func (m *VolumeFilter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *VolumeFilter) XXX_Merge(src proto.Message) + func (m *VolumeFilter) XXX_Size() int + func (m *VolumeFilter) XXX_Unmarshal(b []byte) error + func (this *VolumeFilter) String() string + type VolumeResources struct + StorageBytes uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + func (*VolumeResources) Descriptor() ([]byte, []int) + func (*VolumeResources) ProtoMessage() + func (m *VolumeResources) GetStorageBytes() uint64 + func (m *VolumeResources) Marshal() (dAtA []byte, err error) + func (m *VolumeResources) MarshalTo(dAtA []byte) (int, error) + func (m *VolumeResources) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *VolumeResources) Reset() + func (m *VolumeResources) Size() (n int) + func (m *VolumeResources) Unmarshal(dAtA []byte) error + func (m *VolumeResources) XXX_DiscardUnknown() + func (m *VolumeResources) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *VolumeResources) XXX_Merge(src proto.Message) + func (m *VolumeResources) XXX_Size() int + func (m *VolumeResources) XXX_Unmarshal(b []byte) error + func (this *VolumeResources) String() string + type VolumeRuntimeClient interface + CreateVolume func(ctx context.Context, in *CreateVolumeRequest, opts ...grpc.CallOption) (*CreateVolumeResponse, error) + DeleteVolume func(ctx context.Context, in *DeleteVolumeRequest, opts ...grpc.CallOption) (*DeleteVolumeResponse, error) + ListVolumeClasses func(ctx context.Context, in *ListVolumeClassesRequest, opts ...grpc.CallOption) (*ListVolumeClassesResponse, error) + ListVolumes func(ctx context.Context, in *ListVolumesRequest, opts ...grpc.CallOption) (*ListVolumesResponse, error) + func NewVolumeRuntimeClient(cc *grpc.ClientConn) VolumeRuntimeClient + type VolumeRuntimeServer interface + CreateVolume func(context.Context, *CreateVolumeRequest) (*CreateVolumeResponse, error) + DeleteVolume func(context.Context, *DeleteVolumeRequest) (*DeleteVolumeResponse, error) + ListVolumeClasses func(context.Context, *ListVolumeClassesRequest) (*ListVolumeClassesResponse, error) + ListVolumes func(context.Context, *ListVolumesRequest) (*ListVolumesResponse, error) + type VolumeSpec struct + Class string + Image string + Resources *VolumeResources + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + func (*VolumeSpec) Descriptor() ([]byte, []int) + func (*VolumeSpec) ProtoMessage() + func (m *VolumeSpec) GetClass() string + func (m *VolumeSpec) GetImage() string + func (m *VolumeSpec) GetResources() *VolumeResources + func (m *VolumeSpec) Marshal() (dAtA []byte, err error) + func (m *VolumeSpec) MarshalTo(dAtA []byte) (int, error) + func (m *VolumeSpec) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *VolumeSpec) Reset() + func (m *VolumeSpec) Size() (n int) + func (m *VolumeSpec) Unmarshal(dAtA []byte) error + func (m *VolumeSpec) XXX_DiscardUnknown() + func (m *VolumeSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *VolumeSpec) XXX_Merge(src proto.Message) + func (m *VolumeSpec) XXX_Size() int + func (m *VolumeSpec) XXX_Unmarshal(b []byte) error + func (this *VolumeSpec) String() string + type VolumeState int32 + const VolumeState_VOLUME_AVAILABLE + const VolumeState_VOLUME_ERROR + const VolumeState_VOLUME_PENDING + func (VolumeState) EnumDescriptor() ([]byte, []int) + func (x VolumeState) String() string + type VolumeStatus struct + Access *VolumeAccess + State VolumeState + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + func (*VolumeStatus) Descriptor() ([]byte, []int) + func (*VolumeStatus) ProtoMessage() + func (m *VolumeStatus) GetAccess() *VolumeAccess + func (m *VolumeStatus) GetState() VolumeState + func (m *VolumeStatus) Marshal() (dAtA []byte, err error) + func (m *VolumeStatus) MarshalTo(dAtA []byte) (int, error) + func (m *VolumeStatus) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *VolumeStatus) Reset() + func (m *VolumeStatus) Size() (n int) + func (m *VolumeStatus) Unmarshal(dAtA []byte) error + func (m *VolumeStatus) XXX_DiscardUnknown() + func (m *VolumeStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *VolumeStatus) XXX_Merge(src proto.Message) + func (m *VolumeStatus) XXX_Size() int + func (m *VolumeStatus) XXX_Unmarshal(b []byte) error + func (this *VolumeStatus) String() string