v1

package
v0.0.0-...-9913de7 Latest Latest
Warning

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

 Go to latest Published: Dec 13, 2024 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	BdevRpc_Create_FullMethodName  = "/mayastor.v1.BdevRpc/Create"
	BdevRpc_Destroy_FullMethodName = "/mayastor.v1.BdevRpc/Destroy"
	BdevRpc_List_FullMethodName    = "/mayastor.v1.BdevRpc/List"
	BdevRpc_Share_FullMethodName   = "/mayastor.v1.BdevRpc/Share"
	BdevRpc_Unshare_FullMethodName = "/mayastor.v1.BdevRpc/Unshare"
)
View Source 
const (
	HostRpc_GetMayastorInfo_FullMethodName          = "/mayastor.v1.HostRpc/GetMayastorInfo"
	HostRpc_ListBlockDevices_FullMethodName         = "/mayastor.v1.HostRpc/ListBlockDevices"
	HostRpc_GetMayastorResourceUsage_FullMethodName = "/mayastor.v1.HostRpc/GetMayastorResourceUsage"
	HostRpc_ListNvmeControllers_FullMethodName      = "/mayastor.v1.HostRpc/ListNvmeControllers"
	HostRpc_StatNvmeController_FullMethodName       = "/mayastor.v1.HostRpc/StatNvmeController"
)
View Source 
const (
	Registration_Register_FullMethodName   = "/mayastor.v1.Registration/Register"
	Registration_Deregister_FullMethodName = "/mayastor.v1.Registration/Deregister"
)
View Source 
const (
	JsonRpc_JsonRpcCall_FullMethodName = "/mayastor.v1.JsonRpc/JsonRpcCall"
)

Variables

View Source 
var (
	ShareProtocol_name = map[int32]string{
		0: "NONE",
		1: "NVMF",
		2: "ISCSI",
	}
	ShareProtocol_value = map[string]int32{
		"NONE":  0,
		"NVMF":  1,
		"ISCSI": 2,
	}
)

Enum value maps for ShareProtocol.

View Source 
var (
	NvmeControllerState_name = map[int32]string{
		0: "NEW",
		1: "INITIALIZING",
		2: "RUNNING",
		3: "FAULTED",
		4: "UNCONFIGURING",
		5: "UNCONFIGURED",
	}
	NvmeControllerState_value = map[string]int32{
		"NEW":           0,
		"INITIALIZING":  1,
		"RUNNING":       2,
		"FAULTED":       3,
		"UNCONFIGURING": 4,
		"UNCONFIGURED":  5,
	}
)

Enum value maps for NvmeControllerState.

View Source 
var (
	NexusNvmePreemption_name = map[int32]string{
		0: "ArgKey",
		1: "Holder",
	}
	NexusNvmePreemption_value = map[string]int32{
		"ArgKey": 0,
		"Holder": 1,
	}
)

Enum value maps for NexusNvmePreemption.

View Source 
var (
	NvmeReservation_name = map[int32]string{
		0: "Reserved",
		1: "WriteExclusive",
		2: "ExclusiveAccess",
		3: "WriteExclusiveRegsOnly",
		4: "ExclusiveAccessRegsOnly",
		5: "WriteExclusiveAllRegs",
		6: "ExclusiveAccessAllRegs",
	}
	NvmeReservation_value = map[string]int32{
		"Reserved":                0,
		"WriteExclusive":          1,
		"ExclusiveAccess":         2,
		"WriteExclusiveRegsOnly":  3,
		"ExclusiveAccessRegsOnly": 4,
		"WriteExclusiveAllRegs":   5,
		"ExclusiveAccessAllRegs":  6,
	}
)

Enum value maps for NvmeReservation.

View Source 
var (
	ChildState_name = map[int32]string{
		0: "CHILD_STATE_UNKNOWN",
		1: "CHILD_STATE_ONLINE",
		2: "CHILD_STATE_DEGRADED",
		3: "CHILD_STATE_FAULTED",
	}
	ChildState_value = map[string]int32{
		"CHILD_STATE_UNKNOWN":  0,
		"CHILD_STATE_ONLINE":   1,
		"CHILD_STATE_DEGRADED": 2,
		"CHILD_STATE_FAULTED":  3,
	}
)

Enum value maps for ChildState.

View Source 
var (
	ChildStateReason_name = map[int32]string{
		0:  "CHILD_STATE_REASON_NONE",
		1:  "CHILD_STATE_REASON_INIT",
		2:  "CHILD_STATE_REASON_CLOSED",
		3:  "CHILD_STATE_REASON_CANNOT_OPEN",
		4:  "CHILD_STATE_REASON_CONFIG_INVALID",
		5:  "CHILD_STATE_REASON_REBUILD_FAILED",
		6:  "CHILD_STATE_REASON_IO_FAILURE",
		7:  "CHILD_STATE_REASON_BY_CLIENT",
		8:  "CHILD_STATE_REASON_OUT_OF_SYNC",
		9:  "CHILD_STATE_REASON_NO_SPACE",
		10: "CHILD_STATE_REASON_TIMED_OUT",
		11: "CHILD_STATE_REASON_ADMIN_FAILED",
	}
	ChildStateReason_value = map[string]int32{
		"CHILD_STATE_REASON_NONE":           0,
		"CHILD_STATE_REASON_INIT":           1,
		"CHILD_STATE_REASON_CLOSED":         2,
		"CHILD_STATE_REASON_CANNOT_OPEN":    3,
		"CHILD_STATE_REASON_CONFIG_INVALID": 4,
		"CHILD_STATE_REASON_REBUILD_FAILED": 5,
		"CHILD_STATE_REASON_IO_FAILURE":     6,
		"CHILD_STATE_REASON_BY_CLIENT":      7,
		"CHILD_STATE_REASON_OUT_OF_SYNC":    8,
		"CHILD_STATE_REASON_NO_SPACE":       9,
		"CHILD_STATE_REASON_TIMED_OUT":      10,
		"CHILD_STATE_REASON_ADMIN_FAILED":   11,
	}
)

Enum value maps for ChildStateReason.

View Source 
var (
	NexusState_name = map[int32]string{
		0: "NEXUS_UNKNOWN",
		1: "NEXUS_ONLINE",
		2: "NEXUS_DEGRADED",
		3: "NEXUS_FAULTED",
		4: "NEXUS_SHUTTING_DOWN",
		5: "NEXUS_SHUTDOWN",
	}
	NexusState_value = map[string]int32{
		"NEXUS_UNKNOWN":       0,
		"NEXUS_ONLINE":        1,
		"NEXUS_DEGRADED":      2,
		"NEXUS_FAULTED":       3,
		"NEXUS_SHUTTING_DOWN": 4,
		"NEXUS_SHUTDOWN":      5,
	}
)

Enum value maps for NexusState.

View Source 
var (
	NvmeAnaState_name = map[int32]string{
		0:  "NVME_ANA_INVALID_STATE",
		1:  "NVME_ANA_OPTIMIZED_STATE",
		2:  "NVME_ANA_NON_OPTIMIZED_STATE",
		3:  "NVME_ANA_INACCESSIBLE_STATE",
		4:  "NVME_ANA_PERSISTENT_LOSS_STATE",
		15: "NVME_ANA_CHANGE_STATE",
	}
	NvmeAnaState_value = map[string]int32{
		"NVME_ANA_INVALID_STATE":         0,
		"NVME_ANA_OPTIMIZED_STATE":       1,
		"NVME_ANA_NON_OPTIMIZED_STATE":   2,
		"NVME_ANA_INACCESSIBLE_STATE":    3,
		"NVME_ANA_PERSISTENT_LOSS_STATE": 4,
		"NVME_ANA_CHANGE_STATE":          15,
	}
)

Enum value maps for NvmeAnaState.

View Source 
var (
	ChildAction_name = map[int32]string{
		0: "Offline",
		1: "Online",
		2: "FaultIOError",
		3: "OfflinePermanent",
	}
	ChildAction_value = map[string]int32{
		"Offline":          0,
		"Online":           1,
		"FaultIOError":     2,
		"OfflinePermanent": 3,
	}
)

Enum value maps for ChildAction.

View Source 
var (
	RebuildJobState_name = map[int32]string{
		0: "Init",
		1: "Rebuilding",
		2: "Stopped",
		3: "Paused",
		4: "Failed",
		5: "Completed",
	}
	RebuildJobState_value = map[string]int32{
		"Init":       0,
		"Rebuilding": 1,
		"Stopped":    2,
		"Paused":     3,
		"Failed":     4,
		"Completed":  5,
	}
)

Enum value maps for RebuildJobState.

View Source 
var (
	PoolType_name = map[int32]string{
		0: "Lvs",
	}
	PoolType_value = map[string]int32{
		"Lvs": 0,
	}
)

Enum value maps for PoolType.

View Source 
var (
	PoolState_name = map[int32]string{
		0: "POOL_UNKNOWN",
		1: "POOL_ONLINE",
		2: "POOL_DEGRADED",
		3: "POOL_FAULTED",
	}
	PoolState_value = map[string]int32{
		"POOL_UNKNOWN":  0,
		"POOL_ONLINE":   1,
		"POOL_DEGRADED": 2,
		"POOL_FAULTED":  3,
	}
)

Enum value maps for PoolState.

View Source 
var (
	APIVersion_name = map[int32]string{
		0: "V0",
		1: "V1",
	}
	APIVersion_value = map[string]int32{
		"V0": 0,
		"V1": 1,
	}
)

Enum value maps for APIVersion.

View Source 
var (
	WipeOptions_WipeMethod_name = map[int32]string{
		0: "NONE",
		1: "WRITE_ZEROES",
		2: "UNMAP",
		3: "WRITE_PATTERN",
		4: "CHECKSUM",
	}
	WipeOptions_WipeMethod_value = map[string]int32{
		"NONE":          0,
		"WRITE_ZEROES":  1,
		"UNMAP":         2,
		"WRITE_PATTERN": 3,
		"CHECKSUM":      4,
	}
)

Enum value maps for WipeOptions_WipeMethod.

View Source 
var (
	WipeOptions_CheckSumAlgorithm_name = map[int32]string{
		0: "Crc32c",
	}
	WipeOptions_CheckSumAlgorithm_value = map[string]int32{
		"Crc32c": 0,
	}
)

Enum value maps for WipeOptions_CheckSumAlgorithm.

View Source 
var BdevRpc_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "mayastor.v1.BdevRpc",
	HandlerType: (*BdevRpcServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Create",
			Handler:    _BdevRpc_Create_Handler,
		},
		{
			MethodName: "Destroy",
			Handler:    _BdevRpc_Destroy_Handler,
		},
		{
			MethodName: "List",
			Handler:    _BdevRpc_List_Handler,
		},
		{
			MethodName: "Share",
			Handler:    _BdevRpc_Share_Handler,
		},
		{
			MethodName: "Unshare",
			Handler:    _BdevRpc_Unshare_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "bdev.proto",
}

BdevRpc_ServiceDesc is the grpc.ServiceDesc for BdevRpc 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_bdev_proto protoreflect.FileDescriptor
View Source 
var File_common_proto protoreflect.FileDescriptor
View Source 
var File_host_proto protoreflect.FileDescriptor
View Source 
var File_json_proto protoreflect.FileDescriptor
View Source 
var File_nexus_proto protoreflect.FileDescriptor
View Source 
var File_pool_proto protoreflect.FileDescriptor
View Source 
var File_registration_proto protoreflect.FileDescriptor
View Source 
var File_replica_proto protoreflect.FileDescriptor
View Source 
var File_snapshot_proto protoreflect.FileDescriptor
View Source 
var File_stats_proto protoreflect.FileDescriptor
View Source 
var File_test_proto protoreflect.FileDescriptor
View Source 
var HostRpc_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "mayastor.v1.HostRpc",
	HandlerType: (*HostRpcServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetMayastorInfo",
			Handler:    _HostRpc_GetMayastorInfo_Handler,
		},
		{
			MethodName: "ListBlockDevices",
			Handler:    _HostRpc_ListBlockDevices_Handler,
		},
		{
			MethodName: "GetMayastorResourceUsage",
			Handler:    _HostRpc_GetMayastorResourceUsage_Handler,
		},
		{
			MethodName: "ListNvmeControllers",
			Handler:    _HostRpc_ListNvmeControllers_Handler,
		},
		{
			MethodName: "StatNvmeController",
			Handler:    _HostRpc_StatNvmeController_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "host.proto",
}

HostRpc_ServiceDesc is the grpc.ServiceDesc for HostRpc 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 JsonRpc_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "mayastor.v1.JsonRpc",
	HandlerType: (*JsonRpcServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "JsonRpcCall",
			Handler:    _JsonRpc_JsonRpcCall_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "json.proto",
}

JsonRpc_ServiceDesc is the grpc.ServiceDesc for JsonRpc 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 NexusRpc_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "mayastor.v1.NexusRpc",
	HandlerType: (*NexusRpcServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateNexus",
			Handler:    _NexusRpc_CreateNexus_Handler,
		},
		{
			MethodName: "DestroyNexus",
			Handler:    _NexusRpc_DestroyNexus_Handler,
		},
		{
			MethodName: "ListNexus",
			Handler:    _NexusRpc_ListNexus_Handler,
		},
		{
			MethodName: "AddChildNexus",
			Handler:    _NexusRpc_AddChildNexus_Handler,
		},
		{
			MethodName: "RemoveChildNexus",
			Handler:    _NexusRpc_RemoveChildNexus_Handler,
		},
		{
			MethodName: "FaultNexusChild",
			Handler:    _NexusRpc_FaultNexusChild_Handler,
		},
		{
			MethodName: "ShutdownNexus",
			Handler:    _NexusRpc_ShutdownNexus_Handler,
		},
		{
			MethodName: "PublishNexus",
			Handler:    _NexusRpc_PublishNexus_Handler,
		},
		{
			MethodName: "UnpublishNexus",
			Handler:    _NexusRpc_UnpublishNexus_Handler,
		},
		{
			MethodName: "GetNvmeAnaState",
			Handler:    _NexusRpc_GetNvmeAnaState_Handler,
		},
		{
			MethodName: "SetNvmeAnaState",
			Handler:    _NexusRpc_SetNvmeAnaState_Handler,
		},
		{
			MethodName: "ChildOperation",
			Handler:    _NexusRpc_ChildOperation_Handler,
		},
		{
			MethodName: "StartRebuild",
			Handler:    _NexusRpc_StartRebuild_Handler,
		},
		{
			MethodName: "StopRebuild",
			Handler:    _NexusRpc_StopRebuild_Handler,
		},
		{
			MethodName: "PauseRebuild",
			Handler:    _NexusRpc_PauseRebuild_Handler,
		},
		{
			MethodName: "ResumeRebuild",
			Handler:    _NexusRpc_ResumeRebuild_Handler,
		},
		{
			MethodName: "GetRebuildState",
			Handler:    _NexusRpc_GetRebuildState_Handler,
		},
		{
			MethodName: "GetRebuildStats",
			Handler:    _NexusRpc_GetRebuildStats_Handler,
		},
		{
			MethodName: "GetRebuildHistory",
			Handler:    _NexusRpc_GetRebuildHistory_Handler,
		},
		{
			MethodName: "ListRebuildHistory",
			Handler:    _NexusRpc_ListRebuildHistory_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "nexus.proto",
}

NexusRpc_ServiceDesc is the grpc.ServiceDesc for NexusRpc 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 PoolRpc_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "mayastor.v1.PoolRpc",
	HandlerType: (*PoolRpcServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreatePool",
			Handler:    _PoolRpc_CreatePool_Handler,
		},
		{
			MethodName: "DestroyPool",
			Handler:    _PoolRpc_DestroyPool_Handler,
		},
		{
			MethodName: "ExportPool",
			Handler:    _PoolRpc_ExportPool_Handler,
		},
		{
			MethodName: "ImportPool",
			Handler:    _PoolRpc_ImportPool_Handler,
		},
		{
			MethodName: "ListPools",
			Handler:    _PoolRpc_ListPools_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "pool.proto",
}

PoolRpc_ServiceDesc is the grpc.ServiceDesc for PoolRpc 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 Registration_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "mayastor.v1.Registration",
	HandlerType: (*RegistrationServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Register",
			Handler:    _Registration_Register_Handler,
		},
		{
			MethodName: "Deregister",
			Handler:    _Registration_Deregister_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "registration.proto",
}

Registration_ServiceDesc is the grpc.ServiceDesc for Registration 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 ReplicaRpc_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "mayastor.v1.ReplicaRpc",
	HandlerType: (*ReplicaRpcServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateReplica",
			Handler:    _ReplicaRpc_CreateReplica_Handler,
		},
		{
			MethodName: "DestroyReplica",
			Handler:    _ReplicaRpc_DestroyReplica_Handler,
		},
		{
			MethodName: "ListReplicas",
			Handler:    _ReplicaRpc_ListReplicas_Handler,
		},
		{
			MethodName: "ShareReplica",
			Handler:    _ReplicaRpc_ShareReplica_Handler,
		},
		{
			MethodName: "UnshareReplica",
			Handler:    _ReplicaRpc_UnshareReplica_Handler,
		},
		{
			MethodName: "ResizeReplica",
			Handler:    _ReplicaRpc_ResizeReplica_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "replica.proto",
}

ReplicaRpc_ServiceDesc is the grpc.ServiceDesc for ReplicaRpc 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 SnapshotRpc_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "mayastor.v1.SnapshotRpc",
	HandlerType: (*SnapshotRpcServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateReplicaSnapshot",
			Handler:    _SnapshotRpc_CreateReplicaSnapshot_Handler,
		},
		{
			MethodName: "CreateNexusSnapshot",
			Handler:    _SnapshotRpc_CreateNexusSnapshot_Handler,
		},
		{
			MethodName: "ListSnapshot",
			Handler:    _SnapshotRpc_ListSnapshot_Handler,
		},
		{
			MethodName: "DestroySnapshot",
			Handler:    _SnapshotRpc_DestroySnapshot_Handler,
		},
		{
			MethodName: "CreateSnapshotClone",
			Handler:    _SnapshotRpc_CreateSnapshotClone_Handler,
		},
		{
			MethodName: "ListSnapshotClone",
			Handler:    _SnapshotRpc_ListSnapshotClone_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "snapshot.proto",
}

SnapshotRpc_ServiceDesc is the grpc.ServiceDesc for SnapshotRpc 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 StatsRpc_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "mayastor.v1.StatsRpc",
	HandlerType: (*StatsRpcServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetPoolIoStats",
			Handler:    _StatsRpc_GetPoolIoStats_Handler,
		},
		{
			MethodName: "ResetIoStats",
			Handler:    _StatsRpc_ResetIoStats_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "stats.proto",
}

StatsRpc_ServiceDesc is the grpc.ServiceDesc for StatsRpc 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 TestRpc_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "mayastor.v1.TestRpc",
	HandlerType: (*TestRpcServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetFeatures",
			Handler:    _TestRpc_GetFeatures_Handler,
		},
		{
			MethodName: "AddFaultInjection",
			Handler:    _TestRpc_AddFaultInjection_Handler,
		},
		{
			MethodName: "RemoveFaultInjection",
			Handler:    _TestRpc_RemoveFaultInjection_Handler,
		},
		{
			MethodName: "ListFaultInjections",
			Handler:    _TestRpc_ListFaultInjections_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "WipeReplica",
			Handler:       _TestRpc_WipeReplica_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "test.proto",
}

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

Functions

func RegisterBdevRpcServer 

func RegisterBdevRpcServer(s grpc.ServiceRegistrar, srv BdevRpcServer)

func RegisterHostRpcServer 

func RegisterHostRpcServer(s grpc.ServiceRegistrar, srv HostRpcServer)

func RegisterJsonRpcServer 

func RegisterJsonRpcServer(s grpc.ServiceRegistrar, srv JsonRpcServer)

func RegisterNexusRpcServer 

func RegisterNexusRpcServer(s grpc.ServiceRegistrar, srv NexusRpcServer)

func RegisterPoolRpcServer 

func RegisterPoolRpcServer(s grpc.ServiceRegistrar, srv PoolRpcServer)

func RegisterRegistrationServer 

func RegisterRegistrationServer(s grpc.ServiceRegistrar, srv RegistrationServer)

func RegisterReplicaRpcServer 

func RegisterReplicaRpcServer(s grpc.ServiceRegistrar, srv ReplicaRpcServer)

func RegisterSnapshotRpcServer 

func RegisterSnapshotRpcServer(s grpc.ServiceRegistrar, srv SnapshotRpcServer)

func RegisterStatsRpcServer 

func RegisterStatsRpcServer(s grpc.ServiceRegistrar, srv StatsRpcServer)

func RegisterTestRpcServer 

func RegisterTestRpcServer(s grpc.ServiceRegistrar, srv TestRpcServer)

Types

type APIVersion 

type APIVersion int32

api version supported by the dataplane 

const (
	APIVersion_V0 APIVersion = 0
	APIVersion_V1 APIVersion = 1
)

func (APIVersion) Descriptor 

func (APIVersion) Descriptor() protoreflect.EnumDescriptor

func (APIVersion) Enum 

func (x APIVersion) Enum() *APIVersion

func (APIVersion) EnumDescriptor deprecated 

func (APIVersion) EnumDescriptor() ([]byte, []int)

Deprecated: Use APIVersion.Descriptor instead.

func (APIVersion) Number 

func (x APIVersion) Number() protoreflect.EnumNumber

func (APIVersion) String 

func (x APIVersion) String() string

func (APIVersion) Type 

func (APIVersion) Type() protoreflect.EnumType

type AddChildNexusRequest 

type AddChildNexusRequest struct {
	Uuid      string `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`            // uuid of the nexus
	Uri       string `protobuf:"bytes,2,opt,name=uri,proto3" json:"uri,omitempty"`              // URI of the child device to be added
	Norebuild bool   `protobuf:"varint,3,opt,name=norebuild,proto3" json:"norebuild,omitempty"` // auto start rebuilding
	// contains filtered or unexported fields
}

func (*AddChildNexusRequest) Descriptor deprecated 

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

Deprecated: Use AddChildNexusRequest.ProtoReflect.Descriptor instead.

func (*AddChildNexusRequest) GetNorebuild 

func (x *AddChildNexusRequest) GetNorebuild() bool

func (*AddChildNexusRequest) GetUri 

func (x *AddChildNexusRequest) GetUri() string

func (*AddChildNexusRequest) GetUuid 

func (x *AddChildNexusRequest) GetUuid() string

func (*AddChildNexusRequest) ProtoMessage 

func (*AddChildNexusRequest) ProtoMessage()

func (*AddChildNexusRequest) ProtoReflect 

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

func (*AddChildNexusRequest) Reset 

func (x *AddChildNexusRequest) Reset()

func (*AddChildNexusRequest) String 

func (x *AddChildNexusRequest) String() string

type AddChildNexusResponse 

type AddChildNexusResponse struct {
	Nexus *Nexus `protobuf:"bytes,1,opt,name=nexus,proto3" json:"nexus,omitempty"`
	// contains filtered or unexported fields
}

func (*AddChildNexusResponse) Descriptor deprecated 

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

Deprecated: Use AddChildNexusResponse.ProtoReflect.Descriptor instead.

func (*AddChildNexusResponse) GetNexus 

func (x *AddChildNexusResponse) GetNexus() *Nexus

func (*AddChildNexusResponse) ProtoMessage 

func (*AddChildNexusResponse) ProtoMessage()

func (*AddChildNexusResponse) ProtoReflect 

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

func (*AddChildNexusResponse) Reset 

func (x *AddChildNexusResponse) Reset()

func (*AddChildNexusResponse) String 

func (x *AddChildNexusResponse) String() string

type AddFaultInjectionRequest 

type AddFaultInjectionRequest struct {

	// URI that defines injection target and parameters.
	Uri string `protobuf:"bytes,1,opt,name=uri,proto3" json:"uri,omitempty"`
	// contains filtered or unexported fields
}

func (*AddFaultInjectionRequest) Descriptor deprecated 

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

Deprecated: Use AddFaultInjectionRequest.ProtoReflect.Descriptor instead.

func (*AddFaultInjectionRequest) GetUri 

func (x *AddFaultInjectionRequest) GetUri() string

func (*AddFaultInjectionRequest) ProtoMessage 

func (*AddFaultInjectionRequest) ProtoMessage()

func (*AddFaultInjectionRequest) ProtoReflect 

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

func (*AddFaultInjectionRequest) Reset 

func (x *AddFaultInjectionRequest) Reset()

func (*AddFaultInjectionRequest) String 

func (x *AddFaultInjectionRequest) String() string

type Bdev 

type Bdev struct {

	// name of the bdev
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// the UUID which may or may not persist across restarts
	Uuid string `protobuf:"bytes,2,opt,name=uuid,proto3" json:"uuid,omitempty"`
	// the number of blocks
	NumBlocks uint64 `protobuf:"varint,3,opt,name=num_blocks,json=numBlocks,proto3" json:"num_blocks,omitempty"`
	// the size of each block
	BlkSize uint32 `protobuf:"varint,5,opt,name=blk_size,json=blkSize,proto3" json:"blk_size,omitempty"`
	// if the device is used by some other subsystem
	Claimed bool `protobuf:"varint,6,opt,name=claimed,proto3" json:"claimed,omitempty"`
	// the subsystem who uses the device
	ClaimedBy string `protobuf:"bytes,7,opt,name=claimed_by,json=claimedBy,proto3" json:"claimed_by,omitempty"`
	// any aliases the device uses
	Aliases string `protobuf:"bytes,8,opt,name=aliases,proto3" json:"aliases,omitempty"`
	// the URI the device was created from
	Uri string `protobuf:"bytes,9,opt,name=uri,proto3" json:"uri,omitempty"`
	// the product name of the device
	ProductName string `protobuf:"bytes,10,opt,name=product_name,json=productName,proto3" json:"product_name,omitempty"`
	// the URI on which the device is exported
	ShareUri string `protobuf:"bytes,11,opt,name=share_uri,json=shareUri,proto3" json:"share_uri,omitempty"`
	// contains filtered or unexported fields
}

func (*Bdev) Descriptor deprecated 

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

Deprecated: Use Bdev.ProtoReflect.Descriptor instead.

func (*Bdev) GetAliases 

func (x *Bdev) GetAliases() string

func (*Bdev) GetBlkSize 

func (x *Bdev) GetBlkSize() uint32

func (*Bdev) GetClaimed 

func (x *Bdev) GetClaimed() bool

func (*Bdev) GetClaimedBy 

func (x *Bdev) GetClaimedBy() string

func (*Bdev) GetName 

func (x *Bdev) GetName() string

func (*Bdev) GetNumBlocks 

func (x *Bdev) GetNumBlocks() uint64

func (*Bdev) GetProductName 

func (x *Bdev) GetProductName() string

func (*Bdev) GetShareUri 

func (x *Bdev) GetShareUri() string

func (*Bdev) GetUri 

func (x *Bdev) GetUri() string

func (*Bdev) GetUuid 

func (x *Bdev) GetUuid() string

func (*Bdev) ProtoMessage 

func (*Bdev) ProtoMessage()

func (*Bdev) ProtoReflect 

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

func (*Bdev) Reset 

func (x *Bdev) Reset()

func (*Bdev) String 

func (x *Bdev) String() string

type BdevRpcClient 

