staticvolume

package
v0.2.4 Latest Latest
Warning

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

 Go to latest Published: Aug 19, 2023 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var Controller_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "staticvolume.Controller",
	HandlerType: (*ControllerServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateVolume",
			Handler:    _Controller_CreateVolume_Handler,
		},
		{
			MethodName: "DeleteVolume",
			Handler:    _Controller_DeleteVolume_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "staticvolume/staticvolume.proto",
}

Controller_ServiceDesc is the grpc.ServiceDesc for Controller service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var File_staticvolume_staticvolume_proto protoreflect.FileDescriptor

Functions

func RegisterControllerServer 

func RegisterControllerServer(s grpc.ServiceRegistrar, srv ControllerServer)

Types

type CapacityRange 

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"`
	// contains filtered or unexported fields
}

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 deprecated 

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

Deprecated: Use CapacityRange.ProtoReflect.Descriptor instead.

func (*CapacityRange) GetLimitBytes 

func (x *CapacityRange) GetLimitBytes() int64

func (*CapacityRange) GetRequiredBytes 

func (x *CapacityRange) GetRequiredBytes() int64

func (*CapacityRange) ProtoMessage 

func (*CapacityRange) ProtoMessage()

func (*CapacityRange) ProtoReflect 

func (x *CapacityRange) ProtoReflect() protoreflect.Message

func (*CapacityRange) Reset 

func (x *CapacityRange) Reset()

func (*CapacityRange) String 

func (x *CapacityRange) String() string

type ControllerClient 

type ControllerClient interface {
	CreateVolume(ctx context.Context, in *CreateVolumeRequest, opts ...grpc.CallOption) (*CreateVolumeResponse, error)
	DeleteVolume(ctx context.Context, in *DeleteVolumeRequest, opts ...grpc.CallOption) (*DeleteVolumeResponse, error)
}

ControllerClient is the client API for Controller service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewControllerClient 

func NewControllerClient(cc grpc.ClientConnInterface) ControllerClient

type ControllerServer 

type ControllerServer interface {
	CreateVolume(context.Context, *CreateVolumeRequest) (*CreateVolumeResponse, error)
	DeleteVolume(context.Context, *DeleteVolumeRequest) (*DeleteVolumeResponse, error)
	// contains filtered or unexported methods
}

ControllerServer is the server API for Controller service. All implementations must embed UnimplementedControllerServer for forward compatibility

type CreateVolumeRequest 

