Documentation ¶
Index ¶
- Variables
- func RegisterNetworkFenceServer(s grpc.ServiceRegistrar, srv NetworkFenceServer)
- func RegisterReclaimSpaceServer(s grpc.ServiceRegistrar, srv ReclaimSpaceServer)
- type NetworkFenceClient
- type NetworkFenceRequest
- func (*NetworkFenceRequest) Descriptor() ([]byte, []int)deprecated
- func (x *NetworkFenceRequest) GetCidrs() []string
- func (x *NetworkFenceRequest) GetParameters() map[string]string
- func (x *NetworkFenceRequest) GetSecretName() string
- func (x *NetworkFenceRequest) GetSecretNamespace() string
- func (*NetworkFenceRequest) ProtoMessage()
- func (x *NetworkFenceRequest) ProtoReflect() protoreflect.Message
- func (x *NetworkFenceRequest) Reset()
- func (x *NetworkFenceRequest) String() string
- type NetworkFenceResponse
- type NetworkFenceServer
- type ReclaimSpaceClient
- type ReclaimSpaceRequest
- func (*ReclaimSpaceRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ReclaimSpaceRequest) GetPvName() string
- func (*ReclaimSpaceRequest) ProtoMessage()
- func (x *ReclaimSpaceRequest) ProtoReflect() protoreflect.Message
- func (x *ReclaimSpaceRequest) Reset()
- func (x *ReclaimSpaceRequest) String() string
- type ReclaimSpaceResponse
- func (*ReclaimSpaceResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ReclaimSpaceResponse) GetPostUsage() *StorageConsumption
- func (x *ReclaimSpaceResponse) GetPreUsage() *StorageConsumption
- func (*ReclaimSpaceResponse) ProtoMessage()
- func (x *ReclaimSpaceResponse) ProtoReflect() protoreflect.Message
- func (x *ReclaimSpaceResponse) Reset()
- func (x *ReclaimSpaceResponse) String() string
- type ReclaimSpaceServer
- type StorageConsumption
- func (*StorageConsumption) Descriptor() ([]byte, []int)deprecated
- func (x *StorageConsumption) GetUsageBytes() int64
- func (*StorageConsumption) ProtoMessage()
- func (x *StorageConsumption) ProtoReflect() protoreflect.Message
- func (x *StorageConsumption) Reset()
- func (x *StorageConsumption) String() string
- type UnimplementedNetworkFenceServer
- type UnimplementedReclaimSpaceServer
- type UnsafeNetworkFenceServer
- type UnsafeReclaimSpaceServer
Constants ¶
This section is empty.
Variables ¶
var File_networkfence_proto protoreflect.FileDescriptor
var File_reclaimspace_proto protoreflect.FileDescriptor
var NetworkFence_ServiceDesc = grpc.ServiceDesc{ ServiceName: "proto.NetworkFence", HandlerType: (*NetworkFenceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "FenceClusterNetwork", Handler: _NetworkFence_FenceClusterNetwork_Handler, }, { MethodName: "UnFenceClusterNetwork", Handler: _NetworkFence_UnFenceClusterNetwork_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "internal/proto/networkfence.proto", }
NetworkFence_ServiceDesc is the grpc.ServiceDesc for NetworkFence service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var ReclaimSpace_ServiceDesc = grpc.ServiceDesc{ ServiceName: "proto.ReclaimSpace", HandlerType: (*ReclaimSpaceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "ControllerReclaimSpace", Handler: _ReclaimSpace_ControllerReclaimSpace_Handler, }, { MethodName: "NodeReclaimSpace", Handler: _ReclaimSpace_NodeReclaimSpace_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "internal/proto/reclaimspace.proto", }
ReclaimSpace_ServiceDesc is the grpc.ServiceDesc for ReclaimSpace service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterNetworkFenceServer ¶
func RegisterNetworkFenceServer(s grpc.ServiceRegistrar, srv NetworkFenceServer)
func RegisterReclaimSpaceServer ¶
func RegisterReclaimSpaceServer(s grpc.ServiceRegistrar, srv ReclaimSpaceServer)
Types ¶
type NetworkFenceClient ¶
type NetworkFenceClient interface { // FenceClusterNetwork RPC call to fence the cluster network. FenceClusterNetwork(ctx context.Context, in *NetworkFenceRequest, opts ...grpc.CallOption) (*NetworkFenceResponse, error) // UnFenceClusterNetwork RPC call to un-fence the cluster network. UnFenceClusterNetwork(ctx context.Context, in *NetworkFenceRequest, opts ...grpc.CallOption) (*NetworkFenceResponse, error) }
NetworkFenceClient is the client API for NetworkFence 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 NewNetworkFenceClient ¶
func NewNetworkFenceClient(cc grpc.ClientConnInterface) NetworkFenceClient
type NetworkFenceRequest ¶
type NetworkFenceRequest struct { // Plugin specific parameters passed in as opaque key-value pairs. Parameters map[string]string `` /* 161-byte string literal not displayed */ // Secrets required by the driver to complete the request. SecretName string `protobuf:"bytes,2,opt,name=secret_name,json=secretName,proto3" json:"secret_name,omitempty"` SecretNamespace string `protobuf:"bytes,3,opt,name=secret_namespace,json=secretNamespace,proto3" json:"secret_namespace,omitempty"` // list of CIDR blocks on which the fencing/unfencing operation is expected // to be performed. Cidrs []string `protobuf:"bytes,4,rep,name=cidrs,proto3" json:"cidrs,omitempty"` // contains filtered or unexported fields }
NetworkFenceRequest holds the required information to fence/unfence the cluster network.
func (*NetworkFenceRequest) Descriptor
deprecated
func (*NetworkFenceRequest) Descriptor() ([]byte, []int)
Deprecated: Use NetworkFenceRequest.ProtoReflect.Descriptor instead.
func (*NetworkFenceRequest) GetCidrs ¶
func (x *NetworkFenceRequest) GetCidrs() []string
func (*NetworkFenceRequest) GetParameters ¶
func (x *NetworkFenceRequest) GetParameters() map[string]string
func (*NetworkFenceRequest) GetSecretName ¶
func (x *NetworkFenceRequest) GetSecretName() string
func (*NetworkFenceRequest) GetSecretNamespace ¶
func (x *NetworkFenceRequest) GetSecretNamespace() string
func (*NetworkFenceRequest) ProtoMessage ¶
func (*NetworkFenceRequest) ProtoMessage()
func (*NetworkFenceRequest) ProtoReflect ¶
func (x *NetworkFenceRequest) ProtoReflect() protoreflect.Message
func (*NetworkFenceRequest) Reset ¶
func (x *NetworkFenceRequest) Reset()
func (*NetworkFenceRequest) String ¶
func (x *NetworkFenceRequest) String() string
type NetworkFenceResponse ¶
type NetworkFenceResponse struct {
// contains filtered or unexported fields
}
NetworkFenceResponse is returned by the CSI-driver as a result of the FenceRequest call.
func (*NetworkFenceResponse) Descriptor
deprecated
func (*NetworkFenceResponse) Descriptor() ([]byte, []int)
Deprecated: Use NetworkFenceResponse.ProtoReflect.Descriptor instead.
func (*NetworkFenceResponse) ProtoMessage ¶
func (*NetworkFenceResponse) ProtoMessage()
func (*NetworkFenceResponse) ProtoReflect ¶
func (x *NetworkFenceResponse) ProtoReflect() protoreflect.Message
func (*NetworkFenceResponse) Reset ¶
func (x *NetworkFenceResponse) Reset()
func (*NetworkFenceResponse) String ¶
func (x *NetworkFenceResponse) String() string
type NetworkFenceServer ¶
type NetworkFenceServer interface { // FenceClusterNetwork RPC call to fence the cluster network. FenceClusterNetwork(context.Context, *NetworkFenceRequest) (*NetworkFenceResponse, error) // UnFenceClusterNetwork RPC call to un-fence the cluster network. UnFenceClusterNetwork(context.Context, *NetworkFenceRequest) (*NetworkFenceResponse, error) // contains filtered or unexported methods }
NetworkFenceServer is the server API for NetworkFence service. All implementations must embed UnimplementedNetworkFenceServer for forward compatibility
type ReclaimSpaceClient ¶
type ReclaimSpaceClient interface { // ControllerReclaimSpace is a procedure that gets called on the CSI // sidecar. ControllerReclaimSpace(ctx context.Context, in *ReclaimSpaceRequest, opts ...grpc.CallOption) (*ReclaimSpaceResponse, error) // NodeReclaimSpace is a procedure that gets called on the CSI // sidecar. NodeReclaimSpace(ctx context.Context, in *ReclaimSpaceRequest, opts ...grpc.CallOption) (*ReclaimSpaceResponse, error) }
ReclaimSpaceClient is the client API for ReclaimSpace 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 NewReclaimSpaceClient ¶
func NewReclaimSpaceClient(cc grpc.ClientConnInterface) ReclaimSpaceClient
type ReclaimSpaceRequest ¶
type ReclaimSpaceRequest struct { // The name of the pv. This field is REQUIRED. PvName string `protobuf:"bytes,1,opt,name=pv_name,json=pvName,proto3" json:"pv_name,omitempty"` // contains filtered or unexported fields }
ReclaimSpaceRequest contains the information i.e., pv_name received from the CSIAddons controller for performing the reclaim operation.
func (*ReclaimSpaceRequest) Descriptor
deprecated
func (*ReclaimSpaceRequest) Descriptor() ([]byte, []int)
Deprecated: Use ReclaimSpaceRequest.ProtoReflect.Descriptor instead.
func (*ReclaimSpaceRequest) GetPvName ¶
func (x *ReclaimSpaceRequest) GetPvName() string
func (*ReclaimSpaceRequest) ProtoMessage ¶
func (*ReclaimSpaceRequest) ProtoMessage()
func (*ReclaimSpaceRequest) ProtoReflect ¶
func (x *ReclaimSpaceRequest) ProtoReflect() protoreflect.Message
func (*ReclaimSpaceRequest) Reset ¶
func (x *ReclaimSpaceRequest) Reset()
func (*ReclaimSpaceRequest) String ¶
func (x *ReclaimSpaceRequest) String() string
type ReclaimSpaceResponse ¶
type ReclaimSpaceResponse struct { // This field is OPTIONAL. This allows the SP to inform the CO about the // storage consumption before the ReclaimSpace operation was executed. PreUsage *StorageConsumption `protobuf:"bytes,1,opt,name=pre_usage,json=preUsage,proto3" json:"pre_usage,omitempty"` // This field is OPTIONAL. This allows the SP to inform the CO about the // storage consumption after the ReclaimSpace operation was executed. PostUsage *StorageConsumption `protobuf:"bytes,2,opt,name=post_usage,json=postUsage,proto3" json:"post_usage,omitempty"` // contains filtered or unexported fields }
ReclaimSpaceResponse holds the information about the result of the ControllerReclaimSpaceRequest/NodeReclaimSpaceRequest call.
func (*ReclaimSpaceResponse) Descriptor
deprecated
func (*ReclaimSpaceResponse) Descriptor() ([]byte, []int)
Deprecated: Use ReclaimSpaceResponse.ProtoReflect.Descriptor instead.
func (*ReclaimSpaceResponse) GetPostUsage ¶
func (x *ReclaimSpaceResponse) GetPostUsage() *StorageConsumption
func (*ReclaimSpaceResponse) GetPreUsage ¶
func (x *ReclaimSpaceResponse) GetPreUsage() *StorageConsumption
func (*ReclaimSpaceResponse) ProtoMessage ¶
func (*ReclaimSpaceResponse) ProtoMessage()
func (*ReclaimSpaceResponse) ProtoReflect ¶
func (x *ReclaimSpaceResponse) ProtoReflect() protoreflect.Message
func (*ReclaimSpaceResponse) Reset ¶
func (x *ReclaimSpaceResponse) Reset()
func (*ReclaimSpaceResponse) String ¶
func (x *ReclaimSpaceResponse) String() string
type ReclaimSpaceServer ¶
type ReclaimSpaceServer interface { // ControllerReclaimSpace is a procedure that gets called on the CSI // sidecar. ControllerReclaimSpace(context.Context, *ReclaimSpaceRequest) (*ReclaimSpaceResponse, error) // NodeReclaimSpace is a procedure that gets called on the CSI // sidecar. NodeReclaimSpace(context.Context, *ReclaimSpaceRequest) (*ReclaimSpaceResponse, error) // contains filtered or unexported methods }
ReclaimSpaceServer is the server API for ReclaimSpace service. All implementations must embed UnimplementedReclaimSpaceServer for forward compatibility
type StorageConsumption ¶
type StorageConsumption struct { // This field is REQUIRED. usage_bytes contains the consumed storage in // bytes. UsageBytes int64 `protobuf:"varint,1,opt,name=usage_bytes,json=usageBytes,proto3" json:"usage_bytes,omitempty"` // contains filtered or unexported fields }
StorageConsumption contains the usage in bytes.
func (*StorageConsumption) Descriptor
deprecated
func (*StorageConsumption) Descriptor() ([]byte, []int)
Deprecated: Use StorageConsumption.ProtoReflect.Descriptor instead.
func (*StorageConsumption) GetUsageBytes ¶
func (x *StorageConsumption) GetUsageBytes() int64
func (*StorageConsumption) ProtoMessage ¶
func (*StorageConsumption) ProtoMessage()
func (*StorageConsumption) ProtoReflect ¶
func (x *StorageConsumption) ProtoReflect() protoreflect.Message
func (*StorageConsumption) Reset ¶
func (x *StorageConsumption) Reset()
func (*StorageConsumption) String ¶
func (x *StorageConsumption) String() string
type UnimplementedNetworkFenceServer ¶
type UnimplementedNetworkFenceServer struct { }
UnimplementedNetworkFenceServer must be embedded to have forward compatible implementations.
func (UnimplementedNetworkFenceServer) FenceClusterNetwork ¶
func (UnimplementedNetworkFenceServer) FenceClusterNetwork(context.Context, *NetworkFenceRequest) (*NetworkFenceResponse, error)
func (UnimplementedNetworkFenceServer) UnFenceClusterNetwork ¶
func (UnimplementedNetworkFenceServer) UnFenceClusterNetwork(context.Context, *NetworkFenceRequest) (*NetworkFenceResponse, error)
type UnimplementedReclaimSpaceServer ¶
type UnimplementedReclaimSpaceServer struct { }
UnimplementedReclaimSpaceServer must be embedded to have forward compatible implementations.
func (UnimplementedReclaimSpaceServer) ControllerReclaimSpace ¶
func (UnimplementedReclaimSpaceServer) ControllerReclaimSpace(context.Context, *ReclaimSpaceRequest) (*ReclaimSpaceResponse, error)
func (UnimplementedReclaimSpaceServer) NodeReclaimSpace ¶
func (UnimplementedReclaimSpaceServer) NodeReclaimSpace(context.Context, *ReclaimSpaceRequest) (*ReclaimSpaceResponse, error)
type UnsafeNetworkFenceServer ¶
type UnsafeNetworkFenceServer interface {
// contains filtered or unexported methods
}
UnsafeNetworkFenceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to NetworkFenceServer will result in compilation errors.
type UnsafeReclaimSpaceServer ¶
type UnsafeReclaimSpaceServer interface {
// contains filtered or unexported methods
}
UnsafeReclaimSpaceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ReclaimSpaceServer will result in compilation errors.