type BdevRpcClient interface {
	// create a new block device using a uri scheme
	Create(ctx context.Context, in *CreateBdevRequest, opts ...grpc.CallOption) (*CreateBdevResponse, error)
	// destroys the block device
	Destroy(ctx context.Context, in *DestroyBdevRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// list the block devices
	List(ctx context.Context, in *ListBdevOptions, opts ...grpc.CallOption) (*ListBdevResponse, error)
	// share the block device
	Share(ctx context.Context, in *BdevShareRequest, opts ...grpc.CallOption) (*BdevShareResponse, error)
	// unshare the block device
	Unshare(ctx context.Context, in *BdevUnshareRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

BdevRpcClient is the client API for BdevRpc 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 NewBdevRpcClient 

func NewBdevRpcClient(cc grpc.ClientConnInterface) BdevRpcClient

type BdevRpcServer 

type BdevRpcServer interface {
	// create a new block device using a uri scheme
	Create(context.Context, *CreateBdevRequest) (*CreateBdevResponse, error)
	// destroys the block device
	Destroy(context.Context, *DestroyBdevRequest) (*emptypb.Empty, error)
	// list the block devices
	List(context.Context, *ListBdevOptions) (*ListBdevResponse, error)
	// share the block device
	Share(context.Context, *BdevShareRequest) (*BdevShareResponse, error)
	// unshare the block device
	Unshare(context.Context, *BdevUnshareRequest) (*emptypb.Empty, error)
	// contains filtered or unexported methods
}

BdevRpcServer is the server API for BdevRpc service. All implementations must embed UnimplementedBdevRpcServer for forward compatibility

type BdevShareRequest 

type BdevShareRequest struct {

	// name of the bdev to share
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// the protocol to use
	Protocol     ShareProtocol `protobuf:"varint,2,opt,name=protocol,proto3,enum=mayastor.v1.ShareProtocol" json:"protocol,omitempty"`
	AllowedHosts []string      `protobuf:"bytes,3,rep,name=allowed_hosts,json=allowedHosts,proto3" json:"allowed_hosts,omitempty"` // host (nqn's) which are allowed to connect to the target.
	// contains filtered or unexported fields
}

func (*BdevShareRequest) Descriptor deprecated 

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

Deprecated: Use BdevShareRequest.ProtoReflect.Descriptor instead.

func (*BdevShareRequest) GetAllowedHosts 

func (x *BdevShareRequest) GetAllowedHosts() []string

func (*BdevShareRequest) GetName 

func (x *BdevShareRequest) GetName() string

func (*BdevShareRequest) GetProtocol 

func (x *BdevShareRequest) GetProtocol() ShareProtocol

func (*BdevShareRequest) ProtoMessage 

func (*BdevShareRequest) ProtoMessage()

func (*BdevShareRequest) ProtoReflect 

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

func (*BdevShareRequest) Reset 

func (x *BdevShareRequest) Reset()

func (*BdevShareRequest) String 

func (x *BdevShareRequest) String() string

type BdevShareResponse 

type BdevShareResponse struct {
	Bdev *Bdev `protobuf:"bytes,1,opt,name=bdev,proto3" json:"bdev,omitempty"`
	// contains filtered or unexported fields
}

func (*BdevShareResponse) Descriptor deprecated 

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

Deprecated: Use BdevShareResponse.ProtoReflect.Descriptor instead.

func (*BdevShareResponse) GetBdev 

func (x *BdevShareResponse) GetBdev() *Bdev

func (*BdevShareResponse) ProtoMessage 

func (*BdevShareResponse) ProtoMessage()

func (*BdevShareResponse) ProtoReflect 

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

func (*BdevShareResponse) Reset 

func (x *BdevShareResponse) Reset()

func (*BdevShareResponse) String 

func (x *BdevShareResponse) String() string

type BdevUnshareRequest 

type BdevUnshareRequest struct {

	// name of the bdev to unshare
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*BdevUnshareRequest) Descriptor deprecated 

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

Deprecated: Use BdevUnshareRequest.ProtoReflect.Descriptor instead.

func (*BdevUnshareRequest) GetName 

func (x *BdevUnshareRequest) GetName() string

func (*BdevUnshareRequest) ProtoMessage 

func (*BdevUnshareRequest) ProtoMessage()

func (*BdevUnshareRequest) ProtoReflect 

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

func (*BdevUnshareRequest) Reset 

func (x *BdevUnshareRequest) Reset()

func (*BdevUnshareRequest) String 

func (x *BdevUnshareRequest) String() string

type BlockDevice 

type BlockDevice struct {
	Devname    string                  `protobuf:"bytes,1,opt,name=devname,proto3" json:"devname,omitempty"`        // entry in /dev associated with device
	Devtype    string                  `protobuf:"bytes,2,opt,name=devtype,proto3" json:"devtype,omitempty"`        // currently "disk" or "partition"
	Devmajor   uint32                  `protobuf:"varint,3,opt,name=devmajor,proto3" json:"devmajor,omitempty"`     // major device number
	Devminor   uint32                  `protobuf:"varint,4,opt,name=devminor,proto3" json:"devminor,omitempty"`     // minor device number
	Model      string                  `protobuf:"bytes,5,opt,name=model,proto3" json:"model,omitempty"`            // device model - useful for identifying mayastor devices
	Devpath    string                  `protobuf:"bytes,6,opt,name=devpath,proto3" json:"devpath,omitempty"`        // official device path
	Devlinks   []string                `protobuf:"bytes,7,rep,name=devlinks,proto3" json:"devlinks,omitempty"`      // list of udev generated symlinks by which device may be identified
	Size       uint64                  `protobuf:"varint,8,opt,name=size,proto3" json:"size,omitempty"`             // size of device in (512 byte) blocks
	Partition  *BlockDevice_Partition  `protobuf:"bytes,9,opt,name=partition,proto3" json:"partition,omitempty"`    // partition information in case where device represents a partition
	Filesystem *BlockDevice_Filesystem `protobuf:"bytes,10,opt,name=filesystem,proto3" json:"filesystem,omitempty"` // filesystem information in case where a filesystem is present
	Available  bool                    `protobuf:"varint,11,opt,name=available,proto3" json:"available,omitempty"`  // identifies if device is available for use (ie. is not "currently" in use)
	// contains filtered or unexported fields
}

func (*BlockDevice) Descriptor deprecated 

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

Deprecated: Use BlockDevice.ProtoReflect.Descriptor instead.

func (*BlockDevice) GetAvailable 

func (x *BlockDevice) GetAvailable() bool
func (x *BlockDevice) GetDevlinks() []string

func (*BlockDevice) GetDevmajor 

func (x *BlockDevice) GetDevmajor() uint32

func (*BlockDevice) GetDevminor 

func (x *BlockDevice) GetDevminor() uint32

func (*BlockDevice) GetDevname 

func (x *BlockDevice) GetDevname() string

func (*BlockDevice) GetDevpath 

func (x *BlockDevice) GetDevpath() string

func (*BlockDevice) GetDevtype 

func (x *BlockDevice) GetDevtype() string

func (*BlockDevice) GetFilesystem 

func (x *BlockDevice) GetFilesystem() *BlockDevice_Filesystem

func (*BlockDevice) GetModel 

func (x *BlockDevice) GetModel() string

func (*BlockDevice) GetPartition 

func (x *BlockDevice) GetPartition() *BlockDevice_Partition

func (*BlockDevice) GetSize 

func (x *BlockDevice) GetSize() uint64

func (*BlockDevice) ProtoMessage 

func (*BlockDevice) ProtoMessage()

func (*BlockDevice) ProtoReflect 

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

func (*BlockDevice) Reset 

func (x *BlockDevice) Reset()

func (*BlockDevice) String 

func (x *BlockDevice) String() string

type BlockDevice_Filesystem 

type BlockDevice_Filesystem struct {
	Fstype      string   `protobuf:"bytes,1,opt,name=fstype,proto3" json:"fstype,omitempty"`           // filesystem type: ext3, ntfs, ...
	Label       string   `protobuf:"bytes,2,opt,name=label,proto3" json:"label,omitempty"`             // volume label
	Uuid        string   `protobuf:"bytes,3,opt,name=uuid,proto3" json:"uuid,omitempty"`               // UUID identifying the volume (filesystem)
	Mountpoints []string `protobuf:"bytes,4,rep,name=mountpoints,proto3" json:"mountpoints,omitempty"` // paths where filesystem is currently mounted
	// contains filtered or unexported fields
}

func (*BlockDevice_Filesystem) Descriptor deprecated 

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

Deprecated: Use BlockDevice_Filesystem.ProtoReflect.Descriptor instead.

func (*BlockDevice_Filesystem) GetFstype 

func (x *BlockDevice_Filesystem) GetFstype() string

func (*BlockDevice_Filesystem) GetLabel 

func (x *BlockDevice_Filesystem) GetLabel() string

func (*BlockDevice_Filesystem) GetMountpoints 

func (x *BlockDevice_Filesystem) GetMountpoints() []string

func (*BlockDevice_Filesystem) GetUuid 

func (x *BlockDevice_Filesystem) GetUuid() string

func (*BlockDevice_Filesystem) ProtoMessage 

func (*BlockDevice_Filesystem) ProtoMessage()

func (*BlockDevice_Filesystem) ProtoReflect 

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

func (*BlockDevice_Filesystem) Reset 

func (x *BlockDevice_Filesystem) Reset()

func (*BlockDevice_Filesystem) String 

func (x *BlockDevice_Filesystem) String() string

type BlockDevice_Partition 

type BlockDevice_Partition struct {
	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`  // devname of parent device to which this partition belongs
	Number uint32 `protobuf:"varint,2,opt,name=number,proto3" json:"number,omitempty"` // partition number
	Name   string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`      // partition name
	Scheme string `protobuf:"bytes,4,opt,name=scheme,proto3" json:"scheme,omitempty"`  // partition scheme: gpt, dos, ...
	Typeid string `protobuf:"bytes,5,opt,name=typeid,proto3" json:"typeid,omitempty"`  // partition type identifier
	Uuid   string `protobuf:"bytes,6,opt,name=uuid,proto3" json:"uuid,omitempty"`      // UUID identifying partition
	// contains filtered or unexported fields
}

func (*BlockDevice_Partition) Descriptor deprecated 

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

Deprecated: Use BlockDevice_Partition.ProtoReflect.Descriptor instead.

func (*BlockDevice_Partition) GetName 

func (x *BlockDevice_Partition) GetName() string

func (*BlockDevice_Partition) GetNumber 

func (x *BlockDevice_Partition) GetNumber() uint32

func (*BlockDevice_Partition) GetParent 

func (x *BlockDevice_Partition) GetParent() string

func (*BlockDevice_Partition) GetScheme 

func (x *BlockDevice_Partition) GetScheme() string

func (*BlockDevice_Partition) GetTypeid 

func (x *BlockDevice_Partition) GetTypeid() string

func (*BlockDevice_Partition) GetUuid 

func (x *BlockDevice_Partition) GetUuid() string

func (*BlockDevice_Partition) ProtoMessage 

func (*BlockDevice_Partition) ProtoMessage()

func (*BlockDevice_Partition) ProtoReflect 

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

func (*BlockDevice_Partition) Reset 

func (x *BlockDevice_Partition) Reset()

func (*BlockDevice_Partition) String 

func (x *BlockDevice_Partition) String() string

type Child 

type Child struct {
	Uri         string           `protobuf:"bytes,1,opt,name=uri,proto3" json:"uri,omitempty"`                                  // uri of the child device
	State       ChildState       `protobuf:"varint,2,opt,name=state,proto3,enum=mayastor.v1.ChildState" json:"state,omitempty"` // state of the child
	StateReason ChildStateReason ``                                                                                             // child state reason
	/* 129-byte string literal not displayed */
	RebuildProgress int32                  `protobuf:"varint,4,opt,name=rebuild_progress,json=rebuildProgress,proto3" json:"rebuild_progress,omitempty"` // rebuild progress
	DeviceName      *string                `protobuf:"bytes,5,opt,name=device_name,json=deviceName,proto3,oneof" json:"device_name,omitempty"`           // child device name
	FaultTimestamp  *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=fault_timestamp,json=faultTimestamp,proto3" json:"fault_timestamp,omitempty"`     // timestamp(UTC) when child went faulted
	HasIoLog        bool                   `protobuf:"varint,7,opt,name=has_io_log,json=hasIoLog,proto3" json:"has_io_log,omitempty"`                    // true if the child has an active I/O log
	// contains filtered or unexported fields
}

represents a child device part of a nexus

func (*Child) Descriptor deprecated 

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

Deprecated: Use Child.ProtoReflect.Descriptor instead.

func (*Child) GetDeviceName 

func (x *Child) GetDeviceName() string

func (*Child) GetFaultTimestamp 

func (x *Child) GetFaultTimestamp() *timestamppb.Timestamp

func (*Child) GetHasIoLog 

func (x *Child) GetHasIoLog() bool

func (*Child) GetRebuildProgress 

func (x *Child) GetRebuildProgress() int32

func (*Child) GetState 

func (x *Child) GetState() ChildState

func (*Child) GetStateReason 

func (x *Child) GetStateReason() ChildStateReason

func (*Child) GetUri 

func (x *Child) GetUri() string

func (*Child) ProtoMessage 

func (*Child) ProtoMessage()

func (*Child) ProtoReflect 

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

func (*Child) Reset 

func (x *Child) Reset()

func (*Child) String 

func (x *Child) String() string

type ChildAction 

type ChildAction int32
const (
	ChildAction_Offline          ChildAction = 0 // take a child offline, e.g. for maintenance
	ChildAction_Online           ChildAction = 1 // bring a child online which was previously offlined or faulted
	ChildAction_FaultIOError     ChildAction = 2 // fault a child with an I/O error (e.g. for testing/debug purposes)
	ChildAction_OfflinePermanent ChildAction = 3 // take a child offline permanently; exactly the same a legacy FaultNexusChild method
)

func (ChildAction) Descriptor 

func (ChildAction) Descriptor() protoreflect.EnumDescriptor

func (ChildAction) Enum 

func (x ChildAction) Enum() *ChildAction

func (ChildAction) EnumDescriptor deprecated 

func (ChildAction) EnumDescriptor() ([]byte, []int)

Deprecated: Use ChildAction.Descriptor instead.

func (ChildAction) Number 

func (x ChildAction) Number() protoreflect.EnumNumber

func (ChildAction) String 

func (x ChildAction) String() string

func (ChildAction) Type 

func (ChildAction) Type() protoreflect.EnumType

type ChildOperationRequest 

type ChildOperationRequest struct {
	NexusUuid string      `protobuf:"bytes,1,opt,name=nexus_uuid,json=nexusUuid,proto3" json:"nexus_uuid,omitempty"` // uuid of the nexus
	Uri       string      `protobuf:"bytes,2,opt,name=uri,proto3" json:"uri,omitempty"`                              // uri of the child to act upon
	Action    ChildAction `protobuf:"varint,3,opt,name=action,proto3,enum=mayastor.v1.ChildAction" json:"action,omitempty"`
	// contains filtered or unexported fields
}

func (*ChildOperationRequest) Descriptor deprecated 

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

Deprecated: Use ChildOperationRequest.ProtoReflect.Descriptor instead.

func (*ChildOperationRequest) GetAction 

func (x *ChildOperationRequest) GetAction() ChildAction

func (*ChildOperationRequest) GetNexusUuid 

func (x *ChildOperationRequest) GetNexusUuid() string

func (*ChildOperationRequest) GetUri 

func (x *ChildOperationRequest) GetUri() string

func (*ChildOperationRequest) ProtoMessage 

func (*ChildOperationRequest) ProtoMessage()

func (*ChildOperationRequest) ProtoReflect 

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

func (*ChildOperationRequest) Reset 

func (x *ChildOperationRequest) Reset()

func (*ChildOperationRequest) String 

func (x *ChildOperationRequest) String() string

type ChildOperationResponse 

type ChildOperationResponse struct {
	Nexus *Nexus `protobuf:"bytes,1,opt,name=nexus,proto3" json:"nexus,omitempty"`
	// contains filtered or unexported fields
}

func (*ChildOperationResponse) Descriptor deprecated 

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

Deprecated: Use ChildOperationResponse.ProtoReflect.Descriptor instead.

func (*ChildOperationResponse) GetNexus 

func (x *ChildOperationResponse) GetNexus() *Nexus

func (*ChildOperationResponse) ProtoMessage 

func (*ChildOperationResponse) ProtoMessage()

func (*ChildOperationResponse) ProtoReflect 

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

func (*ChildOperationResponse) Reset 

func (x *ChildOperationResponse) Reset()

func (*ChildOperationResponse) String 

func (x *ChildOperationResponse) String() string

type ChildState 

type ChildState int32

State of the nexus child. 

const (
	ChildState_CHILD_STATE_UNKNOWN  ChildState = 0 // no particular reason for the child to be in this state; this is typically the init state
	ChildState_CHILD_STATE_ONLINE   ChildState = 1 // healthy and contains the latest bits
	ChildState_CHILD_STATE_DEGRADED ChildState = 2 // rebuild is in progress (or other recoverable error)
	ChildState_CHILD_STATE_FAULTED  ChildState = 3 // unrecoverable error (control plane must act)
)

func (ChildState) Descriptor 

func (ChildState) Descriptor() protoreflect.EnumDescriptor

func (ChildState) Enum 

func (x ChildState) Enum() *ChildState

func (ChildState) EnumDescriptor deprecated 

func (ChildState) EnumDescriptor() ([]byte, []int)

Deprecated: Use ChildState.Descriptor instead.

func (ChildState) Number 

func (x ChildState) Number() protoreflect.EnumNumber

func (ChildState) String 

func (x ChildState) String() string

func (ChildState) Type 

func (ChildState) Type() protoreflect.EnumType

type ChildStateReason 

type ChildStateReason int32

State of the nexus child. 

const (
	ChildStateReason_CHILD_STATE_REASON_NONE           ChildStateReason = 0  // reason for CHILD_REASON_NONE, CHILD_UNKNOWN
	ChildStateReason_CHILD_STATE_REASON_INIT           ChildStateReason = 1  // child is being initialized
	ChildStateReason_CHILD_STATE_REASON_CLOSED         ChildStateReason = 2  // child is being destroyed or has been closed
	ChildStateReason_CHILD_STATE_REASON_CANNOT_OPEN    ChildStateReason = 3  // failed to open child (e.g. cannot access device)
	ChildStateReason_CHILD_STATE_REASON_CONFIG_INVALID ChildStateReason = 4  // invalid child device configuration (e.g. mismatching size)
	ChildStateReason_CHILD_STATE_REASON_REBUILD_FAILED ChildStateReason = 5  // rebuild operation failed for this child
	ChildStateReason_CHILD_STATE_REASON_IO_FAILURE     ChildStateReason = 6  // child faulted because of other I/O errors
	ChildStateReason_CHILD_STATE_REASON_BY_CLIENT      ChildStateReason = 7  // child has been faulted by a client
	ChildStateReason_CHILD_STATE_REASON_OUT_OF_SYNC    ChildStateReason = 8  // child is being rebuilt
	ChildStateReason_CHILD_STATE_REASON_NO_SPACE       ChildStateReason = 9  // child faulted because I/O operation failed with ENOSPC
	ChildStateReason_CHILD_STATE_REASON_TIMED_OUT      ChildStateReason = 10 // child faulted because I/O operation failed with timeout
	ChildStateReason_CHILD_STATE_REASON_ADMIN_FAILED   ChildStateReason = 11 // child faulted of an admin command failure
)

func (ChildStateReason) Descriptor 

func (ChildStateReason) Descriptor() protoreflect.EnumDescriptor

func (ChildStateReason) Enum 

func (x ChildStateReason) Enum() *ChildStateReason

func (ChildStateReason) EnumDescriptor deprecated 

func (ChildStateReason) EnumDescriptor() ([]byte, []int)

Deprecated: Use ChildStateReason.Descriptor instead.

func (ChildStateReason) Number 

func (x ChildStateReason) Number() protoreflect.EnumNumber

func (ChildStateReason) String 

func (x ChildStateReason) String() string

func (ChildStateReason) Type 

func (ChildStateReason) Type() protoreflect.EnumType

type CreateBdevRequest 

type CreateBdevRequest struct {
	Uri string `protobuf:"bytes,1,opt,name=uri,proto3" json:"uri,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateBdevRequest) Descriptor deprecated 

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

Deprecated: Use CreateBdevRequest.ProtoReflect.Descriptor instead.

func (*CreateBdevRequest) GetUri 

func (x *CreateBdevRequest) GetUri() string

func (*CreateBdevRequest) ProtoMessage 

func (*CreateBdevRequest) ProtoMessage()

func (*CreateBdevRequest) ProtoReflect 

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

func (*CreateBdevRequest) Reset 

func (x *CreateBdevRequest) Reset()

func (*CreateBdevRequest) String 

func (x *CreateBdevRequest) String() string

type CreateBdevResponse 

type CreateBdevResponse struct {
	Bdev *Bdev `protobuf:"bytes,1,opt,name=bdev,proto3" json:"bdev,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateBdevResponse) Descriptor deprecated 

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

Deprecated: Use CreateBdevResponse.ProtoReflect.Descriptor instead.

func (*CreateBdevResponse) GetBdev 

func (x *CreateBdevResponse) GetBdev() *Bdev

func (*CreateBdevResponse) ProtoMessage 

func (*CreateBdevResponse) ProtoMessage()

func (*CreateBdevResponse) ProtoReflect 

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

func (*CreateBdevResponse) Reset 

func (x *CreateBdevResponse) Reset()

func (*CreateBdevResponse) String 

func (x *CreateBdevResponse) String() string

type CreateNexusRequest 

type CreateNexusRequest struct {
	Name          string              `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`                                                          // name of the nexus
	Uuid          string              `protobuf:"bytes,2,opt,name=uuid,proto3" json:"uuid,omitempty"`                                                          // UUID of the nexus
	Size          uint64              `protobuf:"varint,3,opt,name=size,proto3" json:"size,omitempty"`                                                         // size of the device in bytes
	MinCntlId     uint32              `protobuf:"varint,4,opt,name=minCntlId,proto3" json:"minCntlId,omitempty"`                                               // minimum NVMe controller ID
	MaxCntlId     uint32              `protobuf:"varint,5,opt,name=maxCntlId,proto3" json:"maxCntlId,omitempty"`                                               // maximum NVMe controller ID
	ResvKey       uint64              `protobuf:"varint,6,opt,name=resvKey,proto3" json:"resvKey,omitempty"`                                                   // NVMe reservation key for children
	PreemptKey    uint64              `protobuf:"varint,7,opt,name=preemptKey,proto3" json:"preemptKey,omitempty"`                                             // NVMe preempt key for children
	Children      []string            `protobuf:"bytes,8,rep,name=children,proto3" json:"children,omitempty"`                                                  // uris to the targets we connect to
	NexusInfoKey  string              `protobuf:"bytes,9,opt,name=nexusInfoKey,proto3" json:"nexusInfoKey,omitempty"`                                          // the key to use to persist the nexus info structure
	ResvType      *NvmeReservation    `protobuf:"varint,10,opt,name=resvType,proto3,enum=mayastor.v1.NvmeReservation,oneof" json:"resvType,omitempty"`         // the reservation type to use
	PreemptPolicy NexusNvmePreemption `protobuf:"varint,11,opt,name=preemptPolicy,proto3,enum=mayastor.v1.NexusNvmePreemption" json:"preemptPolicy,omitempty"` // the preemption policy to use
	// contains filtered or unexported fields
}

Create nexus arguments.

func (*CreateNexusRequest) Descriptor deprecated 

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

Deprecated: Use CreateNexusRequest.ProtoReflect.Descriptor instead.

func (*CreateNexusRequest) GetChildren 

func (x *CreateNexusRequest) GetChildren() []string

func (*CreateNexusRequest) GetMaxCntlId 

func (x *CreateNexusRequest) GetMaxCntlId() uint32

func (*CreateNexusRequest) GetMinCntlId 

func (x *CreateNexusRequest) GetMinCntlId() uint32

func (*CreateNexusRequest) GetName 

func (x *CreateNexusRequest) GetName() string

func (*CreateNexusRequest) GetNexusInfoKey 

func (x *CreateNexusRequest) GetNexusInfoKey() string

func (*CreateNexusRequest) GetPreemptKey 

func (x *CreateNexusRequest) GetPreemptKey() uint64

func (*CreateNexusRequest) GetPreemptPolicy 

func (x *CreateNexusRequest) GetPreemptPolicy() NexusNvmePreemption

func (*CreateNexusRequest) GetResvKey 

func (x *CreateNexusRequest) GetResvKey() uint64

func (*CreateNexusRequest) GetResvType 

func (x *CreateNexusRequest) GetResvType() NvmeReservation

func (*CreateNexusRequest) GetSize 

func (x *CreateNexusRequest) GetSize() uint64

func (*CreateNexusRequest) GetUuid 

func (x *CreateNexusRequest) GetUuid() string

func (*CreateNexusRequest) ProtoMessage 

func (*CreateNexusRequest) ProtoMessage()

func (*CreateNexusRequest) ProtoReflect 

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

func (*CreateNexusRequest) Reset 

func (x *CreateNexusRequest) Reset()

func (*CreateNexusRequest) String 

func (x *CreateNexusRequest) String() string

type CreateNexusResponse 

type CreateNexusResponse struct {
	Nexus *Nexus `protobuf:"bytes,1,opt,name=nexus,proto3" json:"nexus,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateNexusResponse) Descriptor deprecated 

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

Deprecated: Use CreateNexusResponse.ProtoReflect.Descriptor instead.

func (*CreateNexusResponse) GetNexus 

func (x *CreateNexusResponse) GetNexus() *Nexus

func (*CreateNexusResponse) ProtoMessage 

func (*CreateNexusResponse) ProtoMessage()

func (*CreateNexusResponse) ProtoReflect 

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

func (*CreateNexusResponse) Reset 

func (x *CreateNexusResponse) Reset()

func (*CreateNexusResponse) String 

func (x *CreateNexusResponse) String() string

type CreatePoolRequest 

type CreatePoolRequest struct {
	Name     string                  `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`                                    // name of the pool
	Uuid     *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=uuid,proto3" json:"uuid,omitempty"`                                    // optional uuid for the pool to be created
	Disks    []string                `protobuf:"bytes,3,rep,name=disks,proto3" json:"disks,omitempty"`                                  // disk device paths or URIs to be claimed by the pool
	Pooltype PoolType                `protobuf:"varint,4,opt,name=pooltype,proto3,enum=mayastor.v1.PoolType" json:"pooltype,omitempty"` // type of the pool
	// Default cluster size is 4MiB (4 * 1024 * 1024), input cluster size must be in "bytes" but
	// must be multiple of 1MiB, else default cluster size i.e 4MiB will be considered. Minimum
	// cluster size can be input as 1048576 (1024 * 1024) bytes (1MiB)
	ClusterSize *uint32 `protobuf:"varint,5,opt,name=cluster_size,json=clusterSize,proto3,oneof" json:"cluster_size,omitempty"`
	// contains filtered or unexported fields
}

Create pool arguments.

func (*CreatePoolRequest) Descriptor deprecated 

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

Deprecated: Use CreatePoolRequest.ProtoReflect.Descriptor instead.

func (*CreatePoolRequest) GetClusterSize 

func (x *CreatePoolRequest) GetClusterSize() uint32

func (*CreatePoolRequest) GetDisks 

func (x *CreatePoolRequest) GetDisks() []string

func (*CreatePoolRequest) GetName 

func (x *CreatePoolRequest) GetName() string

func (*CreatePoolRequest) GetPooltype 

func (x *CreatePoolRequest) GetPooltype() PoolType

func (*CreatePoolRequest) GetUuid 

func (x *CreatePoolRequest) GetUuid() *wrapperspb.StringValue

func (*CreatePoolRequest) ProtoMessage 

func (*CreatePoolRequest) ProtoMessage()

func (*CreatePoolRequest) ProtoReflect 

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

func (*CreatePoolRequest) Reset 

func (x *CreatePoolRequest) Reset()

func (*CreatePoolRequest) String 

func (x *CreatePoolRequest) String() string

type CreateReplicaRequest 

type CreateReplicaRequest struct {
	Name         string        `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`                                     // name of the replica
	Uuid         string        `protobuf:"bytes,2,opt,name=uuid,proto3" json:"uuid,omitempty"`                                     // uuid of the replica
	Pooluuid     string        `protobuf:"bytes,3,opt,name=pooluuid,proto3" json:"pooluuid,omitempty"`                             // uuid of the pool on which replica needs to be created.
	Size         uint64        `protobuf:"varint,4,opt,name=size,proto3" json:"size,omitempty"`                                    // size of the replica in bytes
	Thin         bool          `protobuf:"varint,5,opt,name=thin,proto3" json:"thin,omitempty"`                                    // thin provisioning
	Share        ShareProtocol `protobuf:"varint,6,opt,name=share,proto3,enum=mayastor.v1.ShareProtocol" json:"share,omitempty"`   // protocol to expose the replica over
	AllowedHosts []string      `protobuf:"bytes,7,rep,name=allowed_hosts,json=allowedHosts,proto3" json:"allowed_hosts,omitempty"` // host (nqn's) which are allowed to connect to the target.
	// contains filtered or unexported fields
}

func (*CreateReplicaRequest) Descriptor deprecated 

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

Deprecated: Use CreateReplicaRequest.ProtoReflect.Descriptor instead.

func (*CreateReplicaRequest) GetAllowedHosts 

func (x *CreateReplicaRequest) GetAllowedHosts() []string

func (*CreateReplicaRequest) GetName 

func (x *CreateReplicaRequest) GetName() string

func (*CreateReplicaRequest) GetPooluuid 

func (x *CreateReplicaRequest) GetPooluuid() string

func (*CreateReplicaRequest) GetShare 

func (x *CreateReplicaRequest) GetShare() ShareProtocol

func (*CreateReplicaRequest) GetSize 

func (x *CreateReplicaRequest) GetSize() uint64

func (*CreateReplicaRequest) GetThin 

func (x *CreateReplicaRequest) GetThin() bool

func (*CreateReplicaRequest) GetUuid 

func (x *CreateReplicaRequest) GetUuid() string

func (*CreateReplicaRequest) ProtoMessage 

func (*CreateReplicaRequest) ProtoMessage()

func (*CreateReplicaRequest) ProtoReflect 

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

func (*CreateReplicaRequest) Reset 

func (x *CreateReplicaRequest) Reset()

func (*CreateReplicaRequest) String 

func (x *CreateReplicaRequest) String() string

type CreateReplicaSnapshotRequest 

type CreateReplicaSnapshotRequest struct {
	ReplicaUuid  string `protobuf:"bytes,1,opt,name=replica_uuid,json=replicaUuid,proto3" json:"replica_uuid,omitempty"`    // uuid of the replica
	SnapshotUuid string `protobuf:"bytes,2,opt,name=snapshot_uuid,json=snapshotUuid,proto3" json:"snapshot_uuid,omitempty"` // uuid of the snapshot
	SnapshotName string `protobuf:"bytes,3,opt,name=snapshot_name,json=snapshotName,proto3" json:"snapshot_name,omitempty"` // snapshot name
	EntityId     string `protobuf:"bytes,4,opt,name=entity_id,json=entityId,proto3" json:"entity_id,omitempty"`             // entity associated with this snapshot
	TxnId        string `protobuf:"bytes,5,opt,name=txn_id,json=txnId,proto3" json:"txn_id,omitempty"`                      // unique transaction id generate for snapshot creation
	// contains filtered or unexported fields
}

Create Replica Snapshot Request.

func (*CreateReplicaSnapshotRequest) Descriptor deprecated 

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

Deprecated: Use CreateReplicaSnapshotRequest.ProtoReflect.Descriptor instead.

func (*CreateReplicaSnapshotRequest) GetEntityId 

func (x *CreateReplicaSnapshotRequest) GetEntityId() string

func (*CreateReplicaSnapshotRequest) GetReplicaUuid 

func (x *CreateReplicaSnapshotRequest) GetReplicaUuid() string

func (*CreateReplicaSnapshotRequest) GetSnapshotName 

func (x *CreateReplicaSnapshotRequest) GetSnapshotName() string

func (*CreateReplicaSnapshotRequest) GetSnapshotUuid 

func (x *CreateReplicaSnapshotRequest) GetSnapshotUuid() string

func (*CreateReplicaSnapshotRequest) GetTxnId 

func (x *CreateReplicaSnapshotRequest) GetTxnId() string

func (*CreateReplicaSnapshotRequest) ProtoMessage 

func (*CreateReplicaSnapshotRequest) ProtoMessage()

func (*CreateReplicaSnapshotRequest) ProtoReflect 

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

func (*CreateReplicaSnapshotRequest) Reset 

func (x *CreateReplicaSnapshotRequest) Reset()

func (*CreateReplicaSnapshotRequest) String 

func (x *CreateReplicaSnapshotRequest) String() string

type CreateReplicaSnapshotResponse 

type CreateReplicaSnapshotResponse struct {
	ReplicaUuid string        `protobuf:"bytes,1,opt,name=replica_uuid,json=replicaUuid,proto3" json:"replica_uuid,omitempty"` // UUID of the source replica
	Snapshot    *SnapshotInfo `protobuf:"bytes,2,opt,name=snapshot,proto3" json:"snapshot,omitempty"`                          // Snapshot detail information
	// contains filtered or unexported fields
}

/ Create Replica Snapshot Response.

func (*CreateReplicaSnapshotResponse) Descriptor deprecated 

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

Deprecated: Use CreateReplicaSnapshotResponse.ProtoReflect.Descriptor instead.

func (*CreateReplicaSnapshotResponse) GetReplicaUuid 

func (x *CreateReplicaSnapshotResponse) GetReplicaUuid() string

func (*CreateReplicaSnapshotResponse) GetSnapshot 

func (x *CreateReplicaSnapshotResponse) GetSnapshot() *SnapshotInfo

func (*CreateReplicaSnapshotResponse) ProtoMessage 

func (*CreateReplicaSnapshotResponse) ProtoMessage()

func (*CreateReplicaSnapshotResponse) ProtoReflect 

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

func (*CreateReplicaSnapshotResponse) Reset 

func (x *CreateReplicaSnapshotResponse) Reset()

func (*CreateReplicaSnapshotResponse) String 

func (x *CreateReplicaSnapshotResponse) String() string

type CreateSnapshotCloneRequest 

type CreateSnapshotCloneRequest struct {
	SnapshotUuid string `protobuf:"bytes,1,opt,name=snapshot_uuid,json=snapshotUuid,proto3" json:"snapshot_uuid,omitempty"` // uuid of the snapshot
	CloneName    string `protobuf:"bytes,2,opt,name=clone_name,json=cloneName,proto3" json:"clone_name,omitempty"`          // snapshot clone name
	CloneUuid    string `protobuf:"bytes,3,opt,name=clone_uuid,json=cloneUuid,proto3" json:"clone_uuid,omitempty"`          // uuid of the clone to be created from snapshot
	// contains filtered or unexported fields
}

Request Parameters for Creating Snapshot Clone.

func (*CreateSnapshotCloneRequest) Descriptor deprecated 

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

Deprecated: Use CreateSnapshotCloneRequest.ProtoReflect.Descriptor instead.

func (*CreateSnapshotCloneRequest) GetCloneName 

func (x *CreateSnapshotCloneRequest) GetCloneName() string

func (*CreateSnapshotCloneRequest) GetCloneUuid 

func (x *CreateSnapshotCloneRequest) GetCloneUuid() string

func (*CreateSnapshotCloneRequest) GetSnapshotUuid 

func (x *CreateSnapshotCloneRequest) GetSnapshotUuid() string

func (*CreateSnapshotCloneRequest) ProtoMessage 

func (*CreateSnapshotCloneRequest) ProtoMessage()

func (*CreateSnapshotCloneRequest) ProtoReflect 

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

func (*CreateSnapshotCloneRequest) Reset 

func (x *CreateSnapshotCloneRequest) Reset()

func (*CreateSnapshotCloneRequest) String 

func (x *CreateSnapshotCloneRequest) String() string

type DeregisterRequest 

type DeregisterRequest struct {

	// id of the mayastor instance
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

deregister a dataplane node from the control-plane

func (*DeregisterRequest) Descriptor deprecated 

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

Deprecated: Use DeregisterRequest.ProtoReflect.Descriptor instead.

func (*DeregisterRequest) GetId 

func (x *DeregisterRequest) GetId() string

func (*DeregisterRequest) ProtoMessage 

func (*DeregisterRequest) ProtoMessage()

func (*DeregisterRequest) ProtoReflect 

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

func (*DeregisterRequest) Reset 

func (x *DeregisterRequest) Reset()

func (*DeregisterRequest) String 

func (x *DeregisterRequest) String() string

type DestroyBdevRequest 

type DestroyBdevRequest struct {
	Uri string `protobuf:"bytes,1,opt,name=uri,proto3" json:"uri,omitempty"`
	// contains filtered or unexported fields
}

func (*DestroyBdevRequest) Descriptor deprecated 

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

Deprecated: Use DestroyBdevRequest.ProtoReflect.Descriptor instead.

func (*DestroyBdevRequest) GetUri 

func (x *DestroyBdevRequest) GetUri() string

func (*DestroyBdevRequest) ProtoMessage 

func (*DestroyBdevRequest) ProtoMessage()

func (*DestroyBdevRequest) ProtoReflect 

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

func (*DestroyBdevRequest) Reset 

func (x *DestroyBdevRequest) Reset()

func (*DestroyBdevRequest) String 

func (x *DestroyBdevRequest) String() string

type DestroyNexusRequest 

type DestroyNexusRequest struct {
	Uuid string `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"` // uuid of the nexus
	// contains filtered or unexported fields
}

func (*DestroyNexusRequest) Descriptor deprecated 

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

Deprecated: Use DestroyNexusRequest.ProtoReflect.Descriptor instead.

func (*DestroyNexusRequest) GetUuid 

func (x *DestroyNexusRequest) GetUuid() string

func (*DestroyNexusRequest) ProtoMessage 

func (*DestroyNexusRequest) ProtoMessage()

func (*DestroyNexusRequest) ProtoReflect 

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

func (*DestroyNexusRequest) Reset 

func (x *DestroyNexusRequest) Reset()

func (*DestroyNexusRequest) String 

func (x *DestroyNexusRequest) String() string

type DestroyPoolRequest 

type DestroyPoolRequest struct {
	Name string                  `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // name of the pool
	Uuid *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=uuid,proto3" json:"uuid,omitempty"` // optional uuid for the pool to be destroyed
	// contains filtered or unexported fields
}

Destroy pool arguments.

func (*DestroyPoolRequest) Descriptor deprecated 

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

Deprecated: Use DestroyPoolRequest.ProtoReflect.Descriptor instead.

func (*DestroyPoolRequest) GetName 

func (x *DestroyPoolRequest) GetName() string

func (*DestroyPoolRequest) GetUuid 

func (x *DestroyPoolRequest) GetUuid() *wrapperspb.StringValue

func (*DestroyPoolRequest) ProtoMessage 

func (*DestroyPoolRequest) ProtoMessage()

func (*DestroyPoolRequest) ProtoReflect 

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

func (*DestroyPoolRequest) Reset 

func (x *DestroyPoolRequest) Reset()

func (*DestroyPoolRequest) String 

func (x *DestroyPoolRequest) String() string

type DestroyReplicaRequest 

type DestroyReplicaRequest struct {
	Uuid string `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"` // uuid of the replica.
	// Types that are assignable to Pool:
	//
	//	*DestroyReplicaRequest_PoolName
	//	*DestroyReplicaRequest_PoolUuid
	Pool isDestroyReplicaRequest_Pool `protobuf_oneof:"pool"`
	// contains filtered or unexported fields
}

Destroy replica arguments.

func (*DestroyReplicaRequest) Descriptor deprecated 

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

Deprecated: Use DestroyReplicaRequest.ProtoReflect.Descriptor instead.

func (*DestroyReplicaRequest) GetPool 

func (m *DestroyReplicaRequest) GetPool() isDestroyReplicaRequest_Pool

func (*DestroyReplicaRequest) GetPoolName 

func (x *DestroyReplicaRequest) GetPoolName() string

func (*DestroyReplicaRequest) GetPoolUuid 

func (x *DestroyReplicaRequest) GetPoolUuid() string

func (*DestroyReplicaRequest) GetUuid 

func (x *DestroyReplicaRequest) GetUuid() string

func (*DestroyReplicaRequest) ProtoMessage 

func (*DestroyReplicaRequest) ProtoMessage()

func (*DestroyReplicaRequest) ProtoReflect 

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

func (*DestroyReplicaRequest) Reset 

func (x *DestroyReplicaRequest) Reset()

func (*DestroyReplicaRequest) String 

func (x *DestroyReplicaRequest) String() string

type DestroyReplicaRequest_PoolName 

type DestroyReplicaRequest_PoolName struct {
	PoolName string `protobuf:"bytes,2,opt,name=pool_name,json=poolName,proto3,oneof"` // name of the pool where the replica resides.
}

type DestroyReplicaRequest_PoolUuid 

type DestroyReplicaRequest_PoolUuid struct {
	PoolUuid string `protobuf:"bytes,3,opt,name=pool_uuid,json=poolUuid,proto3,oneof"` // optional uuid for the pool where the replica resides.
}

type DestroySnapshotRequest 

type DestroySnapshotRequest struct {
	SnapshotUuid string `protobuf:"bytes,1,opt,name=snapshot_uuid,json=snapshotUuid,proto3" json:"snapshot_uuid,omitempty"` // snapshot to be deleted
	// Types that are assignable to Pool:
	//
	//	*DestroySnapshotRequest_PoolName
	//	*DestroySnapshotRequest_PoolUuid
	Pool isDestroySnapshotRequest_Pool `protobuf_oneof:"pool"`
	// contains filtered or unexported fields
}

Delete Snapshot Request.

func (*DestroySnapshotRequest) Descriptor deprecated 

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

Deprecated: Use DestroySnapshotRequest.ProtoReflect.Descriptor instead.

func (*DestroySnapshotRequest) GetPool 

func (m *DestroySnapshotRequest) GetPool() isDestroySnapshotRequest_Pool

func (*DestroySnapshotRequest) GetPoolName 

func (x *DestroySnapshotRequest) GetPoolName() string

func (*DestroySnapshotRequest) GetPoolUuid 

func (x *DestroySnapshotRequest) GetPoolUuid() string

func (*DestroySnapshotRequest) GetSnapshotUuid 

func (x *DestroySnapshotRequest) GetSnapshotUuid() string

func (*DestroySnapshotRequest) ProtoMessage 

func (*DestroySnapshotRequest) ProtoMessage()

func (*DestroySnapshotRequest) ProtoReflect 

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

func (*DestroySnapshotRequest) Reset 

func (x *DestroySnapshotRequest) Reset()

func (*DestroySnapshotRequest) String 

func (x *DestroySnapshotRequest) String() string

type DestroySnapshotRequest_PoolName 

type DestroySnapshotRequest_PoolName struct {
	PoolName string `protobuf:"bytes,2,opt,name=pool_name,json=poolName,proto3,oneof"` // name of the pool where the snapshot resides.
}

type DestroySnapshotRequest_PoolUuid 

type DestroySnapshotRequest_PoolUuid struct {
	PoolUuid string `protobuf:"bytes,3,opt,name=pool_uuid,json=poolUuid,proto3,oneof"` // optional uuid for the pool where the snapshot resides.
}

type ExportPoolRequest 

type ExportPoolRequest struct {
	Name string                  `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // name of the pool
	Uuid *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=uuid,proto3" json:"uuid,omitempty"` // optional uuid for the pool to be exported
	// contains filtered or unexported fields
}

Export pool arguments.

func (*ExportPoolRequest) Descriptor deprecated 

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

Deprecated: Use ExportPoolRequest.ProtoReflect.Descriptor instead.

func (*ExportPoolRequest) GetName 

func (x *ExportPoolRequest) GetName() string

func (*ExportPoolRequest) GetUuid 

func (x *ExportPoolRequest) GetUuid() *wrapperspb.StringValue

func (*ExportPoolRequest) ProtoMessage 

func (*ExportPoolRequest) ProtoMessage()

func (*ExportPoolRequest) ProtoReflect 

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

func (*ExportPoolRequest) Reset 

func (x *ExportPoolRequest) Reset()

func (*ExportPoolRequest) String 

func (x *ExportPoolRequest) String() string

type FaultInjection 

type FaultInjection struct {

	// URI that was used to add the fault injection.
	Uri string `protobuf:"bytes,1,opt,name=uri,proto3" json:"uri,omitempty"`
	// Target device name to which the injection applies.
	DeviceName string `protobuf:"bytes,2,opt,name=device_name,json=deviceName,proto3" json:"device_name,omitempty"`
	// True if the injection is currently active (injection active condition
	// has been met).
	IsActive bool `protobuf:"varint,3,opt,name=is_active,json=isActive,proto3" json:"is_active,omitempty"`
	// contains filtered or unexported fields
}

func (*FaultInjection) Descriptor deprecated 

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

Deprecated: Use FaultInjection.ProtoReflect.Descriptor instead.

func (*FaultInjection) GetDeviceName 

func (x *FaultInjection) GetDeviceName() string

func (*FaultInjection) GetIsActive 

func (x *FaultInjection) GetIsActive() bool

func (*FaultInjection) GetUri 

func (x *FaultInjection) GetUri() string

func (*FaultInjection) ProtoMessage 

func (*FaultInjection) ProtoMessage()

func (*FaultInjection) ProtoReflect 

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

func (*FaultInjection) Reset 

func (x *FaultInjection) Reset()

func (*FaultInjection) String 

func (x *FaultInjection) String() string

type FaultNexusChildRequest 

type FaultNexusChildRequest struct {
	Uuid string `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"` // uuid of the nexus
	Uri  string `protobuf:"bytes,2,opt,name=uri,proto3" json:"uri,omitempty"`   // URI of the child device to be faulted
	// contains filtered or unexported fields
}

func (*FaultNexusChildRequest) Descriptor deprecated 

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

Deprecated: Use FaultNexusChildRequest.ProtoReflect.Descriptor instead.

func (*FaultNexusChildRequest) GetUri 

func (x *FaultNexusChildRequest) GetUri() string

func (*FaultNexusChildRequest) GetUuid 

func (x *FaultNexusChildRequest) GetUuid() string

func (*FaultNexusChildRequest) ProtoMessage 

func (*FaultNexusChildRequest) ProtoMessage()

func (*FaultNexusChildRequest) ProtoReflect 

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

func (*FaultNexusChildRequest) Reset 

func (x *FaultNexusChildRequest) Reset()

func (*FaultNexusChildRequest) String 

func (x *FaultNexusChildRequest) String() string

type FaultNexusChildResponse 

type FaultNexusChildResponse struct {
	Nexus *Nexus `protobuf:"bytes,1,opt,name=nexus,proto3" json:"nexus,omitempty"`
	// contains filtered or unexported fields
}

func (*FaultNexusChildResponse) Descriptor deprecated 

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

Deprecated: Use FaultNexusChildResponse.ProtoReflect.Descriptor instead.

func (*FaultNexusChildResponse) GetNexus 

func (x *FaultNexusChildResponse) GetNexus() *Nexus

func (*FaultNexusChildResponse) ProtoMessage 

func (*FaultNexusChildResponse) ProtoMessage()

func (*FaultNexusChildResponse) ProtoReflect 

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

func (*FaultNexusChildResponse) Reset 

func (x *FaultNexusChildResponse) Reset()

func (*FaultNexusChildResponse) String 

func (x *FaultNexusChildResponse) String() string

type GetMayastorResourceUsageResponse 

type GetMayastorResourceUsageResponse struct {
	Usage *ResourceUsage `protobuf:"bytes,1,opt,name=usage,proto3" json:"usage,omitempty"`
	// contains filtered or unexported fields
}

func (*GetMayastorResourceUsageResponse) Descriptor deprecated 

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

Deprecated: Use GetMayastorResourceUsageResponse.ProtoReflect.Descriptor instead.

func (*GetMayastorResourceUsageResponse) GetUsage 

func (x *GetMayastorResourceUsageResponse) GetUsage() *ResourceUsage

func (*GetMayastorResourceUsageResponse) ProtoMessage 

func (*GetMayastorResourceUsageResponse) ProtoMessage()

func (*GetMayastorResourceUsageResponse) ProtoReflect 

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

func (*GetMayastorResourceUsageResponse) Reset 

func (x *GetMayastorResourceUsageResponse) Reset()

func (*GetMayastorResourceUsageResponse) String 

func (x *GetMayastorResourceUsageResponse) String() string

type GetNvmeAnaStateRequest 

type GetNvmeAnaStateRequest struct {
	Uuid string `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"` // uuid of the nexus
	// contains filtered or unexported fields
}

func (*GetNvmeAnaStateRequest) Descriptor deprecated 

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

Deprecated: Use GetNvmeAnaStateRequest.ProtoReflect.Descriptor instead.

func (*GetNvmeAnaStateRequest) GetUuid 

func (x *GetNvmeAnaStateRequest) GetUuid() string

func (*GetNvmeAnaStateRequest) ProtoMessage 

func (*GetNvmeAnaStateRequest) ProtoMessage()

func (*GetNvmeAnaStateRequest) ProtoReflect 

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

func (*GetNvmeAnaStateRequest) Reset 

func (x *GetNvmeAnaStateRequest) Reset()

func (*GetNvmeAnaStateRequest) String 

func (x *GetNvmeAnaStateRequest) String() string

type GetNvmeAnaStateResponse 

type GetNvmeAnaStateResponse struct {
	AnaState NvmeAnaState `protobuf:"varint,1,opt,name=ana_state,json=anaState,proto3,enum=mayastor.v1.NvmeAnaState" json:"ana_state,omitempty"`
	// contains filtered or unexported fields
}

func (*GetNvmeAnaStateResponse) Descriptor deprecated 

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

Deprecated: Use GetNvmeAnaStateResponse.ProtoReflect.Descriptor instead.

func (*GetNvmeAnaStateResponse) GetAnaState 

func (x *GetNvmeAnaStateResponse) GetAnaState() NvmeAnaState

func (*GetNvmeAnaStateResponse) ProtoMessage 

func (*GetNvmeAnaStateResponse) ProtoMessage()

func (*GetNvmeAnaStateResponse) ProtoReflect 

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

func (*GetNvmeAnaStateResponse) Reset 

func (x *GetNvmeAnaStateResponse) Reset()

func (*GetNvmeAnaStateResponse) String 

func (x *GetNvmeAnaStateResponse) String() string

type HostRpcClient 

type HostRpcClient interface {
	GetMayastorInfo(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*MayastorInfoResponse, error)
	// Enumerate block devices on current host
	ListBlockDevices(ctx context.Context, in *ListBlockDevicesRequest, opts ...grpc.CallOption) (*ListBlockDevicesResponse, error)
	// Obtain resource usage statistics for the current process
	GetMayastorResourceUsage(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*GetMayastorResourceUsageResponse, error)
	// NVMe controllers
	ListNvmeControllers(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ListNvmeControllersResponse, error)
	StatNvmeController(ctx context.Context, in *StatNvmeControllerRequest, opts ...grpc.CallOption) (*StatNvmeControllerResponse, error)
}

HostRpcClient is the client API for HostRpc 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 NewHostRpcClient 

func NewHostRpcClient(cc grpc.ClientConnInterface) HostRpcClient

type HostRpcServer 

type HostRpcServer interface {
	GetMayastorInfo(context.Context, *emptypb.Empty) (*MayastorInfoResponse, error)
	// Enumerate block devices on current host
	ListBlockDevices(context.Context, *ListBlockDevicesRequest) (*ListBlockDevicesResponse, error)
	// Obtain resource usage statistics for the current process
	GetMayastorResourceUsage(context.Context, *emptypb.Empty) (*GetMayastorResourceUsageResponse, error)
	// NVMe controllers
	ListNvmeControllers(context.Context, *emptypb.Empty) (*ListNvmeControllersResponse, error)
	StatNvmeController(context.Context, *StatNvmeControllerRequest) (*StatNvmeControllerResponse, error)
	// contains filtered or unexported methods
}

HostRpcServer is the server API for HostRpc service. All implementations must embed UnimplementedHostRpcServer for forward compatibility

type ImportPoolRequest 

type ImportPoolRequest struct {
	Name     string                  `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`                                    // name of the pool
	Uuid     *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=uuid,proto3" json:"uuid,omitempty"`                                    // optional uuid for the pool to be imported
	Disks    []string                `protobuf:"bytes,3,rep,name=disks,proto3" json:"disks,omitempty"`                                  // disk device paths or URIs to be claimed by the pool
	Pooltype PoolType                `protobuf:"varint,4,opt,name=pooltype,proto3,enum=mayastor.v1.PoolType" json:"pooltype,omitempty"` // type of the pool
	// contains filtered or unexported fields
}

Create pool arguments.

func (*ImportPoolRequest) Descriptor deprecated 

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

Deprecated: Use ImportPoolRequest.ProtoReflect.Descriptor instead.

func (*ImportPoolRequest) GetDisks 

func (x *ImportPoolRequest) GetDisks() []string

func (*ImportPoolRequest) GetName 

func (x *ImportPoolRequest) GetName() string

func (*ImportPoolRequest) GetPooltype 

func (x *ImportPoolRequest) GetPooltype() PoolType

func (*ImportPoolRequest) GetUuid 

func (x *ImportPoolRequest) GetUuid() *wrapperspb.StringValue

func (*ImportPoolRequest) ProtoMessage 

func (*ImportPoolRequest) ProtoMessage()

func (*ImportPoolRequest) ProtoReflect 

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

func (*ImportPoolRequest) Reset 

func (x *ImportPoolRequest) Reset()

func (*ImportPoolRequest) String 

func (x *ImportPoolRequest) String() string

type IoStats 

type IoStats struct {
	Name                 string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`                                                                // Name of the device/resource.
	NumReadOps           uint64 `protobuf:"varint,2,opt,name=num_read_ops,json=numReadOps,proto3" json:"num_read_ops,omitempty"`                               // Number of read operations on the device.
	BytesRead            uint64 `protobuf:"varint,3,opt,name=bytes_read,json=bytesRead,proto3" json:"bytes_read,omitempty"`                                    // Total bytes read on the device.
	NumWriteOps          uint64 `protobuf:"varint,4,opt,name=num_write_ops,json=numWriteOps,proto3" json:"num_write_ops,omitempty"`                            // Number of write operations on the device.
	BytesWritten         uint64 `protobuf:"varint,5,opt,name=bytes_written,json=bytesWritten,proto3" json:"bytes_written,omitempty"`                           // Total bytes written on the device.
	NumUnmapOps          uint64 `protobuf:"varint,6,opt,name=num_unmap_ops,json=numUnmapOps,proto3" json:"num_unmap_ops,omitempty"`                            // Number of unmap operations on the device.
	BytesUnmapped        uint64 `protobuf:"varint,7,opt,name=bytes_unmapped,json=bytesUnmapped,proto3" json:"bytes_unmapped,omitempty"`                        // Total bytes unmapped on the device.
	ReadLatencyTicks     uint64 `protobuf:"varint,8,opt,name=read_latency_ticks,json=readLatencyTicks,proto3" json:"read_latency_ticks,omitempty"`             // Total read latency on the device in ticks.
	WriteLatencyTicks    uint64 `protobuf:"varint,9,opt,name=write_latency_ticks,json=writeLatencyTicks,proto3" json:"write_latency_ticks,omitempty"`          // Total write latency on the device in ticks.
	UnmapLatencyTicks    uint64 `protobuf:"varint,10,opt,name=unmap_latency_ticks,json=unmapLatencyTicks,proto3" json:"unmap_latency_ticks,omitempty"`         // Total unmap latency on the device in ticks.
	MaxReadLatencyTicks  uint64 `protobuf:"varint,11,opt,name=max_read_latency_ticks,json=maxReadLatencyTicks,proto3" json:"max_read_latency_ticks,omitempty"` // Max read latency in ticks occurred over num_read_ops.
	MinReadLatencyTicks  uint64 `protobuf:"varint,12,opt,name=min_read_latency_ticks,json=minReadLatencyTicks,proto3" json:"min_read_latency_ticks,omitempty"` // Min read latency in ticks occurred over num_read_ops.
	MaxWriteLatencyTicks uint64 ``                                                                                                                             // Max write latency in ticks occurred over num_write_ops.
	/* 127-byte string literal not displayed */
	MinWriteLatencyTicks uint64 `` // Min write latency in ticks occurred over num_write_ops.
	/* 127-byte string literal not displayed */
	MaxUnmapLatencyTicks uint64 `` // Max unmap latency in ticks occurred over num_unmap_ops.
	/* 127-byte string literal not displayed */
	MinUnmapLatencyTicks uint64 `` // Min unmap latency in ticks occurred over num_unmap_ops.
	/* 127-byte string literal not displayed */
	TickRate uint64 `protobuf:"varint,17,opt,name=tick_rate,json=tickRate,proto3" json:"tick_rate,omitempty"` // Tick rate specific to node hosting the device.
	// contains filtered or unexported fields
}

Common IO stats struct for all resource types.

func (*IoStats) Descriptor deprecated 

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

Deprecated: Use IoStats.ProtoReflect.Descriptor instead.

func (*IoStats) GetBytesRead 

func (x *IoStats) GetBytesRead() uint64

func (*IoStats) GetBytesUnmapped 

func (x *IoStats) GetBytesUnmapped() uint64

func (*IoStats) GetBytesWritten 

func (x *IoStats) GetBytesWritten() uint64

func (*IoStats) GetMaxReadLatencyTicks 

func (x *IoStats) GetMaxReadLatencyTicks() uint64

func (*IoStats) GetMaxUnmapLatencyTicks 

func (x *IoStats) GetMaxUnmapLatencyTicks() uint64

func (*IoStats) GetMaxWriteLatencyTicks 

func (x *IoStats) GetMaxWriteLatencyTicks() uint64

func (*IoStats) GetMinReadLatencyTicks 

func (x *IoStats) GetMinReadLatencyTicks() uint64

func (*IoStats) GetMinUnmapLatencyTicks 

func (x *IoStats) GetMinUnmapLatencyTicks() uint64

func (*IoStats) GetMinWriteLatencyTicks 

func (x *IoStats) GetMinWriteLatencyTicks() uint64

func (*IoStats) GetName 

func (x *IoStats) GetName() string

func (*IoStats) GetNumReadOps 

func (x *IoStats) GetNumReadOps() uint64

func (*IoStats) GetNumUnmapOps 

func (x *IoStats) GetNumUnmapOps() uint64

func (*IoStats) GetNumWriteOps 

func (x *IoStats) GetNumWriteOps() uint64

func (*IoStats) GetReadLatencyTicks 

func (x *IoStats) GetReadLatencyTicks() uint64

func (*IoStats) GetTickRate 

func (x *IoStats) GetTickRate() uint64

func (*IoStats) GetUnmapLatencyTicks 

func (x *IoStats) GetUnmapLatencyTicks() uint64

func (*IoStats) GetWriteLatencyTicks 

func (x *IoStats) GetWriteLatencyTicks() uint64

func (*IoStats) ProtoMessage 

func (*IoStats) ProtoMessage()

func (*IoStats) ProtoReflect 

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

func (*IoStats) Reset 

func (x *IoStats) Reset()

func (*IoStats) String 

func (x *IoStats) String() string

type JsonRpcClient 

type JsonRpcClient interface {
	// Call a (SPDK) json-rpc method
	JsonRpcCall(ctx context.Context, in *JsonRpcRequest, opts ...grpc.CallOption) (*JsonRpcResponse, error)
}

JsonRpcClient is the client API for JsonRpc 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 NewJsonRpcClient 

func NewJsonRpcClient(cc grpc.ClientConnInterface) JsonRpcClient

type JsonRpcRequest 

type JsonRpcRequest struct {
	Method string `protobuf:"bytes,1,opt,name=method,proto3" json:"method,omitempty"`
	Params string `protobuf:"bytes,2,opt,name=params,proto3" json:"params,omitempty"`
	// contains filtered or unexported fields
}

func (*JsonRpcRequest) Descriptor deprecated 

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

Deprecated: Use JsonRpcRequest.ProtoReflect.Descriptor instead.

func (*JsonRpcRequest) GetMethod 

func (x *JsonRpcRequest) GetMethod() string

func (*JsonRpcRequest) GetParams 

func (x *JsonRpcRequest) GetParams() string

func (*JsonRpcRequest) ProtoMessage 

func (*JsonRpcRequest) ProtoMessage()

func (*JsonRpcRequest) ProtoReflect 

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

func (*JsonRpcRequest) Reset 

func (x *JsonRpcRequest) Reset()

func (*JsonRpcRequest) String 

func (x *JsonRpcRequest) String() string

type JsonRpcResponse 

type JsonRpcResponse struct {
	Result string `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}

func (*JsonRpcResponse) Descriptor deprecated 

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

Deprecated: Use JsonRpcResponse.ProtoReflect.Descriptor instead.

func (*JsonRpcResponse) GetResult 

func (x *JsonRpcResponse) GetResult() string

func (*JsonRpcResponse) ProtoMessage 

func (*JsonRpcResponse) ProtoMessage()

func (*JsonRpcResponse) ProtoReflect 

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

func (*JsonRpcResponse) Reset 

func (x *JsonRpcResponse) Reset()

func (*JsonRpcResponse) String 

func (x *JsonRpcResponse) String() string

type JsonRpcServer 

type JsonRpcServer interface {
	// Call a (SPDK) json-rpc method
	JsonRpcCall(context.Context, *JsonRpcRequest) (*JsonRpcResponse, error)
	// contains filtered or unexported methods
}

JsonRpcServer is the server API for JsonRpc service. All implementations must embed UnimplementedJsonRpcServer for forward compatibility

type ListBdevOptions 

type ListBdevOptions struct {
	Name *wrapperspb.StringValue `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*ListBdevOptions) Descriptor deprecated 

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

Deprecated: Use ListBdevOptions.ProtoReflect.Descriptor instead.

func (*ListBdevOptions) GetName 

func (x *ListBdevOptions) GetName() *wrapperspb.StringValue

func (*ListBdevOptions) ProtoMessage 

func (*ListBdevOptions) ProtoMessage()

func (*ListBdevOptions) ProtoReflect 

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

func (*ListBdevOptions) Reset 

func (x *ListBdevOptions) Reset()

func (*ListBdevOptions) String 

func (x *ListBdevOptions) String() string

type ListBdevResponse 

type ListBdevResponse struct {
	Bdevs []*Bdev `protobuf:"bytes,1,rep,name=bdevs,proto3" json:"bdevs,omitempty"`
	// contains filtered or unexported fields
}

func (*ListBdevResponse) Descriptor deprecated 

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

Deprecated: Use ListBdevResponse.ProtoReflect.Descriptor instead.

func (*ListBdevResponse) GetBdevs 

func (x *ListBdevResponse) GetBdevs() []*Bdev

func (*ListBdevResponse) ProtoMessage 

func (*ListBdevResponse) ProtoMessage()

func (*ListBdevResponse) ProtoReflect 

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

func (*ListBdevResponse) Reset 

func (x *ListBdevResponse) Reset()

func (*ListBdevResponse) String 

func (x *ListBdevResponse) String() string

type ListBlockDevicesRequest 

type ListBlockDevicesRequest struct {
	All bool `protobuf:"varint,1,opt,name=all,proto3" json:"all,omitempty"` // list "all" block devices found (not just "available" ones)
	// contains filtered or unexported fields
}

func (*ListBlockDevicesRequest) Descriptor deprecated 

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

Deprecated: Use ListBlockDevicesRequest.ProtoReflect.Descriptor instead.

func (*ListBlockDevicesRequest) GetAll 

func (x *ListBlockDevicesRequest) GetAll() bool

func (*ListBlockDevicesRequest) ProtoMessage 

func (*ListBlockDevicesRequest) ProtoMessage()

func (*ListBlockDevicesRequest) ProtoReflect 

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

func (*ListBlockDevicesRequest) Reset 

func (x *ListBlockDevicesRequest) Reset()

func (*ListBlockDevicesRequest) String 

func (x *ListBlockDevicesRequest) String() string

type ListBlockDevicesResponse 

type ListBlockDevicesResponse struct {
	Devices []*BlockDevice `protobuf:"bytes,1,rep,name=devices,proto3" json:"devices,omitempty"`
	// contains filtered or unexported fields
}

func (*ListBlockDevicesResponse) Descriptor deprecated 

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

Deprecated: Use ListBlockDevicesResponse.ProtoReflect.Descriptor instead.

func (*ListBlockDevicesResponse) GetDevices 

func (x *ListBlockDevicesResponse) GetDevices() []*BlockDevice

func (*ListBlockDevicesResponse) ProtoMessage 

func (*ListBlockDevicesResponse) ProtoMessage()

func (*ListBlockDevicesResponse) ProtoReflect 

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

func (*ListBlockDevicesResponse) Reset 

func (x *ListBlockDevicesResponse) Reset()

func (*ListBlockDevicesResponse) String 

func (x *ListBlockDevicesResponse) String() string

type ListFaultInjectionsReply 

type ListFaultInjectionsReply struct {
	Injections []*FaultInjection `protobuf:"bytes,1,rep,name=injections,proto3" json:"injections,omitempty"`
	// contains filtered or unexported fields
}

func (*ListFaultInjectionsReply) Descriptor deprecated 

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

Deprecated: Use ListFaultInjectionsReply.ProtoReflect.Descriptor instead.

func (*ListFaultInjectionsReply) GetInjections 

func (x *ListFaultInjectionsReply) GetInjections() []*FaultInjection

func (*ListFaultInjectionsReply) ProtoMessage 

func (*ListFaultInjectionsReply) ProtoMessage()

func (*ListFaultInjectionsReply) ProtoReflect 

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

func (*ListFaultInjectionsReply) Reset 

func (x *ListFaultInjectionsReply) Reset()

func (*ListFaultInjectionsReply) String 

func (x *ListFaultInjectionsReply) String() string

type ListFaultInjectionsRequest 

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

func (*ListFaultInjectionsRequest) Descriptor deprecated 

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

Deprecated: Use ListFaultInjectionsRequest.ProtoReflect.Descriptor instead.

func (*ListFaultInjectionsRequest) ProtoMessage 

func (*ListFaultInjectionsRequest) ProtoMessage()

func (*ListFaultInjectionsRequest) ProtoReflect 

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

func (*ListFaultInjectionsRequest) Reset 

func (x *ListFaultInjectionsRequest) Reset()

func (*ListFaultInjectionsRequest) String 

func (x *ListFaultInjectionsRequest) String() string

type ListNexusOptions 

type ListNexusOptions struct {

	// list the nexuses matching the name if provided
	Name *wrapperspb.StringValue `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// list the nexus matching the uuid if provided
	Uuid *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=uuid,proto3" json:"uuid,omitempty"`
	// contains filtered or unexported fields
}

func (*ListNexusOptions) Descriptor deprecated 

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

Deprecated: Use ListNexusOptions.ProtoReflect.Descriptor instead.

func (*ListNexusOptions) GetName 

func (x *ListNexusOptions) GetName() *wrapperspb.StringValue

func (*ListNexusOptions) GetUuid 

func (x *ListNexusOptions) GetUuid() *wrapperspb.StringValue

func (*ListNexusOptions) ProtoMessage 

func (*ListNexusOptions) ProtoMessage()

func (*ListNexusOptions) ProtoReflect 

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

func (*ListNexusOptions) Reset 

func (x *ListNexusOptions) Reset()

func (*ListNexusOptions) String 

func (x *ListNexusOptions) String() string

type ListNexusResponse 

type ListNexusResponse struct {
	NexusList []*Nexus `protobuf:"bytes,1,rep,name=nexus_list,json=nexusList,proto3" json:"nexus_list,omitempty"`
	// contains filtered or unexported fields
}

func (*ListNexusResponse) Descriptor deprecated 

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

Deprecated: Use ListNexusResponse.ProtoReflect.Descriptor instead.

func (*ListNexusResponse) GetNexusList 

func (x *ListNexusResponse) GetNexusList() []*Nexus

func (*ListNexusResponse) ProtoMessage 

func (*ListNexusResponse) ProtoMessage()

func (*ListNexusResponse) ProtoReflect 

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

func (*ListNexusResponse) Reset 

func (x *ListNexusResponse) Reset()

func (*ListNexusResponse) String 

func (x *ListNexusResponse) String() string

type ListNvmeControllersResponse 

type ListNvmeControllersResponse struct {
	Controllers []*NvmeController `protobuf:"bytes,1,rep,name=controllers,proto3" json:"controllers,omitempty"`
	// contains filtered or unexported fields
}

func (*ListNvmeControllersResponse) Descriptor deprecated 

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

Deprecated: Use ListNvmeControllersResponse.ProtoReflect.Descriptor instead.

func (*ListNvmeControllersResponse) GetControllers 

func (x *ListNvmeControllersResponse) GetControllers() []*NvmeController

func (*ListNvmeControllersResponse) ProtoMessage 

func (*ListNvmeControllersResponse) ProtoMessage()

func (*ListNvmeControllersResponse) ProtoReflect 

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

func (*ListNvmeControllersResponse) Reset 

func (x *ListNvmeControllersResponse) Reset()

func (*ListNvmeControllersResponse) String 

func (x *ListNvmeControllersResponse) String() string

type ListPoolOptions 

type ListPoolOptions struct {
	Name     *wrapperspb.StringValue `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`         // list the pools matching the name if provided
	Pooltype *PoolTypeValue          `protobuf:"bytes,2,opt,name=pooltype,proto3" json:"pooltype,omitempty"` // optional pooltype filter
	Uuid     *wrapperspb.StringValue `protobuf:"bytes,3,opt,name=uuid,proto3" json:"uuid,omitempty"`         // get the pool matching the uuid if provided
	// contains filtered or unexported fields
}

func (*ListPoolOptions) Descriptor deprecated 

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

Deprecated: Use ListPoolOptions.ProtoReflect.Descriptor instead.

func (*ListPoolOptions) GetName 

func (x *ListPoolOptions) GetName() *wrapperspb.StringValue

func (*ListPoolOptions) GetPooltype 

func (x *ListPoolOptions) GetPooltype() *PoolTypeValue

func (*ListPoolOptions) GetUuid 

func (x *ListPoolOptions) GetUuid() *wrapperspb.StringValue

func (*ListPoolOptions) ProtoMessage 

func (*ListPoolOptions) ProtoMessage()

func (*ListPoolOptions) ProtoReflect 

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

func (*ListPoolOptions) Reset 

func (x *ListPoolOptions) Reset()

func (*ListPoolOptions) String 

func (x *ListPoolOptions) String() string

type ListPoolsResponse 

type ListPoolsResponse struct {
	Pools []*Pool `protobuf:"bytes,1,rep,name=pools,proto3" json:"pools,omitempty"` // list of the pools
	// contains filtered or unexported fields
}

List of pools and their properties.

func (*ListPoolsResponse) Descriptor deprecated 

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

Deprecated: Use ListPoolsResponse.ProtoReflect.Descriptor instead.

func (*ListPoolsResponse) GetPools 

func (x *ListPoolsResponse) GetPools() []*Pool

func (*ListPoolsResponse) ProtoMessage 

func (*ListPoolsResponse) ProtoMessage()

func (*ListPoolsResponse) ProtoReflect 

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

func (*ListPoolsResponse) Reset 

func (x *ListPoolsResponse) Reset()

func (*ListPoolsResponse) String 

func (x *ListPoolsResponse) String() string

type ListRebuildHistoryRequest 

type ListRebuildHistoryRequest struct {
	Count        *uint32                `protobuf:"varint,1,opt,name=count,proto3,oneof" json:"count,omitempty"`                                    // Maximum of rebuild records to be returned per nexus.
	SinceEndTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=since_end_time,json=sinceEndTime,proto3,oneof" json:"since_end_time,omitempty"` // List records with an end_time starting from this timestamp.
	// contains filtered or unexported fields
}

func (*ListRebuildHistoryRequest) Descriptor deprecated 

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

Deprecated: Use ListRebuildHistoryRequest.ProtoReflect.Descriptor instead.

func (*ListRebuildHistoryRequest) GetCount 

func (x *ListRebuildHistoryRequest) GetCount() uint32

func (*ListRebuildHistoryRequest) GetSinceEndTime 

func (x *ListRebuildHistoryRequest) GetSinceEndTime() *timestamppb.Timestamp

func (*ListRebuildHistoryRequest) ProtoMessage 

func (*ListRebuildHistoryRequest) ProtoMessage()

func (*ListRebuildHistoryRequest) ProtoReflect 

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

func (*ListRebuildHistoryRequest) Reset 

func (x *ListRebuildHistoryRequest) Reset()

func (*ListRebuildHistoryRequest) String 

func (x *ListRebuildHistoryRequest) String() string

type ListRebuildHistoryResponse 

type ListRebuildHistoryResponse struct {
	Histories map[string]*RebuildHistoryResponse `` // Map of Nexus Id and its rebuild history.
	/* 159-byte string literal not displayed */
	EndTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"` // Newest end_time record. Next List call can use this as since_end_time.
	// contains filtered or unexported fields
}

func (*ListRebuildHistoryResponse) Descriptor deprecated 

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

Deprecated: Use ListRebuildHistoryResponse.ProtoReflect.Descriptor instead.

func (*ListRebuildHistoryResponse) GetEndTime 

func (x *ListRebuildHistoryResponse) GetEndTime() *timestamppb.Timestamp

func (*ListRebuildHistoryResponse) GetHistories 

func (x *ListRebuildHistoryResponse) GetHistories() map[string]*RebuildHistoryResponse

func (*ListRebuildHistoryResponse) ProtoMessage 

func (*ListRebuildHistoryResponse) ProtoMessage()

func (*ListRebuildHistoryResponse) ProtoReflect 

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

func (*ListRebuildHistoryResponse) Reset 

func (x *ListRebuildHistoryResponse) Reset()

func (*ListRebuildHistoryResponse) String 

func (x *ListRebuildHistoryResponse) String() string

type ListReplicaOptions 

type ListReplicaOptions struct {
	Name     *wrapperspb.StringValue   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`         // list the replica with the name if provided
	Poolname *wrapperspb.StringValue   `protobuf:"bytes,2,opt,name=poolname,proto3" json:"poolname,omitempty"` // list the replicas on the provided pool, by name
	Uuid     *wrapperspb.StringValue   `protobuf:"bytes,3,opt,name=uuid,proto3" json:"uuid,omitempty"`         // list the replica with the uuid if provided
	Pooluuid *wrapperspb.StringValue   `protobuf:"bytes,4,opt,name=pooluuid,proto3" json:"pooluuid,omitempty"` // list the replicas on the provided pool, by uuid
	Query    *ListReplicaOptions_Query `protobuf:"bytes,5,opt,name=query,proto3" json:"query,omitempty"`       // list replica based on Query value
	// contains filtered or unexported fields
}

func (*ListReplicaOptions) Descriptor deprecated 

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

Deprecated: Use ListReplicaOptions.ProtoReflect.Descriptor instead.

func (*ListReplicaOptions) GetName 

func (x *ListReplicaOptions) GetName() *wrapperspb.StringValue

func (*ListReplicaOptions) GetPoolname 

func (x *ListReplicaOptions) GetPoolname() *wrapperspb.StringValue

func (*ListReplicaOptions) GetPooluuid 

func (x *ListReplicaOptions) GetPooluuid() *wrapperspb.StringValue

func (*ListReplicaOptions) GetQuery 

func (x *ListReplicaOptions) GetQuery() *ListReplicaOptions_Query

func (*ListReplicaOptions) GetUuid 

func (x *ListReplicaOptions) GetUuid() *wrapperspb.StringValue

func (*ListReplicaOptions) ProtoMessage 

func (*ListReplicaOptions) ProtoMessage()

func (*ListReplicaOptions) ProtoReflect 

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

func (*ListReplicaOptions) Reset 

func (x *ListReplicaOptions) Reset()

func (*ListReplicaOptions) String 

func (x *ListReplicaOptions) String() string

type ListReplicaOptions_Query 

type ListReplicaOptions_Query struct {
	Replica  bool `protobuf:"varint,1,opt,name=replica,proto3" json:"replica,omitempty"`   // query for selecting or normal replica types.
	Snapshot bool `protobuf:"varint,2,opt,name=snapshot,proto3" json:"snapshot,omitempty"` // query for selecting or snapshot types.
	Clone    bool `protobuf:"varint,3,opt,name=clone,proto3" json:"clone,omitempty"`       // query for selecting or clone types.
	// contains filtered or unexported fields
}

/ Query used for getting specific types of replicas. These are mutually exclusive, ex. a snapshot cannot be clone.

func (*ListReplicaOptions_Query) Descriptor deprecated 

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

Deprecated: Use ListReplicaOptions_Query.ProtoReflect.Descriptor instead.

func (*ListReplicaOptions_Query) GetClone 

func (x *ListReplicaOptions_Query) GetClone() bool

func (*ListReplicaOptions_Query) GetReplica 

func (x *ListReplicaOptions_Query) GetReplica() bool

func (*ListReplicaOptions_Query) GetSnapshot 

func (x *ListReplicaOptions_Query) GetSnapshot() bool

func (*ListReplicaOptions_Query) ProtoMessage 

func (*ListReplicaOptions_Query) ProtoMessage()

func (*ListReplicaOptions_Query) ProtoReflect 

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

func (*ListReplicaOptions_Query) Reset 

func (x *ListReplicaOptions_Query) Reset()

func (*ListReplicaOptions_Query) String 

func (x *ListReplicaOptions_Query) String() string

type ListReplicasResponse 

type ListReplicasResponse struct {
	Replicas []*Replica `protobuf:"bytes,1,rep,name=replicas,proto3" json:"replicas,omitempty"` // list of the replicas
	// contains filtered or unexported fields
}

List of replicas and their properties.

func (*ListReplicasResponse) Descriptor deprecated 

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

Deprecated: Use ListReplicasResponse.ProtoReflect.Descriptor instead.

func (*ListReplicasResponse) GetReplicas 

func (x *ListReplicasResponse) GetReplicas() []*Replica

func (*ListReplicasResponse) ProtoMessage 

func (*ListReplicasResponse) ProtoMessage()

func (*ListReplicasResponse) ProtoReflect 

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

func (*ListReplicasResponse) Reset 

func (x *ListReplicasResponse) Reset()

func (*ListReplicasResponse) String 

func (x *ListReplicasResponse) String() string

type ListSnapshotCloneRequest 

type ListSnapshotCloneRequest struct {
	SnapshotUuid *string `protobuf:"bytes,1,opt,name=snapshot_uuid,json=snapshotUuid,proto3,oneof" json:"snapshot_uuid,omitempty"` // if snapshot uuid is present, return snapshot specific clone, else return all clones
	// contains filtered or unexported fields
}

Request Parameters for List Snapshot Clone.

func (*ListSnapshotCloneRequest) Descriptor deprecated 

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

Deprecated: Use ListSnapshotCloneRequest.ProtoReflect.Descriptor instead.

func (*ListSnapshotCloneRequest) GetSnapshotUuid 

func (x *ListSnapshotCloneRequest) GetSnapshotUuid() string

func (*ListSnapshotCloneRequest) ProtoMessage 

func (*ListSnapshotCloneRequest) ProtoMessage()

func (*ListSnapshotCloneRequest) ProtoReflect 

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

func (*ListSnapshotCloneRequest) Reset 

func (x *ListSnapshotCloneRequest) Reset()

func (*ListSnapshotCloneRequest) String 

func (x *ListSnapshotCloneRequest) String() string

type ListSnapshotCloneResponse 

type ListSnapshotCloneResponse struct {
	Replicas []*Replica `protobuf:"bytes,1,rep,name=replicas,proto3" json:"replicas,omitempty"` // list of the replicas
	// contains filtered or unexported fields
}

Response Parameters for List Snapshot Clone.

func (*ListSnapshotCloneResponse) Descriptor deprecated 

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

Deprecated: Use ListSnapshotCloneResponse.ProtoReflect.Descriptor instead.

func (*ListSnapshotCloneResponse) GetReplicas 

func (x *ListSnapshotCloneResponse) GetReplicas() []*Replica

func (*ListSnapshotCloneResponse) ProtoMessage 

func (*ListSnapshotCloneResponse) ProtoMessage()

func (*ListSnapshotCloneResponse) ProtoReflect 

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

func (*ListSnapshotCloneResponse) Reset 

func (x *ListSnapshotCloneResponse) Reset()

func (*ListSnapshotCloneResponse) String 

func (x *ListSnapshotCloneResponse) String() string

type ListSnapshotsRequest 

type ListSnapshotsRequest struct {
	SourceUuid   *string                     `protobuf:"bytes,1,opt,name=source_uuid,json=sourceUuid,proto3,oneof" json:"source_uuid,omitempty"`       // source uuid from which snapshot is taken
	SnapshotUuid *string                     `protobuf:"bytes,2,opt,name=snapshot_uuid,json=snapshotUuid,proto3,oneof" json:"snapshot_uuid,omitempty"` // snapshot uuid for which the detail can be listed
	Query        *ListSnapshotsRequest_Query `protobuf:"bytes,3,opt,name=query,proto3" json:"query,omitempty"`                                         // list snapshot based on Query's inner field values if some.
	// contains filtered or unexported fields
}

Request parameters to list snapshot.

func (*ListSnapshotsRequest) Descriptor deprecated 

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

Deprecated: Use ListSnapshotsRequest.ProtoReflect.Descriptor instead.

func (*ListSnapshotsRequest) GetQuery 

func (x *ListSnapshotsRequest) GetQuery() *ListSnapshotsRequest_Query

func (*ListSnapshotsRequest) GetSnapshotUuid 

func (x *ListSnapshotsRequest) GetSnapshotUuid() string

func (*ListSnapshotsRequest) GetSourceUuid 

func (x *ListSnapshotsRequest) GetSourceUuid() string

func (*ListSnapshotsRequest) ProtoMessage 

func (*ListSnapshotsRequest) ProtoMessage()

func (*ListSnapshotsRequest) ProtoReflect 

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

func (*ListSnapshotsRequest) Reset 

func (x *ListSnapshotsRequest) Reset()

func (*ListSnapshotsRequest) String 

func (x *ListSnapshotsRequest) String() string

type ListSnapshotsRequest_Query 

type ListSnapshotsRequest_Query struct {
	Invalid   *bool `protobuf:"varint,1,opt,name=invalid,proto3,oneof" json:"invalid,omitempty"`     // Filter based on invalid if some.
	Discarded *bool `protobuf:"varint,2,opt,name=discarded,proto3,oneof" json:"discarded,omitempty"` // Filter based on discarded if some.
	// contains filtered or unexported fields
}

Query is used to filter snapshots in list snapshot response based on it's inner field values if some.

func (*ListSnapshotsRequest_Query) Descriptor deprecated 

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

Deprecated: Use ListSnapshotsRequest_Query.ProtoReflect.Descriptor instead.

func (*ListSnapshotsRequest_Query) GetDiscarded 

func (x *ListSnapshotsRequest_Query) GetDiscarded() bool

func (*ListSnapshotsRequest_Query) GetInvalid 

func (x *ListSnapshotsRequest_Query) GetInvalid() bool

func (*ListSnapshotsRequest_Query) ProtoMessage 

func (*ListSnapshotsRequest_Query) ProtoMessage()

func (*ListSnapshotsRequest_Query) ProtoReflect 

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

func (*ListSnapshotsRequest_Query) Reset 

func (x *ListSnapshotsRequest_Query) Reset()

func (*ListSnapshotsRequest_Query) String 

func (x *ListSnapshotsRequest_Query) String() string

type ListSnapshotsResponse 

type ListSnapshotsResponse struct {
	Snapshots []*SnapshotInfo `protobuf:"bytes,1,rep,name=snapshots,proto3" json:"snapshots,omitempty"` // list of Snapshot Params.
	// contains filtered or unexported fields
}

List Snapshot Response.

func (*ListSnapshotsResponse) Descriptor deprecated 

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

Deprecated: Use ListSnapshotsResponse.ProtoReflect.Descriptor instead.

func (*ListSnapshotsResponse) GetSnapshots 

func (x *ListSnapshotsResponse) GetSnapshots() []*SnapshotInfo

func (*ListSnapshotsResponse) ProtoMessage 

func (*ListSnapshotsResponse) ProtoMessage()

func (*ListSnapshotsResponse) ProtoReflect 

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

func (*ListSnapshotsResponse) Reset 

func (x *ListSnapshotsResponse) Reset()

func (*ListSnapshotsResponse) String 

func (x *ListSnapshotsResponse) String() string

type ListStatsOption 

type ListStatsOption struct {
	Name *string `protobuf:"bytes,1,opt,name=name,proto3,oneof" json:"name,omitempty"` // If specified, returns IO stats of only specified resource.
	// contains filtered or unexported fields
}

func (*ListStatsOption) Descriptor deprecated 

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

Deprecated: Use ListStatsOption.ProtoReflect.Descriptor instead.

func (*ListStatsOption) GetName 

func (x *ListStatsOption) GetName() string

func (*ListStatsOption) ProtoMessage 

func (*ListStatsOption) ProtoMessage()

func (*ListStatsOption) ProtoReflect 

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

func (*ListStatsOption) Reset 

func (x *ListStatsOption) Reset()

func (*ListStatsOption) String 

func (x *ListStatsOption) String() string

type MayastorFeatures 

type MayastorFeatures struct {
	AsymmetricNamespaceAccess bool `protobuf:"varint,1,opt,name=asymmetricNamespaceAccess,proto3" json:"asymmetricNamespaceAccess,omitempty"`
	// contains filtered or unexported fields
}

func (*MayastorFeatures) Descriptor deprecated 

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

Deprecated: Use MayastorFeatures.ProtoReflect.Descriptor instead.

func (*MayastorFeatures) GetAsymmetricNamespaceAccess 

func (x *MayastorFeatures) GetAsymmetricNamespaceAccess() bool

func (*MayastorFeatures) ProtoMessage 

func (*MayastorFeatures) ProtoMessage()

func (*MayastorFeatures) ProtoReflect 

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

func (*MayastorFeatures) Reset 

func (x *MayastorFeatures) Reset()

func (*MayastorFeatures) String 

func (x *MayastorFeatures) String() string

type MayastorInfoResponse 

type MayastorInfoResponse struct {
	Version           string            `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
	SupportedFeatures *MayastorFeatures `protobuf:"bytes,2,opt,name=supportedFeatures,proto3" json:"supportedFeatures,omitempty"`
	RegistrationInfo  *RegisterRequest  `protobuf:"bytes,3,opt,name=registration_info,json=registrationInfo,proto3" json:"registration_info,omitempty"`
	// contains filtered or unexported fields
}

func (*MayastorInfoResponse) Descriptor deprecated 

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

Deprecated: Use MayastorInfoResponse.ProtoReflect.Descriptor instead.

func (*MayastorInfoResponse) GetRegistrationInfo 

func (x *MayastorInfoResponse) GetRegistrationInfo() *RegisterRequest

func (*MayastorInfoResponse) GetSupportedFeatures 

func (x *MayastorInfoResponse) GetSupportedFeatures() *MayastorFeatures

func (*MayastorInfoResponse) GetVersion 

func (x *MayastorInfoResponse) GetVersion() string

func (*MayastorInfoResponse) ProtoMessage 

func (*MayastorInfoResponse) ProtoMessage()

func (*MayastorInfoResponse) ProtoReflect 

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

func (*MayastorInfoResponse) Reset 

func (x *MayastorInfoResponse) Reset()

func (*MayastorInfoResponse) String 

func (x *MayastorInfoResponse) String() string

type Nexus 

type Nexus struct {
	Name     string     `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`                                // name of the nexus
	Uuid     string     `protobuf:"bytes,2,opt,name=uuid,proto3" json:"uuid,omitempty"`                                // UUID of the bdev
	Size     uint64     `protobuf:"varint,3,opt,name=size,proto3" json:"size,omitempty"`                               // size of the volume in bytes
	State    NexusState `protobuf:"varint,4,opt,name=state,proto3,enum=mayastor.v1.NexusState" json:"state,omitempty"` // current state of the nexus
	Children []*Child   `protobuf:"bytes,5,rep,name=children,proto3" json:"children,omitempty"`                        // array of children
	// URI of the device for the volume (missing if not published).
	// Missing property and empty string are treated the same.
	DeviceUri    string       `protobuf:"bytes,6,opt,name=device_uri,json=deviceUri,proto3" json:"device_uri,omitempty"`
	Rebuilds     uint32       `protobuf:"varint,7,opt,name=rebuilds,proto3" json:"rebuilds,omitempty"`                                               // total number of rebuild tasks
	AnaState     NvmeAnaState `protobuf:"varint,8,opt,name=ana_state,json=anaState,proto3,enum=mayastor.v1.NvmeAnaState" json:"ana_state,omitempty"` // Nexus ANA state.
	AllowedHosts []string     `protobuf:"bytes,9,rep,name=allowed_hosts,json=allowedHosts,proto3" json:"allowed_hosts,omitempty"`                    // host (nqn's) which are allowed to connect to the target
	// contains filtered or unexported fields
}

represents a nexus device

func (*Nexus) Descriptor deprecated 

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

Deprecated: Use Nexus.ProtoReflect.Descriptor instead.

func (*Nexus) GetAllowedHosts 

func (x *Nexus) GetAllowedHosts() []string

func (*Nexus) GetAnaState 

func (x *Nexus) GetAnaState() NvmeAnaState

func (*Nexus) GetChildren 

func (x *Nexus) GetChildren() []*Child

func (*Nexus) GetDeviceUri 

func (x *Nexus) GetDeviceUri() string

func (*Nexus) GetName 

func (x *Nexus) GetName() string

func (*Nexus) GetRebuilds 

func (x *Nexus) GetRebuilds() uint32

func (*Nexus) GetSize 

func (x *Nexus) GetSize() uint64

func (*Nexus) GetState 

func (x *Nexus) GetState() NexusState

func (*Nexus) GetUuid 

func (x *Nexus) GetUuid() string

func (*Nexus) ProtoMessage 

func (*Nexus) ProtoMessage()

func (*Nexus) ProtoReflect 

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

func (*Nexus) Reset 

func (x *Nexus) Reset()

func (*Nexus) String 

func (x *Nexus) String() string

type NexusCreateSnapshotReplicaDescriptor 

type NexusCreateSnapshotReplicaDescriptor struct {
	ReplicaUuid  string  `protobuf:"bytes,1,opt,name=replica_uuid,json=replicaUuid,proto3" json:"replica_uuid,omitempty"`          // uuid of the replica
	SnapshotUuid *string `protobuf:"bytes,2,opt,name=snapshot_uuid,json=snapshotUuid,proto3,oneof" json:"snapshot_uuid,omitempty"` // uuid of the snapshot (can be omitted if replica is skipped)
	Skip         bool    `protobuf:"varint,3,opt,name=skip,proto3" json:"skip,omitempty"`                                          // skip this replica
	// contains filtered or unexported fields
}

func (*NexusCreateSnapshotReplicaDescriptor) Descriptor deprecated 

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

Deprecated: Use NexusCreateSnapshotReplicaDescriptor.ProtoReflect.Descriptor instead.

func (*NexusCreateSnapshotReplicaDescriptor) GetReplicaUuid 

func (x *NexusCreateSnapshotReplicaDescriptor) GetReplicaUuid() string

func (*NexusCreateSnapshotReplicaDescriptor) GetSkip 

func (x *NexusCreateSnapshotReplicaDescriptor) GetSkip() bool

func (*NexusCreateSnapshotReplicaDescriptor) GetSnapshotUuid 

func (x *NexusCreateSnapshotReplicaDescriptor) GetSnapshotUuid() string

func (*NexusCreateSnapshotReplicaDescriptor) ProtoMessage 

func (*NexusCreateSnapshotReplicaDescriptor) ProtoMessage()

func (*NexusCreateSnapshotReplicaDescriptor) ProtoReflect 

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

func (*NexusCreateSnapshotReplicaDescriptor) Reset 

func (x *NexusCreateSnapshotReplicaDescriptor) Reset()

func (*NexusCreateSnapshotReplicaDescriptor) String 

func (x *NexusCreateSnapshotReplicaDescriptor) String() string

type NexusCreateSnapshotReplicaStatus 

type NexusCreateSnapshotReplicaStatus struct {
	ReplicaUuid string `protobuf:"bytes,1,opt,name=replica_uuid,json=replicaUuid,proto3" json:"replica_uuid,omitempty"` // uuid of the replica
	StatusCode  uint32 `protobuf:"varint,2,opt,name=status_code,json=statusCode,proto3" json:"status_code,omitempty"`   // snapshot operation status (0 means successful completion)
	// contains filtered or unexported fields
}

func (*NexusCreateSnapshotReplicaStatus) Descriptor deprecated 

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

Deprecated: Use NexusCreateSnapshotReplicaStatus.ProtoReflect.Descriptor instead.

func (*NexusCreateSnapshotReplicaStatus) GetReplicaUuid 

func (x *NexusCreateSnapshotReplicaStatus) GetReplicaUuid() string

func (*NexusCreateSnapshotReplicaStatus) GetStatusCode 

func (x *NexusCreateSnapshotReplicaStatus) GetStatusCode() uint32

func (*NexusCreateSnapshotReplicaStatus) ProtoMessage 

func (*NexusCreateSnapshotReplicaStatus) ProtoMessage()

func (*NexusCreateSnapshotReplicaStatus) ProtoReflect 

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

func (*NexusCreateSnapshotReplicaStatus) Reset 

func (x *NexusCreateSnapshotReplicaStatus) Reset()

func (*NexusCreateSnapshotReplicaStatus) String 

func (x *NexusCreateSnapshotReplicaStatus) String() string

type NexusCreateSnapshotRequest 

type NexusCreateSnapshotRequest struct {
	NexusUuid    string                                  `protobuf:"bytes,1,opt,name=nexus_uuid,json=nexusUuid,proto3" json:"nexus_uuid,omitempty"`          // uuid of the nexus
	EntityId     string                                  `protobuf:"bytes,2,opt,name=entity_id,json=entityId,proto3" json:"entity_id,omitempty"`             // entity associated with this snapshot
	TxnId        string                                  `protobuf:"bytes,3,opt,name=txn_id,json=txnId,proto3" json:"txn_id,omitempty"`                      // transaction id of the snapshot
	SnapshotName string                                  `protobuf:"bytes,4,opt,name=snapshot_name,json=snapshotName,proto3" json:"snapshot_name,omitempty"` // name of the snapshot
	Replicas     []*NexusCreateSnapshotReplicaDescriptor `protobuf:"bytes,5,rep,name=replicas,proto3" json:"replicas,omitempty"`                             // replicas that participate in snapshot operation
	// contains filtered or unexported fields
}

Request parameter for Nexus Snapshot Create.

func (*NexusCreateSnapshotRequest) Descriptor deprecated 

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

Deprecated: Use NexusCreateSnapshotRequest.ProtoReflect.Descriptor instead.

func (*NexusCreateSnapshotRequest) GetEntityId 

func (x *NexusCreateSnapshotRequest) GetEntityId() string

func (*NexusCreateSnapshotRequest) GetNexusUuid 

func (x *NexusCreateSnapshotRequest) GetNexusUuid() string

func (*NexusCreateSnapshotRequest) GetReplicas 

func (x *NexusCreateSnapshotRequest) GetReplicas() []*NexusCreateSnapshotReplicaDescriptor

func (*NexusCreateSnapshotRequest) GetSnapshotName 

func (x *NexusCreateSnapshotRequest) GetSnapshotName() string

func (*NexusCreateSnapshotRequest) GetTxnId 

func (x *NexusCreateSnapshotRequest) GetTxnId() string

func (*NexusCreateSnapshotRequest) ProtoMessage 

func (*NexusCreateSnapshotRequest) ProtoMessage()

func (*NexusCreateSnapshotRequest) ProtoReflect 

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

func (*NexusCreateSnapshotRequest) Reset 

func (x *NexusCreateSnapshotRequest) Reset()

func (*NexusCreateSnapshotRequest) String 

func (x *NexusCreateSnapshotRequest) String() string

type NexusCreateSnapshotResponse 

type NexusCreateSnapshotResponse struct {
	Nexus             *Nexus                              `protobuf:"bytes,1,opt,name=nexus,proto3" json:"nexus,omitempty"`                                                  // nexus descriptor
	SnapshotTimestamp *timestamppb.Timestamp              `protobuf:"bytes,2,opt,name=snapshot_timestamp,json=snapshotTimestamp,proto3" json:"snapshot_timestamp,omitempty"` // snapshot creation timestamp
	ReplicasDone      []*NexusCreateSnapshotReplicaStatus `protobuf:"bytes,3,rep,name=replicas_done,json=replicasDone,proto3" json:"replicas_done,omitempty"`                // status for replicas that participated in nexus snapshot operation
	ReplicasSkipped   []string                            `protobuf:"bytes,4,rep,name=replicas_skipped,json=replicasSkipped,proto3" json:"replicas_skipped,omitempty"`       // replicas that did not participate in nexus snapshot operation (uuids)
	// contains filtered or unexported fields
}

Response parameter for Nexus Snapshot Create.

func (*NexusCreateSnapshotResponse) Descriptor deprecated 

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

Deprecated: Use NexusCreateSnapshotResponse.ProtoReflect.Descriptor instead.

func (*NexusCreateSnapshotResponse) GetNexus 

func (x *NexusCreateSnapshotResponse) GetNexus() *Nexus

func (*NexusCreateSnapshotResponse) GetReplicasDone 

func (x *NexusCreateSnapshotResponse) GetReplicasDone() []*NexusCreateSnapshotReplicaStatus

func (*NexusCreateSnapshotResponse) GetReplicasSkipped 

func (x *NexusCreateSnapshotResponse) GetReplicasSkipped() []string

func (*NexusCreateSnapshotResponse) GetSnapshotTimestamp 

func (x *NexusCreateSnapshotResponse) GetSnapshotTimestamp() *timestamppb.Timestamp

func (*NexusCreateSnapshotResponse) ProtoMessage 

func (*NexusCreateSnapshotResponse) ProtoMessage()

func (*NexusCreateSnapshotResponse) ProtoReflect 

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

func (*NexusCreateSnapshotResponse) Reset 

func (x *NexusCreateSnapshotResponse) Reset()

func (*NexusCreateSnapshotResponse) String 

func (x *NexusCreateSnapshotResponse) String() string

type NexusNvmePreemption 

type NexusNvmePreemption int32

/ Nexus NVMe preemption policy. 

const (
	NexusNvmePreemption_ArgKey NexusNvmePreemption = 0 // preempts using the preemptKey argument, if any
	NexusNvmePreemption_Holder NexusNvmePreemption = 1 // preempts the current reservation holder, if any
)

func (NexusNvmePreemption) Descriptor 

func (NexusNvmePreemption) Descriptor() protoreflect.EnumDescriptor

func (NexusNvmePreemption) Enum 

func (x NexusNvmePreemption) Enum() *NexusNvmePreemption

func (NexusNvmePreemption) EnumDescriptor deprecated 

func (NexusNvmePreemption) EnumDescriptor() ([]byte, []int)

Deprecated: Use NexusNvmePreemption.Descriptor instead.

func (NexusNvmePreemption) Number 

func (x NexusNvmePreemption) Number() protoreflect.EnumNumber

func (NexusNvmePreemption) String 

func (x NexusNvmePreemption) String() string

func (NexusNvmePreemption) Type 

func (NexusNvmePreemption) Type() protoreflect.EnumType

type NexusRpcClient 

type NexusRpcClient interface {
	CreateNexus(ctx context.Context, in *CreateNexusRequest, opts ...grpc.CallOption) (*CreateNexusResponse, error)
	DestroyNexus(ctx context.Context, in *DestroyNexusRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	ListNexus(ctx context.Context, in *ListNexusOptions, opts ...grpc.CallOption) (*ListNexusResponse, error)
	AddChildNexus(ctx context.Context, in *AddChildNexusRequest, opts ...grpc.CallOption) (*AddChildNexusResponse, error)
	RemoveChildNexus(ctx context.Context, in *RemoveChildNexusRequest, opts ...grpc.CallOption) (*RemoveChildNexusResponse, error)
	// take a child offline permanently; exactly the same ChildOperation OfflinePermanent
	FaultNexusChild(ctx context.Context, in *FaultNexusChildRequest, opts ...grpc.CallOption) (*FaultNexusChildResponse, error)
	ShutdownNexus(ctx context.Context, in *ShutdownNexusRequest, opts ...grpc.CallOption) (*ShutdownNexusResponse, error)
	// This method is called by control plane to construct a block device
	// (/dev/...) that will be used to connect the nexus to the OS.
	PublishNexus(ctx context.Context, in *PublishNexusRequest, opts ...grpc.CallOption) (*PublishNexusResponse, error)
	UnpublishNexus(ctx context.Context, in *UnpublishNexusRequest, opts ...grpc.CallOption) (*UnpublishNexusResponse, error)
	// NVMe ANA state
	GetNvmeAnaState(ctx context.Context, in *GetNvmeAnaStateRequest, opts ...grpc.CallOption) (*GetNvmeAnaStateResponse, error)
	SetNvmeAnaState(ctx context.Context, in *SetNvmeAnaStateRequest, opts ...grpc.CallOption) (*SetNvmeAnaStateResponse, error)
	// Nexus child operations
	ChildOperation(ctx context.Context, in *ChildOperationRequest, opts ...grpc.CallOption) (*ChildOperationResponse, error)
	// Rebuild operations
	StartRebuild(ctx context.Context, in *StartRebuildRequest, opts ...grpc.CallOption) (*StartRebuildResponse, error)
	StopRebuild(ctx context.Context, in *StopRebuildRequest, opts ...grpc.CallOption) (*StopRebuildResponse, error)
	PauseRebuild(ctx context.Context, in *PauseRebuildRequest, opts ...grpc.CallOption) (*PauseRebuildResponse, error)
	ResumeRebuild(ctx context.Context, in *ResumeRebuildRequest, opts ...grpc.CallOption) (*ResumeRebuildResponse, error)
	GetRebuildState(ctx context.Context, in *RebuildStateRequest, opts ...grpc.CallOption) (*RebuildStateResponse, error)
	GetRebuildStats(ctx context.Context, in *RebuildStatsRequest, opts ...grpc.CallOption) (*RebuildStatsResponse, error)
	GetRebuildHistory(ctx context.Context, in *RebuildHistoryRequest, opts ...grpc.CallOption) (*RebuildHistoryResponse, error)
	ListRebuildHistory(ctx context.Context, in *ListRebuildHistoryRequest, opts ...grpc.CallOption) (*ListRebuildHistoryResponse, error)
}

NexusRpcClient is the client API for NexusRpc 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 NewNexusRpcClient 

func NewNexusRpcClient(cc grpc.ClientConnInterface) NexusRpcClient

type NexusRpcServer 

type NexusRpcServer interface {
	CreateNexus(context.Context, *CreateNexusRequest) (*CreateNexusResponse, error)
	DestroyNexus(context.Context, *DestroyNexusRequest) (*emptypb.Empty, error)
	ListNexus(context.Context, *ListNexusOptions) (*ListNexusResponse, error)
	AddChildNexus(context.Context, *AddChildNexusRequest) (*AddChildNexusResponse, error)
	RemoveChildNexus(context.Context, *RemoveChildNexusRequest) (*RemoveChildNexusResponse, error)
	// take a child offline permanently; exactly the same ChildOperation OfflinePermanent
	FaultNexusChild(context.Context, *FaultNexusChildRequest) (*FaultNexusChildResponse, error)
	ShutdownNexus(context.Context, *ShutdownNexusRequest) (*ShutdownNexusResponse, error)
	// This method is called by control plane to construct a block device
	// (/dev/...) that will be used to connect the nexus to the OS.
	PublishNexus(context.Context, *PublishNexusRequest) (*PublishNexusResponse, error)
	UnpublishNexus(context.Context, *UnpublishNexusRequest) (*UnpublishNexusResponse, error)
	// NVMe ANA state
	GetNvmeAnaState(context.Context, *GetNvmeAnaStateRequest) (*GetNvmeAnaStateResponse, error)
	SetNvmeAnaState(context.Context, *SetNvmeAnaStateRequest) (*SetNvmeAnaStateResponse, error)
	// Nexus child operations
	ChildOperation(context.Context, *ChildOperationRequest) (*ChildOperationResponse, error)
	// Rebuild operations
	StartRebuild(context.Context, *StartRebuildRequest) (*StartRebuildResponse, error)
	StopRebuild(context.Context, *StopRebuildRequest) (*StopRebuildResponse, error)
	PauseRebuild(context.Context, *PauseRebuildRequest) (*PauseRebuildResponse, error)
	ResumeRebuild(context.Context, *ResumeRebuildRequest) (*ResumeRebuildResponse, error)
	GetRebuildState(context.Context, *RebuildStateRequest) (*RebuildStateResponse, error)
	GetRebuildStats(context.Context, *RebuildStatsRequest) (*RebuildStatsResponse, error)
	GetRebuildHistory(context.Context, *RebuildHistoryRequest) (*RebuildHistoryResponse, error)
	ListRebuildHistory(context.Context, *ListRebuildHistoryRequest) (*ListRebuildHistoryResponse, error)
	// contains filtered or unexported methods
}

NexusRpcServer is the server API for NexusRpc service. All implementations must embed UnimplementedNexusRpcServer for forward compatibility

type NexusState 

type NexusState int32

State of the nexus (terminology inspired by ZFS). 

const (
	NexusState_NEXUS_UNKNOWN       NexusState = 0
	NexusState_NEXUS_ONLINE        NexusState = 1 // healthy and working
	NexusState_NEXUS_DEGRADED      NexusState = 2 // not healthy but is able to serve IO (i.e. rebuild is in progress)
	NexusState_NEXUS_FAULTED       NexusState = 3 // broken and unable to serve IO
	NexusState_NEXUS_SHUTTING_DOWN NexusState = 4 // shutdown in progress: not able to serve I/O
	NexusState_NEXUS_SHUTDOWN      NexusState = 5 // shutdown complete: not able to serve I/O
)

func (NexusState) Descriptor 

func (NexusState) Descriptor() protoreflect.EnumDescriptor

func (NexusState) Enum 

func (x NexusState) Enum() *NexusState

func (NexusState) EnumDescriptor deprecated 

func (NexusState) EnumDescriptor() ([]byte, []int)

Deprecated: Use NexusState.Descriptor instead.

func (NexusState) Number 

func (x NexusState) Number() protoreflect.EnumNumber

func (NexusState) String 

func (x NexusState) String() string

func (NexusState) Type 

func (NexusState) Type() protoreflect.EnumType

type NvmeAnaState 

type NvmeAnaState int32
const (
	NvmeAnaState_NVME_ANA_INVALID_STATE         NvmeAnaState = 0 // invalid, do not use
	NvmeAnaState_NVME_ANA_OPTIMIZED_STATE       NvmeAnaState = 1
	NvmeAnaState_NVME_ANA_NON_OPTIMIZED_STATE   NvmeAnaState = 2
	NvmeAnaState_NVME_ANA_INACCESSIBLE_STATE    NvmeAnaState = 3
	NvmeAnaState_NVME_ANA_PERSISTENT_LOSS_STATE NvmeAnaState = 4  // not yet supported
	NvmeAnaState_NVME_ANA_CHANGE_STATE          NvmeAnaState = 15 // not yet supported
)

func (NvmeAnaState) Descriptor 

func (NvmeAnaState) Descriptor() protoreflect.EnumDescriptor

func (NvmeAnaState) Enum 

func (x NvmeAnaState) Enum() *NvmeAnaState

func (NvmeAnaState) EnumDescriptor deprecated 

func (NvmeAnaState) EnumDescriptor() ([]byte, []int)

Deprecated: Use NvmeAnaState.Descriptor instead.

func (NvmeAnaState) Number 

func (x NvmeAnaState) Number() protoreflect.EnumNumber

func (NvmeAnaState) String 

func (x NvmeAnaState) String() string

func (NvmeAnaState) Type 

func (NvmeAnaState) Type() protoreflect.EnumType

type NvmeController 

type NvmeController struct {
	Name    string              `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`                                         // NVMe controller name
	State   NvmeControllerState `protobuf:"varint,2,opt,name=state,proto3,enum=mayastor.v1.NvmeControllerState" json:"state,omitempty"` // Current state of the NVMe controller
	Size    uint64              `protobuf:"varint,3,opt,name=size,proto3" json:"size,omitempty"`                                        // Size of the controller's namespace (0 if no namespace attached).
	BlkSize uint32              `protobuf:"varint,4,opt,name=blk_size,json=blkSize,proto3" json:"blk_size,omitempty"`                   // Block size of the namespace (0 if no namespace attached).
	// contains filtered or unexported fields
}

func (*NvmeController) Descriptor deprecated 

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

Deprecated: Use NvmeController.ProtoReflect.Descriptor instead.

func (*NvmeController) GetBlkSize 

func (x *NvmeController) GetBlkSize() uint32

func (*NvmeController) GetName 

func (x *NvmeController) GetName() string

func (*NvmeController) GetSize 

func (x *NvmeController) GetSize() uint64

func (*NvmeController) GetState 

func (x *NvmeController) GetState() NvmeControllerState

func (*NvmeController) ProtoMessage 

func (*NvmeController) ProtoMessage()

func (*NvmeController) ProtoReflect 

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

func (*NvmeController) Reset 

func (x *NvmeController) Reset()

func (*NvmeController) String 

func (x *NvmeController) String() string

type NvmeControllerIoStats 

type NvmeControllerIoStats struct {
	NumReadOps    uint64 `protobuf:"varint,1,opt,name=num_read_ops,json=numReadOps,proto3" json:"num_read_ops,omitempty"`
	NumWriteOps   uint64 `protobuf:"varint,2,opt,name=num_write_ops,json=numWriteOps,proto3" json:"num_write_ops,omitempty"`
	BytesRead     uint64 `protobuf:"varint,3,opt,name=bytes_read,json=bytesRead,proto3" json:"bytes_read,omitempty"`
	BytesWritten  uint64 `protobuf:"varint,4,opt,name=bytes_written,json=bytesWritten,proto3" json:"bytes_written,omitempty"`
	NumUnmapOps   uint64 `protobuf:"varint,5,opt,name=num_unmap_ops,json=numUnmapOps,proto3" json:"num_unmap_ops,omitempty"`
	BytesUnmapped uint64 `protobuf:"varint,6,opt,name=bytes_unmapped,json=bytesUnmapped,proto3" json:"bytes_unmapped,omitempty"`
	// contains filtered or unexported fields
}

func (*NvmeControllerIoStats) Descriptor deprecated 

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

Deprecated: Use NvmeControllerIoStats.ProtoReflect.Descriptor instead.

func (*NvmeControllerIoStats) GetBytesRead 

func (x *NvmeControllerIoStats) GetBytesRead() uint64

func (*NvmeControllerIoStats) GetBytesUnmapped 

func (x *NvmeControllerIoStats) GetBytesUnmapped() uint64

func (*NvmeControllerIoStats) GetBytesWritten 

func (x *NvmeControllerIoStats) GetBytesWritten() uint64

func (*NvmeControllerIoStats) GetNumReadOps 

func (x *NvmeControllerIoStats) GetNumReadOps() uint64

func (*NvmeControllerIoStats) GetNumUnmapOps 

func (x *NvmeControllerIoStats) GetNumUnmapOps() uint64

func (*NvmeControllerIoStats) GetNumWriteOps 

func (x *NvmeControllerIoStats) GetNumWriteOps() uint64

func (*NvmeControllerIoStats) ProtoMessage 

func (*NvmeControllerIoStats) ProtoMessage()

func (*NvmeControllerIoStats) ProtoReflect 

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

func (*NvmeControllerIoStats) Reset 

func (x *NvmeControllerIoStats) Reset()

func (*NvmeControllerIoStats) String 

func (x *NvmeControllerIoStats) String() string

type NvmeControllerState 

type NvmeControllerState int32
const (
	NvmeControllerState_NEW           NvmeControllerState = 0
	NvmeControllerState_INITIALIZING  NvmeControllerState = 1
	NvmeControllerState_RUNNING       NvmeControllerState = 2
	NvmeControllerState_FAULTED       NvmeControllerState = 3
	NvmeControllerState_UNCONFIGURING NvmeControllerState = 4
	NvmeControllerState_UNCONFIGURED  NvmeControllerState = 5
)

func (NvmeControllerState) Descriptor 

func (NvmeControllerState) Descriptor() protoreflect.EnumDescriptor

func (NvmeControllerState) Enum 

func (x NvmeControllerState) Enum() *NvmeControllerState

func (NvmeControllerState) EnumDescriptor deprecated 

func (NvmeControllerState) EnumDescriptor() ([]byte, []int)

Deprecated: Use NvmeControllerState.Descriptor instead.

func (NvmeControllerState) Number 

func (x NvmeControllerState) Number() protoreflect.EnumNumber

func (NvmeControllerState) String 

func (x NvmeControllerState) String() string

func (NvmeControllerState) Type 

func (NvmeControllerState) Type() protoreflect.EnumType

type NvmeReservation 

type NvmeReservation int32

/ NVMe reservation types. 

const (
	NvmeReservation_Reserved                NvmeReservation = 0
	NvmeReservation_WriteExclusive          NvmeReservation = 1
	NvmeReservation_ExclusiveAccess         NvmeReservation = 2
	NvmeReservation_WriteExclusiveRegsOnly  NvmeReservation = 3
	NvmeReservation_ExclusiveAccessRegsOnly NvmeReservation = 4
	NvmeReservation_WriteExclusiveAllRegs   NvmeReservation = 5
	NvmeReservation_ExclusiveAccessAllRegs  NvmeReservation = 6
)

func (NvmeReservation) Descriptor 

func (NvmeReservation) Descriptor() protoreflect.EnumDescriptor

func (NvmeReservation) Enum 

func (x NvmeReservation) Enum() *NvmeReservation

func (NvmeReservation) EnumDescriptor deprecated 

func (NvmeReservation) EnumDescriptor() ([]byte, []int)

Deprecated: Use NvmeReservation.Descriptor instead.

func (NvmeReservation) Number 

func (x NvmeReservation) Number() protoreflect.EnumNumber

func (NvmeReservation) String 

func (x NvmeReservation) String() string

func (NvmeReservation) Type 

func (NvmeReservation) Type() protoreflect.EnumType

type PauseRebuildRequest 

type PauseRebuildRequest struct {
	NexusUuid string `protobuf:"bytes,1,opt,name=nexus_uuid,json=nexusUuid,proto3" json:"nexus_uuid,omitempty"` // uuid of the nexus
	Uri       string `protobuf:"bytes,2,opt,name=uri,proto3" json:"uri,omitempty"`                              // uri of the destination child
	// contains filtered or unexported fields
}

func (*PauseRebuildRequest) Descriptor deprecated 

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

Deprecated: Use PauseRebuildRequest.ProtoReflect.Descriptor instead.

func (*PauseRebuildRequest) GetNexusUuid 

func (x *PauseRebuildRequest) GetNexusUuid() string

func (*PauseRebuildRequest) GetUri 

func (x *PauseRebuildRequest) GetUri() string

func (*PauseRebuildRequest) ProtoMessage 

func (*PauseRebuildRequest) ProtoMessage()

func (*PauseRebuildRequest) ProtoReflect 

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

func (*PauseRebuildRequest) Reset 

func (x *PauseRebuildRequest) Reset()

func (*PauseRebuildRequest) String 

func (x *PauseRebuildRequest) String() string

type PauseRebuildResponse 

type PauseRebuildResponse struct {
	Nexus *Nexus `protobuf:"bytes,1,opt,name=nexus,proto3" json:"nexus,omitempty"`
	// contains filtered or unexported fields
}

func (*PauseRebuildResponse) Descriptor deprecated 

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

Deprecated: Use PauseRebuildResponse.ProtoReflect.Descriptor instead.

func (*PauseRebuildResponse) GetNexus 

func (x *PauseRebuildResponse) GetNexus() *Nexus

func (*PauseRebuildResponse) ProtoMessage 

func (*PauseRebuildResponse) ProtoMessage()

func (*PauseRebuildResponse) ProtoReflect 

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

func (*PauseRebuildResponse) Reset 

func (x *PauseRebuildResponse) Reset()

func (*PauseRebuildResponse) String 

func (x *PauseRebuildResponse) String() string

type Pool 

type Pool struct {
	Uuid        string    `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`                                    // uuid of the pool
	Name        string    `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`                                    // name of the pool
	Disks       []string  `protobuf:"bytes,3,rep,name=disks,proto3" json:"disks,omitempty"`                                  // absolute disk paths claimed by the pool
	State       PoolState `protobuf:"varint,4,opt,name=state,proto3,enum=mayastor.v1.PoolState" json:"state,omitempty"`      // current state of the pool
	Capacity    uint64    `protobuf:"varint,5,opt,name=capacity,proto3" json:"capacity,omitempty"`                           // size of the pool in bytes
	Used        uint64    `protobuf:"varint,6,opt,name=used,proto3" json:"used,omitempty"`                                   // used bytes from the pool
	Pooltype    PoolType  `protobuf:"varint,7,opt,name=pooltype,proto3,enum=mayastor.v1.PoolType" json:"pooltype,omitempty"` // type of the pool
	Committed   uint64    `protobuf:"varint,8,opt,name=committed,proto3" json:"committed,omitempty"`                         // committed size of all pool replicas (sum of capacities of all replicas)
	ClusterSize uint32    `protobuf:"varint,9,opt,name=cluster_size,json=clusterSize,proto3" json:"cluster_size,omitempty"`  // blobstor cluster size set (in bytes) during pool creation
	// contains filtered or unexported fields
}

Storage pool properties

func (*Pool) Descriptor deprecated 

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

Deprecated: Use Pool.ProtoReflect.Descriptor instead.

func (*Pool) GetCapacity 

func (x *Pool) GetCapacity() uint64

func (*Pool) GetClusterSize 

func (x *Pool) GetClusterSize() uint32

func (*Pool) GetCommitted 

func (x *Pool) GetCommitted() uint64

func (*Pool) GetDisks 

func (x *Pool) GetDisks() []string

func (*Pool) GetName 

func (x *Pool) GetName() string

func (*Pool) GetPooltype 

func (x *Pool) GetPooltype() PoolType

func (*Pool) GetState 

func (x *Pool) GetState() PoolState

func (*Pool) GetUsed 

func (x *Pool) GetUsed() uint64

func (*Pool) GetUuid 

func (x *Pool) GetUuid() string

func (*Pool) ProtoMessage 

func (*Pool) ProtoMessage()

func (*Pool) ProtoReflect 

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

func (*Pool) Reset 

func (x *Pool) Reset()

func (*Pool) String 

func (x *Pool) String() string

type PoolIoStatsResponse 

type PoolIoStatsResponse struct {
	Stats []*IoStats `protobuf:"bytes,1,rep,name=stats,proto3" json:"stats,omitempty"`
	// contains filtered or unexported fields
}

func (*PoolIoStatsResponse) Descriptor deprecated 

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

Deprecated: Use PoolIoStatsResponse.ProtoReflect.Descriptor instead.

func (*PoolIoStatsResponse) GetStats 

func (x *PoolIoStatsResponse) GetStats() []*IoStats

func (*PoolIoStatsResponse) ProtoMessage 

func (*PoolIoStatsResponse) ProtoMessage()

func (*PoolIoStatsResponse) ProtoReflect 

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

func (*PoolIoStatsResponse) Reset 

func (x *PoolIoStatsResponse) Reset()

func (*PoolIoStatsResponse) String 

func (x *PoolIoStatsResponse) String() string

type PoolRpcClient 

type PoolRpcClient interface {
	// Storage pool related methods.
	//
	// Storage pool is made up of block devices disks and provides a storage
	// space for provisioning of replicas.
	CreatePool(ctx context.Context, in *CreatePoolRequest, opts ...grpc.CallOption) (*Pool, error)
	DestroyPool(ctx context.Context, in *DestroyPoolRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	ExportPool(ctx context.Context, in *ExportPoolRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	ImportPool(ctx context.Context, in *ImportPoolRequest, opts ...grpc.CallOption) (*Pool, error)
	ListPools(ctx context.Context, in *ListPoolOptions, opts ...grpc.CallOption) (*ListPoolsResponse, error)
}

PoolRpcClient is the client API for PoolRpc 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 NewPoolRpcClient 

func NewPoolRpcClient(cc grpc.ClientConnInterface) PoolRpcClient

type PoolRpcServer 

type PoolRpcServer interface {
	// Storage pool related methods.
	//
	// Storage pool is made up of block devices disks and provides a storage
	// space for provisioning of replicas.
	CreatePool(context.Context, *CreatePoolRequest) (*Pool, error)
	DestroyPool(context.Context, *DestroyPoolRequest) (*emptypb.Empty, error)
	ExportPool(context.Context, *ExportPoolRequest) (*emptypb.Empty, error)
	ImportPool(context.Context, *ImportPoolRequest) (*Pool, error)
	ListPools(context.Context, *ListPoolOptions) (*ListPoolsResponse, error)
	// contains filtered or unexported methods
}

PoolRpcServer is the server API for PoolRpc service. All implementations must embed UnimplementedPoolRpcServer for forward compatibility

type PoolState 

type PoolState int32

State of the storage pool (terminology comes from ZFS). 

const (
	PoolState_POOL_UNKNOWN  PoolState = 0
	PoolState_POOL_ONLINE   PoolState = 1 // the pool is in normal working order
	PoolState_POOL_DEGRADED PoolState = 2 // the pool has experienced a failure but can still function
	PoolState_POOL_FAULTED  PoolState = 3 // the pool is completely inaccessible
)

func (PoolState) Descriptor 

func (PoolState) Descriptor() protoreflect.EnumDescriptor

func (PoolState) Enum 

func (x PoolState) Enum() *PoolState

func (PoolState) EnumDescriptor deprecated 

func (PoolState) EnumDescriptor() ([]byte, []int)

Deprecated: Use PoolState.Descriptor instead.

func (PoolState) Number 

func (x PoolState) Number() protoreflect.EnumNumber

func (PoolState) String 

func (x PoolState) String() string

func (PoolState) Type 

func (PoolState) Type() protoreflect.EnumType

type PoolType 

type PoolType int32

Specifies the type of the pool 

const (
	PoolType_Lvs PoolType = 0 // pool backed by spdk lvs
)

func (PoolType) Descriptor 

func (PoolType) Descriptor() protoreflect.EnumDescriptor

func (PoolType) Enum 

func (x PoolType) Enum() *PoolType

func (PoolType) EnumDescriptor deprecated 

func (PoolType) EnumDescriptor() ([]byte, []int)

Deprecated: Use PoolType.Descriptor instead.

func (PoolType) Number 

func (x PoolType) Number() protoreflect.EnumNumber

func (PoolType) String 

func (x PoolType) String() string

func (PoolType) Type 

func (PoolType) Type() protoreflect.EnumType

type PoolTypeValue 

type PoolTypeValue struct {
	Value PoolType `protobuf:"varint,1,opt,name=value,proto3,enum=mayastor.v1.PoolType" json:"value,omitempty"`
	// contains filtered or unexported fields
}

The wrapper for pooltype. It helps in defining optional fields when required.

func (*PoolTypeValue) Descriptor deprecated 

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

Deprecated: Use PoolTypeValue.ProtoReflect.Descriptor instead.

func (*PoolTypeValue) GetValue 

func (x *PoolTypeValue) GetValue() PoolType

func (*PoolTypeValue) ProtoMessage 

func (*PoolTypeValue) ProtoMessage()

func (*PoolTypeValue) ProtoReflect 

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

func (*PoolTypeValue) Reset 

func (x *PoolTypeValue) Reset()

func (*PoolTypeValue) String 

func (x *PoolTypeValue) String() string

type PublishNexusRequest 

type PublishNexusRequest struct {
	Uuid         string        `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`                                     // uuid of the nexus which to create device for
	Key          string        `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`                                       // encryption key
	Share        ShareProtocol `protobuf:"varint,3,opt,name=share,proto3,enum=mayastor.v1.ShareProtocol" json:"share,omitempty"`   // protocol used for the front end.
	AllowedHosts []string      `protobuf:"bytes,4,rep,name=allowed_hosts,json=allowedHosts,proto3" json:"allowed_hosts,omitempty"` // host (nqn's) which are allowed to connect to the target.
	// contains filtered or unexported fields
}

this message will be subject to change as we will add support for remote storage protocols.

func (*PublishNexusRequest) Descriptor deprecated 

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

Deprecated: Use PublishNexusRequest.ProtoReflect.Descriptor instead.

func (*PublishNexusRequest) GetAllowedHosts 

func (x *PublishNexusRequest) GetAllowedHosts() []string

func (*PublishNexusRequest) GetKey 

func (x *PublishNexusRequest) GetKey() string

func (*PublishNexusRequest) GetShare 

func (x *PublishNexusRequest) GetShare() ShareProtocol

func (*PublishNexusRequest) GetUuid 

func (x *PublishNexusRequest) GetUuid() string

func (*PublishNexusRequest) ProtoMessage 

func (*PublishNexusRequest) ProtoMessage()

func (*PublishNexusRequest) ProtoReflect 

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

func (*PublishNexusRequest) Reset 

func (x *PublishNexusRequest) Reset()

func (*PublishNexusRequest) String 

func (x *PublishNexusRequest) String() string

type PublishNexusResponse 

type PublishNexusResponse struct {
	Nexus *Nexus `protobuf:"bytes,1,opt,name=nexus,proto3" json:"nexus,omitempty"`
	// contains filtered or unexported fields
}

func (*PublishNexusResponse) Descriptor deprecated 

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

Deprecated: Use PublishNexusResponse.ProtoReflect.Descriptor instead.

func (*PublishNexusResponse) GetNexus 

func (x *PublishNexusResponse) GetNexus() *Nexus

func (*PublishNexusResponse) ProtoMessage 

func (*PublishNexusResponse) ProtoMessage()

func (*PublishNexusResponse) ProtoReflect 

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

func (*PublishNexusResponse) Reset 

func (x *PublishNexusResponse) Reset()

func (*PublishNexusResponse) String 

func (x *PublishNexusResponse) String() string

type RebuildHistoryRecord 

type RebuildHistoryRecord struct {
	ChildUri          string                 `protobuf:"bytes,1,opt,name=child_uri,json=childUri,proto3" json:"child_uri,omitempty"`                             // URI of the rebuilt child (destination)
	SrcUri            string                 `protobuf:"bytes,2,opt,name=src_uri,json=srcUri,proto3" json:"src_uri,omitempty"`                                   // URI of the source replica
	State             RebuildJobState        `protobuf:"varint,3,opt,name=state,proto3,enum=mayastor.v1.RebuildJobState" json:"state,omitempty"`                 // final state of the rebuild job
	BlocksTotal       uint64                 `protobuf:"varint,4,opt,name=blocks_total,json=blocksTotal,proto3" json:"blocks_total,omitempty"`                   // total number of blocks of the replicas
	BlocksRecovered   uint64                 `protobuf:"varint,5,opt,name=blocks_recovered,json=blocksRecovered,proto3" json:"blocks_recovered,omitempty"`       // number of blocks recovered
	BlocksTransferred uint64                 `protobuf:"varint,6,opt,name=blocks_transferred,json=blocksTransferred,proto3" json:"blocks_transferred,omitempty"` // number of blocks for which the actual data transfer occurred
	BlocksRemaining   uint64                 `protobuf:"varint,7,opt,name=blocks_remaining,json=blocksRemaining,proto3" json:"blocks_remaining,omitempty"`       // number of blocks remaining to transfer
	BlocksPerTask     uint64                 `protobuf:"varint,8,opt,name=blocks_per_task,json=blocksPerTask,proto3" json:"blocks_per_task,omitempty"`           // granularity of each recovery task in blocks
	BlockSize         uint64                 `protobuf:"varint,9,opt,name=block_size,json=blockSize,proto3" json:"block_size,omitempty"`                         // size in bytes of logical block
	IsPartial         bool                   `protobuf:"varint,10,opt,name=is_partial,json=isPartial,proto3" json:"is_partial,omitempty"`                        // true for partial (only modified blocked transferred); false for the full rebuild (all blocks transferred)
	StartTime         *timestamppb.Timestamp `protobuf:"bytes,11,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`                         // start time of the rebuild (UTC)
	EndTime           *timestamppb.Timestamp `protobuf:"bytes,12,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`                               // end time of the rebuild (UTC)
	// contains filtered or unexported fields
}

func (*RebuildHistoryRecord) Descriptor deprecated 

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

Deprecated: Use RebuildHistoryRecord.ProtoReflect.Descriptor instead.

func (*RebuildHistoryRecord) GetBlockSize 

func (x *RebuildHistoryRecord) GetBlockSize() uint64

func (*RebuildHistoryRecord) GetBlocksPerTask 

func (x *RebuildHistoryRecord) GetBlocksPerTask() uint64

func (*RebuildHistoryRecord) GetBlocksRecovered 

func (x *RebuildHistoryRecord) GetBlocksRecovered() uint64

func (*RebuildHistoryRecord) GetBlocksRemaining 

func (x *RebuildHistoryRecord) GetBlocksRemaining() uint64

func (*RebuildHistoryRecord) GetBlocksTotal 

func (x *RebuildHistoryRecord) GetBlocksTotal() uint64

func (*RebuildHistoryRecord) GetBlocksTransferred 

func (x *RebuildHistoryRecord) GetBlocksTransferred() uint64

func (*RebuildHistoryRecord) GetChildUri 

func (x *RebuildHistoryRecord) GetChildUri() string

func (*RebuildHistoryRecord) GetEndTime 

func (x *RebuildHistoryRecord) GetEndTime() *timestamppb.Timestamp

func (*RebuildHistoryRecord) GetIsPartial 

func (x *RebuildHistoryRecord) GetIsPartial() bool

func (*RebuildHistoryRecord) GetSrcUri 

func (x *RebuildHistoryRecord) GetSrcUri() string

func (*RebuildHistoryRecord) GetStartTime 

func (x *RebuildHistoryRecord) GetStartTime() *timestamppb.Timestamp

func (*RebuildHistoryRecord) GetState 

func (x *RebuildHistoryRecord) GetState() RebuildJobState

func (*RebuildHistoryRecord) ProtoMessage 

func (*RebuildHistoryRecord) ProtoMessage()

func (*RebuildHistoryRecord) ProtoReflect 

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

func (*RebuildHistoryRecord) Reset 

func (x *RebuildHistoryRecord) Reset()

func (*RebuildHistoryRecord) String 

func (x *RebuildHistoryRecord) String() string

type RebuildHistoryRequest 

type RebuildHistoryRequest struct {
	Uuid string `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"` // uuid of the nexus
	// contains filtered or unexported fields
}

func (*RebuildHistoryRequest) Descriptor deprecated 

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

Deprecated: Use RebuildHistoryRequest.ProtoReflect.Descriptor instead.

func (*RebuildHistoryRequest) GetUuid 

func (x *RebuildHistoryRequest) GetUuid() string

func (*RebuildHistoryRequest) ProtoMessage 

func (*RebuildHistoryRequest) ProtoMessage()

func (*RebuildHistoryRequest) ProtoReflect 

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

func (*RebuildHistoryRequest) Reset 

func (x *RebuildHistoryRequest) Reset()

func (*RebuildHistoryRequest) String 

func (x *RebuildHistoryRequest) String() string

type RebuildHistoryResponse 

type RebuildHistoryResponse struct {
	Uuid    string                  `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`       // uuid of the nexus
	Name    string                  `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`       // name of the nexus
	Records []*RebuildHistoryRecord `protobuf:"bytes,2,rep,name=records,proto3" json:"records,omitempty"` // List of all the rebuild records
	// contains filtered or unexported fields
}

func (*RebuildHistoryResponse) Descriptor deprecated 

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

Deprecated: Use RebuildHistoryResponse.ProtoReflect.Descriptor instead.

func (*RebuildHistoryResponse) GetName 

func (x *RebuildHistoryResponse) GetName() string

func (*RebuildHistoryResponse) GetRecords 

func (x *RebuildHistoryResponse) GetRecords() []*RebuildHistoryRecord

func (*RebuildHistoryResponse) GetUuid 

func (x *RebuildHistoryResponse) GetUuid() string

func (*RebuildHistoryResponse) ProtoMessage 

func (*RebuildHistoryResponse) ProtoMessage()

func (*RebuildHistoryResponse) ProtoReflect 

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

func (*RebuildHistoryResponse) Reset 

func (x *RebuildHistoryResponse) Reset()

func (*RebuildHistoryResponse) String 

func (x *RebuildHistoryResponse) String() string

type RebuildJobState 

type RebuildJobState int32
const (
	RebuildJobState_Init       RebuildJobState = 0 // Initialized, not yet rebuilding
	RebuildJobState_Rebuilding RebuildJobState = 1 // Running rebuild
	RebuildJobState_Stopped    RebuildJobState = 2 // Stopped rebuild
	RebuildJobState_Paused     RebuildJobState = 3 // Paused rebuild
	RebuildJobState_Failed     RebuildJobState = 4 // Failed for some reason
	RebuildJobState_Completed  RebuildJobState = 5 // Rebuild completed succesfully
)

func (RebuildJobState) Descriptor 

func (RebuildJobState) Descriptor() protoreflect.EnumDescriptor

func (RebuildJobState) Enum 

func (x RebuildJobState) Enum() *RebuildJobState

func (RebuildJobState) EnumDescriptor deprecated 

func (RebuildJobState) EnumDescriptor() ([]byte, []int)

Deprecated: Use RebuildJobState.Descriptor instead.

func (RebuildJobState) Number 

func (x RebuildJobState) Number() protoreflect.EnumNumber

func (RebuildJobState) String 

func (x RebuildJobState) String() string

func (RebuildJobState) Type 

func (RebuildJobState) Type() protoreflect.EnumType

type RebuildStateRequest 

type RebuildStateRequest struct {
	NexusUuid string `protobuf:"bytes,1,opt,name=nexus_uuid,json=nexusUuid,proto3" json:"nexus_uuid,omitempty"` // uuid of the nexus
	Uri       string `protobuf:"bytes,2,opt,name=uri,proto3" json:"uri,omitempty"`                              // uri of the destination child
	// contains filtered or unexported fields
}

func (*RebuildStateRequest) Descriptor deprecated 

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

Deprecated: Use RebuildStateRequest.ProtoReflect.Descriptor instead.

func (*RebuildStateRequest) GetNexusUuid 

func (x *RebuildStateRequest) GetNexusUuid() string

func (*RebuildStateRequest) GetUri 

func (x *RebuildStateRequest) GetUri() string

func (*RebuildStateRequest) ProtoMessage 

func (*RebuildStateRequest) ProtoMessage()

func (*RebuildStateRequest) ProtoReflect 

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

func (*RebuildStateRequest) Reset 

func (x *RebuildStateRequest) Reset()

func (*RebuildStateRequest) String 

func (x *RebuildStateRequest) String() string

type RebuildStateResponse 

type RebuildStateResponse struct {
	State string `protobuf:"bytes,1,opt,name=state,proto3" json:"state,omitempty"` // current rebuild state (i.e. ready/running/completed etc.)
	// contains filtered or unexported fields
}

func (*RebuildStateResponse) Descriptor deprecated 

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

Deprecated: Use RebuildStateResponse.ProtoReflect.Descriptor instead.

func (*RebuildStateResponse) GetState 

func (x *RebuildStateResponse) GetState() string

func (*RebuildStateResponse) ProtoMessage 

func (*RebuildStateResponse) ProtoMessage()

func (*RebuildStateResponse) ProtoReflect 

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

func (*RebuildStateResponse) Reset 

func (x *RebuildStateResponse) Reset()

func (*RebuildStateResponse) String 

func (x *RebuildStateResponse) String() string

type RebuildStatsRequest 

type RebuildStatsRequest struct {
	NexusUuid string `protobuf:"bytes,1,opt,name=nexus_uuid,json=nexusUuid,proto3" json:"nexus_uuid,omitempty"` // uuid of the nexus
	Uri       string `protobuf:"bytes,2,opt,name=uri,proto3" json:"uri,omitempty"`                              // uri of the destination child
	// contains filtered or unexported fields
}

func (*RebuildStatsRequest) Descriptor deprecated 

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

Deprecated: Use RebuildStatsRequest.ProtoReflect.Descriptor instead.

func (*RebuildStatsRequest) GetNexusUuid 

func (x *RebuildStatsRequest) GetNexusUuid() string

func (*RebuildStatsRequest) GetUri 

func (x *RebuildStatsRequest) GetUri() string

func (*RebuildStatsRequest) ProtoMessage 

func (*RebuildStatsRequest) ProtoMessage()

func (*RebuildStatsRequest) ProtoReflect 

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

func (*RebuildStatsRequest) Reset 

func (x *RebuildStatsRequest) Reset()

func (*RebuildStatsRequest) String 

func (x *RebuildStatsRequest) String() string

type RebuildStatsResponse 

type RebuildStatsResponse struct {
	BlocksTotal       uint64                 `protobuf:"varint,1,opt,name=blocks_total,json=blocksTotal,proto3" json:"blocks_total,omitempty"`                   // total number of blocks to recover
	BlocksRecovered   uint64                 `protobuf:"varint,2,opt,name=blocks_recovered,json=blocksRecovered,proto3" json:"blocks_recovered,omitempty"`       // number of blocks already recovered
	BlocksTransferred uint64                 `protobuf:"varint,8,opt,name=blocks_transferred,json=blocksTransferred,proto3" json:"blocks_transferred,omitempty"` // number of blocks for which the actual data transfer already occurred
	BlocksRemaining   uint64                 `protobuf:"varint,9,opt,name=blocks_remaining,json=blocksRemaining,proto3" json:"blocks_remaining,omitempty"`       // number of blocks remaining to transfer
	Progress          uint64                 `protobuf:"varint,3,opt,name=progress,proto3" json:"progress,omitempty"`                                            // rebuild progress %
	BlocksPerTask     uint64                 `protobuf:"varint,4,opt,name=blocks_per_task,json=blocksPerTask,proto3" json:"blocks_per_task,omitempty"`           // granularity of each recovery task in blocks
	BlockSize         uint64                 `protobuf:"varint,5,opt,name=block_size,json=blockSize,proto3" json:"block_size,omitempty"`                         // size in bytes of logical block
	TasksTotal        uint64                 `protobuf:"varint,6,opt,name=tasks_total,json=tasksTotal,proto3" json:"tasks_total,omitempty"`                      // total number of concurrent rebuild tasks
	TasksActive       uint64                 `protobuf:"varint,7,opt,name=tasks_active,json=tasksActive,proto3" json:"tasks_active,omitempty"`                   // number of current active tasks
	IsPartial         bool                   `protobuf:"varint,10,opt,name=is_partial,json=isPartial,proto3" json:"is_partial,omitempty"`                        // true for partial (only modified blocked transferred); false for the full rebuild (all blocks transferred)
	StartTime         *timestamppb.Timestamp `protobuf:"bytes,11,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`                         // start time of the rebuild (UTC)
	// contains filtered or unexported fields
}

func (*RebuildStatsResponse) Descriptor deprecated 

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

Deprecated: Use RebuildStatsResponse.ProtoReflect.Descriptor instead.

func (*RebuildStatsResponse) GetBlockSize 

func (x *RebuildStatsResponse) GetBlockSize() uint64

func (*RebuildStatsResponse) GetBlocksPerTask 

func (x *RebuildStatsResponse) GetBlocksPerTask() uint64

func (*RebuildStatsResponse) GetBlocksRecovered 

func (x *RebuildStatsResponse) GetBlocksRecovered() uint64

func (*RebuildStatsResponse) GetBlocksRemaining 

func (x *RebuildStatsResponse) GetBlocksRemaining() uint64

func (*RebuildStatsResponse) GetBlocksTotal 

func (x *RebuildStatsResponse) GetBlocksTotal() uint64

func (*RebuildStatsResponse) GetBlocksTransferred 

func (x *RebuildStatsResponse) GetBlocksTransferred() uint64

func (*RebuildStatsResponse) GetIsPartial 

func (x *RebuildStatsResponse) GetIsPartial() bool

func (*RebuildStatsResponse) GetProgress 

func (x *RebuildStatsResponse) GetProgress() uint64

func (*RebuildStatsResponse) GetStartTime 

func (x *RebuildStatsResponse) GetStartTime() *timestamppb.Timestamp

func (*RebuildStatsResponse) GetTasksActive 

func (x *RebuildStatsResponse) GetTasksActive() uint64

func (*RebuildStatsResponse) GetTasksTotal 

func (x *RebuildStatsResponse) GetTasksTotal() uint64

func (*RebuildStatsResponse) ProtoMessage 

func (*RebuildStatsResponse) ProtoMessage()

func (*RebuildStatsResponse) ProtoReflect 

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

func (*RebuildStatsResponse) Reset 

func (x *RebuildStatsResponse) Reset()

func (*RebuildStatsResponse) String 

func (x *RebuildStatsResponse) String() string

type RegisterRequest 

type RegisterRequest struct {

	// id of the mayastor instance
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// grpc endpoint of the mayastor instance
	GrpcEndpoint string `protobuf:"bytes,2,opt,name=grpc_endpoint,json=grpcEndpoint,proto3" json:"grpc_endpoint,omitempty"`
	// uuid generated by the instance on startup
	InstanceUuid *wrapperspb.StringValue `protobuf:"bytes,3,opt,name=instance_uuid,json=instanceUuid,proto3" json:"instance_uuid,omitempty"`
	// list api version supported by the dataplane
	ApiVersion []APIVersion `` /* 127-byte string literal not displayed */
	// nvme initiator hostnqn used by this instance
	Hostnqn *wrapperspb.StringValue `protobuf:"bytes,5,opt,name=hostnqn,proto3" json:"hostnqn,omitempty"`
	// contains filtered or unexported fields
}

register the dataplane node with control-plane

func (*RegisterRequest) Descriptor deprecated 

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

Deprecated: Use RegisterRequest.ProtoReflect.Descriptor instead.

func (*RegisterRequest) GetApiVersion 

func (x *RegisterRequest) GetApiVersion() []APIVersion

func (*RegisterRequest) GetGrpcEndpoint 

func (x *RegisterRequest) GetGrpcEndpoint() string

func (*RegisterRequest) GetHostnqn 

func (x *RegisterRequest) GetHostnqn() *wrapperspb.StringValue

func (*RegisterRequest) GetId 

func (x *RegisterRequest) GetId() string

func (*RegisterRequest) GetInstanceUuid 

func (x *RegisterRequest) GetInstanceUuid() *wrapperspb.StringValue

func (*RegisterRequest) ProtoMessage 

func (*RegisterRequest) ProtoMessage()

func (*RegisterRequest) ProtoReflect 

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

func (*RegisterRequest) Reset 

func (x *RegisterRequest) Reset()

func (*RegisterRequest) String 

func (x *RegisterRequest) String() string

type RegistrationClient 

type RegistrationClient interface {
	Register(ctx context.Context, in *RegisterRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	Deregister(ctx context.Context, in *DeregisterRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

RegistrationClient is the client API for Registration 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 NewRegistrationClient 

func NewRegistrationClient(cc grpc.ClientConnInterface) RegistrationClient

type RegistrationServer 

type RegistrationServer interface {
	Register(context.Context, *RegisterRequest) (*emptypb.Empty, error)
	Deregister(context.Context, *DeregisterRequest) (*emptypb.Empty, error)
	// contains filtered or unexported methods
}

RegistrationServer is the server API for Registration service. All implementations must embed UnimplementedRegistrationServer for forward compatibility

type RemoveChildNexusRequest 

type RemoveChildNexusRequest struct {
	Uuid string `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"` // uuid of the nexus
	Uri  string `protobuf:"bytes,2,opt,name=uri,proto3" json:"uri,omitempty"`   // URI of the child device to be removed
	// contains filtered or unexported fields
}

func (*RemoveChildNexusRequest) Descriptor deprecated 

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

Deprecated: Use RemoveChildNexusRequest.ProtoReflect.Descriptor instead.

func (*RemoveChildNexusRequest) GetUri 

func (x *RemoveChildNexusRequest) GetUri() string

func (*RemoveChildNexusRequest) GetUuid 

func (x *RemoveChildNexusRequest) GetUuid() string

func (*RemoveChildNexusRequest) ProtoMessage 

func (*RemoveChildNexusRequest) ProtoMessage()

func (*RemoveChildNexusRequest) ProtoReflect 

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

func (*RemoveChildNexusRequest) Reset 

func (x *RemoveChildNexusRequest) Reset()

func (*RemoveChildNexusRequest) String 

func (x *RemoveChildNexusRequest) String() string

type RemoveChildNexusResponse 

type RemoveChildNexusResponse struct {
	Nexus *Nexus `protobuf:"bytes,1,opt,name=nexus,proto3" json:"nexus,omitempty"`
	// contains filtered or unexported fields
}

func (*RemoveChildNexusResponse) Descriptor deprecated 

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

Deprecated: Use RemoveChildNexusResponse.ProtoReflect.Descriptor instead.

func (*RemoveChildNexusResponse) GetNexus 

func (x *RemoveChildNexusResponse) GetNexus() *Nexus

func (*RemoveChildNexusResponse) ProtoMessage 

func (*RemoveChildNexusResponse) ProtoMessage()

func (*RemoveChildNexusResponse) ProtoReflect 

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

func (*RemoveChildNexusResponse) Reset 

func (x *RemoveChildNexusResponse) Reset()

func (*RemoveChildNexusResponse) String 

func (x *RemoveChildNexusResponse) String() string

type RemoveFaultInjectionRequest 

type RemoveFaultInjectionRequest struct {

	// URI that was used to add the fault injection.
	Uri string `protobuf:"bytes,1,opt,name=uri,proto3" json:"uri,omitempty"`
	// contains filtered or unexported fields
}

func (*RemoveFaultInjectionRequest) Descriptor deprecated 

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

Deprecated: Use RemoveFaultInjectionRequest.ProtoReflect.Descriptor instead.

func (*RemoveFaultInjectionRequest) GetUri 

func (x *RemoveFaultInjectionRequest) GetUri() string

func (*RemoveFaultInjectionRequest) ProtoMessage 

func (*RemoveFaultInjectionRequest) ProtoMessage()

func (*RemoveFaultInjectionRequest) ProtoReflect 

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

func (*RemoveFaultInjectionRequest) Reset 

func (x *RemoveFaultInjectionRequest) Reset()

func (*RemoveFaultInjectionRequest) String 

func (x *RemoveFaultInjectionRequest) String() string

type Replica 

type Replica struct {
	Name         string             `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`                                            // name of the replica
	Uuid         string             `protobuf:"bytes,2,opt,name=uuid,proto3" json:"uuid,omitempty"`                                            // uuid of the replica
	Pooluuid     string             `protobuf:"bytes,3,opt,name=pooluuid,proto3" json:"pooluuid,omitempty"`                                    // uuid of the pool on which replica is present
	Size         uint64             `protobuf:"varint,4,opt,name=size,proto3" json:"size,omitempty"`                                           // size of the replica in bytes
	Thin         bool               `protobuf:"varint,5,opt,name=thin,proto3" json:"thin,omitempty"`                                           // thin provisioning
	Share        ShareProtocol      `protobuf:"varint,6,opt,name=share,proto3,enum=mayastor.v1.ShareProtocol" json:"share,omitempty"`          // protocol used for exposing the replica
	Uri          string             `protobuf:"bytes,7,opt,name=uri,proto3" json:"uri,omitempty"`                                              // uri under which the replica is accessible by nexus
	Poolname     string             `protobuf:"bytes,8,opt,name=poolname,proto3" json:"poolname,omitempty"`                                    // name of the pool on which replica is present
	Usage        *ReplicaSpaceUsage `protobuf:"bytes,9,opt,name=usage,proto3" json:"usage,omitempty"`                                          // replica space usage
	AllowedHosts []string           `protobuf:"bytes,10,rep,name=allowed_hosts,json=allowedHosts,proto3" json:"allowed_hosts,omitempty"`       // host (nqn's) which are allowed to connect to the target
	IsSnapshot   bool               `protobuf:"varint,11,opt,name=is_snapshot,json=isSnapshot,proto3" json:"is_snapshot,omitempty"`            // true: snapshot false: normal replica
	IsClone      bool               `protobuf:"varint,12,opt,name=is_clone,json=isClone,proto3" json:"is_clone,omitempty"`                     // true: clone replica from snapshot, false: normal replica
	SnapshotUuid *string            `protobuf:"bytes,13,opt,name=snapshot_uuid,json=snapshotUuid,proto3,oneof" json:"snapshot_uuid,omitempty"` // snapshot uuid from which the clone replica is created
	// contains filtered or unexported fields
}

Replica properties

func (*Replica) Descriptor deprecated 

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

Deprecated: Use Replica.ProtoReflect.Descriptor instead.

func (*Replica) GetAllowedHosts 

func (x *Replica) GetAllowedHosts() []string

func (*Replica) GetIsClone 

func (x *Replica) GetIsClone() bool

func (*Replica) GetIsSnapshot 

func (x *Replica) GetIsSnapshot() bool

func (*Replica) GetName 

func (x *Replica) GetName() string

func (*Replica) GetPoolname 

func (x *Replica) GetPoolname() string

func (*Replica) GetPooluuid 

func (x *Replica) GetPooluuid() string

func (*Replica) GetShare 

func (x *Replica) GetShare() ShareProtocol

func (*Replica) GetSize 

func (x *Replica) GetSize() uint64

func (*Replica) GetSnapshotUuid 

func (x *Replica) GetSnapshotUuid() string

func (*Replica) GetThin 

func (x *Replica) GetThin() bool

func (*Replica) GetUri 

func (x *Replica) GetUri() string

func (*Replica) GetUsage 

func (x *Replica) GetUsage() *ReplicaSpaceUsage

func (*Replica) GetUuid 

func (x *Replica) GetUuid() string

func (*Replica) ProtoMessage 

func (*Replica) ProtoMessage()

func (*Replica) ProtoReflect 

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

func (*Replica) Reset 

func (x *Replica) Reset()

func (*Replica) String 

func (x *Replica) String() string

type ReplicaRpcClient 

type ReplicaRpcClient interface {
	// Replica related methods.
	//
	// Replica allocates space from storage pool.
	CreateReplica(ctx context.Context, in *CreateReplicaRequest, opts ...grpc.CallOption) (*Replica, error)
	DestroyReplica(ctx context.Context, in *DestroyReplicaRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	ListReplicas(ctx context.Context, in *ListReplicaOptions, opts ...grpc.CallOption) (*ListReplicasResponse, error)
	ShareReplica(ctx context.Context, in *ShareReplicaRequest, opts ...grpc.CallOption) (*Replica, error)
	UnshareReplica(ctx context.Context, in *UnshareReplicaRequest, opts ...grpc.CallOption) (*Replica, error)
	ResizeReplica(ctx context.Context, in *ResizeReplicaRequest, opts ...grpc.CallOption) (*Replica, error)
}

ReplicaRpcClient is the client API for ReplicaRpc 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 NewReplicaRpcClient 

func NewReplicaRpcClient(cc grpc.ClientConnInterface) ReplicaRpcClient

type ReplicaRpcServer 

type ReplicaRpcServer interface {
	// Replica related methods.
	//
	// Replica allocates space from storage pool.
	CreateReplica(context.Context, *CreateReplicaRequest) (*Replica, error)
	DestroyReplica(context.Context, *DestroyReplicaRequest) (*emptypb.Empty, error)
	ListReplicas(context.Context, *ListReplicaOptions) (*ListReplicasResponse, error)
	ShareReplica(context.Context, *ShareReplicaRequest) (*Replica, error)
	UnshareReplica(context.Context, *UnshareReplicaRequest) (*Replica, error)
	ResizeReplica(context.Context, *ResizeReplicaRequest) (*Replica, error)
	// contains filtered or unexported methods
}

ReplicaRpcServer is the server API for ReplicaRpc service. All implementations must embed UnimplementedReplicaRpcServer for forward compatibility

type ReplicaSpaceUsage 

type ReplicaSpaceUsage struct {
	CapacityBytes           uint64 `protobuf:"varint,1,opt,name=capacity_bytes,json=capacityBytes,proto3" json:"capacity_bytes,omitempty"`                        // replica capacity in bytes.
	AllocatedBytes          uint64 `protobuf:"varint,2,opt,name=allocated_bytes,json=allocatedBytes,proto3" json:"allocated_bytes,omitempty"`                     // amount of actually allocated disk space for this replica in bytes
	ClusterSize             uint64 `protobuf:"varint,3,opt,name=cluster_size,json=clusterSize,proto3" json:"cluster_size,omitempty"`                              // cluster size in bytes
	NumClusters             uint64 `protobuf:"varint,4,opt,name=num_clusters,json=numClusters,proto3" json:"num_clusters,omitempty"`                              // total number of clusters
	NumAllocatedClusters    uint64 `protobuf:"varint,5,opt,name=num_allocated_clusters,json=numAllocatedClusters,proto3" json:"num_allocated_clusters,omitempty"` // number of actually used clusters
	AllocatedBytesSnapshots uint64 ``                                                                                                                             // amount of space allocated by all replica snapshots
	/* 133-byte string literal not displayed */
	NumAllocatedClustersSnapshots uint64 `` // number of clusters used by all replica snapshots
	/* 153-byte string literal not displayed */
	AllocatedBytesSnapshotFromClone *uint64 `` // actual amount of disk space allocated by snapshot which is created from clone
	/* 167-byte string literal not displayed */
	// contains filtered or unexported fields
}

Replica space usage

func (*ReplicaSpaceUsage) Descriptor deprecated 

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

Deprecated: Use ReplicaSpaceUsage.ProtoReflect.Descriptor instead.

func (*ReplicaSpaceUsage) GetAllocatedBytes 

func (x *ReplicaSpaceUsage) GetAllocatedBytes() uint64

func (*ReplicaSpaceUsage) GetAllocatedBytesSnapshotFromClone 

func (x *ReplicaSpaceUsage) GetAllocatedBytesSnapshotFromClone() uint64

func (*ReplicaSpaceUsage) GetAllocatedBytesSnapshots 

func (x *ReplicaSpaceUsage) GetAllocatedBytesSnapshots() uint64

func (*ReplicaSpaceUsage) GetCapacityBytes 

func (x *ReplicaSpaceUsage) GetCapacityBytes() uint64

func (*ReplicaSpaceUsage) GetClusterSize 

func (x *ReplicaSpaceUsage) GetClusterSize() uint64

func (*ReplicaSpaceUsage) GetNumAllocatedClusters 

func (x *ReplicaSpaceUsage) GetNumAllocatedClusters() uint64

func (*ReplicaSpaceUsage) GetNumAllocatedClustersSnapshots 

func (x *ReplicaSpaceUsage) GetNumAllocatedClustersSnapshots() uint64

func (*ReplicaSpaceUsage) GetNumClusters 

func (x *ReplicaSpaceUsage) GetNumClusters() uint64

func (*ReplicaSpaceUsage) ProtoMessage 

func (*ReplicaSpaceUsage) ProtoMessage()

func (*ReplicaSpaceUsage) ProtoReflect 

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

func (*ReplicaSpaceUsage) Reset 

func (x *ReplicaSpaceUsage) Reset()

func (*ReplicaSpaceUsage) String 

func (x *ReplicaSpaceUsage) String() string

type ResizeReplicaRequest 

type ResizeReplicaRequest struct {
	Uuid          string `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`                                         // uuid of the replica.
	RequestedSize uint64 `protobuf:"varint,2,opt,name=requested_size,json=requestedSize,proto3" json:"requested_size,omitempty"` // indicates the requested new size of replica.
	// contains filtered or unexported fields
}

Resize(expand or shrink) a replica. Only valid for normal lvol replicas, and not lvols that are a snapshot.

func (*ResizeReplicaRequest) Descriptor deprecated 

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

Deprecated: Use ResizeReplicaRequest.ProtoReflect.Descriptor instead.

func (*ResizeReplicaRequest) GetRequestedSize 

func (x *ResizeReplicaRequest) GetRequestedSize() uint64

func (*ResizeReplicaRequest) GetUuid 

func (x *ResizeReplicaRequest) GetUuid() string

func (*ResizeReplicaRequest) ProtoMessage 

func (*ResizeReplicaRequest) ProtoMessage()

func (*ResizeReplicaRequest) ProtoReflect 

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

func (*ResizeReplicaRequest) Reset 

func (x *ResizeReplicaRequest) Reset()

func (*ResizeReplicaRequest) String 

func (x *ResizeReplicaRequest) String() string

type ResourceUsage 

type ResourceUsage struct {
	SoftFaults  int64 `protobuf:"varint,1,opt,name=soft_faults,json=softFaults,proto3" json:"soft_faults,omitempty"`      // page reclaims (soft page faults)
	HardFaults  int64 `protobuf:"varint,2,opt,name=hard_faults,json=hardFaults,proto3" json:"hard_faults,omitempty"`      // hard page faults
	Swaps       int64 `protobuf:"varint,3,opt,name=swaps,proto3" json:"swaps,omitempty"`                                  // swaps
	InBlockOps  int64 `protobuf:"varint,4,opt,name=in_block_ops,json=inBlockOps,proto3" json:"in_block_ops,omitempty"`    // input block operations
	OutBlockOps int64 `protobuf:"varint,5,opt,name=out_block_ops,json=outBlockOps,proto3" json:"out_block_ops,omitempty"` // output block operations
	IpcMsgSend  int64 `protobuf:"varint,6,opt,name=ipc_msg_send,json=ipcMsgSend,proto3" json:"ipc_msg_send,omitempty"`    // IPC messages sent
	IpcMsgRcv   int64 `protobuf:"varint,7,opt,name=ipc_msg_rcv,json=ipcMsgRcv,proto3" json:"ipc_msg_rcv,omitempty"`       // IPC messages received
	Signals     int64 `protobuf:"varint,8,opt,name=signals,proto3" json:"signals,omitempty"`                              // signals received
	VolCsw      int64 `protobuf:"varint,9,opt,name=vol_csw,json=volCsw,proto3" json:"vol_csw,omitempty"`                  // voluntary context switches
	InvolCsw    int64 `protobuf:"varint,10,opt,name=invol_csw,json=involCsw,proto3" json:"invol_csw,omitempty"`           // involuntary context switches
	// contains filtered or unexported fields
}

func (*ResourceUsage) Descriptor deprecated 

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

Deprecated: Use ResourceUsage.ProtoReflect.Descriptor instead.

func (*ResourceUsage) GetHardFaults 

func (x *ResourceUsage) GetHardFaults() int64

func (*ResourceUsage) GetInBlockOps 

func (x *ResourceUsage) GetInBlockOps() int64

func (*ResourceUsage) GetInvolCsw 

func (x *ResourceUsage) GetInvolCsw() int64

func (*ResourceUsage) GetIpcMsgRcv 

func (x *ResourceUsage) GetIpcMsgRcv() int64

func (*ResourceUsage) GetIpcMsgSend 

func (x *ResourceUsage) GetIpcMsgSend() int64

func (*ResourceUsage) GetOutBlockOps 

func (x *ResourceUsage) GetOutBlockOps() int64

func (*ResourceUsage) GetSignals 

func (x *ResourceUsage) GetSignals() int64

func (*ResourceUsage) GetSoftFaults 

func (x *ResourceUsage) GetSoftFaults() int64

func (*ResourceUsage) GetSwaps 

func (x *ResourceUsage) GetSwaps() int64

func (*ResourceUsage) GetVolCsw 

func (x *ResourceUsage) GetVolCsw() int64

func (*ResourceUsage) ProtoMessage 

func (*ResourceUsage) ProtoMessage()

func (*ResourceUsage) ProtoReflect 

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

func (*ResourceUsage) Reset 

func (x *ResourceUsage) Reset()

func (*ResourceUsage) String 

func (x *ResourceUsage) String() string

type ResumeRebuildRequest 

type ResumeRebuildRequest struct {
	NexusUuid string `protobuf:"bytes,1,opt,name=nexus_uuid,json=nexusUuid,proto3" json:"nexus_uuid,omitempty"` // uuid of the nexus
	Uri       string `protobuf:"bytes,2,opt,name=uri,proto3" json:"uri,omitempty"`                              // uri of the destination child
	// contains filtered or unexported fields
}

func (*ResumeRebuildRequest) Descriptor deprecated 

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

Deprecated: Use ResumeRebuildRequest.ProtoReflect.Descriptor instead.

func (*ResumeRebuildRequest) GetNexusUuid 

func (x *ResumeRebuildRequest) GetNexusUuid() string

func (*ResumeRebuildRequest) GetUri 

func (x *ResumeRebuildRequest) GetUri() string

func (*ResumeRebuildRequest) ProtoMessage 

func (*ResumeRebuildRequest) ProtoMessage()

func (*ResumeRebuildRequest) ProtoReflect 

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

func (*ResumeRebuildRequest) Reset 

func (x *ResumeRebuildRequest) Reset()

func (*ResumeRebuildRequest) String 

func (x *ResumeRebuildRequest) String() string

type ResumeRebuildResponse 

type ResumeRebuildResponse struct {
	Nexus *Nexus `protobuf:"bytes,1,opt,name=nexus,proto3" json:"nexus,omitempty"`
	// contains filtered or unexported fields
}

func (*ResumeRebuildResponse) Descriptor deprecated 

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

Deprecated: Use ResumeRebuildResponse.ProtoReflect.Descriptor instead.

func (*ResumeRebuildResponse) GetNexus 

func (x *ResumeRebuildResponse) GetNexus() *Nexus

func (*ResumeRebuildResponse) ProtoMessage 

func (*ResumeRebuildResponse) ProtoMessage()

func (*ResumeRebuildResponse) ProtoReflect 

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

func (*ResumeRebuildResponse) Reset 

func (x *ResumeRebuildResponse) Reset()

func (*ResumeRebuildResponse) String 

func (x *ResumeRebuildResponse) String() string

type SetNvmeAnaStateRequest 

type SetNvmeAnaStateRequest struct {
	Uuid     string       `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"` // uuid of the nexus
	AnaState NvmeAnaState `protobuf:"varint,2,opt,name=ana_state,json=anaState,proto3,enum=mayastor.v1.NvmeAnaState" json:"ana_state,omitempty"`
	// contains filtered or unexported fields
}

func (*SetNvmeAnaStateRequest) Descriptor deprecated 

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

Deprecated: Use SetNvmeAnaStateRequest.ProtoReflect.Descriptor instead.

func (*SetNvmeAnaStateRequest) GetAnaState 

func (x *SetNvmeAnaStateRequest) GetAnaState() NvmeAnaState

func (*SetNvmeAnaStateRequest) GetUuid 

func (x *SetNvmeAnaStateRequest) GetUuid() string

func (*SetNvmeAnaStateRequest) ProtoMessage 

func (*SetNvmeAnaStateRequest) ProtoMessage()

func (*SetNvmeAnaStateRequest) ProtoReflect 

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

func (*SetNvmeAnaStateRequest) Reset 

func (x *SetNvmeAnaStateRequest) Reset()

func (*SetNvmeAnaStateRequest) String 

func (x *SetNvmeAnaStateRequest) String() string

type SetNvmeAnaStateResponse 

type SetNvmeAnaStateResponse struct {
	Nexus *Nexus `protobuf:"bytes,1,opt,name=nexus,proto3" json:"nexus,omitempty"`
	// contains filtered or unexported fields
}

func (*SetNvmeAnaStateResponse) Descriptor deprecated 

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

Deprecated: Use SetNvmeAnaStateResponse.ProtoReflect.Descriptor instead.

func (*SetNvmeAnaStateResponse) GetNexus 

func (x *SetNvmeAnaStateResponse) GetNexus() *Nexus

func (*SetNvmeAnaStateResponse) ProtoMessage 

func (*SetNvmeAnaStateResponse) ProtoMessage()

func (*SetNvmeAnaStateResponse) ProtoReflect 

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

func (*SetNvmeAnaStateResponse) Reset 

func (x *SetNvmeAnaStateResponse) Reset()

func (*SetNvmeAnaStateResponse) String 

func (x *SetNvmeAnaStateResponse) String() string

type ShareProtocol 

type ShareProtocol int32

Protocol over which the bdev/replica/nexus etc will be shared. 

const (
	ShareProtocol_NONE  ShareProtocol = 0 // not exposed
	ShareProtocol_NVMF  ShareProtocol = 1 // NVMe over Fabrics (TCP)
	ShareProtocol_ISCSI ShareProtocol = 2 // iSCSI
)

func (ShareProtocol) Descriptor 

func (ShareProtocol) Descriptor() protoreflect.EnumDescriptor

func (ShareProtocol) Enum 

func (x ShareProtocol) Enum() *ShareProtocol

func (ShareProtocol) EnumDescriptor deprecated 

func (ShareProtocol) EnumDescriptor() ([]byte, []int)

Deprecated: Use ShareProtocol.Descriptor instead.

func (ShareProtocol) Number 

func (x ShareProtocol) Number() protoreflect.EnumNumber

func (ShareProtocol) String 

func (x ShareProtocol) String() string

func (ShareProtocol) Type 

func (ShareProtocol) Type() protoreflect.EnumType

type ShareReplicaRequest 

type ShareReplicaRequest struct {
	Uuid string `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"` // uuid of the replica
	// protocol used for exposing the replica
	Share        ShareProtocol `protobuf:"varint,2,opt,name=share,proto3,enum=mayastor.v1.ShareProtocol" json:"share,omitempty"`
	AllowedHosts []string      `protobuf:"bytes,3,rep,name=allowed_hosts,json=allowedHosts,proto3" json:"allowed_hosts,omitempty"` // host (nqn's) which are allowed to connect to the target.
	// contains filtered or unexported fields
}

Share replica request.

func (*ShareReplicaRequest) Descriptor deprecated 

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

Deprecated: Use ShareReplicaRequest.ProtoReflect.Descriptor instead.

func (*ShareReplicaRequest) GetAllowedHosts 

func (x *ShareReplicaRequest) GetAllowedHosts() []string

func (*ShareReplicaRequest) GetShare 

func (x *ShareReplicaRequest) GetShare() ShareProtocol

func (*ShareReplicaRequest) GetUuid 

func (x *ShareReplicaRequest) GetUuid() string

func (*ShareReplicaRequest) ProtoMessage 

func (*ShareReplicaRequest) ProtoMessage()

func (*ShareReplicaRequest) ProtoReflect 

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

func (*ShareReplicaRequest) Reset 

func (x *ShareReplicaRequest) Reset()

func (*ShareReplicaRequest) String 

func (x *ShareReplicaRequest) String() string

type ShutdownNexusRequest 

type ShutdownNexusRequest struct {
	Uuid string `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"` // uuid of the nexus
	// contains filtered or unexported fields
}

func (*ShutdownNexusRequest) Descriptor deprecated 

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

Deprecated: Use ShutdownNexusRequest.ProtoReflect.Descriptor instead.

func (*ShutdownNexusRequest) GetUuid 

func (x *ShutdownNexusRequest) GetUuid() string

func (*ShutdownNexusRequest) ProtoMessage 

func (*ShutdownNexusRequest) ProtoMessage()

func (*ShutdownNexusRequest) ProtoReflect 

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

func (*ShutdownNexusRequest) Reset 

func (x *ShutdownNexusRequest) Reset()

func (*ShutdownNexusRequest) String 

func (x *ShutdownNexusRequest) String() string

type ShutdownNexusResponse 

type ShutdownNexusResponse struct {
	Nexus *Nexus `protobuf:"bytes,1,opt,name=nexus,proto3" json:"nexus,omitempty"`
	// contains filtered or unexported fields
}

func (*ShutdownNexusResponse) Descriptor deprecated 

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

Deprecated: Use ShutdownNexusResponse.ProtoReflect.Descriptor instead.

func (*ShutdownNexusResponse) GetNexus 

func (x *ShutdownNexusResponse) GetNexus() *Nexus

func (*ShutdownNexusResponse) ProtoMessage 

func (*ShutdownNexusResponse) ProtoMessage()

func (*ShutdownNexusResponse) ProtoReflect 

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

func (*ShutdownNexusResponse) Reset 

func (x *ShutdownNexusResponse) Reset()

func (*ShutdownNexusResponse) String 

func (x *ShutdownNexusResponse) String() string

type SnapshotInfo 

type SnapshotInfo struct {
	SnapshotUuid      string                 `protobuf:"bytes,1,opt,name=snapshot_uuid,json=snapshotUuid,proto3" json:"snapshot_uuid,omitempty"`                  // uuid of the snapshot
	SnapshotName      string                 `protobuf:"bytes,2,opt,name=snapshot_name,json=snapshotName,proto3" json:"snapshot_name,omitempty"`                  // name of the snapshot
	SnapshotSize      uint64                 `protobuf:"varint,3,opt,name=snapshot_size,json=snapshotSize,proto3" json:"snapshot_size,omitempty"`                 // amount of bytes referenced by snapshot
	NumClones         uint64                 `protobuf:"varint,4,opt,name=num_clones,json=numClones,proto3" json:"num_clones,omitempty"`                          // number of clones created from this snapshot
	Timestamp         *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=timestamp,proto3" json:"timestamp,omitempty"`                                            // snapshot creation_timestamp
	SourceUuid        string                 `protobuf:"bytes,6,opt,name=source_uuid,json=sourceUuid,proto3" json:"source_uuid,omitempty"`                        // uuid of the source from which snapshot is created (nexus / replica)
	SourceSize        uint64                 `protobuf:"varint,7,opt,name=source_size,json=sourceSize,proto3" json:"source_size,omitempty"`                       // amount of bytes referenced by source
	PoolUuid          string                 `protobuf:"bytes,8,opt,name=pool_uuid,json=poolUuid,proto3" json:"pool_uuid,omitempty"`                              // pool UUID in which snapshot is present
	PoolName          string                 `protobuf:"bytes,9,opt,name=pool_name,json=poolName,proto3" json:"pool_name,omitempty"`                              // pool name in which snapshot is present
	EntityId          string                 `protobuf:"bytes,10,opt,name=entity_id,json=entityId,proto3" json:"entity_id,omitempty"`                             // uuid of the entity for which snapshot is taken.
	TxnId             string                 `protobuf:"bytes,11,opt,name=txn_id,json=txnId,proto3" json:"txn_id,omitempty"`                                      // unique transaction id for snapshot.
	ValidSnapshot     bool                   `protobuf:"varint,12,opt,name=valid_snapshot,json=validSnapshot,proto3" json:"valid_snapshot,omitempty"`             // true: valid, false: invalid (missing one/more snapshot descriptor field i.e. txn_id, entity_id, source_uuid
	ReadyAsSource     bool                   `protobuf:"varint,13,opt,name=ready_as_source,json=readyAsSource,proto3" json:"ready_as_source,omitempty"`           // ready for usage, i,e source for another volume.
	ReferencedBytes   uint64                 `protobuf:"varint,14,opt,name=referenced_bytes,json=referencedBytes,proto3" json:"referenced_bytes,omitempty"`       // amount of bytes referenced by all successor snapshots.
	DiscardedSnapshot bool                   `protobuf:"varint,15,opt,name=discarded_snapshot,json=discardedSnapshot,proto3" json:"discarded_snapshot,omitempty"` // true: snapshot is marked as discarded. false: Valid Snapshot
	// contains filtered or unexported fields
}

Parameter details of a single snapshot

func (*SnapshotInfo) Descriptor deprecated 

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

Deprecated: Use SnapshotInfo.ProtoReflect.Descriptor instead.

func (*SnapshotInfo) GetDiscardedSnapshot 

func (x *SnapshotInfo) GetDiscardedSnapshot() bool

func (*SnapshotInfo) GetEntityId 

func (x *SnapshotInfo) GetEntityId() string

func (*SnapshotInfo) GetNumClones 

func (x *SnapshotInfo) GetNumClones() uint64

func (*SnapshotInfo) GetPoolName 

func (x *SnapshotInfo) GetPoolName() string

func (*SnapshotInfo) GetPoolUuid 

func (x *SnapshotInfo) GetPoolUuid() string

func (*SnapshotInfo) GetReadyAsSource 

func (x *SnapshotInfo) GetReadyAsSource() bool

func (*SnapshotInfo) GetReferencedBytes 

func (x *SnapshotInfo) GetReferencedBytes() uint64

func (*SnapshotInfo) GetSnapshotName 

func (x *SnapshotInfo) GetSnapshotName() string

func (*SnapshotInfo) GetSnapshotSize 

func (x *SnapshotInfo) GetSnapshotSize() uint64

func (*SnapshotInfo) GetSnapshotUuid 

func (x *SnapshotInfo) GetSnapshotUuid() string

func (*SnapshotInfo) GetSourceSize 

func (x *SnapshotInfo) GetSourceSize() uint64

func (*SnapshotInfo) GetSourceUuid 

func (x *SnapshotInfo) GetSourceUuid() string

func (*SnapshotInfo) GetTimestamp 

func (x *SnapshotInfo) GetTimestamp() *timestamppb.Timestamp

func (*SnapshotInfo) GetTxnId 

func (x *SnapshotInfo) GetTxnId() string

func (*SnapshotInfo) GetValidSnapshot 

func (x *SnapshotInfo) GetValidSnapshot() bool

func (*SnapshotInfo) ProtoMessage 

func (*SnapshotInfo) ProtoMessage()

func (*SnapshotInfo) ProtoReflect 

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

func (*SnapshotInfo) Reset 

func (x *SnapshotInfo) Reset()

func (*SnapshotInfo) String 

func (x *SnapshotInfo) String() string

type SnapshotRpcClient 

type SnapshotRpcClient interface {
	// Common snapshot related methods.
	CreateReplicaSnapshot(ctx context.Context, in *CreateReplicaSnapshotRequest, opts ...grpc.CallOption) (*CreateReplicaSnapshotResponse, error)
	CreateNexusSnapshot(ctx context.Context, in *NexusCreateSnapshotRequest, opts ...grpc.CallOption) (*NexusCreateSnapshotResponse, error)
	ListSnapshot(ctx context.Context, in *ListSnapshotsRequest, opts ...grpc.CallOption) (*ListSnapshotsResponse, error)
	DestroySnapshot(ctx context.Context, in *DestroySnapshotRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	CreateSnapshotClone(ctx context.Context, in *CreateSnapshotCloneRequest, opts ...grpc.CallOption) (*Replica, error)
	ListSnapshotClone(ctx context.Context, in *ListSnapshotCloneRequest, opts ...grpc.CallOption) (*ListSnapshotCloneResponse, error)
}

SnapshotRpcClient is the client API for SnapshotRpc 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 NewSnapshotRpcClient 

func NewSnapshotRpcClient(cc grpc.ClientConnInterface) SnapshotRpcClient

type SnapshotRpcServer 

type SnapshotRpcServer interface {
	// Common snapshot related methods.
	CreateReplicaSnapshot(context.Context, *CreateReplicaSnapshotRequest) (*CreateReplicaSnapshotResponse, error)
	CreateNexusSnapshot(context.Context, *NexusCreateSnapshotRequest) (*NexusCreateSnapshotResponse, error)
	ListSnapshot(context.Context, *ListSnapshotsRequest) (*ListSnapshotsResponse, error)
	DestroySnapshot(context.Context, *DestroySnapshotRequest) (*emptypb.Empty, error)
	CreateSnapshotClone(context.Context, *CreateSnapshotCloneRequest) (*Replica, error)
	ListSnapshotClone(context.Context, *ListSnapshotCloneRequest) (*ListSnapshotCloneResponse, error)
	// contains filtered or unexported methods
}

SnapshotRpcServer is the server API for SnapshotRpc service. All implementations must embed UnimplementedSnapshotRpcServer for forward compatibility

type StartRebuildRequest 

type StartRebuildRequest struct {
	NexusUuid string `protobuf:"bytes,1,opt,name=nexus_uuid,json=nexusUuid,proto3" json:"nexus_uuid,omitempty"` // uuid of the nexus
	Uri       string `protobuf:"bytes,2,opt,name=uri,proto3" json:"uri,omitempty"`                              // uri of the child to be rebuilt
	// contains filtered or unexported fields
}

func (*StartRebuildRequest) Descriptor deprecated 

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

Deprecated: Use StartRebuildRequest.ProtoReflect.Descriptor instead.

func (*StartRebuildRequest) GetNexusUuid 

func (x *StartRebuildRequest) GetNexusUuid() string

func (*StartRebuildRequest) GetUri 

func (x *StartRebuildRequest) GetUri() string

func (*StartRebuildRequest) ProtoMessage 

func (*StartRebuildRequest) ProtoMessage()

func (*StartRebuildRequest) ProtoReflect 

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

func (*StartRebuildRequest) Reset 

func (x *StartRebuildRequest) Reset()

func (*StartRebuildRequest) String 

func (x *StartRebuildRequest) String() string

type StartRebuildResponse 

type StartRebuildResponse struct {
	Nexus *Nexus `protobuf:"bytes,1,opt,name=nexus,proto3" json:"nexus,omitempty"`
	// contains filtered or unexported fields
}

func (*StartRebuildResponse) Descriptor deprecated 

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

Deprecated: Use StartRebuildResponse.ProtoReflect.Descriptor instead.

func (*StartRebuildResponse) GetNexus 

func (x *StartRebuildResponse) GetNexus() *Nexus

func (*StartRebuildResponse) ProtoMessage 

func (*StartRebuildResponse) ProtoMessage()

func (*StartRebuildResponse) ProtoReflect 

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

func (*StartRebuildResponse) Reset 

func (x *StartRebuildResponse) Reset()

func (*StartRebuildResponse) String 

func (x *StartRebuildResponse) String() string

type StatNvmeControllerRequest 

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

func (*StatNvmeControllerRequest) Descriptor deprecated 

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

Deprecated: Use StatNvmeControllerRequest.ProtoReflect.Descriptor instead.

func (*StatNvmeControllerRequest) GetName 

func (x *StatNvmeControllerRequest) GetName() string

func (*StatNvmeControllerRequest) ProtoMessage 

func (*StatNvmeControllerRequest) ProtoMessage()

func (*StatNvmeControllerRequest) ProtoReflect 

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

func (*StatNvmeControllerRequest) Reset 

func (x *StatNvmeControllerRequest) Reset()

func (*StatNvmeControllerRequest) String 

func (x *StatNvmeControllerRequest) String() string

type StatNvmeControllerResponse 

type StatNvmeControllerResponse struct {
	Stats *NvmeControllerIoStats `protobuf:"bytes,1,opt,name=stats,proto3" json:"stats,omitempty"` // Controller I/O statistics
	// contains filtered or unexported fields
}

func (*StatNvmeControllerResponse) Descriptor deprecated 

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

Deprecated: Use StatNvmeControllerResponse.ProtoReflect.Descriptor instead.

func (*StatNvmeControllerResponse) GetStats 

func (x *StatNvmeControllerResponse) GetStats() *NvmeControllerIoStats

func (*StatNvmeControllerResponse) ProtoMessage 

func (*StatNvmeControllerResponse) ProtoMessage()

func (*StatNvmeControllerResponse) ProtoReflect 

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

func (*StatNvmeControllerResponse) Reset 

func (x *StatNvmeControllerResponse) Reset()

func (*StatNvmeControllerResponse) String 

func (x *StatNvmeControllerResponse) String() string

type StatsRpcClient 

type StatsRpcClient interface {
	// RPC to get Pool IO stats.
	GetPoolIoStats(ctx context.Context, in *ListStatsOption, opts ...grpc.CallOption) (*PoolIoStatsResponse, error)
	// RPC to reset Io Stats for all Pool, Replica and Nexus hosted on the node.
	ResetIoStats(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

StatsRpcClient is the client API for StatsRpc 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 NewStatsRpcClient 

func NewStatsRpcClient(cc grpc.ClientConnInterface) StatsRpcClient

type StatsRpcServer 

type StatsRpcServer interface {
	// RPC to get Pool IO stats.
	GetPoolIoStats(context.Context, *ListStatsOption) (*PoolIoStatsResponse, error)
	// RPC to reset Io Stats for all Pool, Replica and Nexus hosted on the node.
	ResetIoStats(context.Context, *emptypb.Empty) (*emptypb.Empty, error)
	// contains filtered or unexported methods
}

StatsRpcServer is the server API for StatsRpc service. All implementations must embed UnimplementedStatsRpcServer for forward compatibility

type StopRebuildRequest 

type StopRebuildRequest struct {
	NexusUuid string `protobuf:"bytes,1,opt,name=nexus_uuid,json=nexusUuid,proto3" json:"nexus_uuid,omitempty"` // uuid of the nexus
	Uri       string `protobuf:"bytes,2,opt,name=uri,proto3" json:"uri,omitempty"`                              // uri of the destination child
	// contains filtered or unexported fields
}

func (*StopRebuildRequest) Descriptor deprecated 

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

Deprecated: Use StopRebuildRequest.ProtoReflect.Descriptor instead.

func (*StopRebuildRequest) GetNexusUuid 

func (x *StopRebuildRequest) GetNexusUuid() string

func (*StopRebuildRequest) GetUri 

func (x *StopRebuildRequest) GetUri() string

func (*StopRebuildRequest) ProtoMessage 

func (*StopRebuildRequest) ProtoMessage()

func (*StopRebuildRequest) ProtoReflect 

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

func (*StopRebuildRequest) Reset 

func (x *StopRebuildRequest) Reset()

func (*StopRebuildRequest) String 

func (x *StopRebuildRequest) String() string

type StopRebuildResponse 

type StopRebuildResponse struct {
	Nexus *Nexus `protobuf:"bytes,1,opt,name=nexus,proto3" json:"nexus,omitempty"`
	// contains filtered or unexported fields
}

func (*StopRebuildResponse) Descriptor deprecated 

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

Deprecated: Use StopRebuildResponse.ProtoReflect.Descriptor instead.

func (*StopRebuildResponse) GetNexus 

func (x *StopRebuildResponse) GetNexus() *Nexus

func (*StopRebuildResponse) ProtoMessage 

func (*StopRebuildResponse) ProtoMessage()

func (*StopRebuildResponse) ProtoReflect 

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

func (*StopRebuildResponse) Reset 

func (x *StopRebuildResponse) Reset()

func (*StopRebuildResponse) String 

func (x *StopRebuildResponse) String() string

type StreamWipeOptions 

type StreamWipeOptions struct {
	Options *WipeOptions `protobuf:"bytes,1,opt,name=options,proto3" json:"options,omitempty"`
	// Notify client when every chunk is complete.
	ChunkSize uint64 `protobuf:"varint,2,opt,name=chunk_size,json=chunkSize,proto3" json:"chunk_size,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamWipeOptions) Descriptor deprecated 

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

Deprecated: Use StreamWipeOptions.ProtoReflect.Descriptor instead.

func (*StreamWipeOptions) GetChunkSize 

func (x *StreamWipeOptions) GetChunkSize() uint64

func (*StreamWipeOptions) GetOptions 

func (x *StreamWipeOptions) GetOptions() *WipeOptions

func (*StreamWipeOptions) ProtoMessage 

func (*StreamWipeOptions) ProtoMessage()

func (*StreamWipeOptions) ProtoReflect 

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

func (*StreamWipeOptions) Reset 

func (x *StreamWipeOptions) Reset()

func (*StreamWipeOptions) String 

func (x *StreamWipeOptions) String() string

type TestFeatures 

type TestFeatures struct {

	// Supported wipe methods.
	WipeMethods []WipeOptions_WipeMethod `` /* 142-byte string literal not displayed */
	// Supported checksum algorithms.
	CksumAlgs []WipeOptions_CheckSumAlgorithm `` /* 143-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*TestFeatures) Descriptor deprecated 

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

Deprecated: Use TestFeatures.ProtoReflect.Descriptor instead.

func (*TestFeatures) GetCksumAlgs 

func (x *TestFeatures) GetCksumAlgs() []WipeOptions_CheckSumAlgorithm

func (*TestFeatures) GetWipeMethods 

func (x *TestFeatures) GetWipeMethods() []WipeOptions_WipeMethod

func (*TestFeatures) ProtoMessage 

func (*TestFeatures) ProtoMessage()

func (*TestFeatures) ProtoReflect 

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

func (*TestFeatures) Reset 

func (x *TestFeatures) Reset()

func (*TestFeatures) String 

func (x *TestFeatures) String() string

type TestRpcClient 

type TestRpcClient interface {
	// Get all the features supported by the test service.
	GetFeatures(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*TestFeatures, error)
	// Replica related methods.
	//
	// Wipe a replica using the selected method.
	// The replica MUST NOT have any user data and must not be currently used
	// by any nexus => this will cause data loss!
	WipeReplica(ctx context.Context, in *WipeReplicaRequest, opts ...grpc.CallOption) (TestRpc_WipeReplicaClient, error)
	// Fault injection methods.
	//
	// Add a fault injection.
	AddFaultInjection(ctx context.Context, in *AddFaultInjectionRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Remove a fault injection.
	RemoveFaultInjection(ctx context.Context, in *RemoveFaultInjectionRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// List existing fault injections.
	ListFaultInjections(ctx context.Context, in *ListFaultInjectionsRequest, opts ...grpc.CallOption) (*ListFaultInjectionsReply, error)
}

TestRpcClient is the client API for TestRpc 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 NewTestRpcClient 

func NewTestRpcClient(cc grpc.ClientConnInterface) TestRpcClient

type TestRpcServer 

type TestRpcServer interface {
	// Get all the features supported by the test service.
	GetFeatures(context.Context, *emptypb.Empty) (*TestFeatures, error)
	// Replica related methods.
	//
	// Wipe a replica using the selected method.
	// The replica MUST NOT have any user data and must not be currently used
	// by any nexus => this will cause data loss!
	WipeReplica(*WipeReplicaRequest, TestRpc_WipeReplicaServer) error
	// Fault injection methods.
	//
	// Add a fault injection.
	AddFaultInjection(context.Context, *AddFaultInjectionRequest) (*emptypb.Empty, error)
	// Remove a fault injection.
	RemoveFaultInjection(context.Context, *RemoveFaultInjectionRequest) (*emptypb.Empty, error)
	// List existing fault injections.
	ListFaultInjections(context.Context, *ListFaultInjectionsRequest) (*ListFaultInjectionsReply, error)
	// contains filtered or unexported methods
}

TestRpcServer is the server API for TestRpc service. All implementations must embed UnimplementedTestRpcServer for forward compatibility

type TestRpc_WipeReplicaClient 

type TestRpc_WipeReplicaClient interface {
	Recv() (*WipeReplicaResponse, error)
	grpc.ClientStream
}

type TestRpc_WipeReplicaServer 

type TestRpc_WipeReplicaServer interface {
	Send(*WipeReplicaResponse) error
	grpc.ServerStream
}

type UnimplementedBdevRpcServer 

type UnimplementedBdevRpcServer struct {
}

UnimplementedBdevRpcServer must be embedded to have forward compatible implementations.

func (UnimplementedBdevRpcServer) Create 

func (UnimplementedBdevRpcServer) Create(context.Context, *CreateBdevRequest) (*CreateBdevResponse, error)

func (UnimplementedBdevRpcServer) Destroy 

func (UnimplementedBdevRpcServer) Destroy(context.Context, *DestroyBdevRequest) (*emptypb.Empty, error)

func (UnimplementedBdevRpcServer) List 

func (UnimplementedBdevRpcServer) List(context.Context, *ListBdevOptions) (*ListBdevResponse, error)

func (UnimplementedBdevRpcServer) Share 

func (UnimplementedBdevRpcServer) Share(context.Context, *BdevShareRequest) (*BdevShareResponse, error)

func (UnimplementedBdevRpcServer) Unshare 

func (UnimplementedBdevRpcServer) Unshare(context.Context, *BdevUnshareRequest) (*emptypb.Empty, error)

type UnimplementedHostRpcServer 

type UnimplementedHostRpcServer struct {
}

UnimplementedHostRpcServer must be embedded to have forward compatible implementations.

func (UnimplementedHostRpcServer) GetMayastorInfo 

func (UnimplementedHostRpcServer) GetMayastorInfo(context.Context, *emptypb.Empty) (*MayastorInfoResponse, error)

func (UnimplementedHostRpcServer) GetMayastorResourceUsage 

func (UnimplementedHostRpcServer) GetMayastorResourceUsage(context.Context, *emptypb.Empty) (*GetMayastorResourceUsageResponse, error)

func (UnimplementedHostRpcServer) ListBlockDevices 

func (UnimplementedHostRpcServer) ListBlockDevices(context.Context, *ListBlockDevicesRequest) (*ListBlockDevicesResponse, error)

func (UnimplementedHostRpcServer) ListNvmeControllers 

func (UnimplementedHostRpcServer) ListNvmeControllers(context.Context, *emptypb.Empty) (*ListNvmeControllersResponse, error)

func (UnimplementedHostRpcServer) StatNvmeController 

func (UnimplementedHostRpcServer) StatNvmeController(context.Context, *StatNvmeControllerRequest) (*StatNvmeControllerResponse, error)

type UnimplementedJsonRpcServer 

type UnimplementedJsonRpcServer struct {
}

UnimplementedJsonRpcServer must be embedded to have forward compatible implementations.

func (UnimplementedJsonRpcServer) JsonRpcCall 

func (UnimplementedJsonRpcServer) JsonRpcCall(context.Context, *JsonRpcRequest) (*JsonRpcResponse, error)

type UnimplementedNexusRpcServer 

type UnimplementedNexusRpcServer struct {
}

UnimplementedNexusRpcServer must be embedded to have forward compatible implementations.

func (UnimplementedNexusRpcServer) AddChildNexus 

func (UnimplementedNexusRpcServer) AddChildNexus(context.Context, *AddChildNexusRequest) (*AddChildNexusResponse, error)

func (UnimplementedNexusRpcServer) ChildOperation 

func (UnimplementedNexusRpcServer) ChildOperation(context.Context, *ChildOperationRequest) (*ChildOperationResponse, error)

func (UnimplementedNexusRpcServer) CreateNexus 

func (UnimplementedNexusRpcServer) CreateNexus(context.Context, *CreateNexusRequest) (*CreateNexusResponse, error)

func (UnimplementedNexusRpcServer) DestroyNexus 

func (UnimplementedNexusRpcServer) DestroyNexus(context.Context, *DestroyNexusRequest) (*emptypb.Empty, error)

func (UnimplementedNexusRpcServer) FaultNexusChild 

func (UnimplementedNexusRpcServer) FaultNexusChild(context.Context, *FaultNexusChildRequest) (*FaultNexusChildResponse, error)

func (UnimplementedNexusRpcServer) GetNvmeAnaState 

func (UnimplementedNexusRpcServer) GetNvmeAnaState(context.Context, *GetNvmeAnaStateRequest) (*GetNvmeAnaStateResponse, error)

func (UnimplementedNexusRpcServer) GetRebuildHistory 

func (UnimplementedNexusRpcServer) GetRebuildHistory(context.Context, *RebuildHistoryRequest) (*RebuildHistoryResponse, error)

func (UnimplementedNexusRpcServer) GetRebuildState 

func (UnimplementedNexusRpcServer) GetRebuildState(context.Context, *RebuildStateRequest) (*RebuildStateResponse, error)

func (UnimplementedNexusRpcServer) GetRebuildStats 

func (UnimplementedNexusRpcServer) GetRebuildStats(context.Context, *RebuildStatsRequest) (*RebuildStatsResponse, error)

func (UnimplementedNexusRpcServer) ListNexus 

func (UnimplementedNexusRpcServer) ListNexus(context.Context, *ListNexusOptions) (*ListNexusResponse, error)

func (UnimplementedNexusRpcServer) ListRebuildHistory 

func (UnimplementedNexusRpcServer) ListRebuildHistory(context.Context, *ListRebuildHistoryRequest) (*ListRebuildHistoryResponse, error)

func (UnimplementedNexusRpcServer) PauseRebuild 

func (UnimplementedNexusRpcServer) PauseRebuild(context.Context, *PauseRebuildRequest) (*PauseRebuildResponse, error)

func (UnimplementedNexusRpcServer) PublishNexus 

func (UnimplementedNexusRpcServer) PublishNexus(context.Context, *PublishNexusRequest) (*PublishNexusResponse, error)

func (UnimplementedNexusRpcServer) RemoveChildNexus 

func (UnimplementedNexusRpcServer) RemoveChildNexus(context.Context, *RemoveChildNexusRequest) (*RemoveChildNexusResponse, error)

func (UnimplementedNexusRpcServer) ResumeRebuild 

func (UnimplementedNexusRpcServer) ResumeRebuild(context.Context, *ResumeRebuildRequest) (*ResumeRebuildResponse, error)

func (UnimplementedNexusRpcServer) SetNvmeAnaState 

func (UnimplementedNexusRpcServer) SetNvmeAnaState(context.Context, *SetNvmeAnaStateRequest) (*SetNvmeAnaStateResponse, error)

func (UnimplementedNexusRpcServer) ShutdownNexus 

func (UnimplementedNexusRpcServer) ShutdownNexus(context.Context, *ShutdownNexusRequest) (*ShutdownNexusResponse, error)

func (UnimplementedNexusRpcServer) StartRebuild 

func (UnimplementedNexusRpcServer) StartRebuild(context.Context, *StartRebuildRequest) (*StartRebuildResponse, error)

func (UnimplementedNexusRpcServer) StopRebuild 

func (UnimplementedNexusRpcServer) StopRebuild(context.Context, *StopRebuildRequest) (*StopRebuildResponse, error)

func (UnimplementedNexusRpcServer) UnpublishNexus 

func (UnimplementedNexusRpcServer) UnpublishNexus(context.Context, *UnpublishNexusRequest) (*UnpublishNexusResponse, error)

type UnimplementedPoolRpcServer 

type UnimplementedPoolRpcServer struct {
}

UnimplementedPoolRpcServer must be embedded to have forward compatible implementations.

func (UnimplementedPoolRpcServer) CreatePool 

func (UnimplementedPoolRpcServer) CreatePool(context.Context, *CreatePoolRequest) (*Pool, error)

func (UnimplementedPoolRpcServer) DestroyPool 

func (UnimplementedPoolRpcServer) DestroyPool(context.Context, *DestroyPoolRequest) (*emptypb.Empty, error)

func (UnimplementedPoolRpcServer) ExportPool 

func (UnimplementedPoolRpcServer) ExportPool(context.Context, *ExportPoolRequest) (*emptypb.Empty, error)

func (UnimplementedPoolRpcServer) ImportPool 

func (UnimplementedPoolRpcServer) ImportPool(context.Context, *ImportPoolRequest) (*Pool, error)

func (UnimplementedPoolRpcServer) ListPools 

func (UnimplementedPoolRpcServer) ListPools(context.Context, *ListPoolOptions) (*ListPoolsResponse, error)

type UnimplementedRegistrationServer 

type UnimplementedRegistrationServer struct {
}

UnimplementedRegistrationServer must be embedded to have forward compatible implementations.

func (UnimplementedRegistrationServer) Deregister 

func (UnimplementedRegistrationServer) Deregister(context.Context, *DeregisterRequest) (*emptypb.Empty, error)

func (UnimplementedRegistrationServer) Register 

func (UnimplementedRegistrationServer) Register(context.Context, *RegisterRequest) (*emptypb.Empty, error)

type UnimplementedReplicaRpcServer 

type UnimplementedReplicaRpcServer struct {
}

UnimplementedReplicaRpcServer must be embedded to have forward compatible implementations.

func (UnimplementedReplicaRpcServer) CreateReplica 

func (UnimplementedReplicaRpcServer) CreateReplica(context.Context, *CreateReplicaRequest) (*Replica, error)

func (UnimplementedReplicaRpcServer) DestroyReplica 

func (UnimplementedReplicaRpcServer) DestroyReplica(context.Context, *DestroyReplicaRequest) (*emptypb.Empty, error)

func (UnimplementedReplicaRpcServer) ListReplicas 

func (UnimplementedReplicaRpcServer) ListReplicas(context.Context, *ListReplicaOptions) (*ListReplicasResponse, error)

func (UnimplementedReplicaRpcServer) ResizeReplica 

func (UnimplementedReplicaRpcServer) ResizeReplica(context.Context, *ResizeReplicaRequest) (*Replica, error)

func (UnimplementedReplicaRpcServer) ShareReplica 

func (UnimplementedReplicaRpcServer) ShareReplica(context.Context, *ShareReplicaRequest) (*Replica, error)

func (UnimplementedReplicaRpcServer) UnshareReplica 

func (UnimplementedReplicaRpcServer) UnshareReplica(context.Context, *UnshareReplicaRequest) (*Replica, error)

type UnimplementedSnapshotRpcServer 

type UnimplementedSnapshotRpcServer struct {
}

UnimplementedSnapshotRpcServer must be embedded to have forward compatible implementations.

func (UnimplementedSnapshotRpcServer) CreateNexusSnapshot 

func (UnimplementedSnapshotRpcServer) CreateNexusSnapshot(context.Context, *NexusCreateSnapshotRequest) (*NexusCreateSnapshotResponse, error)

func (UnimplementedSnapshotRpcServer) CreateReplicaSnapshot 

func (UnimplementedSnapshotRpcServer) CreateReplicaSnapshot(context.Context, *CreateReplicaSnapshotRequest) (*CreateReplicaSnapshotResponse, error)

func (UnimplementedSnapshotRpcServer) CreateSnapshotClone 

func (UnimplementedSnapshotRpcServer) CreateSnapshotClone(context.Context, *CreateSnapshotCloneRequest) (*Replica, error)

func (UnimplementedSnapshotRpcServer) DestroySnapshot 

func (UnimplementedSnapshotRpcServer) DestroySnapshot(context.Context, *DestroySnapshotRequest) (*emptypb.Empty, error)

func (UnimplementedSnapshotRpcServer) ListSnapshot 

func (UnimplementedSnapshotRpcServer) ListSnapshot(context.Context, *ListSnapshotsRequest) (*ListSnapshotsResponse, error)

func (UnimplementedSnapshotRpcServer) ListSnapshotClone 

func (UnimplementedSnapshotRpcServer) ListSnapshotClone(context.Context, *ListSnapshotCloneRequest) (*ListSnapshotCloneResponse, error)

type UnimplementedStatsRpcServer 

type UnimplementedStatsRpcServer struct {
}

UnimplementedStatsRpcServer must be embedded to have forward compatible implementations.

func (UnimplementedStatsRpcServer) GetPoolIoStats 

func (UnimplementedStatsRpcServer) GetPoolIoStats(context.Context, *ListStatsOption) (*PoolIoStatsResponse, error)

func (UnimplementedStatsRpcServer) ResetIoStats 

func (UnimplementedStatsRpcServer) ResetIoStats(context.Context, *emptypb.Empty) (*emptypb.Empty, error)

type UnimplementedTestRpcServer 

type UnimplementedTestRpcServer struct {
}

UnimplementedTestRpcServer must be embedded to have forward compatible implementations.

func (UnimplementedTestRpcServer) AddFaultInjection 

func (UnimplementedTestRpcServer) AddFaultInjection(context.Context, *AddFaultInjectionRequest) (*emptypb.Empty, error)

func (UnimplementedTestRpcServer) GetFeatures 

func (UnimplementedTestRpcServer) GetFeatures(context.Context, *emptypb.Empty) (*TestFeatures, error)

func (UnimplementedTestRpcServer) ListFaultInjections 

func (UnimplementedTestRpcServer) ListFaultInjections(context.Context, *ListFaultInjectionsRequest) (*ListFaultInjectionsReply, error)

func (UnimplementedTestRpcServer) RemoveFaultInjection 

func (UnimplementedTestRpcServer) RemoveFaultInjection(context.Context, *RemoveFaultInjectionRequest) (*emptypb.Empty, error)

func (UnimplementedTestRpcServer) WipeReplica 

func (UnimplementedTestRpcServer) WipeReplica(*WipeReplicaRequest, TestRpc_WipeReplicaServer) error

type UnpublishNexusRequest 

type UnpublishNexusRequest struct {
	Uuid string `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"` // uuid of the nexus which to destroy
	// contains filtered or unexported fields
}

func (*UnpublishNexusRequest) Descriptor deprecated 

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

Deprecated: Use UnpublishNexusRequest.ProtoReflect.Descriptor instead.

func (*UnpublishNexusRequest) GetUuid 

func (x *UnpublishNexusRequest) GetUuid() string

func (*UnpublishNexusRequest) ProtoMessage 

func (*UnpublishNexusRequest) ProtoMessage()

func (*UnpublishNexusRequest) ProtoReflect 

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

func (*UnpublishNexusRequest) Reset 

func (x *UnpublishNexusRequest) Reset()

func (*UnpublishNexusRequest) String 

func (x *UnpublishNexusRequest) String() string

type UnpublishNexusResponse 

type UnpublishNexusResponse struct {
	Nexus *Nexus `protobuf:"bytes,1,opt,name=nexus,proto3" json:"nexus,omitempty"`
	// contains filtered or unexported fields
}

func (*UnpublishNexusResponse) Descriptor deprecated 

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

Deprecated: Use UnpublishNexusResponse.ProtoReflect.Descriptor instead.

func (*UnpublishNexusResponse) GetNexus 

func (x *UnpublishNexusResponse) GetNexus() *Nexus

func (*UnpublishNexusResponse) ProtoMessage 

func (*UnpublishNexusResponse) ProtoMessage()

func (*UnpublishNexusResponse) ProtoReflect 

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

func (*UnpublishNexusResponse) Reset 

func (x *UnpublishNexusResponse) Reset()

func (*UnpublishNexusResponse) String 

func (x *UnpublishNexusResponse) String() string

type UnsafeBdevRpcServer 

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

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

type UnsafeHostRpcServer 

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

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

type UnsafeJsonRpcServer 

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

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

type UnsafeNexusRpcServer 

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

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

type UnsafePoolRpcServer 

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

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

type UnsafeRegistrationServer 

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

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

type UnsafeReplicaRpcServer 

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

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

type UnsafeSnapshotRpcServer 

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

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

type UnsafeStatsRpcServer 

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

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

type UnsafeTestRpcServer 

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

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

type UnshareReplicaRequest 

type UnshareReplicaRequest struct {
	Uuid string `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"` // uuid of the replica
	// contains filtered or unexported fields
}

Unshare replica request

func (*UnshareReplicaRequest) Descriptor deprecated 

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

Deprecated: Use UnshareReplicaRequest.ProtoReflect.Descriptor instead.

func (*UnshareReplicaRequest) GetUuid 

func (x *UnshareReplicaRequest) GetUuid() string

func (*UnshareReplicaRequest) ProtoMessage 

func (*UnshareReplicaRequest) ProtoMessage()

func (*UnshareReplicaRequest) ProtoReflect 

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

func (*UnshareReplicaRequest) Reset 

func (x *UnshareReplicaRequest) Reset()

func (*UnshareReplicaRequest) String 

func (x *UnshareReplicaRequest) String() string

type WipeOptions 

type WipeOptions struct {

	// Method used to wipe the bdev.
	WipeMethod WipeOptions_WipeMethod `` /* 132-byte string literal not displayed */
	// When using WRITE_PATTERN, wipe using this 32bit write pattern
	// Default: 0xDEADBEEF.
	WritePattern *uint32 `protobuf:"varint,2,opt,name=write_pattern,json=writePattern,proto3,oneof" json:"write_pattern,omitempty"`
	// When using CHECKSUM, use the following algorithm.
	CksumAlg WipeOptions_CheckSumAlgorithm `` /* 133-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*WipeOptions) Descriptor deprecated 

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

Deprecated: Use WipeOptions.ProtoReflect.Descriptor instead.

func (*WipeOptions) GetCksumAlg 

func (x *WipeOptions) GetCksumAlg() WipeOptions_CheckSumAlgorithm

func (*WipeOptions) GetWipeMethod 

func (x *WipeOptions) GetWipeMethod() WipeOptions_WipeMethod

func (*WipeOptions) GetWritePattern 

func (x *WipeOptions) GetWritePattern() uint32

func (*WipeOptions) ProtoMessage 

func (*WipeOptions) ProtoMessage()

func (*WipeOptions) ProtoReflect 

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

func (*WipeOptions) Reset 

func (x *WipeOptions) Reset()

func (*WipeOptions) String 

func (x *WipeOptions) String() string

type WipeOptions_CheckSumAlgorithm 

type WipeOptions_CheckSumAlgorithm int32
const (
	// The CRC32C is a variant of CRC32.
	WipeOptions_Crc32c WipeOptions_CheckSumAlgorithm = 0
)

func (WipeOptions_CheckSumAlgorithm) Descriptor 

func (WipeOptions_CheckSumAlgorithm) Descriptor() protoreflect.EnumDescriptor

func (WipeOptions_CheckSumAlgorithm) Enum 

func (x WipeOptions_CheckSumAlgorithm) Enum() *WipeOptions_CheckSumAlgorithm

func (WipeOptions_CheckSumAlgorithm) EnumDescriptor deprecated 

func (WipeOptions_CheckSumAlgorithm) EnumDescriptor() ([]byte, []int)

Deprecated: Use WipeOptions_CheckSumAlgorithm.Descriptor instead.

func (WipeOptions_CheckSumAlgorithm) Number 

func (x WipeOptions_CheckSumAlgorithm) Number() protoreflect.EnumNumber

func (WipeOptions_CheckSumAlgorithm) String 

func (x WipeOptions_CheckSumAlgorithm) String() string

func (WipeOptions_CheckSumAlgorithm) Type 

func (WipeOptions_CheckSumAlgorithm) Type() protoreflect.EnumType

type WipeOptions_WipeMethod 

type WipeOptions_WipeMethod int32
const (
	// Don't actually wipe, just pretend.
	WipeOptions_NONE WipeOptions_WipeMethod = 0
	// Wipe by writing zeroes.
	WipeOptions_WRITE_ZEROES WipeOptions_WipeMethod = 1
	// Wipe by sending unmap/trim.
	WipeOptions_UNMAP WipeOptions_WipeMethod = 2
	// Wipe by writing a given patter (see write_pattern(6) field).
	WipeOptions_WRITE_PATTERN WipeOptions_WipeMethod = 3
	// Checksum the bdev.
	WipeOptions_CHECKSUM WipeOptions_WipeMethod = 4
)

func (WipeOptions_WipeMethod) Descriptor 

func (WipeOptions_WipeMethod) Descriptor() protoreflect.EnumDescriptor

func (WipeOptions_WipeMethod) Enum 

func (x WipeOptions_WipeMethod) Enum() *WipeOptions_WipeMethod

func (WipeOptions_WipeMethod) EnumDescriptor deprecated 

func (WipeOptions_WipeMethod) EnumDescriptor() ([]byte, []int)

Deprecated: Use WipeOptions_WipeMethod.Descriptor instead.

func (WipeOptions_WipeMethod) Number 

func (x WipeOptions_WipeMethod) Number() protoreflect.EnumNumber

func (WipeOptions_WipeMethod) String 

func (x WipeOptions_WipeMethod) String() string

func (WipeOptions_WipeMethod) Type 

func (WipeOptions_WipeMethod) Type() protoreflect.EnumType

type WipeReplicaRequest 

type WipeReplicaRequest struct {

	// Uuid of the replica.
	Uuid string `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
	// Types that are assignable to Pool:
	//
	//	*WipeReplicaRequest_PoolName
	//	*WipeReplicaRequest_PoolUuid
	Pool        isWipeReplicaRequest_Pool `protobuf_oneof:"pool"`
	WipeOptions *StreamWipeOptions        `protobuf:"bytes,4,opt,name=wipe_options,json=wipeOptions,proto3" json:"wipe_options,omitempty"`
	// contains filtered or unexported fields
}

func (*WipeReplicaRequest) Descriptor deprecated 

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

Deprecated: Use WipeReplicaRequest.ProtoReflect.Descriptor instead.

func (*WipeReplicaRequest) GetPool 

func (m *WipeReplicaRequest) GetPool() isWipeReplicaRequest_Pool

func (*WipeReplicaRequest) GetPoolName 

func (x *WipeReplicaRequest) GetPoolName() string

func (*WipeReplicaRequest) GetPoolUuid 

func (x *WipeReplicaRequest) GetPoolUuid() string

func (*WipeReplicaRequest) GetUuid 

func (x *WipeReplicaRequest) GetUuid() string

func (*WipeReplicaRequest) GetWipeOptions 

func (x *WipeReplicaRequest) GetWipeOptions() *StreamWipeOptions

func (*WipeReplicaRequest) ProtoMessage 

func (*WipeReplicaRequest) ProtoMessage()

func (*WipeReplicaRequest) ProtoReflect 

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

func (*WipeReplicaRequest) Reset 

func (x *WipeReplicaRequest) Reset()

func (*WipeReplicaRequest) String 

func (x *WipeReplicaRequest) String() string

type WipeReplicaRequest_PoolName 

type WipeReplicaRequest_PoolName struct {
	// Name of the pool where the replica resides.
	PoolName string `protobuf:"bytes,2,opt,name=pool_name,json=poolName,proto3,oneof"`
}

type WipeReplicaRequest_PoolUuid 

type WipeReplicaRequest_PoolUuid struct {
	// Optional uuid for the pool where the replica resides.
	PoolUuid string `protobuf:"bytes,3,opt,name=pool_uuid,json=poolUuid,proto3,oneof"`
}

type WipeReplicaResponse 

type WipeReplicaResponse struct {

	// Uuid of the replica.
	Uuid string `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
	// Total bytes to be wiped.
	TotalBytes uint64 `protobuf:"varint,2,opt,name=total_bytes,json=totalBytes,proto3" json:"total_bytes,omitempty"`
	// Size of a chunk.
	ChunkSize uint64 `protobuf:"varint,3,opt,name=chunk_size,json=chunkSize,proto3" json:"chunk_size,omitempty"`
	// Size of the last chunk (may differ in case of non multiple of the total size).
	LastChunkSize uint64 `protobuf:"varint,4,opt,name=last_chunk_size,json=lastChunkSize,proto3" json:"last_chunk_size,omitempty"`
	// Number of chunks (how many notifications -1) to be received.
	TotalChunks uint64 `protobuf:"varint,5,opt,name=total_chunks,json=totalChunks,proto3" json:"total_chunks,omitempty"`
	// How many bytes we've wiped so far (this will be incremented in chunks).
	WipedBytes uint64 `protobuf:"varint,6,opt,name=wiped_bytes,json=wipedBytes,proto3" json:"wiped_bytes,omitempty"`
	// How many chunks we've wiped so far.
	WipedChunks uint64 `protobuf:"varint,7,opt,name=wiped_chunks,json=wipedChunks,proto3" json:"wiped_chunks,omitempty"`
	// Remaining bytes to be wiped.
	RemainingBytes uint64 `protobuf:"varint,8,opt,name=remaining_bytes,json=remainingBytes,proto3" json:"remaining_bytes,omitempty"`
	// Duration since the start of the wipe.
	Since *durationpb.Duration `protobuf:"bytes,9,opt,name=since,proto3" json:"since,omitempty"`
	// When using CHECKSUM, output of the algorithm.
	//
	// Types that are assignable to Checksum:
	//
	//	*WipeReplicaResponse_Crc32
	Checksum isWipeReplicaResponse_Checksum `protobuf_oneof:"checksum"`
	// contains filtered or unexported fields
}

Stream of messages which are sent from the server to the client. A message is sent at the beginning, then a message will be sent after each chunk sized bytes are wiped. In case of successful wipes this brings the total number of messages to total_chunks + 1.

func (*WipeReplicaResponse) Descriptor deprecated 

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

Deprecated: Use WipeReplicaResponse.ProtoReflect.Descriptor instead.

func (*WipeReplicaResponse) GetChecksum 

func (m *WipeReplicaResponse) GetChecksum() isWipeReplicaResponse_Checksum

func (*WipeReplicaResponse) GetChunkSize 

func (x *WipeReplicaResponse) GetChunkSize() uint64

func (*WipeReplicaResponse) GetCrc32 

func (x *WipeReplicaResponse) GetCrc32() uint32

func (*WipeReplicaResponse) GetLastChunkSize 

func (x *WipeReplicaResponse) GetLastChunkSize() uint64

func (*WipeReplicaResponse) GetRemainingBytes 

func (x *WipeReplicaResponse) GetRemainingBytes() uint64

func (*WipeReplicaResponse) GetSince 

func (x *WipeReplicaResponse) GetSince() *durationpb.Duration

func (*WipeReplicaResponse) GetTotalBytes 

func (x *WipeReplicaResponse) GetTotalBytes() uint64

func (*WipeReplicaResponse) GetTotalChunks 

func (x *WipeReplicaResponse) GetTotalChunks() uint64

func (*WipeReplicaResponse) GetUuid 

func (x *WipeReplicaResponse) GetUuid() string

func (*WipeReplicaResponse) GetWipedBytes 

func (x *WipeReplicaResponse) GetWipedBytes() uint64

func (*WipeReplicaResponse) GetWipedChunks 

func (x *WipeReplicaResponse) GetWipedChunks() uint64

func (*WipeReplicaResponse) ProtoMessage 

func (*WipeReplicaResponse) ProtoMessage()

func (*WipeReplicaResponse) ProtoReflect 

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

func (*WipeReplicaResponse) Reset 

func (x *WipeReplicaResponse) Reset()

func (*WipeReplicaResponse) String 

func (x *WipeReplicaResponse) String() string

type WipeReplicaResponse_Crc32 

type WipeReplicaResponse_Crc32 struct {
	// 32bit CRC.
	Crc32 uint32 `protobuf:"varint,10,opt,name=crc32,proto3,oneof"`
}

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.