type CreateVolumeRequest struct {
	Name          string            `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	CapacityRange *CapacityRange    `protobuf:"bytes,2,opt,name=capacity_range,json=capacityRange,proto3" json:"capacity_range,omitempty"`
	Parameters    map[string]string `` /* 161-byte string literal not displayed */
	Secrets       map[string]string `` /* 155-byte string literal not displayed */
	Pv            *PV               `protobuf:"bytes,5,opt,name=pv,proto3" json:"pv,omitempty"`
	Pvc           *PVC              `protobuf:"bytes,6,opt,name=pvc,proto3" json:"pvc,omitempty"`
	Sc            *SC               `protobuf:"bytes,7,opt,name=sc,proto3" json:"sc,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateVolumeRequest) Descriptor deprecated 

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

Deprecated: Use CreateVolumeRequest.ProtoReflect.Descriptor instead.

func (*CreateVolumeRequest) GetCapacityRange 

func (x *CreateVolumeRequest) GetCapacityRange() *CapacityRange

func (*CreateVolumeRequest) GetName 

func (x *CreateVolumeRequest) GetName() string

func (*CreateVolumeRequest) GetParameters 

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

func (*CreateVolumeRequest) GetPv added in v0.2.3 

func (x *CreateVolumeRequest) GetPv() *PV

func (*CreateVolumeRequest) GetPvc added in v0.2.3 

func (x *CreateVolumeRequest) GetPvc() *PVC

func (*CreateVolumeRequest) GetSc added in v0.2.3 

func (x *CreateVolumeRequest) GetSc() *SC

func (*CreateVolumeRequest) GetSecrets 

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

func (*CreateVolumeRequest) ProtoMessage 

func (*CreateVolumeRequest) ProtoMessage()

func (*CreateVolumeRequest) ProtoReflect 

func (x *CreateVolumeRequest) ProtoReflect() protoreflect.Message

func (*CreateVolumeRequest) Reset 

func (x *CreateVolumeRequest) Reset()

func (*CreateVolumeRequest) String 

func (x *CreateVolumeRequest) String() string

type CreateVolumeResponse 

type CreateVolumeResponse struct {
	VolumeId string `protobuf:"bytes,1,opt,name=volume_id,json=volumeId,proto3" json:"volume_id,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateVolumeResponse) Descriptor deprecated 

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

Deprecated: Use CreateVolumeResponse.ProtoReflect.Descriptor instead.

func (*CreateVolumeResponse) GetVolumeId 

func (x *CreateVolumeResponse) GetVolumeId() string

func (*CreateVolumeResponse) ProtoMessage 

func (*CreateVolumeResponse) ProtoMessage()

func (*CreateVolumeResponse) ProtoReflect 

func (x *CreateVolumeResponse) ProtoReflect() protoreflect.Message

func (*CreateVolumeResponse) Reset 

func (x *CreateVolumeResponse) Reset()

func (*CreateVolumeResponse) String 

func (x *CreateVolumeResponse) String() string

type DeleteVolumeRequest 

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 `` /* 155-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*DeleteVolumeRequest) Descriptor deprecated 

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

Deprecated: Use DeleteVolumeRequest.ProtoReflect.Descriptor instead.

func (*DeleteVolumeRequest) GetSecrets 

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

func (*DeleteVolumeRequest) GetVolumeId 

func (x *DeleteVolumeRequest) GetVolumeId() string

func (*DeleteVolumeRequest) ProtoMessage 

func (*DeleteVolumeRequest) ProtoMessage()

func (*DeleteVolumeRequest) ProtoReflect 

func (x *DeleteVolumeRequest) ProtoReflect() protoreflect.Message

func (*DeleteVolumeRequest) Reset 

func (x *DeleteVolumeRequest) Reset()

func (*DeleteVolumeRequest) String 

func (x *DeleteVolumeRequest) String() string

type DeleteVolumeResponse 

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

func (*DeleteVolumeResponse) Descriptor deprecated 

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

Deprecated: Use DeleteVolumeResponse.ProtoReflect.Descriptor instead.

func (*DeleteVolumeResponse) ProtoMessage 

func (*DeleteVolumeResponse) ProtoMessage()

func (*DeleteVolumeResponse) ProtoReflect 

func (x *DeleteVolumeResponse) ProtoReflect() protoreflect.Message

func (*DeleteVolumeResponse) Reset 

func (x *DeleteVolumeResponse) Reset()

func (*DeleteVolumeResponse) String 

func (x *DeleteVolumeResponse) String() string

type PV added in v0.2.3 

type PV struct {
	Name             string                           `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Namespace        string                           `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	VolumeHandle     string                           `protobuf:"bytes,3,opt,name=volume_handle,json=volumeHandle,proto3" json:"volume_handle,omitempty"`
	CapacityRange    *CapacityRange                   `protobuf:"bytes,4,opt,name=capacity_range,json=capacityRange,proto3" json:"capacity_range,omitempty"`
	VolumeAttributes map[string]string                `` /* 197-byte string literal not displayed */
	AccessMode       *csi.VolumeCapability_AccessMode `protobuf:"bytes,6,opt,name=access_mode,json=accessMode,proto3" json:"access_mode,omitempty"`
	ReclaimPolicy    *anypb.Any                       `protobuf:"bytes,7,opt,name=reclaim_policy,json=reclaimPolicy,proto3" json:"reclaim_policy,omitempty"`
	// contains filtered or unexported fields
}

func (*PV) Descriptor deprecated added in v0.2.3 

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

Deprecated: Use PV.ProtoReflect.Descriptor instead.

func (*PV) GetAccessMode added in v0.2.3 

func (x *PV) GetAccessMode() *csi.VolumeCapability_AccessMode

func (*PV) GetCapacityRange added in v0.2.4 

func (x *PV) GetCapacityRange() *CapacityRange

func (*PV) GetName added in v0.2.3 

func (x *PV) GetName() string

func (*PV) GetNamespace added in v0.2.3 

func (x *PV) GetNamespace() string

func (*PV) GetReclaimPolicy added in v0.2.3 

func (x *PV) GetReclaimPolicy() *anypb.Any

func (*PV) GetVolumeAttributes added in v0.2.3 

func (x *PV) GetVolumeAttributes() map[string]string

func (*PV) GetVolumeHandle added in v0.2.3 

func (x *PV) GetVolumeHandle() string

func (*PV) ProtoMessage added in v0.2.3 

func (*PV) ProtoMessage()

func (*PV) ProtoReflect added in v0.2.3 

func (x *PV) ProtoReflect() protoreflect.Message

func (*PV) Reset added in v0.2.3 

func (x *PV) Reset()

func (*PV) String added in v0.2.3 

func (x *PV) String() string

type PVC added in v0.2.3 

type PVC struct {
	Name          string                           `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Namespace     string                           `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	CapacityRange *CapacityRange                   `protobuf:"bytes,3,opt,name=capacity_range,json=capacityRange,proto3" json:"capacity_range,omitempty"`
	AccessMode    *csi.VolumeCapability_AccessMode `protobuf:"bytes,4,opt,name=access_mode,json=accessMode,proto3" json:"access_mode,omitempty"`
	ReadOnly      bool                             `protobuf:"varint,5,opt,name=read_only,json=readOnly,proto3" json:"read_only,omitempty"`
	// contains filtered or unexported fields
}

func (*PVC) Descriptor deprecated added in v0.2.3 

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

Deprecated: Use PVC.ProtoReflect.Descriptor instead.

func (*PVC) GetAccessMode added in v0.2.3 

func (x *PVC) GetAccessMode() *csi.VolumeCapability_AccessMode

func (*PVC) GetCapacityRange added in v0.2.4 

func (x *PVC) GetCapacityRange() *CapacityRange

func (*PVC) GetName added in v0.2.3 

func (x *PVC) GetName() string

func (*PVC) GetNamespace added in v0.2.3 

func (x *PVC) GetNamespace() string

func (*PVC) GetReadOnly added in v0.2.3 

func (x *PVC) GetReadOnly() bool

func (*PVC) ProtoMessage added in v0.2.3 

func (*PVC) ProtoMessage()

func (*PVC) ProtoReflect added in v0.2.3 

func (x *PVC) ProtoReflect() protoreflect.Message

func (*PVC) Reset added in v0.2.3 

func (x *PVC) Reset()

func (*PVC) String added in v0.2.3 

func (x *PVC) String() string

type SC added in v0.2.3 

type SC struct {
	Name       string            `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Namespace  string            `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	DriverName string            `protobuf:"bytes,3,opt,name=driver_name,json=driverName,proto3" json:"driver_name,omitempty"`
	ClusterId  string            `protobuf:"bytes,4,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	Parameters map[string]string `` /* 161-byte string literal not displayed */
	Secret     map[string]string `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*SC) Descriptor deprecated added in v0.2.3 

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

Deprecated: Use SC.ProtoReflect.Descriptor instead.

func (*SC) GetClusterId added in v0.2.3 

func (x *SC) GetClusterId() string

func (*SC) GetDriverName added in v0.2.3 

func (x *SC) GetDriverName() string

func (*SC) GetName added in v0.2.3 

func (x *SC) GetName() string

func (*SC) GetNamespace added in v0.2.3 

func (x *SC) GetNamespace() string

func (*SC) GetParameters added in v0.2.3 

func (x *SC) GetParameters() map[string]string

func (*SC) GetSecret added in v0.2.3 

func (x *SC) GetSecret() map[string]string

func (*SC) ProtoMessage added in v0.2.3 

func (*SC) ProtoMessage()

func (*SC) ProtoReflect added in v0.2.3 

func (x *SC) ProtoReflect() protoreflect.Message

func (*SC) Reset added in v0.2.3 

func (x *SC) Reset()

func (*SC) String added in v0.2.3 

func (x *SC) String() string

type UnimplementedControllerServer 

type UnimplementedControllerServer struct {
}

UnimplementedControllerServer must be embedded to have forward compatible implementations.

func (UnimplementedControllerServer) CreateVolume 

func (UnimplementedControllerServer) CreateVolume(context.Context, *CreateVolumeRequest) (*CreateVolumeResponse, error)

func (UnimplementedControllerServer) DeleteVolume 

func (UnimplementedControllerServer) DeleteVolume(context.Context, *DeleteVolumeRequest) (*DeleteVolumeResponse, error)

type UnsafeControllerServer 

type UnsafeControllerServer interface {
	// contains filtered or unexported methods
}

UnsafeControllerServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ControllerServer will result in compilation errors.

Source Files

View all Source files

Jump to

Keyboard shortcuts

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