podmon

package module
v1.4.0 Latest Latest
Warning

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

Go to latest
Published: Feb 26, 2024 License: Apache-2.0 Imports: 8 Imported by: 5

Documentation

Index

Constants

This section is empty.

Variables

View Source
var File_podmon_proto protoreflect.FileDescriptor
View Source
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.

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 (*ValidateVolumeHostConnectivityRequest) GetIoSampleTimeSeconds

func (x *ValidateVolumeHostConnectivityRequest) GetIoSampleTimeSeconds() int32

func (*ValidateVolumeHostConnectivityRequest) GetNodeId

func (*ValidateVolumeHostConnectivityRequest) GetVolumeIds

func (x *ValidateVolumeHostConnectivityRequest) GetVolumeIds() []string

func (*ValidateVolumeHostConnectivityRequest) ProtoMessage

func (*ValidateVolumeHostConnectivityRequest) ProtoMessage()

func (*ValidateVolumeHostConnectivityRequest) ProtoReflect

func (*ValidateVolumeHostConnectivityRequest) Reset

func (*ValidateVolumeHostConnectivityRequest) 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 (*ValidateVolumeHostConnectivityResponse) ProtoMessage

func (*ValidateVolumeHostConnectivityResponse) ProtoReflect

func (*ValidateVolumeHostConnectivityResponse) Reset

func (*ValidateVolumeHostConnectivityResponse) String

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL