Documentation ¶
Index ¶
- Variables
- func RegisterPodmonServer(s grpc.ServiceRegistrar, srv PodmonServer)
- type PodmonClient
- type PodmonServer
- type UnimplementedPodmonServer
- type UnsafePodmonServer
- type ValidateVolumeHostConnectivityRequest
- func (*ValidateVolumeHostConnectivityRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ValidateVolumeHostConnectivityRequest) GetArrayId() string
- func (x *ValidateVolumeHostConnectivityRequest) GetIoSampleTimeSeconds() int32
- func (x *ValidateVolumeHostConnectivityRequest) GetNodeId() string
- func (x *ValidateVolumeHostConnectivityRequest) GetVolumeIds() []string
- func (*ValidateVolumeHostConnectivityRequest) ProtoMessage()
- func (x *ValidateVolumeHostConnectivityRequest) ProtoReflect() protoreflect.Message
- func (x *ValidateVolumeHostConnectivityRequest) Reset()
- func (x *ValidateVolumeHostConnectivityRequest) String() string
- type ValidateVolumeHostConnectivityResponse
- func (*ValidateVolumeHostConnectivityResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ValidateVolumeHostConnectivityResponse) GetConnected() bool
- func (x *ValidateVolumeHostConnectivityResponse) GetIosInProgress() bool
- func (x *ValidateVolumeHostConnectivityResponse) GetMessages() []string
- func (*ValidateVolumeHostConnectivityResponse) ProtoMessage()
- func (x *ValidateVolumeHostConnectivityResponse) ProtoReflect() protoreflect.Message
- func (x *ValidateVolumeHostConnectivityResponse) Reset()
- func (x *ValidateVolumeHostConnectivityResponse) String() string
Constants ¶
This section is empty.
Variables ¶
var File_podmon_proto protoreflect.FileDescriptor
var Podmon_ServiceDesc = grpc.ServiceDesc{ ServiceName: "podmon.v1.Podmon", HandlerType: (*PodmonServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "ValidateVolumeHostConnectivity", Handler: _Podmon_ValidateVolumeHostConnectivity_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "podmon.proto", }
Podmon_ServiceDesc is the grpc.ServiceDesc for Podmon service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterPodmonServer ¶
func RegisterPodmonServer(s grpc.ServiceRegistrar, srv PodmonServer)
Types ¶
type PodmonClient ¶
type PodmonClient interface { // ValidateVolumeHostconnectivity validates host connectivity for one or more volumes, by // either or both of two methds: // 1. Verifying the link status of the host, returned in the connected. // 2. Verifying if any I/O activity has been observerd in the recent past, returned in ios_in_progress. ValidateVolumeHostConnectivity(ctx context.Context, in *ValidateVolumeHostConnectivityRequest, opts ...grpc.CallOption) (*ValidateVolumeHostConnectivityResponse, error) }
PodmonClient is the client API for Podmon 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 NewPodmonClient ¶
func NewPodmonClient(cc grpc.ClientConnInterface) PodmonClient
type PodmonServer ¶
type PodmonServer interface { // ValidateVolumeHostconnectivity validates host connectivity for one or more volumes, by // either or both of two methds: // 1. Verifying the link status of the host, returned in the connected. // 2. Verifying if any I/O activity has been observerd in the recent past, returned in ios_in_progress. ValidateVolumeHostConnectivity(context.Context, *ValidateVolumeHostConnectivityRequest) (*ValidateVolumeHostConnectivityResponse, error) }
PodmonServer is the server API for Podmon service. All implementations should embed UnimplementedPodmonServer for forward compatibility
type UnimplementedPodmonServer ¶
type UnimplementedPodmonServer struct { }
UnimplementedPodmonServer should be embedded to have forward compatible implementations.
func (UnimplementedPodmonServer) ValidateVolumeHostConnectivity ¶
func (UnimplementedPodmonServer) ValidateVolumeHostConnectivity(context.Context, *ValidateVolumeHostConnectivityRequest) (*ValidateVolumeHostConnectivityResponse, error)
type UnsafePodmonServer ¶ added in v1.0.0
type UnsafePodmonServer interface {
// contains filtered or unexported methods
}
UnsafePodmonServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to PodmonServer will result in compilation errors.
type ValidateVolumeHostConnectivityRequest ¶
type ValidateVolumeHostConnectivityRequest struct { // The IDs of the volumes that are used on the specified node. // This field is REQUIRED. VolumeIds []string `protobuf:"bytes,1,rep,name=volume_ids,json=volumeIds,proto3" json:"volume_ids,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"` // The array ID used to query connectivity to the node. // All the volume_ids if specified should blong to this array id. ArrayId string `protobuf:"bytes,4,opt,name=array_id,json=arrayId,proto3" json:"array_id,omitempty"` // The length of time in seconds to sample for I/O activity IoSampleTimeSeconds int32 `protobuf:"varint,3,opt,name=io_sample_time_seconds,json=ioSampleTimeSeconds,proto3" json:"io_sample_time_seconds,omitempty"` // contains filtered or unexported fields }
func (*ValidateVolumeHostConnectivityRequest) Descriptor
deprecated
func (*ValidateVolumeHostConnectivityRequest) Descriptor() ([]byte, []int)
Deprecated: Use ValidateVolumeHostConnectivityRequest.ProtoReflect.Descriptor instead.
func (*ValidateVolumeHostConnectivityRequest) GetArrayId ¶
func (x *ValidateVolumeHostConnectivityRequest) GetArrayId() string
func (*ValidateVolumeHostConnectivityRequest) GetIoSampleTimeSeconds ¶
func (x *ValidateVolumeHostConnectivityRequest) GetIoSampleTimeSeconds() int32
func (*ValidateVolumeHostConnectivityRequest) GetNodeId ¶
func (x *ValidateVolumeHostConnectivityRequest) GetNodeId() string
func (*ValidateVolumeHostConnectivityRequest) GetVolumeIds ¶
func (x *ValidateVolumeHostConnectivityRequest) GetVolumeIds() []string
func (*ValidateVolumeHostConnectivityRequest) ProtoMessage ¶
func (*ValidateVolumeHostConnectivityRequest) ProtoMessage()
func (*ValidateVolumeHostConnectivityRequest) ProtoReflect ¶
func (x *ValidateVolumeHostConnectivityRequest) ProtoReflect() protoreflect.Message
func (*ValidateVolumeHostConnectivityRequest) Reset ¶
func (x *ValidateVolumeHostConnectivityRequest) Reset()
func (*ValidateVolumeHostConnectivityRequest) String ¶
func (x *ValidateVolumeHostConnectivityRequest) String() string
type ValidateVolumeHostConnectivityResponse ¶
type ValidateVolumeHostConnectivityResponse struct { // The host is currently connected. Connected bool `protobuf:"varint,1,opt,name=connected,proto3" json:"connected,omitempty"` // I/Os have been overserved recently. IosInProgress bool `protobuf:"varint,2,opt,name=ios_in_progress,json=iosInProgress,proto3" json:"ios_in_progress,omitempty"` // General status messages. Messages []string `protobuf:"bytes,3,rep,name=messages,proto3" json:"messages,omitempty"` // contains filtered or unexported fields }
func (*ValidateVolumeHostConnectivityResponse) Descriptor
deprecated
func (*ValidateVolumeHostConnectivityResponse) Descriptor() ([]byte, []int)
Deprecated: Use ValidateVolumeHostConnectivityResponse.ProtoReflect.Descriptor instead.
func (*ValidateVolumeHostConnectivityResponse) GetConnected ¶
func (x *ValidateVolumeHostConnectivityResponse) GetConnected() bool
func (*ValidateVolumeHostConnectivityResponse) GetIosInProgress ¶
func (x *ValidateVolumeHostConnectivityResponse) GetIosInProgress() bool
func (*ValidateVolumeHostConnectivityResponse) GetMessages ¶
func (x *ValidateVolumeHostConnectivityResponse) GetMessages() []string
func (*ValidateVolumeHostConnectivityResponse) ProtoMessage ¶
func (*ValidateVolumeHostConnectivityResponse) ProtoMessage()
func (*ValidateVolumeHostConnectivityResponse) ProtoReflect ¶
func (x *ValidateVolumeHostConnectivityResponse) ProtoReflect() protoreflect.Message
func (*ValidateVolumeHostConnectivityResponse) Reset ¶
func (x *ValidateVolumeHostConnectivityResponse) Reset()
func (*ValidateVolumeHostConnectivityResponse) String ¶
func (x *ValidateVolumeHostConnectivityResponse) String() string