mgmt

package
v0.0.0-...-ebe7275 Latest Latest
Warning

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

 Go to latest Published: Dec 23, 2024 License: BSD-2-Clause-Patent Imports: 13 Imported by: 16

Documentation

Index

Constants

View Source 
const (
	MgmtSvc_Join_FullMethodName                     = "/mgmt.MgmtSvc/Join"
	MgmtSvc_ClusterEvent_FullMethodName             = "/mgmt.MgmtSvc/ClusterEvent"
	MgmtSvc_LeaderQuery_FullMethodName              = "/mgmt.MgmtSvc/LeaderQuery"
	MgmtSvc_PoolCreate_FullMethodName               = "/mgmt.MgmtSvc/PoolCreate"
	MgmtSvc_PoolDestroy_FullMethodName              = "/mgmt.MgmtSvc/PoolDestroy"
	MgmtSvc_PoolEvict_FullMethodName                = "/mgmt.MgmtSvc/PoolEvict"
	MgmtSvc_PoolExclude_FullMethodName              = "/mgmt.MgmtSvc/PoolExclude"
	MgmtSvc_PoolDrain_FullMethodName                = "/mgmt.MgmtSvc/PoolDrain"
	MgmtSvc_PoolExtend_FullMethodName               = "/mgmt.MgmtSvc/PoolExtend"
	MgmtSvc_PoolReintegrate_FullMethodName          = "/mgmt.MgmtSvc/PoolReintegrate"
	MgmtSvc_PoolQuery_FullMethodName                = "/mgmt.MgmtSvc/PoolQuery"
	MgmtSvc_PoolQueryTarget_FullMethodName          = "/mgmt.MgmtSvc/PoolQueryTarget"
	MgmtSvc_PoolSetProp_FullMethodName              = "/mgmt.MgmtSvc/PoolSetProp"
	MgmtSvc_PoolGetProp_FullMethodName              = "/mgmt.MgmtSvc/PoolGetProp"
	MgmtSvc_PoolGetACL_FullMethodName               = "/mgmt.MgmtSvc/PoolGetACL"
	MgmtSvc_PoolOverwriteACL_FullMethodName         = "/mgmt.MgmtSvc/PoolOverwriteACL"
	MgmtSvc_PoolUpdateACL_FullMethodName            = "/mgmt.MgmtSvc/PoolUpdateACL"
	MgmtSvc_PoolDeleteACL_FullMethodName            = "/mgmt.MgmtSvc/PoolDeleteACL"
	MgmtSvc_GetAttachInfo_FullMethodName            = "/mgmt.MgmtSvc/GetAttachInfo"
	MgmtSvc_ListPools_FullMethodName                = "/mgmt.MgmtSvc/ListPools"
	MgmtSvc_ListContainers_FullMethodName           = "/mgmt.MgmtSvc/ListContainers"
	MgmtSvc_ContSetOwner_FullMethodName             = "/mgmt.MgmtSvc/ContSetOwner"
	MgmtSvc_SystemQuery_FullMethodName              = "/mgmt.MgmtSvc/SystemQuery"
	MgmtSvc_SystemStop_FullMethodName               = "/mgmt.MgmtSvc/SystemStop"
	MgmtSvc_SystemStart_FullMethodName              = "/mgmt.MgmtSvc/SystemStart"
	MgmtSvc_SystemExclude_FullMethodName            = "/mgmt.MgmtSvc/SystemExclude"
	MgmtSvc_SystemDrain_FullMethodName              = "/mgmt.MgmtSvc/SystemDrain"
	MgmtSvc_SystemErase_FullMethodName              = "/mgmt.MgmtSvc/SystemErase"
	MgmtSvc_SystemCleanup_FullMethodName            = "/mgmt.MgmtSvc/SystemCleanup"
	MgmtSvc_SystemCheckEnable_FullMethodName        = "/mgmt.MgmtSvc/SystemCheckEnable"
	MgmtSvc_SystemCheckDisable_FullMethodName       = "/mgmt.MgmtSvc/SystemCheckDisable"
	MgmtSvc_SystemCheckStart_FullMethodName         = "/mgmt.MgmtSvc/SystemCheckStart"
	MgmtSvc_SystemCheckStop_FullMethodName          = "/mgmt.MgmtSvc/SystemCheckStop"
	MgmtSvc_SystemCheckQuery_FullMethodName         = "/mgmt.MgmtSvc/SystemCheckQuery"
	MgmtSvc_SystemCheckSetPolicy_FullMethodName     = "/mgmt.MgmtSvc/SystemCheckSetPolicy"
	MgmtSvc_SystemCheckGetPolicy_FullMethodName     = "/mgmt.MgmtSvc/SystemCheckGetPolicy"
	MgmtSvc_SystemCheckRepair_FullMethodName        = "/mgmt.MgmtSvc/SystemCheckRepair"
	MgmtSvc_PoolUpgrade_FullMethodName              = "/mgmt.MgmtSvc/PoolUpgrade"
	MgmtSvc_SystemSetAttr_FullMethodName            = "/mgmt.MgmtSvc/SystemSetAttr"
	MgmtSvc_SystemGetAttr_FullMethodName            = "/mgmt.MgmtSvc/SystemGetAttr"
	MgmtSvc_SystemSetProp_FullMethodName            = "/mgmt.MgmtSvc/SystemSetProp"
	MgmtSvc_SystemGetProp_FullMethodName            = "/mgmt.MgmtSvc/SystemGetProp"
	MgmtSvc_FaultInjectReport_FullMethodName        = "/mgmt.MgmtSvc/FaultInjectReport"
	MgmtSvc_FaultInjectPoolFault_FullMethodName     = "/mgmt.MgmtSvc/FaultInjectPoolFault"
	MgmtSvc_FaultInjectMgmtPoolFault_FullMethodName = "/mgmt.MgmtSvc/FaultInjectMgmtPoolFault"
)

Variables

View Source 
var (
	StorageMediaType_name = map[int32]string{
		0: "SCM",
		1: "NVME",
	}
	StorageMediaType_value = map[string]int32{
		"SCM":  0,
		"NVME": 1,
	}
)

Enum value maps for StorageMediaType.

View Source 
var (
	PoolServiceState_name = map[int32]string{
		0: "Creating",
		1: "Ready",
		2: "Destroying",
		3: "Degraded",
		4: "Unknown",
	}
	PoolServiceState_value = map[string]int32{
		"Creating":   0,
		"Ready":      1,
		"Destroying": 2,
		"Degraded":   3,
		"Unknown":    4,
	}
)

Enum value maps for PoolServiceState.

View Source 
var (
	PoolRebuildStatus_State_name = map[int32]string{
		0: "IDLE",
		1: "DONE",
		2: "BUSY",
	}
	PoolRebuildStatus_State_value = map[string]int32{
		"IDLE": 0,
		"DONE": 1,
		"BUSY": 2,
	}
)

Enum value maps for PoolRebuildStatus_State.

View Source 
var (
	PoolQueryTargetInfo_TargetType_name = map[int32]string{
		0: "UNKNOWN",
		1: "HDD",
		2: "SSD",
		3: "PM",
		4: "VM",
	}
	PoolQueryTargetInfo_TargetType_value = map[string]int32{
		"UNKNOWN": 0,
		"HDD":     1,
		"SSD":     2,
		"PM":      3,
		"VM":      4,
	}
)

Enum value maps for PoolQueryTargetInfo_TargetType.

View Source 
var (
	PoolQueryTargetInfo_TargetState_name = map[int32]string{
		0: "STATE_UNKNOWN",
		1: "DOWN_OUT",
		2: "DOWN",
		3: "UP",
		4: "UP_IN",
		5: "NEW",
		6: "DRAIN",
	}
	PoolQueryTargetInfo_TargetState_value = map[string]int32{
		"STATE_UNKNOWN": 0,
		"DOWN_OUT":      1,
		"DOWN":          2,
		"UP":            3,
		"UP_IN":         4,
		"NEW":           5,
		"DRAIN":         6,
	}
)

Enum value maps for PoolQueryTargetInfo_TargetState.

View Source 
var (
	JoinResp_State_name = map[int32]string{
		0: "IN",
		1: "OUT",
		2: "CHECK",
	}
	JoinResp_State_value = map[string]int32{
		"IN":    0,
		"OUT":   1,
		"CHECK": 2,
	}
)

Enum value maps for JoinResp_State.

View Source 
var File_mgmt_acl_proto protoreflect.FileDescriptor
View Source 
var File_mgmt_check_proto protoreflect.FileDescriptor
View Source 
var File_mgmt_cont_proto protoreflect.FileDescriptor
View Source 
var File_mgmt_mgmt_proto protoreflect.FileDescriptor
View Source 
var File_mgmt_pool_proto protoreflect.FileDescriptor
View Source 
var File_mgmt_svc_proto protoreflect.FileDescriptor
View Source 
var File_mgmt_system_proto protoreflect.FileDescriptor
View Source 
var MgmtSvc_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "mgmt.MgmtSvc",
	HandlerType: (*MgmtSvcServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Join",
			Handler:    _MgmtSvc_Join_Handler,
		},
		{
			MethodName: "ClusterEvent",
			Handler:    _MgmtSvc_ClusterEvent_Handler,
		},
		{
			MethodName: "LeaderQuery",
			Handler:    _MgmtSvc_LeaderQuery_Handler,
		},
		{
			MethodName: "PoolCreate",
			Handler:    _MgmtSvc_PoolCreate_Handler,
		},
		{
			MethodName: "PoolDestroy",
			Handler:    _MgmtSvc_PoolDestroy_Handler,
		},
		{
			MethodName: "PoolEvict",
			Handler:    _MgmtSvc_PoolEvict_Handler,
		},
		{
			MethodName: "PoolExclude",
			Handler:    _MgmtSvc_PoolExclude_Handler,
		},
		{
			MethodName: "PoolDrain",
			Handler:    _MgmtSvc_PoolDrain_Handler,
		},
		{
			MethodName: "PoolExtend",
			Handler:    _MgmtSvc_PoolExtend_Handler,
		},
		{
			MethodName: "PoolReintegrate",
			Handler:    _MgmtSvc_PoolReintegrate_Handler,
		},
		{
			MethodName: "PoolQuery",
			Handler:    _MgmtSvc_PoolQuery_Handler,
		},
		{
			MethodName: "PoolQueryTarget",
			Handler:    _MgmtSvc_PoolQueryTarget_Handler,
		},
		{
			MethodName: "PoolSetProp",
			Handler:    _MgmtSvc_PoolSetProp_Handler,
		},
		{
			MethodName: "PoolGetProp",
			Handler:    _MgmtSvc_PoolGetProp_Handler,
		},
		{
			MethodName: "PoolGetACL",
			Handler:    _MgmtSvc_PoolGetACL_Handler,
		},
		{
			MethodName: "PoolOverwriteACL",
			Handler:    _MgmtSvc_PoolOverwriteACL_Handler,
		},
		{
			MethodName: "PoolUpdateACL",
			Handler:    _MgmtSvc_PoolUpdateACL_Handler,
		},
		{
			MethodName: "PoolDeleteACL",
			Handler:    _MgmtSvc_PoolDeleteACL_Handler,
		},
		{
			MethodName: "GetAttachInfo",
			Handler:    _MgmtSvc_GetAttachInfo_Handler,
		},
		{
			MethodName: "ListPools",
			Handler:    _MgmtSvc_ListPools_Handler,
		},
		{
			MethodName: "ListContainers",
			Handler:    _MgmtSvc_ListContainers_Handler,
		},
		{
			MethodName: "ContSetOwner",
			Handler:    _MgmtSvc_ContSetOwner_Handler,
		},
		{
			MethodName: "SystemQuery",
			Handler:    _MgmtSvc_SystemQuery_Handler,
		},
		{
			MethodName: "SystemStop",
			Handler:    _MgmtSvc_SystemStop_Handler,
		},
		{
			MethodName: "SystemStart",
			Handler:    _MgmtSvc_SystemStart_Handler,
		},
		{
			MethodName: "SystemExclude",
			Handler:    _MgmtSvc_SystemExclude_Handler,
		},
		{
			MethodName: "SystemDrain",
			Handler:    _MgmtSvc_SystemDrain_Handler,
		},
		{
			MethodName: "SystemErase",
			Handler:    _MgmtSvc_SystemErase_Handler,
		},
		{
			MethodName: "SystemCleanup",
			Handler:    _MgmtSvc_SystemCleanup_Handler,
		},
		{
			MethodName: "SystemCheckEnable",
			Handler:    _MgmtSvc_SystemCheckEnable_Handler,
		},
		{
			MethodName: "SystemCheckDisable",
			Handler:    _MgmtSvc_SystemCheckDisable_Handler,
		},
		{
			MethodName: "SystemCheckStart",
			Handler:    _MgmtSvc_SystemCheckStart_Handler,
		},
		{
			MethodName: "SystemCheckStop",
			Handler:    _MgmtSvc_SystemCheckStop_Handler,
		},
		{
			MethodName: "SystemCheckQuery",
			Handler:    _MgmtSvc_SystemCheckQuery_Handler,
		},
		{
			MethodName: "SystemCheckSetPolicy",
			Handler:    _MgmtSvc_SystemCheckSetPolicy_Handler,
		},
		{
			MethodName: "SystemCheckGetPolicy",
			Handler:    _MgmtSvc_SystemCheckGetPolicy_Handler,
		},
		{
			MethodName: "SystemCheckRepair",
			Handler:    _MgmtSvc_SystemCheckRepair_Handler,
		},
		{
			MethodName: "PoolUpgrade",
			Handler:    _MgmtSvc_PoolUpgrade_Handler,
		},
		{
			MethodName: "SystemSetAttr",
			Handler:    _MgmtSvc_SystemSetAttr_Handler,
		},
		{
			MethodName: "SystemGetAttr",
			Handler:    _MgmtSvc_SystemGetAttr_Handler,
		},
		{
			MethodName: "SystemSetProp",
			Handler:    _MgmtSvc_SystemSetProp_Handler,
		},
		{
			MethodName: "SystemGetProp",
			Handler:    _MgmtSvc_SystemGetProp_Handler,
		},
		{
			MethodName: "FaultInjectReport",
			Handler:    _MgmtSvc_FaultInjectReport_Handler,
		},
		{
			MethodName: "FaultInjectPoolFault",
			Handler:    _MgmtSvc_FaultInjectPoolFault_Handler,
		},
		{
			MethodName: "FaultInjectMgmtPoolFault",
			Handler:    _MgmtSvc_FaultInjectMgmtPoolFault_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "mgmt/mgmt.proto",
}

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

Functions

func RegisterMgmtSvcServer 

func RegisterMgmtSvcServer(s grpc.ServiceRegistrar, srv MgmtSvcServer)

Types

type ACLResp 

type ACLResp struct {
	Status int32              `protobuf:"varint,1,opt,name=status,proto3" json:"status,omitempty"` // DAOS error code
	Acl    *AccessControlList `protobuf:"bytes,2,opt,name=acl,proto3" json:"acl,omitempty"`
	// contains filtered or unexported fields
}

Response to ACL-related requests includes the command status and current ACL

func (*ACLResp) Descriptor deprecated 

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

Deprecated: Use ACLResp.ProtoReflect.Descriptor instead.

func (*ACLResp) GetAcl 

func (x *ACLResp) GetAcl() *AccessControlList

func (*ACLResp) GetStatus 

func (x *ACLResp) GetStatus() int32

func (*ACLResp) ProtoMessage 

func (*ACLResp) ProtoMessage()

func (*ACLResp) ProtoReflect 

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

func (*ACLResp) Reset 

func (x *ACLResp) Reset()

func (*ACLResp) String 

func (x *ACLResp) String() string

type AccessControlList 

type AccessControlList struct {
	Entries    []string `protobuf:"bytes,1,rep,name=entries,proto3" json:"entries,omitempty"`                         // List of ACEs in short string format
	OwnerUser  string   `protobuf:"bytes,2,opt,name=owner_user,json=ownerUser,proto3" json:"owner_user,omitempty"`    // Name of user that owns the resource
	OwnerGroup string   `protobuf:"bytes,3,opt,name=owner_group,json=ownerGroup,proto3" json:"owner_group,omitempty"` // Name of group that owns the resource
	// contains filtered or unexported fields
}

Access control list and ownership information

func (*AccessControlList) Descriptor deprecated 

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

Deprecated: Use AccessControlList.ProtoReflect.Descriptor instead.

func (*AccessControlList) GetEntries 

func (x *AccessControlList) GetEntries() []string

func (*AccessControlList) GetOwnerGroup 

func (x *AccessControlList) GetOwnerGroup() string

func (*AccessControlList) GetOwnerUser 

func (x *AccessControlList) GetOwnerUser() string

func (*AccessControlList) ProtoMessage 

func (*AccessControlList) ProtoMessage()

func (*AccessControlList) ProtoReflect 

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

func (*AccessControlList) Reset 

func (x *AccessControlList) Reset()

func (*AccessControlList) String 

func (x *AccessControlList) String() string

type BuildInfo 

type BuildInfo struct {
	Major uint32 `protobuf:"varint,1,opt,name=major,proto3" json:"major,omitempty"`
	Minor uint32 `protobuf:"varint,2,opt,name=minor,proto3" json:"minor,omitempty"`
	Patch uint32 `protobuf:"varint,3,opt,name=patch,proto3" json:"patch,omitempty"`
	Tag   string `protobuf:"bytes,4,opt,name=tag,proto3" json:"tag,omitempty"`
	// contains filtered or unexported fields
}

func (*BuildInfo) BuildString 

func (bi *BuildInfo) BuildString() string

func (*BuildInfo) Descriptor deprecated 

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

Deprecated: Use BuildInfo.ProtoReflect.Descriptor instead.

func (*BuildInfo) GetMajor 

func (x *BuildInfo) GetMajor() uint32

func (*BuildInfo) GetMinor 

func (x *BuildInfo) GetMinor() uint32

func (*BuildInfo) GetPatch 

func (x *BuildInfo) GetPatch() uint32

func (*BuildInfo) GetTag 

func (x *BuildInfo) GetTag() string

func (*BuildInfo) ProtoMessage 

func (*BuildInfo) ProtoMessage()

func (*BuildInfo) ProtoReflect 

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

func (*BuildInfo) Reset 

func (x *BuildInfo) Reset()

func (*BuildInfo) String 

func (x *BuildInfo) String() string

func (*BuildInfo) VersionString 

func (bi *BuildInfo) VersionString() string

type CheckActReq 

type CheckActReq struct {
	Sys string `protobuf:"bytes,1,opt,name=sys,proto3" json:"sys,omitempty"` // DAOS system identifier.
	// DAOS RAS event sequence - see RASEvent::extended_info::check_info::chk_inconsist_seq.
	Seq uint64 `protobuf:"varint,2,opt,name=seq,proto3" json:"seq,omitempty"`
	// The decision from RASEvent::extended_info::check_info::chk_opts.
	Act    chk.CheckInconsistAction `protobuf:"varint,3,opt,name=act,proto3,enum=chk.CheckInconsistAction" json:"act,omitempty"`
	ForAll bool                     `protobuf:"varint,4,opt,name=for_all,json=forAll,proto3" json:"for_all,omitempty"` // The same action is applicable to the same type of inconsistency.
	// contains filtered or unexported fields
}

For the admin's decision from DAOS check interaction.

func (*CheckActReq) Descriptor deprecated 

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

Deprecated: Use CheckActReq.ProtoReflect.Descriptor instead.

func (*CheckActReq) GetAct 

func (x *CheckActReq) GetAct() chk.CheckInconsistAction

func (*CheckActReq) GetForAll 

func (x *CheckActReq) GetForAll() bool

func (*CheckActReq) GetSeq 

func (x *CheckActReq) GetSeq() uint64

func (*CheckActReq) GetSys 

func (x *CheckActReq) GetSys() string

func (*CheckActReq) ProtoMessage 

func (*CheckActReq) ProtoMessage()

func (*CheckActReq) ProtoReflect 

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

func (*CheckActReq) Reset 

func (x *CheckActReq) Reset()

func (*CheckActReq) String 

func (x *CheckActReq) String() string

type CheckActResp 

type CheckActResp struct {
	Status int32 `protobuf:"varint,1,opt,name=status,proto3" json:"status,omitempty"` // DAOS error code.
	// contains filtered or unexported fields
}

CheckActResp returns the result of executing admin's decision.

func (*CheckActResp) Descriptor deprecated 

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

Deprecated: Use CheckActResp.ProtoReflect.Descriptor instead.

func (*CheckActResp) GetStatus 

func (x *CheckActResp) GetStatus() int32

func (*CheckActResp) ProtoMessage 

func (*CheckActResp) ProtoMessage()

func (*CheckActResp) ProtoReflect 

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

func (*CheckActResp) Reset 

func (x *CheckActResp) Reset()

func (*CheckActResp) String 

func (x *CheckActResp) String() string

type CheckDisableReq 

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

func (*CheckDisableReq) Descriptor deprecated 

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

Deprecated: Use CheckDisableReq.ProtoReflect.Descriptor instead.

func (*CheckDisableReq) GetSys 

func (x *CheckDisableReq) GetSys() string

func (*CheckDisableReq) ProtoMessage 

func (*CheckDisableReq) ProtoMessage()

func (*CheckDisableReq) ProtoReflect 

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

func (*CheckDisableReq) Reset 

func (x *CheckDisableReq) Reset()

func (*CheckDisableReq) String 

func (x *CheckDisableReq) String() string

type CheckEnableReq 

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

func (*CheckEnableReq) Descriptor deprecated 

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

Deprecated: Use CheckEnableReq.ProtoReflect.Descriptor instead.

func (*CheckEnableReq) GetSys 

func (x *CheckEnableReq) GetSys() string

func (*CheckEnableReq) ProtoMessage 

func (*CheckEnableReq) ProtoMessage()

func (*CheckEnableReq) ProtoReflect 

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

func (*CheckEnableReq) Reset 

func (x *CheckEnableReq) Reset()

func (*CheckEnableReq) String 

func (x *CheckEnableReq) String() string

type CheckGetPolicyReq 

type CheckGetPolicyReq struct {
	Sys      string                    `protobuf:"bytes,1,opt,name=sys,proto3" json:"sys,omitempty"` // DAOS system identifier.
	Classes  []chk.CheckInconsistClass `protobuf:"varint,2,rep,packed,name=classes,proto3,enum=chk.CheckInconsistClass" json:"classes,omitempty"`
	LastUsed bool                      `protobuf:"varint,3,opt,name=last_used,json=lastUsed,proto3" json:"last_used,omitempty"`
	// contains filtered or unexported fields
}

For 'dmg check get-policy'

func (*CheckGetPolicyReq) Descriptor deprecated 

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

Deprecated: Use CheckGetPolicyReq.ProtoReflect.Descriptor instead.

func (*CheckGetPolicyReq) GetClasses 

func (x *CheckGetPolicyReq) GetClasses() []chk.CheckInconsistClass

func (*CheckGetPolicyReq) GetLastUsed 

func (x *CheckGetPolicyReq) GetLastUsed() bool

func (*CheckGetPolicyReq) GetSys 

func (x *CheckGetPolicyReq) GetSys() string

func (*CheckGetPolicyReq) ProtoMessage 

func (*CheckGetPolicyReq) ProtoMessage()

func (*CheckGetPolicyReq) ProtoReflect 

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

func (*CheckGetPolicyReq) Reset 

func (x *CheckGetPolicyReq) Reset()

func (*CheckGetPolicyReq) String 

func (x *CheckGetPolicyReq) String() string

type CheckGetPolicyResp 

type CheckGetPolicyResp struct {
	Status   int32                   `protobuf:"varint,1,opt,name=status,proto3" json:"status,omitempty"`    // DAOS error code.
	Flags    uint32                  `protobuf:"varint,2,opt,name=flags,proto3" json:"flags,omitempty"`      // The flags when start check - see CheckFlag.
	Policies []*CheckInconsistPolicy `protobuf:"bytes,3,rep,name=policies,proto3" json:"policies,omitempty"` // Inconsistency policy array.
	// contains filtered or unexported fields
}

CheckGetPolicyResp returns the result of check prop and the properties when start check. NB: Dupe of CheckPropResp currently; may consolidate if they don't diverge.

func (*CheckGetPolicyResp) Descriptor deprecated 

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

Deprecated: Use CheckGetPolicyResp.ProtoReflect.Descriptor instead.

func (*CheckGetPolicyResp) GetFlags 

func (x *CheckGetPolicyResp) GetFlags() uint32

func (*CheckGetPolicyResp) GetPolicies 

func (x *CheckGetPolicyResp) GetPolicies() []*CheckInconsistPolicy

func (*CheckGetPolicyResp) GetStatus 

func (x *CheckGetPolicyResp) GetStatus() int32

func (*CheckGetPolicyResp) ProtoMessage 

func (*CheckGetPolicyResp) ProtoMessage()

func (*CheckGetPolicyResp) ProtoReflect 

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

func (*CheckGetPolicyResp) Reset 

func (x *CheckGetPolicyResp) Reset()

func (*CheckGetPolicyResp) String 

func (x *CheckGetPolicyResp) String() string

type CheckInconsistPolicy 

type CheckInconsistPolicy struct {
	InconsistCas chk.CheckInconsistClass `` // See CheckInconsistClass.
	/* 127-byte string literal not displayed */
	InconsistAct chk.CheckInconsistAction `` // See CheckInconsistAction.
	/* 128-byte string literal not displayed */
	// contains filtered or unexported fields
}

The pairs for kinds of inconsistency and related repair action. The control plane need to generate such policy array from some configuration file either via command line option or some default location, such as /etc/daos/daos_check.yml. Such policy arrge will be passed to DAOS engine when start check and cannot changed during check scanning, but can be list via 'dmg check prop' - see CheckPropResp.

func (*CheckInconsistPolicy) Descriptor deprecated 

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

Deprecated: Use CheckInconsistPolicy.ProtoReflect.Descriptor instead.

func (*CheckInconsistPolicy) GetInconsistAct 

func (x *CheckInconsistPolicy) GetInconsistAct() chk.CheckInconsistAction

func (*CheckInconsistPolicy) GetInconsistCas 

func (x *CheckInconsistPolicy) GetInconsistCas() chk.CheckInconsistClass

func (*CheckInconsistPolicy) ProtoMessage 

func (*CheckInconsistPolicy) ProtoMessage()

func (*CheckInconsistPolicy) ProtoReflect 

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

func (*CheckInconsistPolicy) Reset 

func (x *CheckInconsistPolicy) Reset()

func (*CheckInconsistPolicy) String 

func (x *CheckInconsistPolicy) String() string

type CheckPropReq 

type CheckPropReq struct {
	Sys string `protobuf:"bytes,1,opt,name=sys,proto3" json:"sys,omitempty"` // DAOS system identifier.
	// contains filtered or unexported fields
}

To allow daos_server to query check leader properties

func (*CheckPropReq) Descriptor deprecated 

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

Deprecated: Use CheckPropReq.ProtoReflect.Descriptor instead.

func (*CheckPropReq) GetSys 

func (x *CheckPropReq) GetSys() string

func (*CheckPropReq) ProtoMessage 

func (*CheckPropReq) ProtoMessage()

func (*CheckPropReq) ProtoReflect 

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

func (*CheckPropReq) Reset 

func (x *CheckPropReq) Reset()

func (*CheckPropReq) String 

func (x *CheckPropReq) String() string

type CheckPropResp 

type CheckPropResp struct {
	Status   int32                   `protobuf:"varint,1,opt,name=status,proto3" json:"status,omitempty"`    // DAOS error code.
	Flags    uint32                  `protobuf:"varint,2,opt,name=flags,proto3" json:"flags,omitempty"`      // The flags when start check - see CheckFlag.
	Policies []*CheckInconsistPolicy `protobuf:"bytes,3,rep,name=policies,proto3" json:"policies,omitempty"` // Inconsistency policy array.
	// contains filtered or unexported fields
}

CheckPropResp returns the result of check prop and the properties when start check.

func (*CheckPropResp) Descriptor deprecated 

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

Deprecated: Use CheckPropResp.ProtoReflect.Descriptor instead.

func (*CheckPropResp) GetFlags 

func (x *CheckPropResp) GetFlags() uint32

func (*CheckPropResp) GetPolicies 

func (x *CheckPropResp) GetPolicies() []*CheckInconsistPolicy

func (*CheckPropResp) GetStatus 

func (x *CheckPropResp) GetStatus() int32

func (*CheckPropResp) ProtoMessage 

func (*CheckPropResp) ProtoMessage()

func (*CheckPropResp) ProtoReflect 

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

func (*CheckPropResp) Reset 

func (x *CheckPropResp) Reset()

func (*CheckPropResp) String 

func (x *CheckPropResp) String() string

type CheckQueryInconsist 

type CheckQueryInconsist struct {
	Total    uint32 `protobuf:"varint,1,opt,name=total,proto3" json:"total,omitempty"`       // The count of total found inconsistency on the component.
	Repaired uint32 `protobuf:"varint,2,opt,name=repaired,proto3" json:"repaired,omitempty"` // The count of repaired inconsistency on the component.
	Ignored  uint32 `protobuf:"varint,3,opt,name=ignored,proto3" json:"ignored,omitempty"`   // The count of ignored inconsistency on the component.
	Failed   uint32 `protobuf:"varint,4,opt,name=failed,proto3" json:"failed,omitempty"`     // The count of fail to repaired inconsistency on the component.
	// contains filtered or unexported fields
}

Inconsistency statistics on related component: system, pool or target.

func (*CheckQueryInconsist) Descriptor deprecated 

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

Deprecated: Use CheckQueryInconsist.ProtoReflect.Descriptor instead.

func (*CheckQueryInconsist) GetFailed 

func (x *CheckQueryInconsist) GetFailed() uint32

func (*CheckQueryInconsist) GetIgnored 

func (x *CheckQueryInconsist) GetIgnored() uint32

func (*CheckQueryInconsist) GetRepaired 

func (x *CheckQueryInconsist) GetRepaired() uint32

func (*CheckQueryInconsist) GetTotal 

func (x *CheckQueryInconsist) GetTotal() uint32

func (*CheckQueryInconsist) ProtoMessage 

func (*CheckQueryInconsist) ProtoMessage()

func (*CheckQueryInconsist) ProtoReflect 

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

func (*CheckQueryInconsist) Reset 

func (x *CheckQueryInconsist) Reset()

func (*CheckQueryInconsist) String 

func (x *CheckQueryInconsist) String() string

type CheckQueryPool 

type CheckQueryPool struct {
	Uuid   string              `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`                               // Pool UUID.
	Status chk.CheckPoolStatus `protobuf:"varint,2,opt,name=status,proto3,enum=chk.CheckPoolStatus" json:"status,omitempty"` // Pool status - see CheckPoolStatus.
	Phase  chk.CheckScanPhase  `protobuf:"varint,3,opt,name=phase,proto3,enum=chk.CheckScanPhase" json:"phase,omitempty"`    // Scan phase - see CheckScanPhase.
	// Inconsistency statistics during the phases range
	// [CSP_POOL_MBS, CSP_CONT_CLEANUP] for the pool.
	Inconsistency *CheckQueryInconsist `protobuf:"bytes,4,opt,name=inconsistency,proto3" json:"inconsistency,omitempty"`
	// Time information for the pool if applicable.
	Time *CheckQueryTime `protobuf:"bytes,5,opt,name=time,proto3" json:"time,omitempty"`
	// Per target based query result for the phases since CSP_DTX_RESYNC.
	Targets []*CheckQueryTarget `protobuf:"bytes,6,rep,name=targets,proto3" json:"targets,omitempty"`
	// contains filtered or unexported fields
}

Check query result for the pool.

func (*CheckQueryPool) Descriptor deprecated 

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

Deprecated: Use CheckQueryPool.ProtoReflect.Descriptor instead.

func (*CheckQueryPool) GetInconsistency 

func (x *CheckQueryPool) GetInconsistency() *CheckQueryInconsist

func (*CheckQueryPool) GetPhase 

func (x *CheckQueryPool) GetPhase() chk.CheckScanPhase

func (*CheckQueryPool) GetStatus 

func (x *CheckQueryPool) GetStatus() chk.CheckPoolStatus

func (*CheckQueryPool) GetTargets 

func (x *CheckQueryPool) GetTargets() []*CheckQueryTarget

func (*CheckQueryPool) GetTime 

func (x *CheckQueryPool) GetTime() *CheckQueryTime

func (*CheckQueryPool) GetUuid 

func (x *CheckQueryPool) GetUuid() string

func (*CheckQueryPool) ProtoMessage 

func (*CheckQueryPool) ProtoMessage()

func (*CheckQueryPool) ProtoReflect 

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

func (*CheckQueryPool) Reset 

func (x *CheckQueryPool) Reset()

func (*CheckQueryPool) String 

func (x *CheckQueryPool) String() string

type CheckQueryReq 

type CheckQueryReq struct {
	Sys string `protobuf:"bytes,1,opt,name=sys,proto3" json:"sys,omitempty"` // DAOS system identifier.
	// UUID for the pools for which to query DAOS check.
	// If empty, then query DAOS check for all pools in the system.
	Uuids   []string `protobuf:"bytes,2,rep,name=uuids,proto3" json:"uuids,omitempty"`
	Shallow bool     `protobuf:"varint,3,opt,name=shallow,proto3" json:"shallow,omitempty"`  // shallow query (findings only)
	Seqs    []uint64 `protobuf:"varint,4,rep,packed,name=seqs,proto3" json:"seqs,omitempty"` // return findings with these sequences (implies shallow)
	// contains filtered or unexported fields
}

For 'dmg check query'.

func (*CheckQueryReq) Descriptor deprecated 

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

Deprecated: Use CheckQueryReq.ProtoReflect.Descriptor instead.

func (*CheckQueryReq) GetSeqs 

func (x *CheckQueryReq) GetSeqs() []uint64

func (*CheckQueryReq) GetShallow 

func (x *CheckQueryReq) GetShallow() bool

func (*CheckQueryReq) GetSys 

func (x *CheckQueryReq) GetSys() string

func (*CheckQueryReq) GetUuids 

func (x *CheckQueryReq) GetUuids() []string

func (*CheckQueryReq) ProtoMessage 

func (*CheckQueryReq) ProtoMessage()

func (*CheckQueryReq) ProtoReflect 

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

func (*CheckQueryReq) Reset 

func (x *CheckQueryReq) Reset()

func (*CheckQueryReq) String 

func (x *CheckQueryReq) String() string

type CheckQueryResp 

type CheckQueryResp struct {
	ReqStatus int32 `protobuf:"varint,1,opt,name=req_status,json=reqStatus,proto3" json:"req_status,omitempty"` // DAOS error code.
	// The whole check instance status depends on the each engine status:
	// As long as one target is in CIS_RUNNING, then the instance is CIS_RUNNING.
	// Otherwise, in turn with the status of CIS_FAILED, CIS_STOPPED, CIS_IMPLICATED,
	// CIS_COMPLETED, CIS_PAUSED, CIS_INIT.
	InsStatus chk.CheckInstStatus `protobuf:"varint,2,opt,name=ins_status,json=insStatus,proto3,enum=chk.CheckInstStatus" json:"ins_status,omitempty"`
	// Scan phase - see CheckScanPhase. Before moving to CSP_POOL_MBS, the check
	// instance status is maintained on the check leader. And then multiple pools
	// can be processed in parallel, so the instance phase for different pools may
	// be different, see CheckQueryPool::phase.
	InsPhase chk.CheckScanPhase `protobuf:"varint,3,opt,name=ins_phase,json=insPhase,proto3,enum=chk.CheckScanPhase" json:"ins_phase,omitempty"`
	// Inconsistency statistics during the phases range
	// [CSP_PREPARE, CSP_POOL_LIST] for the whole system.
	Inconsistency *CheckQueryInconsist `protobuf:"bytes,4,opt,name=inconsistency,proto3" json:"inconsistency,omitempty"`
	// Time information for the whole system if applicable.
	Time *CheckQueryTime `protobuf:"bytes,5,opt,name=time,proto3" json:"time,omitempty"`
	// Per pool based query result for the phases since CSP_POOL_MBS.
	Pools []*CheckQueryPool `protobuf:"bytes,6,rep,name=pools,proto3" json:"pools,omitempty"`
	// Inconsistency reports to be displayed
	Reports []*chk.CheckReport `protobuf:"bytes,7,rep,name=reports,proto3" json:"reports,omitempty"`
	// contains filtered or unexported fields
}

CheckQueryResp returns DAOS check status for required pool(s) or the whole system. Depend on the dmg command line option, the control plane needs to reorganize the query results with summary (of pool shards from targets) and different detailed information.

func (*CheckQueryResp) Descriptor deprecated 

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

Deprecated: Use CheckQueryResp.ProtoReflect.Descriptor instead.

func (*CheckQueryResp) GetInconsistency 

func (x *CheckQueryResp) GetInconsistency() *CheckQueryInconsist

func (*CheckQueryResp) GetInsPhase 

func (x *CheckQueryResp) GetInsPhase() chk.CheckScanPhase

func (*CheckQueryResp) GetInsStatus 

func (x *CheckQueryResp) GetInsStatus() chk.CheckInstStatus

func (*CheckQueryResp) GetPools 

func (x *CheckQueryResp) GetPools() []*CheckQueryPool

func (*CheckQueryResp) GetReports 

func (x *CheckQueryResp) GetReports() []*chk.CheckReport

func (*CheckQueryResp) GetReqStatus 

func (x *CheckQueryResp) GetReqStatus() int32

func (*CheckQueryResp) GetTime 

func (x *CheckQueryResp) GetTime() *CheckQueryTime

func (*CheckQueryResp) ProtoMessage 

func (*CheckQueryResp) ProtoMessage()

func (*CheckQueryResp) ProtoReflect 

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

func (*CheckQueryResp) Reset 

func (x *CheckQueryResp) Reset()

func (*CheckQueryResp) String 

func (x *CheckQueryResp) String() string

type CheckQueryTarget 

type CheckQueryTarget struct {
	Rank   uint32              `protobuf:"varint,1,opt,name=rank,proto3" json:"rank,omitempty"`                              // Rank ID.
	Target uint32              `protobuf:"varint,2,opt,name=target,proto3" json:"target,omitempty"`                          // Target index in the rank.
	Status chk.CheckInstStatus `protobuf:"varint,3,opt,name=status,proto3,enum=chk.CheckInstStatus" json:"status,omitempty"` // Check instance status on this target - see CheckInstStatus.
	// Inconsistency statistics during the phases range
	// [CSP_DTX_RESYNC, CSP_AGGREGATION] for the pool shard on the target.
	Inconsistency *CheckQueryInconsist `protobuf:"bytes,4,opt,name=inconsistency,proto3" json:"inconsistency,omitempty"`
	// Time information for the pool shard on the target if applicable.
	Time *CheckQueryTime `protobuf:"bytes,5,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

Check query result for the pool shard on the target.

func (*CheckQueryTarget) Descriptor deprecated 

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

Deprecated: Use CheckQueryTarget.ProtoReflect.Descriptor instead.

func (*CheckQueryTarget) GetInconsistency 

func (x *CheckQueryTarget) GetInconsistency() *CheckQueryInconsist

func (*CheckQueryTarget) GetRank 

func (x *CheckQueryTarget) GetRank() uint32

func (*CheckQueryTarget) GetStatus 

func (x *CheckQueryTarget) GetStatus() chk.CheckInstStatus

func (*CheckQueryTarget) GetTarget 

func (x *CheckQueryTarget) GetTarget() uint32

func (*CheckQueryTarget) GetTime 

func (x *CheckQueryTarget) GetTime() *CheckQueryTime

func (*CheckQueryTarget) ProtoMessage 

func (*CheckQueryTarget) ProtoMessage()

func (*CheckQueryTarget) ProtoReflect 

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

func (*CheckQueryTarget) Reset 

func (x *CheckQueryTarget) Reset()

func (*CheckQueryTarget) String 

func (x *CheckQueryTarget) String() string

type CheckQueryTime 

type CheckQueryTime struct {
	StartTime uint64 `protobuf:"varint,1,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"` // The time of check instance being started on the component.
	// If the check instance is still running on the component, then it is the estimated
	// remaining time to complete the check on the component. Otherwise, it is the time
	// of the check instance completed, failed or stopped on the component.
	MiscTime uint64 `protobuf:"varint,2,opt,name=misc_time,json=miscTime,proto3" json:"misc_time,omitempty"`
	// contains filtered or unexported fields
}

Time information on related component: system, pool or target.

func (*CheckQueryTime) Descriptor deprecated 

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

Deprecated: Use CheckQueryTime.ProtoReflect.Descriptor instead.

func (*CheckQueryTime) GetMiscTime 

func (x *CheckQueryTime) GetMiscTime() uint64

func (*CheckQueryTime) GetStartTime 

func (x *CheckQueryTime) GetStartTime() uint64

func (*CheckQueryTime) ProtoMessage 

func (*CheckQueryTime) ProtoMessage()

func (*CheckQueryTime) ProtoReflect 

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

func (*CheckQueryTime) Reset 

func (x *CheckQueryTime) Reset()

func (*CheckQueryTime) String 

func (x *CheckQueryTime) String() string

type CheckSetPolicyReq 

type CheckSetPolicyReq struct {
	Sys      string                  `protobuf:"bytes,1,opt,name=sys,proto3" json:"sys,omitempty"`           // DAOS system identifier.
	Flags    uint32                  `protobuf:"varint,2,opt,name=flags,proto3" json:"flags,omitempty"`      // The flags when start check - see CheckFlag.
	Policies []*CheckInconsistPolicy `protobuf:"bytes,3,rep,name=policies,proto3" json:"policies,omitempty"` // Inconsistency policy array.
	// contains filtered or unexported fields
}

For 'dmg check set-policy'

func (*CheckSetPolicyReq) Descriptor deprecated 

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

Deprecated: Use CheckSetPolicyReq.ProtoReflect.Descriptor instead.

func (*CheckSetPolicyReq) GetFlags 

func (x *CheckSetPolicyReq) GetFlags() uint32

func (*CheckSetPolicyReq) GetPolicies 

func (x *CheckSetPolicyReq) GetPolicies() []*CheckInconsistPolicy

func (*CheckSetPolicyReq) GetSys 

func (x *CheckSetPolicyReq) GetSys() string

func (*CheckSetPolicyReq) ProtoMessage 

func (*CheckSetPolicyReq) ProtoMessage()

func (*CheckSetPolicyReq) ProtoReflect 

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

func (*CheckSetPolicyReq) Reset 

func (x *CheckSetPolicyReq) Reset()

func (*CheckSetPolicyReq) String 

func (x *CheckSetPolicyReq) String() string

type CheckStartReq 

type CheckStartReq struct {
	Sys   string `protobuf:"bytes,1,opt,name=sys,proto3" json:"sys,omitempty"`      // DAOS system identifier.
	Flags uint32 `protobuf:"varint,2,opt,name=flags,proto3" json:"flags,omitempty"` // See CheckFlag.
	// The list of ranks to start DAOS check. Cannot be empty.
	//
	// The control plane will generate the ranks list and guarantee that any rank in the system
	// is either will participate in check or has been excluded. Otherwise, partial ranks check
	// may cause some unexpected and unrecoverable result unless the specified pool(s) does not
	// exist on those missed rank(s).
	Ranks []uint32 `protobuf:"varint,3,rep,packed,name=ranks,proto3" json:"ranks,omitempty"`
	// UUID for the pools for which to start DAOS check.
	// If empty, then start DAOS check for all pools in the system.
	Uuids    []string                `protobuf:"bytes,4,rep,name=uuids,proto3" json:"uuids,omitempty"`
	Policies []*CheckInconsistPolicy `protobuf:"bytes,5,rep,name=policies,proto3" json:"policies,omitempty"` // Policy array for handling inconsistency.
	// contains filtered or unexported fields
}

For 'dmg check start'.

func (*CheckStartReq) Descriptor deprecated 

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

Deprecated: Use CheckStartReq.ProtoReflect.Descriptor instead.

func (*CheckStartReq) GetFlags 

func (x *CheckStartReq) GetFlags() uint32

func (*CheckStartReq) GetPolicies 

func (x *CheckStartReq) GetPolicies() []*CheckInconsistPolicy

func (*CheckStartReq) GetRanks 

func (x *CheckStartReq) GetRanks() []uint32

func (*CheckStartReq) GetSys 

func (x *CheckStartReq) GetSys() string

func (*CheckStartReq) GetUuids 

func (x *CheckStartReq) GetUuids() []string

func (*CheckStartReq) ProtoMessage 

func (*CheckStartReq) ProtoMessage()

func (*CheckStartReq) ProtoReflect 

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

func (*CheckStartReq) Reset 

func (x *CheckStartReq) Reset()

func (*CheckStartReq) String 

func (x *CheckStartReq) String() string

type CheckStartResp 

type CheckStartResp struct {
	Status int32 `protobuf:"varint,1,opt,name=status,proto3" json:"status,omitempty"` // DAOS error code.
	// contains filtered or unexported fields
}

CheckStartResp returns the result of check start.

func (*CheckStartResp) Descriptor deprecated 

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

Deprecated: Use CheckStartResp.ProtoReflect.Descriptor instead.

func (*CheckStartResp) GetStatus 

func (x *CheckStartResp) GetStatus() int32

func (*CheckStartResp) ProtoMessage 

func (*CheckStartResp) ProtoMessage()

func (*CheckStartResp) ProtoReflect 

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

func (*CheckStartResp) Reset 

func (x *CheckStartResp) Reset()

func (*CheckStartResp) String 

func (x *CheckStartResp) String() string

type CheckStopReq 

type CheckStopReq struct {
	Sys string `protobuf:"bytes,1,opt,name=sys,proto3" json:"sys,omitempty"` // DAOS system identifier.
	// UUID for the pools for which to stop DAOS check.
	// If empty, then stop check for all pools in the system.
	Uuids []string `protobuf:"bytes,2,rep,name=uuids,proto3" json:"uuids,omitempty"`
	// contains filtered or unexported fields
}

For 'dmg check stop'.

func (*CheckStopReq) Descriptor deprecated 

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

Deprecated: Use CheckStopReq.ProtoReflect.Descriptor instead.

func (*CheckStopReq) GetSys 

func (x *CheckStopReq) GetSys() string

func (*CheckStopReq) GetUuids 

func (x *CheckStopReq) GetUuids() []string

func (*CheckStopReq) ProtoMessage 

func (*CheckStopReq) ProtoMessage()

func (*CheckStopReq) ProtoReflect 

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

func (*CheckStopReq) Reset 

func (x *CheckStopReq) Reset()

func (*CheckStopReq) String 

func (x *CheckStopReq) String() string

type CheckStopResp 

type CheckStopResp struct {
	Status int32 `protobuf:"varint,1,opt,name=status,proto3" json:"status,omitempty"` // DAOS error code.
	// contains filtered or unexported fields
}

CheckStopResp returns the result of check stop.

func (*CheckStopResp) Descriptor deprecated 

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

Deprecated: Use CheckStopResp.ProtoReflect.Descriptor instead.

func (*CheckStopResp) GetStatus 

func (x *CheckStopResp) GetStatus() int32

func (*CheckStopResp) ProtoMessage 

func (*CheckStopResp) ProtoMessage()

func (*CheckStopResp) ProtoReflect 

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

func (*CheckStopResp) Reset 

func (x *CheckStopResp) Reset()

func (*CheckStopResp) String 

func (x *CheckStopResp) String() string

type ClientNetHint 

type ClientNetHint struct {
	Provider    string `protobuf:"bytes,1,opt,name=provider,proto3" json:"provider,omitempty"`                             // CaRT provider
	Interface   string `protobuf:"bytes,2,opt,name=interface,proto3" json:"interface,omitempty"`                           // CaRT D_INTERFACE
	Domain      string `protobuf:"bytes,3,opt,name=domain,proto3" json:"domain,omitempty"`                                 // CaRT D_DOMAIN for given D_INTERFACE
	CrtTimeout  uint32 `protobuf:"varint,5,opt,name=crt_timeout,json=crtTimeout,proto3" json:"crt_timeout,omitempty"`      // CaRT CRT_TIMEOUT
	NetDevClass uint32 `protobuf:"varint,6,opt,name=net_dev_class,json=netDevClass,proto3" json:"net_dev_class,omitempty"` // ARP protocol hardware identifier of the
	// I/O Engine network interface
	SrvSrxSet   int32    `protobuf:"varint,7,opt,name=srv_srx_set,json=srvSrxSet,proto3" json:"srv_srx_set,omitempty"`     // Server SRX setting (-1, 0, 1; -1 == unset)
	EnvVars     []string `protobuf:"bytes,8,rep,name=env_vars,json=envVars,proto3" json:"env_vars,omitempty"`              // Client-side environment variables to set
	ProviderIdx uint32   `protobuf:"varint,9,opt,name=provider_idx,json=providerIdx,proto3" json:"provider_idx,omitempty"` // Provider index - anything > 0 is a secondary provider
	// contains filtered or unexported fields
}

func (*ClientNetHint) Descriptor deprecated 

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

Deprecated: Use ClientNetHint.ProtoReflect.Descriptor instead.

func (*ClientNetHint) GetCrtTimeout 

func (x *ClientNetHint) GetCrtTimeout() uint32

func (*ClientNetHint) GetDomain 

func (x *ClientNetHint) GetDomain() string

func (*ClientNetHint) GetEnvVars 

func (x *ClientNetHint) GetEnvVars() []string

func (*ClientNetHint) GetInterface 

func (x *ClientNetHint) GetInterface() string

func (*ClientNetHint) GetNetDevClass 

func (x *ClientNetHint) GetNetDevClass() uint32

func (*ClientNetHint) GetProvider 

func (x *ClientNetHint) GetProvider() string

func (*ClientNetHint) GetProviderIdx 

func (x *ClientNetHint) GetProviderIdx() uint32

func (*ClientNetHint) GetSrvSrxSet 

func (x *ClientNetHint) GetSrvSrxSet() int32

func (*ClientNetHint) ProtoMessage 

func (*ClientNetHint) ProtoMessage()

func (*ClientNetHint) ProtoReflect 

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

func (*ClientNetHint) Reset 

func (x *ClientNetHint) Reset()

func (*ClientNetHint) String 

func (x *ClientNetHint) String() string

type ClientTelemetryReq 

type ClientTelemetryReq struct {
	Sys    string `protobuf:"bytes,1,opt,name=sys,proto3" json:"sys,omitempty"`                      // DAOS system identifier
	Jobid  string `protobuf:"bytes,2,opt,name=jobid,proto3" json:"jobid,omitempty"`                  // Job ID used for client telemetry
	ShmKey int32  `protobuf:"varint,3,opt,name=shm_key,json=shmKey,proto3" json:"shm_key,omitempty"` // Client's shared memory segment key
	// contains filtered or unexported fields
}

func (*ClientTelemetryReq) Descriptor deprecated 

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

Deprecated: Use ClientTelemetryReq.ProtoReflect.Descriptor instead.

func (*ClientTelemetryReq) GetJobid 

func (x *ClientTelemetryReq) GetJobid() string

func (*ClientTelemetryReq) GetShmKey 

func (x *ClientTelemetryReq) GetShmKey() int32

func (*ClientTelemetryReq) GetSys 

func (x *ClientTelemetryReq) GetSys() string

func (*ClientTelemetryReq) ProtoMessage 

func (*ClientTelemetryReq) ProtoMessage()

func (*ClientTelemetryReq) ProtoReflect 

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

func (*ClientTelemetryReq) Reset 

func (x *ClientTelemetryReq) Reset()

func (*ClientTelemetryReq) String 

func (x *ClientTelemetryReq) String() string

type ClientTelemetryResp 

type ClientTelemetryResp struct {
	Status   int32 `protobuf:"varint,1,opt,name=status,proto3" json:"status,omitempty"`                     // DAOS status code
	AgentUid int32 `protobuf:"varint,2,opt,name=agent_uid,json=agentUid,proto3" json:"agent_uid,omitempty"` // UID of agent process
	// contains filtered or unexported fields
}

func (*ClientTelemetryResp) Descriptor deprecated 

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

Deprecated: Use ClientTelemetryResp.ProtoReflect.Descriptor instead.

func (*ClientTelemetryResp) GetAgentUid 

func (x *ClientTelemetryResp) GetAgentUid() int32

func (*ClientTelemetryResp) GetStatus 

func (x *ClientTelemetryResp) GetStatus() int32

func (*ClientTelemetryResp) ProtoMessage 

func (*ClientTelemetryResp) ProtoMessage()

func (*ClientTelemetryResp) ProtoReflect 

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

func (*ClientTelemetryResp) Reset 

func (x *ClientTelemetryResp) Reset()

func (*ClientTelemetryResp) String 

func (x *ClientTelemetryResp) String() string

type ContSetOwnerReq 

type ContSetOwnerReq struct {
	Sys        string   `protobuf:"bytes,1,opt,name=sys,proto3" json:"sys,omitempty"`                                   // DAOS system identifier
	ContId     string   `protobuf:"bytes,2,opt,name=cont_id,json=contId,proto3" json:"cont_id,omitempty"`               // UUID or label of the container
	PoolId     string   `protobuf:"bytes,3,opt,name=pool_id,json=poolId,proto3" json:"pool_id,omitempty"`               // UUID or label of the pool that the container is in
	OwnerUser  string   `protobuf:"bytes,4,opt,name=owner_user,json=ownerUser,proto3" json:"owner_user,omitempty"`      // formatted user e.g. "bob@"
	OwnerGroup string   `protobuf:"bytes,5,opt,name=owner_group,json=ownerGroup,proto3" json:"owner_group,omitempty"`   // formatted group e.g. "builders@"
	SvcRanks   []uint32 `protobuf:"varint,6,rep,packed,name=svc_ranks,json=svcRanks,proto3" json:"svc_ranks,omitempty"` // List of pool service ranks
	// contains filtered or unexported fields
}

ContSetOwnerReq changes the ownership of a container.

func (*ContSetOwnerReq) Descriptor deprecated 

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

Deprecated: Use ContSetOwnerReq.ProtoReflect.Descriptor instead.

func (*ContSetOwnerReq) GetContId 

func (x *ContSetOwnerReq) GetContId() string

func (*ContSetOwnerReq) GetId 

func (r *ContSetOwnerReq) GetId() string

GetId fetches the pool ID.

func (*ContSetOwnerReq) GetOwnerGroup 

func (x *ContSetOwnerReq) GetOwnerGroup() string

func (*ContSetOwnerReq) GetOwnerUser 

func (x *ContSetOwnerReq) GetOwnerUser() string

func (*ContSetOwnerReq) GetPoolId 

func (x *ContSetOwnerReq) GetPoolId() string

func (*ContSetOwnerReq) GetSvcRanks 

func (x *ContSetOwnerReq) GetSvcRanks() []uint32

func (*ContSetOwnerReq) GetSys 

func (x *ContSetOwnerReq) GetSys() string

func (*ContSetOwnerReq) ProtoMessage 

func (*ContSetOwnerReq) ProtoMessage()

func (*ContSetOwnerReq) ProtoReflect 

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

func (*ContSetOwnerReq) Reset 

func (x *ContSetOwnerReq) Reset()

func (*ContSetOwnerReq) SetSvcRanks 

func (r *ContSetOwnerReq) SetSvcRanks(rl []uint32)

SetSvcRanks sets the request's Pool Service Ranks.

func (*ContSetOwnerReq) SetUUID 

func (r *ContSetOwnerReq) SetUUID(id uuid.UUID)

SetUUID sets the request's ID to a UUID.

func (*ContSetOwnerReq) String 

func (x *ContSetOwnerReq) String() string

type DaosResp 

type DaosResp struct {
	Status int32 `protobuf:"varint,1,opt,name=status,proto3" json:"status,omitempty"` // DAOS error code.
	// contains filtered or unexported fields
}

Generic response just containing DER from I/O Engine.

func (*DaosResp) Descriptor deprecated 

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

Deprecated: Use DaosResp.ProtoReflect.Descriptor instead.

func (*DaosResp) GetStatus 

func (x *DaosResp) GetStatus() int32

func (*DaosResp) ProtoMessage 

func (*DaosResp) ProtoMessage()

func (*DaosResp) ProtoReflect 

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

func (*DaosResp) Reset 

func (x *DaosResp) Reset()

func (*DaosResp) String 

func (x *DaosResp) String() string

type DeleteACLReq 

type DeleteACLReq struct {
	Sys       string   `protobuf:"bytes,1,opt,name=sys,proto3" json:"sys,omitempty"`                                   // DAOS system identifier
	Id        string   `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`                                     // Target UUID or label
	Principal string   `protobuf:"bytes,3,opt,name=principal,proto3" json:"principal,omitempty"`                       // Principal whose entry is to be deleted
	SvcRanks  []uint32 `protobuf:"varint,4,rep,packed,name=svc_ranks,json=svcRanks,proto3" json:"svc_ranks,omitempty"` // List of pool service ranks
	// contains filtered or unexported fields
}

Delete a principal's entry from the ACL

func (*DeleteACLReq) Descriptor deprecated 

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

Deprecated: Use DeleteACLReq.ProtoReflect.Descriptor instead.

func (*DeleteACLReq) GetId 

func (x *DeleteACLReq) GetId() string

func (*DeleteACLReq) GetPrincipal 

func (x *DeleteACLReq) GetPrincipal() string

func (*DeleteACLReq) GetSvcRanks 

func (x *DeleteACLReq) GetSvcRanks() []uint32

func (*DeleteACLReq) GetSys 

func (x *DeleteACLReq) GetSys() string

func (*DeleteACLReq) ProtoMessage 

func (*DeleteACLReq) ProtoMessage()

func (*DeleteACLReq) ProtoReflect 

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

func (*DeleteACLReq) Reset 

func (x *DeleteACLReq) Reset()

func (*DeleteACLReq) SetSvcRanks 

func (r *DeleteACLReq) SetSvcRanks(rl []uint32)

SetSvcRanks sets the request's Pool Service Ranks.

func (*DeleteACLReq) SetUUID 

func (r *DeleteACLReq) SetUUID(id uuid.UUID)

SetUUID sets the request's ID to a UUID.

func (*DeleteACLReq) String 

func (x *DeleteACLReq) String() string

type FabricInterface 

type FabricInterface struct {
	NumaNode  uint32 `protobuf:"varint,1,opt,name=numa_node,json=numaNode,proto3" json:"numa_node,omitempty"`
	Interface string `protobuf:"bytes,2,opt,name=interface,proto3" json:"interface,omitempty"`
	Domain    string `protobuf:"bytes,3,opt,name=domain,proto3" json:"domain,omitempty"`
	Provider  string `protobuf:"bytes,4,opt,name=provider,proto3" json:"provider,omitempty"`
	// contains filtered or unexported fields
}

func (*FabricInterface) Descriptor deprecated 

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

Deprecated: Use FabricInterface.ProtoReflect.Descriptor instead.

func (*FabricInterface) GetDomain 

func (x *FabricInterface) GetDomain() string

func (*FabricInterface) GetInterface 

func (x *FabricInterface) GetInterface() string

func (*FabricInterface) GetNumaNode 

func (x *FabricInterface) GetNumaNode() uint32

func (*FabricInterface) GetProvider 

func (x *FabricInterface) GetProvider() string

func (*FabricInterface) ProtoMessage 

func (*FabricInterface) ProtoMessage()

func (*FabricInterface) ProtoReflect 

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

func (*FabricInterface) Reset 

func (x *FabricInterface) Reset()

func (*FabricInterface) String 

func (x *FabricInterface) String() string

type FabricInterfaces 

type FabricInterfaces struct {
	NumaNode uint32             `protobuf:"varint,1,opt,name=numa_node,json=numaNode,proto3" json:"numa_node,omitempty"`
	Ifaces   []*FabricInterface `protobuf:"bytes,2,rep,name=ifaces,proto3" json:"ifaces,omitempty"`
	// contains filtered or unexported fields
}

func (*FabricInterfaces) Descriptor deprecated 

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

Deprecated: Use FabricInterfaces.ProtoReflect.Descriptor instead.

func (*FabricInterfaces) GetIfaces 

func (x *FabricInterfaces) GetIfaces() []*FabricInterface

func (*FabricInterfaces) GetNumaNode 

func (x *FabricInterfaces) GetNumaNode() uint32

func (*FabricInterfaces) ProtoMessage 

func (*FabricInterfaces) ProtoMessage()

func (*FabricInterfaces) ProtoReflect 

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

func (*FabricInterfaces) Reset 

func (x *FabricInterfaces) Reset()

func (*FabricInterfaces) String 

func (x *FabricInterfaces) String() string

type GetACLReq 

type GetACLReq struct {
	Sys      string   `protobuf:"bytes,1,opt,name=sys,proto3" json:"sys,omitempty"`                                   // DAOS system identifier
	Id       string   `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`                                     // Target UUID or label
	SvcRanks []uint32 `protobuf:"varint,3,rep,packed,name=svc_ranks,json=svcRanks,proto3" json:"svc_ranks,omitempty"` // List of pool service ranks
	// contains filtered or unexported fields
}

Request to fetch an ACL

func (*GetACLReq) Descriptor deprecated 

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

Deprecated: Use GetACLReq.ProtoReflect.Descriptor instead.

func (*GetACLReq) GetId 

func (x *GetACLReq) GetId() string

func (*GetACLReq) GetSvcRanks 

func (x *GetACLReq) GetSvcRanks() []uint32

func (*GetACLReq) GetSys 

func (x *GetACLReq) GetSys() string

func (*GetACLReq) ProtoMessage 

func (*GetACLReq) ProtoMessage()

func (*GetACLReq) ProtoReflect 

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

func (*GetACLReq) Reset 

func (x *GetACLReq) Reset()

func (*GetACLReq) SetSvcRanks 

func (r *GetACLReq) SetSvcRanks(rl []uint32)

SetSvcRanks sets the request's Pool Service Ranks.

func (*GetACLReq) SetUUID 

func (r *GetACLReq) SetUUID(id uuid.UUID)

SetUUID sets the request's ID to a UUID.

func (*GetACLReq) String 

func (x *GetACLReq) String() string

type GetAttachInfoReq 

type GetAttachInfoReq struct {
	Sys       string `protobuf:"bytes,1,opt,name=sys,proto3" json:"sys,omitempty"`                            // System name. For daos_agent only.
	AllRanks  bool   `protobuf:"varint,2,opt,name=all_ranks,json=allRanks,proto3" json:"all_ranks,omitempty"` // Return Rank URIs for all ranks.
	Interface string `protobuf:"bytes,3,opt,name=interface,proto3" json:"interface,omitempty"`                // Preferred fabric interface.
	Domain    string `protobuf:"bytes,4,opt,name=domain,proto3" json:"domain,omitempty"`                      // Preferred fabric domain.
	// contains filtered or unexported fields
}

func (*GetAttachInfoReq) Descriptor deprecated 

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

Deprecated: Use GetAttachInfoReq.ProtoReflect.Descriptor instead.

func (*GetAttachInfoReq) GetAllRanks 

func (x *GetAttachInfoReq) GetAllRanks() bool

func (*GetAttachInfoReq) GetDomain 

func (x *GetAttachInfoReq) GetDomain() string

func (*GetAttachInfoReq) GetInterface 

func (x *GetAttachInfoReq) GetInterface() string

func (*GetAttachInfoReq) GetSys 

func (x *GetAttachInfoReq) GetSys() string

func (*GetAttachInfoReq) ProtoMessage 

func (*GetAttachInfoReq) ProtoMessage()

func (*GetAttachInfoReq) ProtoReflect 

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

func (*GetAttachInfoReq) Reset 

func (x *GetAttachInfoReq) Reset()

func (*GetAttachInfoReq) String 

func (x *GetAttachInfoReq) String() string

type GetAttachInfoResp 

type GetAttachInfoResp struct {
	Status   int32                        `protobuf:"varint,1,opt,name=status,proto3" json:"status,omitempty"`                    // DAOS error code
	RankUris []*GetAttachInfoResp_RankUri `protobuf:"bytes,2,rep,name=rank_uris,json=rankUris,proto3" json:"rank_uris,omitempty"` // Rank URIs for the primary provider
	// These CaRT settings are shared with the
	// libdaos client to aid in CaRT initialization.
	MsRanks                 []uint32                     `protobuf:"varint,3,rep,packed,name=ms_ranks,json=msRanks,proto3" json:"ms_ranks,omitempty"`                         // Ranks local to MS replicas
	ClientNetHint           *ClientNetHint               `protobuf:"bytes,4,opt,name=client_net_hint,json=clientNetHint,proto3" json:"client_net_hint,omitempty"`             // Primary provider hint
	DataVersion             uint64                       `protobuf:"varint,5,opt,name=data_version,json=dataVersion,proto3" json:"data_version,omitempty"`                    // Version of the system database.
	Sys                     string                       `protobuf:"bytes,6,opt,name=sys,proto3" json:"sys,omitempty"`                                                        // Name of the DAOS system
	SecondaryRankUris       []*GetAttachInfoResp_RankUri `protobuf:"bytes,7,rep,name=secondary_rank_uris,json=secondaryRankUris,proto3" json:"secondary_rank_uris,omitempty"` // Rank URIs for additional providers
	SecondaryClientNetHints []*ClientNetHint             ``                                                                                                                   // Hints for additional providers
	/* 134-byte string literal not displayed */
	BuildInfo            *BuildInfo          `protobuf:"bytes,9,opt,name=build_info,json=buildInfo,proto3" json:"build_info,omitempty"`                                     // Structured server build information
	NumaFabricInterfaces []*FabricInterfaces `protobuf:"bytes,10,rep,name=numa_fabric_interfaces,json=numaFabricInterfaces,proto3" json:"numa_fabric_interfaces,omitempty"` // Usable fabric interfaces by NUMA node (populated by agent)
	// contains filtered or unexported fields
}

func (*GetAttachInfoResp) Descriptor deprecated 

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

Deprecated: Use GetAttachInfoResp.ProtoReflect.Descriptor instead.

func (*GetAttachInfoResp) GetBuildInfo 

func (x *GetAttachInfoResp) GetBuildInfo() *BuildInfo

func (*GetAttachInfoResp) GetClientNetHint 

func (x *GetAttachInfoResp) GetClientNetHint() *ClientNetHint

func (*GetAttachInfoResp) GetDataVersion 

func (x *GetAttachInfoResp) GetDataVersion() uint64

func (*GetAttachInfoResp) GetMsRanks 

func (x *GetAttachInfoResp) GetMsRanks() []uint32

func (*GetAttachInfoResp) GetNumaFabricInterfaces 

func (x *GetAttachInfoResp) GetNumaFabricInterfaces() []*FabricInterfaces

func (*GetAttachInfoResp) GetRankUris 

func (x *GetAttachInfoResp) GetRankUris() []*GetAttachInfoResp_RankUri

func (*GetAttachInfoResp) GetSecondaryClientNetHints 

func (x *GetAttachInfoResp) GetSecondaryClientNetHints() []*ClientNetHint

func (*GetAttachInfoResp) GetSecondaryRankUris 

func (x *GetAttachInfoResp) GetSecondaryRankUris() []*GetAttachInfoResp_RankUri

func (*GetAttachInfoResp) GetStatus 

func (x *GetAttachInfoResp) GetStatus() int32

func (*GetAttachInfoResp) GetSys 

func (x *GetAttachInfoResp) GetSys() string

func (*GetAttachInfoResp) ProtoMessage 

func (*GetAttachInfoResp) ProtoMessage()

func (*GetAttachInfoResp) ProtoReflect 

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

func (*GetAttachInfoResp) Reset 

func (x *GetAttachInfoResp) Reset()

func (*GetAttachInfoResp) String 

func (x *GetAttachInfoResp) String() string

type GetAttachInfoResp_RankUri 

type GetAttachInfoResp_RankUri struct {
	Rank        uint32 `protobuf:"varint,1,opt,name=rank,proto3" json:"rank,omitempty"`
	Uri         string `protobuf:"bytes,2,opt,name=uri,proto3" json:"uri,omitempty"`
	ProviderIdx uint32 `protobuf:"varint,3,opt,name=provider_idx,json=providerIdx,proto3" json:"provider_idx,omitempty"`
	NumCtxs     uint32 `protobuf:"varint,4,opt,name=num_ctxs,json=numCtxs,proto3" json:"num_ctxs,omitempty"`
	// contains filtered or unexported fields
}

func (*GetAttachInfoResp_RankUri) Descriptor deprecated 

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

Deprecated: Use GetAttachInfoResp_RankUri.ProtoReflect.Descriptor instead.

func (*GetAttachInfoResp_RankUri) GetNumCtxs 

func (x *GetAttachInfoResp_RankUri) GetNumCtxs() uint32

func (*GetAttachInfoResp_RankUri) GetProviderIdx 

func (x *GetAttachInfoResp_RankUri) GetProviderIdx() uint32

func (*GetAttachInfoResp_RankUri) GetRank 

func (x *GetAttachInfoResp_RankUri) GetRank() uint32

func (*GetAttachInfoResp_RankUri) GetUri 

func (x *GetAttachInfoResp_RankUri) GetUri() string

func (*GetAttachInfoResp_RankUri) ProtoMessage 

func (*GetAttachInfoResp_RankUri) ProtoMessage()

func (*GetAttachInfoResp_RankUri) ProtoReflect 

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

func (*GetAttachInfoResp_RankUri) Reset 

func (x *GetAttachInfoResp_RankUri) Reset()

func (*GetAttachInfoResp_RankUri) String 

func (x *GetAttachInfoResp_RankUri) String() string

type GroupUpdateReq 

type GroupUpdateReq struct {
	MapVersion uint32                   `protobuf:"varint,1,opt,name=map_version,json=mapVersion,proto3" json:"map_version,omitempty"`
	Engines    []*GroupUpdateReq_Engine `protobuf:"bytes,2,rep,name=engines,proto3" json:"engines,omitempty"`
	// contains filtered or unexported fields
}

func (*GroupUpdateReq) Descriptor deprecated 

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

Deprecated: Use GroupUpdateReq.ProtoReflect.Descriptor instead.

func (*GroupUpdateReq) GetEngines 

func (x *GroupUpdateReq) GetEngines() []*GroupUpdateReq_Engine

func (*GroupUpdateReq) GetMapVersion 

func (x *GroupUpdateReq) GetMapVersion() uint32

func (*GroupUpdateReq) ProtoMessage 

func (*GroupUpdateReq) ProtoMessage()

func (*GroupUpdateReq) ProtoReflect 

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

func (*GroupUpdateReq) Reset 

func (x *GroupUpdateReq) Reset()

func (*GroupUpdateReq) String 

func (x *GroupUpdateReq) String() string

type GroupUpdateReq_Engine 

type GroupUpdateReq_Engine struct {
	Rank        uint32 `protobuf:"varint,1,opt,name=rank,proto3" json:"rank,omitempty"`
	Uri         string `protobuf:"bytes,2,opt,name=uri,proto3" json:"uri,omitempty"` // primary URI is the only one group update is concerned with
	Incarnation uint64 `protobuf:"varint,3,opt,name=incarnation,proto3" json:"incarnation,omitempty"`
	// contains filtered or unexported fields
}

func (*GroupUpdateReq_Engine) Descriptor deprecated 

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

Deprecated: Use GroupUpdateReq_Engine.ProtoReflect.Descriptor instead.

func (*GroupUpdateReq_Engine) GetIncarnation 

func (x *GroupUpdateReq_Engine) GetIncarnation() uint64

func (*GroupUpdateReq_Engine) GetRank 

func (x *GroupUpdateReq_Engine) GetRank() uint32

func (*GroupUpdateReq_Engine) GetUri 

func (x *GroupUpdateReq_Engine) GetUri() string

func (*GroupUpdateReq_Engine) ProtoMessage 

func (*GroupUpdateReq_Engine) ProtoMessage()

func (*GroupUpdateReq_Engine) ProtoReflect 

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

func (*GroupUpdateReq_Engine) Reset 

func (x *GroupUpdateReq_Engine) Reset()

func (*GroupUpdateReq_Engine) String 

func (x *GroupUpdateReq_Engine) String() string

type GroupUpdateResp 

type GroupUpdateResp struct {
	Status int32 `protobuf:"varint,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*GroupUpdateResp) Descriptor deprecated 

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

Deprecated: Use GroupUpdateResp.ProtoReflect.Descriptor instead.

func (*GroupUpdateResp) GetStatus 

func (x *GroupUpdateResp) GetStatus() int32

func (*GroupUpdateResp) ProtoMessage 

func (*GroupUpdateResp) ProtoMessage()

func (*GroupUpdateResp) ProtoReflect 

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

func (*GroupUpdateResp) Reset 

func (x *GroupUpdateResp) Reset()

func (*GroupUpdateResp) String 

func (x *GroupUpdateResp) String() string

type JoinReq 

type JoinReq struct {
	Sys            string   `protobuf:"bytes,1,opt,name=sys,proto3" json:"sys,omitempty"`                                                      // DAOS system name.
	Uuid           string   `protobuf:"bytes,2,opt,name=uuid,proto3" json:"uuid,omitempty"`                                                    // Server UUID.
	Rank           uint32   `protobuf:"varint,3,opt,name=rank,proto3" json:"rank,omitempty"`                                                   // Server rank desired, if not MAX_UINT32.
	Uri            string   `protobuf:"bytes,4,opt,name=uri,proto3" json:"uri,omitempty"`                                                      // Server CaRT primary provider URI (i.e., for context 0).
	Nctxs          uint32   `protobuf:"varint,5,opt,name=nctxs,proto3" json:"nctxs,omitempty"`                                                 // Server CaRT context count.
	Addr           string   `protobuf:"bytes,6,opt,name=addr,proto3" json:"addr,omitempty"`                                                    // Server management address.
	SrvFaultDomain string   `protobuf:"bytes,7,opt,name=srvFaultDomain,proto3" json:"srvFaultDomain,omitempty"`                                // Fault domain for this instance's server
	Idx            uint32   `protobuf:"varint,8,opt,name=idx,proto3" json:"idx,omitempty"`                                                     // Instance index on server node.
	Incarnation    uint64   `protobuf:"varint,9,opt,name=incarnation,proto3" json:"incarnation,omitempty"`                                     // rank incarnation
	SecondaryUris  []string `protobuf:"bytes,10,rep,name=secondary_uris,json=secondaryUris,proto3" json:"secondary_uris,omitempty"`            // URIs for any secondary providers
	SecondaryNctxs []uint32 `protobuf:"varint,11,rep,packed,name=secondary_nctxs,json=secondaryNctxs,proto3" json:"secondary_nctxs,omitempty"` // CaRT context count for each secondary provider
	CheckMode      bool     `protobuf:"varint,12,opt,name=check_mode,json=checkMode,proto3" json:"check_mode,omitempty"`                       // rank started in check mode
	// contains filtered or unexported fields
}

func (*JoinReq) Descriptor deprecated 

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

Deprecated: Use JoinReq.ProtoReflect.Descriptor instead.

func (*JoinReq) GetAddr 

func (x *JoinReq) GetAddr() string

func (*JoinReq) GetCheckMode 

func (x *JoinReq) GetCheckMode() bool

func (*JoinReq) GetIdx 

func (x *JoinReq) GetIdx() uint32

func (*JoinReq) GetIncarnation 

func (x *JoinReq) GetIncarnation() uint64

func (*JoinReq) GetNctxs 

func (x *JoinReq) GetNctxs() uint32

func (*JoinReq) GetRank 

func (x *JoinReq) GetRank() uint32

func (*JoinReq) GetSecondaryNctxs 

func (x *JoinReq) GetSecondaryNctxs() []uint32

func (*JoinReq) GetSecondaryUris 

func (x *JoinReq) GetSecondaryUris() []string

func (*JoinReq) GetSrvFaultDomain 

func (x *JoinReq) GetSrvFaultDomain() string

func (*JoinReq) GetSys 

func (x *JoinReq) GetSys() string

func (*JoinReq) GetUri 

func (x *JoinReq) GetUri() string

func (*JoinReq) GetUuid 

func (x *JoinReq) GetUuid() string

func (*JoinReq) ProtoMessage 

func (*JoinReq) ProtoMessage()

func (*JoinReq) ProtoReflect 

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

func (*JoinReq) Reset 

func (x *JoinReq) Reset()

func (*JoinReq) String 

func (x *JoinReq) String() string

type JoinResp 

type JoinResp struct {
	Status      int32          `protobuf:"varint,1,opt,name=status,proto3" json:"status,omitempty"`                           // DAOS error code
	Rank        uint32         `protobuf:"varint,2,opt,name=rank,proto3" json:"rank,omitempty"`                               // Server rank assigned.
	State       JoinResp_State `protobuf:"varint,3,opt,name=state,proto3,enum=mgmt.JoinResp_State" json:"state,omitempty"`    // Server state in the system map.
	FaultDomain string         `protobuf:"bytes,4,opt,name=faultDomain,proto3" json:"faultDomain,omitempty"`                  // Fault domain for the instance
	LocalJoin   bool           `protobuf:"varint,5,opt,name=localJoin,proto3" json:"localJoin,omitempty"`                     // Join processed locally.
	MapVersion  uint32         `protobuf:"varint,6,opt,name=map_version,json=mapVersion,proto3" json:"map_version,omitempty"` // Join processed in this version of the system map.
	// contains filtered or unexported fields
}

func (*JoinResp) Descriptor deprecated 

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

Deprecated: Use JoinResp.ProtoReflect.Descriptor instead.

func (*JoinResp) GetFaultDomain 

func (x *JoinResp) GetFaultDomain() string

func (*JoinResp) GetLocalJoin 

func (x *JoinResp) GetLocalJoin() bool

func (*JoinResp) GetMapVersion 

func (x *JoinResp) GetMapVersion() uint32

func (*JoinResp) GetRank 

func (x *JoinResp) GetRank() uint32

func (*JoinResp) GetState 

func (x *JoinResp) GetState() JoinResp_State

func (*JoinResp) GetStatus 

func (x *JoinResp) GetStatus() int32

func (*JoinResp) ProtoMessage 

func (*JoinResp) ProtoMessage()

func (*JoinResp) ProtoReflect 

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

func (*JoinResp) Reset 

func (x *JoinResp) Reset()

func (*JoinResp) String 

func (x *JoinResp) String() string

type JoinResp_State 

type JoinResp_State int32
const (
	JoinResp_IN    JoinResp_State = 0 // Server in the system.
	JoinResp_OUT   JoinResp_State = 1 // Server excluded from the system.
	JoinResp_CHECK JoinResp_State = 2 // Server should start in checker mode.
)

func (JoinResp_State) Descriptor 

func (JoinResp_State) Descriptor() protoreflect.EnumDescriptor

func (JoinResp_State) Enum 

func (x JoinResp_State) Enum() *JoinResp_State

func (JoinResp_State) EnumDescriptor deprecated 

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

Deprecated: Use JoinResp_State.Descriptor instead.

func (JoinResp_State) Number 

func (x JoinResp_State) Number() protoreflect.EnumNumber

func (JoinResp_State) String 

func (x JoinResp_State) String() string

func (JoinResp_State) Type 

func (JoinResp_State) Type() protoreflect.EnumType

type LeaderQueryReq 

type LeaderQueryReq struct {
	Sys   string `protobuf:"bytes,1,opt,name=sys,proto3" json:"sys,omitempty"`     // System name.
	Hosts string `protobuf:"bytes,2,opt,name=hosts,proto3" json:"hosts,omitempty"` // hostset to query
	// contains filtered or unexported fields
}

func (*LeaderQueryReq) Descriptor deprecated 

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

Deprecated: Use LeaderQueryReq.ProtoReflect.Descriptor instead.

func (*LeaderQueryReq) GetHosts 

func (x *LeaderQueryReq) GetHosts() string

func (*LeaderQueryReq) GetSys 

func (x *LeaderQueryReq) GetSys() string

func (*LeaderQueryReq) ProtoMessage 

func (*LeaderQueryReq) ProtoMessage()

func (*LeaderQueryReq) ProtoReflect 

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

func (*LeaderQueryReq) Reset 

func (x *LeaderQueryReq) Reset()

func (*LeaderQueryReq) String 

func (x *LeaderQueryReq) String() string

type LeaderQueryResp 

type LeaderQueryResp struct {
	CurrentLeader string   `protobuf:"bytes,1,opt,name=current_leader,json=currentLeader,proto3" json:"current_leader,omitempty"`
	Replicas      []string `protobuf:"bytes,2,rep,name=replicas,proto3" json:"replicas,omitempty"`
	DownReplicas  []string `protobuf:"bytes,3,rep,name=DownReplicas,proto3" json:"DownReplicas,omitempty"`
	// contains filtered or unexported fields
}

func (*LeaderQueryResp) Descriptor deprecated 

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

Deprecated: Use LeaderQueryResp.ProtoReflect.Descriptor instead.

func (*LeaderQueryResp) GetCurrentLeader 

func (x *LeaderQueryResp) GetCurrentLeader() string

func (*LeaderQueryResp) GetDownReplicas 

func (x *LeaderQueryResp) GetDownReplicas() []string

func (*LeaderQueryResp) GetReplicas 

func (x *LeaderQueryResp) GetReplicas() []string

func (*LeaderQueryResp) ProtoMessage 

func (*LeaderQueryResp) ProtoMessage()

func (*LeaderQueryResp) ProtoReflect 

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

func (*LeaderQueryResp) Reset 

func (x *LeaderQueryResp) Reset()

func (*LeaderQueryResp) String 

func (x *LeaderQueryResp) String() string

type ListContReq 

type ListContReq struct {
	Sys      string   `protobuf:"bytes,1,opt,name=sys,proto3" json:"sys,omitempty"`                                   // DAOS system identifier
	Id       string   `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`                                     // uuid or label of pool
	SvcRanks []uint32 `protobuf:"varint,3,rep,packed,name=svc_ranks,json=svcRanks,proto3" json:"svc_ranks,omitempty"` // List of pool service ranks
	// contains filtered or unexported fields
}

ListContainers Initial implementation differs from C API (numContainers not provided in request - get whole list)

func (*ListContReq) Descriptor deprecated 

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

Deprecated: Use ListContReq.ProtoReflect.Descriptor instead.

func (*ListContReq) GetId 

func (x *ListContReq) GetId() string

func (*ListContReq) GetSvcRanks 

func (x *ListContReq) GetSvcRanks() []uint32

func (*ListContReq) GetSys 

func (x *ListContReq) GetSys() string

func (*ListContReq) ProtoMessage 

func (*ListContReq) ProtoMessage()

func (*ListContReq) ProtoReflect 

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

func (*ListContReq) Reset 

func (x *ListContReq) Reset()

func (*ListContReq) SetSvcRanks 

func (r *ListContReq) SetSvcRanks(rl []uint32)

SetSvcRanks sets the request's Pool Service Ranks.

func (*ListContReq) SetUUID 

func (r *ListContReq) SetUUID(id uuid.UUID)

SetUUID sets the request's ID to a UUID.

func (*ListContReq) String 

func (x *ListContReq) String() string

type ListContResp 

type ListContResp struct {
	Status     int32                `protobuf:"varint,1,opt,name=status,proto3" json:"status,omitempty"`        // DAOS error code
	Containers []*ListContResp_Cont `protobuf:"bytes,2,rep,name=containers,proto3" json:"containers,omitempty"` // containers
	// contains filtered or unexported fields
}

func (*ListContResp) Descriptor deprecated 

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

Deprecated: Use ListContResp.ProtoReflect.Descriptor instead.

func (*ListContResp) GetContainers 

func (x *ListContResp) GetContainers() []*ListContResp_Cont

func (*ListContResp) GetStatus 

func (x *ListContResp) GetStatus() int32

func (*ListContResp) ProtoMessage 

func (*ListContResp) ProtoMessage()

func (*ListContResp) ProtoReflect 

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

func (*ListContResp) Reset 

func (x *ListContResp) Reset()

func (*ListContResp) String 

func (x *ListContResp) String() string

type ListContResp_Cont 

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

func (*ListContResp_Cont) Descriptor deprecated 

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

Deprecated: Use ListContResp_Cont.ProtoReflect.Descriptor instead.

func (*ListContResp_Cont) GetUuid 

func (x *ListContResp_Cont) GetUuid() string

func (*ListContResp_Cont) ProtoMessage 

func (*ListContResp_Cont) ProtoMessage()

func (*ListContResp_Cont) ProtoReflect 

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

func (*ListContResp_Cont) Reset 

func (x *ListContResp_Cont) Reset()

func (*ListContResp_Cont) String 

func (x *ListContResp_Cont) String() string

type ListPoolsReq 

type ListPoolsReq struct {
	Sys string `protobuf:"bytes,1,opt,name=sys,proto3" json:"sys,omitempty"` // DAOS system identifier
	// contains filtered or unexported fields
}

ListPoolsReq represents a request to list pools on a given DAOS system.

func (*ListPoolsReq) Descriptor deprecated 

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

Deprecated: Use ListPoolsReq.ProtoReflect.Descriptor instead.

func (*ListPoolsReq) GetSys 

func (x *ListPoolsReq) GetSys() string

func (*ListPoolsReq) ProtoMessage 

func (*ListPoolsReq) ProtoMessage()

func (*ListPoolsReq) ProtoReflect 

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

func (*ListPoolsReq) Reset 

func (x *ListPoolsReq) Reset()

func (*ListPoolsReq) String 

func (x *ListPoolsReq) String() string

type ListPoolsResp 

type ListPoolsResp struct {
	Status      int32                 `protobuf:"varint,1,opt,name=status,proto3" json:"status,omitempty"`                              // DAOS error code
	Pools       []*ListPoolsResp_Pool `protobuf:"bytes,2,rep,name=pools,proto3" json:"pools,omitempty"`                                 // pools list
	DataVersion uint64                `protobuf:"varint,3,opt,name=data_version,json=dataVersion,proto3" json:"data_version,omitempty"` // Version of the system database.
	// contains filtered or unexported fields
}

ListPoolsResp returns the list of pools in the system.

func (*ListPoolsResp) Descriptor deprecated 

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

Deprecated: Use ListPoolsResp.ProtoReflect.Descriptor instead.

func (*ListPoolsResp) GetDataVersion 

func (x *ListPoolsResp) GetDataVersion() uint64

func (*ListPoolsResp) GetPools 

func (x *ListPoolsResp) GetPools() []*ListPoolsResp_Pool

func (*ListPoolsResp) GetStatus 

func (x *ListPoolsResp) GetStatus() int32

func (*ListPoolsResp) ProtoMessage 

func (*ListPoolsResp) ProtoMessage()

func (*ListPoolsResp) ProtoReflect 

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

func (*ListPoolsResp) Reset 

func (x *ListPoolsResp) Reset()

func (*ListPoolsResp) String 

func (x *ListPoolsResp) String() string

type ListPoolsResp_Pool 

type ListPoolsResp_Pool struct {
	Uuid         string   `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`                                     // uuid of pool
	Label        string   `protobuf:"bytes,2,opt,name=label,proto3" json:"label,omitempty"`                                   // pool label
	SvcReps      []uint32 `protobuf:"varint,3,rep,packed,name=svc_reps,json=svcReps,proto3" json:"svc_reps,omitempty"`        // pool service replica ranks
	State        string   `protobuf:"bytes,4,opt,name=state,proto3" json:"state,omitempty"`                                   // pool state
	RebuildState string   `protobuf:"bytes,5,opt,name=rebuild_state,json=rebuildState,proto3" json:"rebuild_state,omitempty"` // pool rebuild state
	// contains filtered or unexported fields
}

func (*ListPoolsResp_Pool) Descriptor deprecated 

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

Deprecated: Use ListPoolsResp_Pool.ProtoReflect.Descriptor instead.

func (*ListPoolsResp_Pool) GetLabel 

func (x *ListPoolsResp_Pool) GetLabel() string

func (*ListPoolsResp_Pool) GetRebuildState 

func (x *ListPoolsResp_Pool) GetRebuildState() string

func (*ListPoolsResp_Pool) GetState 

func (x *ListPoolsResp_Pool) GetState() string

func (*ListPoolsResp_Pool) GetSvcReps 

func (x *ListPoolsResp_Pool) GetSvcReps() []uint32

func (*ListPoolsResp_Pool) GetUuid 

func (x *ListPoolsResp_Pool) GetUuid() string

func (*ListPoolsResp_Pool) ProtoMessage 

func (*ListPoolsResp_Pool) ProtoMessage()

func (*ListPoolsResp_Pool) ProtoReflect 

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

func (*ListPoolsResp_Pool) Reset 

func (x *ListPoolsResp_Pool) Reset()

func (*ListPoolsResp_Pool) String 

func (x *ListPoolsResp_Pool) String() string

type MgmtSvcClient 

type MgmtSvcClient interface {
	// Join the server described by JoinReq to the system.
	Join(ctx context.Context, in *JoinReq, opts ...grpc.CallOption) (*JoinResp, error)
	// ClusterEvent notify MS of a RAS event in the cluster.
	ClusterEvent(ctx context.Context, in *shared.ClusterEventReq, opts ...grpc.CallOption) (*shared.ClusterEventResp, error)
	// LeaderQuery provides a mechanism for clients to discover
	// the system's current Management Service leader
	LeaderQuery(ctx context.Context, in *LeaderQueryReq, opts ...grpc.CallOption) (*LeaderQueryResp, error)
	// Create a DAOS pool allocated across a number of ranks
	PoolCreate(ctx context.Context, in *PoolCreateReq, opts ...grpc.CallOption) (*PoolCreateResp, error)
	// Destroy a DAOS pool allocated across a number of ranks.
	PoolDestroy(ctx context.Context, in *PoolDestroyReq, opts ...grpc.CallOption) (*PoolDestroyResp, error)
	// Evict a DAOS pool's connections.
	PoolEvict(ctx context.Context, in *PoolEvictReq, opts ...grpc.CallOption) (*PoolEvictResp, error)
	// Exclude a pool target.
	PoolExclude(ctx context.Context, in *PoolExcludeReq, opts ...grpc.CallOption) (*PoolExcludeResp, error)
	// Drain a pool target.
	PoolDrain(ctx context.Context, in *PoolDrainReq, opts ...grpc.CallOption) (*PoolDrainResp, error)
	// Extend a pool.
	PoolExtend(ctx context.Context, in *PoolExtendReq, opts ...grpc.CallOption) (*PoolExtendResp, error)
	// Reintegrate a pool target.
	PoolReintegrate(ctx context.Context, in *PoolReintegrateReq, opts ...grpc.CallOption) (*PoolReintegrateResp, error)
	// PoolQuery queries a DAOS pool.
	PoolQuery(ctx context.Context, in *PoolQueryReq, opts ...grpc.CallOption) (*PoolQueryResp, error)
	// PoolQueryTarget queries a DAOS storage target.
	PoolQueryTarget(ctx context.Context, in *PoolQueryTargetReq, opts ...grpc.CallOption) (*PoolQueryTargetResp, error)
	// Set a DAOS pool property.
	PoolSetProp(ctx context.Context, in *PoolSetPropReq, opts ...grpc.CallOption) (*PoolSetPropResp, error)
	// Get a DAOS pool property list.
	PoolGetProp(ctx context.Context, in *PoolGetPropReq, opts ...grpc.CallOption) (*PoolGetPropResp, error)
	// Fetch the Access Control List for a DAOS pool.
	PoolGetACL(ctx context.Context, in *GetACLReq, opts ...grpc.CallOption) (*ACLResp, error)
	// Overwrite the Access Control List for a DAOS pool with a new one.
	PoolOverwriteACL(ctx context.Context, in *ModifyACLReq, opts ...grpc.CallOption) (*ACLResp, error)
	// Update existing the Access Control List for a DAOS pool with new entries.
	PoolUpdateACL(ctx context.Context, in *ModifyACLReq, opts ...grpc.CallOption) (*ACLResp, error)
	// Delete an entry from a DAOS pool's Access Control List.
	PoolDeleteACL(ctx context.Context, in *DeleteACLReq, opts ...grpc.CallOption) (*ACLResp, error)
	// Get the information required by libdaos to attach to the system.
	GetAttachInfo(ctx context.Context, in *GetAttachInfoReq, opts ...grpc.CallOption) (*GetAttachInfoResp, error)
	// List all pools in a DAOS system: basic info: UUIDs, service ranks.
	ListPools(ctx context.Context, in *ListPoolsReq, opts ...grpc.CallOption) (*ListPoolsResp, error)
	// List all containers in a pool
	ListContainers(ctx context.Context, in *ListContReq, opts ...grpc.CallOption) (*ListContResp, error)
	// Change the owner of a DAOS container
	ContSetOwner(ctx context.Context, in *ContSetOwnerReq, opts ...grpc.CallOption) (*DaosResp, error)
	// Query DAOS system status
	SystemQuery(ctx context.Context, in *SystemQueryReq, opts ...grpc.CallOption) (*SystemQueryResp, error)
	// Stop DAOS system (shutdown data-plane instances)
	SystemStop(ctx context.Context, in *SystemStopReq, opts ...grpc.CallOption) (*SystemStopResp, error)
	// Start DAOS system (restart data-plane instances)
	SystemStart(ctx context.Context, in *SystemStartReq, opts ...grpc.CallOption) (*SystemStartResp, error)
	// Exclude DAOS ranks
	SystemExclude(ctx context.Context, in *SystemExcludeReq, opts ...grpc.CallOption) (*SystemExcludeResp, error)
	// Drain DAOS ranks from all pools
	SystemDrain(ctx context.Context, in *SystemDrainReq, opts ...grpc.CallOption) (*SystemDrainResp, error)
	// Erase DAOS system database prior to reformat
	SystemErase(ctx context.Context, in *SystemEraseReq, opts ...grpc.CallOption) (*SystemEraseResp, error)
	// Clean up leaked resources for a given node
	SystemCleanup(ctx context.Context, in *SystemCleanupReq, opts ...grpc.CallOption) (*SystemCleanupResp, error)
	// Enable system check mode
	SystemCheckEnable(ctx context.Context, in *CheckEnableReq, opts ...grpc.CallOption) (*DaosResp, error)
	// Disable system check mode
	SystemCheckDisable(ctx context.Context, in *CheckDisableReq, opts ...grpc.CallOption) (*DaosResp, error)
	// Initiate a system check
	SystemCheckStart(ctx context.Context, in *CheckStartReq, opts ...grpc.CallOption) (*CheckStartResp, error)
	// Stop a system check
	SystemCheckStop(ctx context.Context, in *CheckStopReq, opts ...grpc.CallOption) (*CheckStopResp, error)
	// Query a system check
	SystemCheckQuery(ctx context.Context, in *CheckQueryReq, opts ...grpc.CallOption) (*CheckQueryResp, error)
	// Set system check properties
	SystemCheckSetPolicy(ctx context.Context, in *CheckSetPolicyReq, opts ...grpc.CallOption) (*DaosResp, error)
	// Query system check properties
	SystemCheckGetPolicy(ctx context.Context, in *CheckGetPolicyReq, opts ...grpc.CallOption) (*CheckGetPolicyResp, error)
	// Send the desired action to repair an inconsistency.
	SystemCheckRepair(ctx context.Context, in *CheckActReq, opts ...grpc.CallOption) (*CheckActResp, error)
	// PoolUpgrade queries a DAOS pool.
	PoolUpgrade(ctx context.Context, in *PoolUpgradeReq, opts ...grpc.CallOption) (*PoolUpgradeResp, error)
	// Set a system attribute or attributes.
	SystemSetAttr(ctx context.Context, in *SystemSetAttrReq, opts ...grpc.CallOption) (*DaosResp, error)
	// Get a system attribute or attributes.
	SystemGetAttr(ctx context.Context, in *SystemGetAttrReq, opts ...grpc.CallOption) (*SystemGetAttrResp, error)
	// Set a system property or properties.
	SystemSetProp(ctx context.Context, in *SystemSetPropReq, opts ...grpc.CallOption) (*DaosResp, error)
	// Get a system property or properties.
	SystemGetProp(ctx context.Context, in *SystemGetPropReq, opts ...grpc.CallOption) (*SystemGetPropResp, error)
	// Fault injection handlers are only implemented in non-release builds.
	// FaultInjectReport injects a checker report.
	FaultInjectReport(ctx context.Context, in *chk.CheckReport, opts ...grpc.CallOption) (*DaosResp, error)
	// FaultInjectPoolFault creates a pool fault for testing the checker.
	FaultInjectPoolFault(ctx context.Context, in *chk.Fault, opts ...grpc.CallOption) (*DaosResp, error)
	FaultInjectMgmtPoolFault(ctx context.Context, in *chk.Fault, opts ...grpc.CallOption) (*DaosResp, error)
}

MgmtSvcClient is the client API for MgmtSvc 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 NewMgmtSvcClient 

func NewMgmtSvcClient(cc grpc.ClientConnInterface) MgmtSvcClient

type MgmtSvcServer 

type MgmtSvcServer interface {
	// Join the server described by JoinReq to the system.
	Join(context.Context, *JoinReq) (*JoinResp, error)
	// ClusterEvent notify MS of a RAS event in the cluster.
	ClusterEvent(context.Context, *shared.ClusterEventReq) (*shared.ClusterEventResp, error)
	// LeaderQuery provides a mechanism for clients to discover
	// the system's current Management Service leader
	LeaderQuery(context.Context, *LeaderQueryReq) (*LeaderQueryResp, error)
	// Create a DAOS pool allocated across a number of ranks
	PoolCreate(context.Context, *PoolCreateReq) (*PoolCreateResp, error)
	// Destroy a DAOS pool allocated across a number of ranks.
	PoolDestroy(context.Context, *PoolDestroyReq) (*PoolDestroyResp, error)
	// Evict a DAOS pool's connections.
	PoolEvict(context.Context, *PoolEvictReq) (*PoolEvictResp, error)
	// Exclude a pool target.
	PoolExclude(context.Context, *PoolExcludeReq) (*PoolExcludeResp, error)
	// Drain a pool target.
	PoolDrain(context.Context, *PoolDrainReq) (*PoolDrainResp, error)
	// Extend a pool.
	PoolExtend(context.Context, *PoolExtendReq) (*PoolExtendResp, error)
	// Reintegrate a pool target.
	PoolReintegrate(context.Context, *PoolReintegrateReq) (*PoolReintegrateResp, error)
	// PoolQuery queries a DAOS pool.
	PoolQuery(context.Context, *PoolQueryReq) (*PoolQueryResp, error)
	// PoolQueryTarget queries a DAOS storage target.
	PoolQueryTarget(context.Context, *PoolQueryTargetReq) (*PoolQueryTargetResp, error)
	// Set a DAOS pool property.
	PoolSetProp(context.Context, *PoolSetPropReq) (*PoolSetPropResp, error)
	// Get a DAOS pool property list.
	PoolGetProp(context.Context, *PoolGetPropReq) (*PoolGetPropResp, error)
	// Fetch the Access Control List for a DAOS pool.
	PoolGetACL(context.Context, *GetACLReq) (*ACLResp, error)
	// Overwrite the Access Control List for a DAOS pool with a new one.
	PoolOverwriteACL(context.Context, *ModifyACLReq) (*ACLResp, error)
	// Update existing the Access Control List for a DAOS pool with new entries.
	PoolUpdateACL(context.Context, *ModifyACLReq) (*ACLResp, error)
	// Delete an entry from a DAOS pool's Access Control List.
	PoolDeleteACL(context.Context, *DeleteACLReq) (*ACLResp, error)
	// Get the information required by libdaos to attach to the system.
	GetAttachInfo(context.Context, *GetAttachInfoReq) (*GetAttachInfoResp, error)
	// List all pools in a DAOS system: basic info: UUIDs, service ranks.
	ListPools(context.Context, *ListPoolsReq) (*ListPoolsResp, error)
	// List all containers in a pool
	ListContainers(context.Context, *ListContReq) (*ListContResp, error)
	// Change the owner of a DAOS container
	ContSetOwner(context.Context, *ContSetOwnerReq) (*DaosResp, error)
	// Query DAOS system status
	SystemQuery(context.Context, *SystemQueryReq) (*SystemQueryResp, error)
	// Stop DAOS system (shutdown data-plane instances)
	SystemStop(context.Context, *SystemStopReq) (*SystemStopResp, error)
	// Start DAOS system (restart data-plane instances)
	SystemStart(context.Context, *SystemStartReq) (*SystemStartResp, error)
	// Exclude DAOS ranks
	SystemExclude(context.Context, *SystemExcludeReq) (*SystemExcludeResp, error)
	// Drain DAOS ranks from all pools
	SystemDrain(context.Context, *SystemDrainReq) (*SystemDrainResp, error)
	// Erase DAOS system database prior to reformat
	SystemErase(context.Context, *SystemEraseReq) (*SystemEraseResp, error)
	// Clean up leaked resources for a given node
	SystemCleanup(context.Context, *SystemCleanupReq) (*SystemCleanupResp, error)
	// Enable system check mode
	SystemCheckEnable(context.Context, *CheckEnableReq) (*DaosResp, error)
	// Disable system check mode
	SystemCheckDisable(context.Context, *CheckDisableReq) (*DaosResp, error)
	// Initiate a system check
	SystemCheckStart(context.Context, *CheckStartReq) (*CheckStartResp, error)
	// Stop a system check
	SystemCheckStop(context.Context, *CheckStopReq) (*CheckStopResp, error)
	// Query a system check
	SystemCheckQuery(context.Context, *CheckQueryReq) (*CheckQueryResp, error)
	// Set system check properties
	SystemCheckSetPolicy(context.Context, *CheckSetPolicyReq) (*DaosResp, error)
	// Query system check properties
	SystemCheckGetPolicy(context.Context, *CheckGetPolicyReq) (*CheckGetPolicyResp, error)
	// Send the desired action to repair an inconsistency.
	SystemCheckRepair(context.Context, *CheckActReq) (*CheckActResp, error)
	// PoolUpgrade queries a DAOS pool.
	PoolUpgrade(context.Context, *PoolUpgradeReq) (*PoolUpgradeResp, error)
	// Set a system attribute or attributes.
	SystemSetAttr(context.Context, *SystemSetAttrReq) (*DaosResp, error)
	// Get a system attribute or attributes.
	SystemGetAttr(context.Context, *SystemGetAttrReq) (*SystemGetAttrResp, error)
	// Set a system property or properties.
	SystemSetProp(context.Context, *SystemSetPropReq) (*DaosResp, error)
	// Get a system property or properties.
	SystemGetProp(context.Context, *SystemGetPropReq) (*SystemGetPropResp, error)
	// Fault injection handlers are only implemented in non-release builds.
	// FaultInjectReport injects a checker report.
	FaultInjectReport(context.Context, *chk.CheckReport) (*DaosResp, error)
	// FaultInjectPoolFault creates a pool fault for testing the checker.
	FaultInjectPoolFault(context.Context, *chk.Fault) (*DaosResp, error)
	FaultInjectMgmtPoolFault(context.Context, *chk.Fault) (*DaosResp, error)
	// contains filtered or unexported methods
}

MgmtSvcServer is the server API for MgmtSvc service. All implementations must embed UnimplementedMgmtSvcServer for forward compatibility

type ModifyACLReq 

type ModifyACLReq struct {
	Sys      string   `protobuf:"bytes,1,opt,name=sys,proto3" json:"sys,omitempty"`                                   // DAOS system identifier
	Id       string   `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`                                     // Target UUID or label
	Entries  []string `protobuf:"bytes,3,rep,name=entries,proto3" json:"entries,omitempty"`                           // List of ACEs to overwrite ACL with
	SvcRanks []uint32 `protobuf:"varint,4,rep,packed,name=svc_ranks,json=svcRanks,proto3" json:"svc_ranks,omitempty"` // List of pool service ranks
	// contains filtered or unexported fields
}

Request to modify an ACL Results depend on the specific modification command.

func (*ModifyACLReq) Descriptor deprecated 

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

Deprecated: Use ModifyACLReq.ProtoReflect.Descriptor instead.

func (*ModifyACLReq) GetEntries 

func (x *ModifyACLReq) GetEntries() []string

func (*ModifyACLReq) GetId 

func (x *ModifyACLReq) GetId() string

func (*ModifyACLReq) GetSvcRanks 

func (x *ModifyACLReq) GetSvcRanks() []uint32

func (*ModifyACLReq) GetSys 

func (x *ModifyACLReq) GetSys() string

func (*ModifyACLReq) ProtoMessage 

func (*ModifyACLReq) ProtoMessage()

func (*ModifyACLReq) ProtoReflect 

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

func (*ModifyACLReq) Reset 

func (x *ModifyACLReq) Reset()

func (*ModifyACLReq) SetSvcRanks 

func (r *ModifyACLReq) SetSvcRanks(rl []uint32)

SetSvcRanks sets the request's Pool Service Ranks.

func (*ModifyACLReq) SetUUID 

func (r *ModifyACLReq) SetUUID(id uuid.UUID)

SetUUID sets the request's ID to a UUID.

func (*ModifyACLReq) String 

func (x *ModifyACLReq) String() string

type PingRankReq 

type PingRankReq struct {
	Rank uint32 `protobuf:"varint,1,opt,name=rank,proto3" json:"rank,omitempty"` // DAOS I/O Engine unique identifier.
	// contains filtered or unexported fields
}

func (*PingRankReq) Descriptor deprecated 

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

Deprecated: Use PingRankReq.ProtoReflect.Descriptor instead.

func (*PingRankReq) GetRank 

func (x *PingRankReq) GetRank() uint32

func (*PingRankReq) ProtoMessage 

func (*PingRankReq) ProtoMessage()

func (*PingRankReq) ProtoReflect 

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

func (*PingRankReq) Reset 

func (x *PingRankReq) Reset()

func (*PingRankReq) String 

func (x *PingRankReq) String() string

type PoolCreateReq 

type PoolCreateReq struct {
	Uuid       string          `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`                            // UUID for new pool, generated on the client
	Sys        string          `protobuf:"bytes,2,opt,name=sys,proto3" json:"sys,omitempty"`                              // DAOS system identifier
	User       string          `protobuf:"bytes,3,opt,name=user,proto3" json:"user,omitempty"`                            // formatted user e.g. "bob@"
	UserGroup  string          `protobuf:"bytes,4,opt,name=user_group,json=userGroup,proto3" json:"user_group,omitempty"` // formatted group e.g. "builders@"
	Acl        []string        `protobuf:"bytes,5,rep,name=acl,proto3" json:"acl,omitempty"`                              // Access Control Entries in short string format
	Properties []*PoolProperty `protobuf:"bytes,6,rep,name=properties,proto3" json:"properties,omitempty"`                // Pool properties to be set
	// The minimal fault domain tree format consists of a set of tuples
	// representing members of the tree in a breadth-first traversal order.
	// Each domain above rank consists of: (level, id, num children)
	// Each rank consists of: (rank number)
	FaultDomains []uint32  `protobuf:"varint,7,rep,packed,name=fault_domains,json=faultDomains,proto3" json:"fault_domains,omitempty"` // Fault domain tree, minimal format
	NumSvcReps   uint32    `protobuf:"varint,8,opt,name=num_svc_reps,json=numSvcReps,proto3" json:"num_svc_reps,omitempty"`            // desired number of pool service replicas
	TotalBytes   uint64    `protobuf:"varint,9,opt,name=total_bytes,json=totalBytes,proto3" json:"total_bytes,omitempty"`              // Total pool size in bytes
	TierRatio    []float64 `protobuf:"fixed64,10,rep,packed,name=tier_ratio,json=tierRatio,proto3" json:"tier_ratio,omitempty"`        // Ratio of storage tiers expressed as % of totalbytes
	NumRanks     uint32    `protobuf:"varint,11,opt,name=num_ranks,json=numRanks,proto3" json:"num_ranks,omitempty"`                   // Number of target ranks to use
	Ranks        []uint32  `protobuf:"varint,12,rep,packed,name=ranks,proto3" json:"ranks,omitempty"`                                  // target ranks
	TierBytes    []uint64  `protobuf:"varint,13,rep,packed,name=tier_bytes,json=tierBytes,proto3" json:"tier_bytes,omitempty"`         // Size in bytes of storage tier
	MemRatio     float32   `protobuf:"fixed32,14,opt,name=mem_ratio,json=memRatio,proto3" json:"mem_ratio,omitempty"`                  // Fraction of meta-blob-sz to use as mem-file-sz
	// contains filtered or unexported fields
}

PoolCreateReq supplies new pool parameters.

func (*PoolCreateReq) Descriptor deprecated 

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

Deprecated: Use PoolCreateReq.ProtoReflect.Descriptor instead.

func (*PoolCreateReq) GetAcl 

func (x *PoolCreateReq) GetAcl() []string

func (*PoolCreateReq) GetFaultDomains 

func (x *PoolCreateReq) GetFaultDomains() []uint32

func (*PoolCreateReq) GetMemRatio 

func (x *PoolCreateReq) GetMemRatio() float32

func (*PoolCreateReq) GetNumRanks 

func (x *PoolCreateReq) GetNumRanks() uint32

func (*PoolCreateReq) GetNumSvcReps 

func (x *PoolCreateReq) GetNumSvcReps() uint32

func (*PoolCreateReq) GetProperties 

func (x *PoolCreateReq) GetProperties() []*PoolProperty

func (*PoolCreateReq) GetRanks 

func (x *PoolCreateReq) GetRanks() []uint32

func (*PoolCreateReq) GetSys 

func (x *PoolCreateReq) GetSys() string

func (*PoolCreateReq) GetTierBytes 

func (x *PoolCreateReq) GetTierBytes() []uint64

func (*PoolCreateReq) GetTierRatio 

func (x *PoolCreateReq) GetTierRatio() []float64

func (*PoolCreateReq) GetTotalBytes 

func (x *PoolCreateReq) GetTotalBytes() uint64

func (*PoolCreateReq) GetUser 

func (x *PoolCreateReq) GetUser() string

func (*PoolCreateReq) GetUserGroup 

func (x *PoolCreateReq) GetUserGroup() string

func (*PoolCreateReq) GetUuid 

func (x *PoolCreateReq) GetUuid() string

func (*PoolCreateReq) ProtoMessage 

func (*PoolCreateReq) ProtoMessage()

func (*PoolCreateReq) ProtoReflect 

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

func (*PoolCreateReq) Reset 

func (x *PoolCreateReq) Reset()

func (*PoolCreateReq) String 

func (x *PoolCreateReq) String() string

type PoolCreateResp 

type PoolCreateResp struct {
	Status       int32    `protobuf:"varint,1,opt,name=status,proto3" json:"status,omitempty"`                                   // DAOS error code
	SvcLdr       uint32   `protobuf:"varint,2,opt,name=svc_ldr,json=svcLdr,proto3" json:"svc_ldr,omitempty"`                     // Current service leader rank
	SvcReps      []uint32 `protobuf:"varint,3,rep,packed,name=svc_reps,json=svcReps,proto3" json:"svc_reps,omitempty"`           // pool service replica ranks
	TgtRanks     []uint32 `protobuf:"varint,4,rep,packed,name=tgt_ranks,json=tgtRanks,proto3" json:"tgt_ranks,omitempty"`        // pool target ranks
	TierBytes    []uint64 `protobuf:"varint,5,rep,packed,name=tier_bytes,json=tierBytes,proto3" json:"tier_bytes,omitempty"`     // per-rank storage tier sizes allocated in pool
	MemFileBytes uint64   `protobuf:"varint,6,opt,name=mem_file_bytes,json=memFileBytes,proto3" json:"mem_file_bytes,omitempty"` // per-rank accumulated value of memory file sizes
	// contains filtered or unexported fields
}

PoolCreateResp returns created pool uuid and ranks.

func (*PoolCreateResp) Descriptor deprecated 

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

Deprecated: Use PoolCreateResp.ProtoReflect.Descriptor instead.

func (*PoolCreateResp) GetMemFileBytes 

func (x *PoolCreateResp) GetMemFileBytes() uint64

func (*PoolCreateResp) GetStatus 

func (x *PoolCreateResp) GetStatus() int32

func (*PoolCreateResp) GetSvcLdr 

func (x *PoolCreateResp) GetSvcLdr() uint32

func (*PoolCreateResp) GetSvcReps 

func (x *PoolCreateResp) GetSvcReps() []uint32

func (*PoolCreateResp) GetTgtRanks 

func (x *PoolCreateResp) GetTgtRanks() []uint32

func (*PoolCreateResp) GetTierBytes 

func (x *PoolCreateResp) GetTierBytes() []uint64

func (*PoolCreateResp) ProtoMessage 

func (*PoolCreateResp) ProtoMessage()

func (*PoolCreateResp) ProtoReflect 

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

func (*PoolCreateResp) Reset 

func (x *PoolCreateResp) Reset()

func (*PoolCreateResp) String 

func (x *PoolCreateResp) String() string

type PoolDestroyReq 

type PoolDestroyReq struct {
	Sys       string   `protobuf:"bytes,1,opt,name=sys,proto3" json:"sys,omitempty"`                                   // DAOS system identifier
	Id        string   `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`                                     // uuid or label of pool to destroy
	Force     bool     `protobuf:"varint,3,opt,name=force,proto3" json:"force,omitempty"`                              // destroy regardless of active connections
	SvcRanks  []uint32 `protobuf:"varint,4,rep,packed,name=svc_ranks,json=svcRanks,proto3" json:"svc_ranks,omitempty"` // List of pool service ranks
	Recursive bool     `protobuf:"varint,5,opt,name=recursive,proto3" json:"recursive,omitempty"`                      // destroy regardless of any child containers
	// contains filtered or unexported fields
}

PoolDestroyReq supplies pool identifier and force flag.

func (*PoolDestroyReq) Descriptor deprecated 

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

Deprecated: Use PoolDestroyReq.ProtoReflect.Descriptor instead.

func (*PoolDestroyReq) GetForce 

func (x *PoolDestroyReq) GetForce() bool

func (*PoolDestroyReq) GetId 

func (x *PoolDestroyReq) GetId() string

func (*PoolDestroyReq) GetRecursive 

func (x *PoolDestroyReq) GetRecursive() bool

func (*PoolDestroyReq) GetSvcRanks 

func (x *PoolDestroyReq) GetSvcRanks() []uint32

func (*PoolDestroyReq) GetSys 

func (x *PoolDestroyReq) GetSys() string

func (*PoolDestroyReq) ProtoMessage 

func (*PoolDestroyReq) ProtoMessage()

func (*PoolDestroyReq) ProtoReflect 

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

func (*PoolDestroyReq) Reset 

func (x *PoolDestroyReq) Reset()

func (*PoolDestroyReq) SetUUID 

func (r *PoolDestroyReq) SetUUID(id uuid.UUID)

SetUUID sets the request's ID to a UUID.

func (*PoolDestroyReq) String 

func (x *PoolDestroyReq) String() string

type PoolDestroyResp 

type PoolDestroyResp struct {
	Status int32 `protobuf:"varint,1,opt,name=status,proto3" json:"status,omitempty"` // DAOS error code
	// contains filtered or unexported fields
}

PoolDestroyResp returns resultant state of destroy operation.

func (*PoolDestroyResp) Descriptor deprecated 

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

Deprecated: Use PoolDestroyResp.ProtoReflect.Descriptor instead.

func (*PoolDestroyResp) GetStatus 

func (x *PoolDestroyResp) GetStatus() int32

func (*PoolDestroyResp) ProtoMessage 

func (*PoolDestroyResp) ProtoMessage()

func (*PoolDestroyResp) ProtoReflect 

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

func (*PoolDestroyResp) Reset 

func (x *PoolDestroyResp) Reset()

func (*PoolDestroyResp) String 

func (x *PoolDestroyResp) String() string

type PoolDrainReq 

type PoolDrainReq struct {
	Sys       string   `protobuf:"bytes,1,opt,name=sys,proto3" json:"sys,omitempty"`                                      // DAOS system identifier
	Id        string   `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`                                        // uuid or label of pool to drain some targets
	Rank      uint32   `protobuf:"varint,3,opt,name=rank,proto3" json:"rank,omitempty"`                                   // rank to move to the down state
	TargetIdx []uint32 `protobuf:"varint,4,rep,packed,name=target_idx,json=targetIdx,proto3" json:"target_idx,omitempty"` // rank targets
	SvcRanks  []uint32 `protobuf:"varint,5,rep,packed,name=svc_ranks,json=svcRanks,proto3" json:"svc_ranks,omitempty"`    // List of pool service ranks
	// contains filtered or unexported fields
}

PoolDrainReq supplies pool identifier, rank, and target_idxs.

func (*PoolDrainReq) Descriptor deprecated 

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

Deprecated: Use PoolDrainReq.ProtoReflect.Descriptor instead.

func (*PoolDrainReq) GetId 

func (x *PoolDrainReq) GetId() string

func (*PoolDrainReq) GetRank 

func (x *PoolDrainReq) GetRank() uint32

func (*PoolDrainReq) GetSvcRanks 

func (x *PoolDrainReq) GetSvcRanks() []uint32

func (*PoolDrainReq) GetSys 

func (x *PoolDrainReq) GetSys() string

func (*PoolDrainReq) GetTargetIdx 

func (x *PoolDrainReq) GetTargetIdx() []uint32

func (*PoolDrainReq) ProtoMessage 

func (*PoolDrainReq) ProtoMessage()

func (*PoolDrainReq) ProtoReflect 

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

func (*PoolDrainReq) Reset 

func (x *PoolDrainReq) Reset()

func (*PoolDrainReq) SetSvcRanks 

func (r *PoolDrainReq) SetSvcRanks(rl []uint32)

SetSvcRanks sets the request's Pool Service Ranks.

func (*PoolDrainReq) SetUUID 

func (r *PoolDrainReq) SetUUID(id uuid.UUID)

SetUUID sets the request's ID to a UUID.

func (*PoolDrainReq) String 

func (x *PoolDrainReq) String() string

type PoolDrainResp 

type PoolDrainResp struct {
	Status int32 `protobuf:"varint,1,opt,name=status,proto3" json:"status,omitempty"` // DAOS error code
	// contains filtered or unexported fields
}

PoolDrainResp returns resultant state of Drain operation.

func (*PoolDrainResp) Descriptor deprecated 

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

Deprecated: Use PoolDrainResp.ProtoReflect.Descriptor instead.

func (*PoolDrainResp) GetStatus 

func (x *PoolDrainResp) GetStatus() int32

func (*PoolDrainResp) ProtoMessage 

func (*PoolDrainResp) ProtoMessage()

func (*PoolDrainResp) ProtoReflect 

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

func (*PoolDrainResp) Reset 

func (x *PoolDrainResp) Reset()

func (*PoolDrainResp) String 

func (x *PoolDrainResp) String() string

type PoolEvictReq 

type PoolEvictReq struct {
	Sys          string   `protobuf:"bytes,1,opt,name=sys,proto3" json:"sys,omitempty"`                                        // DAOS system identifier
	Id           string   `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`                                          // uuid or label of pool to evict
	SvcRanks     []uint32 `protobuf:"varint,3,rep,packed,name=svc_ranks,json=svcRanks,proto3" json:"svc_ranks,omitempty"`      // List of pool service ranks
	Handles      []string `protobuf:"bytes,4,rep,name=handles,proto3" json:"handles,omitempty"`                                // Optional list of handles to evict (Mutually exclusive with destroy/force_destroy)
	Destroy      bool     `protobuf:"varint,5,opt,name=destroy,proto3" json:"destroy,omitempty"`                               // If true, evict is first step of a pool destroy operation
	ForceDestroy bool     `protobuf:"varint,6,opt,name=force_destroy,json=forceDestroy,proto3" json:"force_destroy,omitempty"` // If true and destroy=true, forcibly closes open pool handles
	Machine      string   `protobuf:"bytes,7,opt,name=machine,proto3" json:"machine,omitempty"`                                // Optional machine name to evict handles for (Mutually exclusive with handles)
	// contains filtered or unexported fields
}

PoolEvictReq supplies pool identifier.

func (*PoolEvictReq) Descriptor deprecated 

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

Deprecated: Use PoolEvictReq.ProtoReflect.Descriptor instead.

func (*PoolEvictReq) GetDestroy 

func (x *PoolEvictReq) GetDestroy() bool

func (*PoolEvictReq) GetForceDestroy 

func (x *PoolEvictReq) GetForceDestroy() bool

func (*PoolEvictReq) GetHandles 

func (x *PoolEvictReq) GetHandles() []string

func (*PoolEvictReq) GetId 

func (x *PoolEvictReq) GetId() string

func (*PoolEvictReq) GetMachine 

func (x *PoolEvictReq) GetMachine() string

func (*PoolEvictReq) GetSvcRanks 

func (x *PoolEvictReq) GetSvcRanks() []uint32

func (*PoolEvictReq) GetSys 

func (x *PoolEvictReq) GetSys() string

func (*PoolEvictReq) ProtoMessage 

func (*PoolEvictReq) ProtoMessage()

func (*PoolEvictReq) ProtoReflect 

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

func (*PoolEvictReq) Reset 

func (x *PoolEvictReq) Reset()

func (*PoolEvictReq) SetSvcRanks 

func (r *PoolEvictReq) SetSvcRanks(rl []uint32)

SetSvcRanks sets the request's Pool Service Ranks.

func (*PoolEvictReq) SetUUID 

func (r *PoolEvictReq) SetUUID(id uuid.UUID)

SetUUID sets the request's ID to a UUID.

func (*PoolEvictReq) String 

func (x *PoolEvictReq) String() string

type PoolEvictResp 

type PoolEvictResp struct {
	Status int32 `protobuf:"varint,1,opt,name=status,proto3" json:"status,omitempty"` // DAOS error code
	Count  int32 `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"`   // Count of handles evicted
	// contains filtered or unexported fields
}

PoolEvictResp returns resultant state of evict operation.

func (*PoolEvictResp) Descriptor deprecated 

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

Deprecated: Use PoolEvictResp.ProtoReflect.Descriptor instead.

func (*PoolEvictResp) GetCount 

func (x *PoolEvictResp) GetCount() int32

func (*PoolEvictResp) GetStatus 

func (x *PoolEvictResp) GetStatus() int32

func (*PoolEvictResp) ProtoMessage 

func (*PoolEvictResp) ProtoMessage()

func (*PoolEvictResp) ProtoReflect 

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

func (*PoolEvictResp) Reset 

func (x *PoolEvictResp) Reset()

func (*PoolEvictResp) String 

func (x *PoolEvictResp) String() string

type PoolExcludeReq 

type PoolExcludeReq struct {
	Sys       string   `protobuf:"bytes,1,opt,name=sys,proto3" json:"sys,omitempty"`                                      // DAOS system identifier
	Id        string   `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`                                        // uuid or label of pool to exclude some targets
	Rank      uint32   `protobuf:"varint,3,opt,name=rank,proto3" json:"rank,omitempty"`                                   // target to move to the down state
	TargetIdx []uint32 `protobuf:"varint,4,rep,packed,name=target_idx,json=targetIdx,proto3" json:"target_idx,omitempty"` // target ranks
	SvcRanks  []uint32 `protobuf:"varint,5,rep,packed,name=svc_ranks,json=svcRanks,proto3" json:"svc_ranks,omitempty"`    // List of pool service ranks
	// contains filtered or unexported fields
}

PoolExcludeReq supplies pool identifier, rank, and target_idxs.

func (*PoolExcludeReq) Descriptor deprecated 

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

Deprecated: Use PoolExcludeReq.ProtoReflect.Descriptor instead.

func (*PoolExcludeReq) GetId 

func (x *PoolExcludeReq) GetId() string

func (*PoolExcludeReq) GetRank 

func (x *PoolExcludeReq) GetRank() uint32

func (*PoolExcludeReq) GetSvcRanks 

func (x *PoolExcludeReq) GetSvcRanks() []uint32

func (*PoolExcludeReq) GetSys 

func (x *PoolExcludeReq) GetSys() string

func (*PoolExcludeReq) GetTargetIdx 

func (x *PoolExcludeReq) GetTargetIdx() []uint32

func (*PoolExcludeReq) ProtoMessage 

func (*PoolExcludeReq) ProtoMessage()

func (*PoolExcludeReq) ProtoReflect 

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

func (*PoolExcludeReq) Reset 

func (x *PoolExcludeReq) Reset()

func (*PoolExcludeReq) SetSvcRanks 

func (r *PoolExcludeReq) SetSvcRanks(rl []uint32)

SetSvcRanks sets the request's Pool Service Ranks.

func (*PoolExcludeReq) SetUUID 

func (r *PoolExcludeReq) SetUUID(id uuid.UUID)

SetUUID sets the request's ID to a UUID.

func (*PoolExcludeReq) String 

func (x *PoolExcludeReq) String() string

type PoolExcludeResp 

type PoolExcludeResp struct {
	Status int32 `protobuf:"varint,1,opt,name=status,proto3" json:"status,omitempty"` // DAOS error code
	// contains filtered or unexported fields
}

PoolExcludeResp returns resultant state of Exclude operation.

func (*PoolExcludeResp) Descriptor deprecated 

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

Deprecated: Use PoolExcludeResp.ProtoReflect.Descriptor instead.

func (*PoolExcludeResp) GetStatus 

func (x *PoolExcludeResp) GetStatus() int32

func (*PoolExcludeResp) ProtoMessage 

func (*PoolExcludeResp) ProtoMessage()

func (*PoolExcludeResp) ProtoReflect 

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

func (*PoolExcludeResp) Reset 

func (x *PoolExcludeResp) Reset()

func (*PoolExcludeResp) String 

func (x *PoolExcludeResp) String() string

type PoolExtendReq 

type PoolExtendReq struct {
	Sys          string   `protobuf:"bytes,1,opt,name=sys,proto3" json:"sys,omitempty"`                                               // DAOS system identifier
	Id           string   `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`                                                 // uuid or label of pool to add target up to
	Ranks        []uint32 `protobuf:"varint,3,rep,packed,name=ranks,proto3" json:"ranks,omitempty"`                                   // ranks
	SvcRanks     []uint32 `protobuf:"varint,4,rep,packed,name=svc_ranks,json=svcRanks,proto3" json:"svc_ranks,omitempty"`             // List of pool service ranks
	TierBytes    []uint64 `protobuf:"varint,5,rep,packed,name=tier_bytes,json=tierBytes,proto3" json:"tier_bytes,omitempty"`          // Size in bytes of storage tiers
	FaultDomains []uint32 `protobuf:"varint,6,rep,packed,name=fault_domains,json=faultDomains,proto3" json:"fault_domains,omitempty"` // fault domain tree, minimal format
	MemRatio     float32  `protobuf:"fixed32,7,opt,name=mem_ratio,json=memRatio,proto3" json:"mem_ratio,omitempty"`                   // Fraction of meta-blob-sz to use as mem-file-sz
	// contains filtered or unexported fields
}

PoolExtendReq supplies pool identifier and rank list.

func (*PoolExtendReq) Descriptor deprecated 

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

Deprecated: Use PoolExtendReq.ProtoReflect.Descriptor instead.

func (*PoolExtendReq) GetFaultDomains 

func (x *PoolExtendReq) GetFaultDomains() []uint32

func (*PoolExtendReq) GetId 

func (x *PoolExtendReq) GetId() string

func (*PoolExtendReq) GetMemRatio 

func (x *PoolExtendReq) GetMemRatio() float32

func (*PoolExtendReq) GetRanks 

func (x *PoolExtendReq) GetRanks() []uint32

func (*PoolExtendReq) GetSvcRanks 

func (x *PoolExtendReq) GetSvcRanks() []uint32

func (*PoolExtendReq) GetSys 

func (x *PoolExtendReq) GetSys() string

func (*PoolExtendReq) GetTierBytes 

func (x *PoolExtendReq) GetTierBytes() []uint64

func (*PoolExtendReq) ProtoMessage 

func (*PoolExtendReq) ProtoMessage()

func (*PoolExtendReq) ProtoReflect 

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

func (*PoolExtendReq) Reset 

func (x *PoolExtendReq) Reset()

func (*PoolExtendReq) SetSvcRanks 

func (r *PoolExtendReq) SetSvcRanks(rl []uint32)

SetSvcRanks sets the request's Pool Service Ranks.

func (*PoolExtendReq) SetUUID 

func (r *PoolExtendReq) SetUUID(id uuid.UUID)

SetUUID sets the request's ID to a UUID.

func (*PoolExtendReq) String 

func (x *PoolExtendReq) String() string

type PoolExtendResp 

type PoolExtendResp struct {
	Status    int32    `protobuf:"varint,1,opt,name=status,proto3" json:"status,omitempty"`                               // DAOS error code
	TierBytes []uint64 `protobuf:"varint,2,rep,packed,name=tier_bytes,json=tierBytes,proto3" json:"tier_bytes,omitempty"` // storage tiers allocated to pool
	// contains filtered or unexported fields
}

PoolExtendResp returns resultant state of Extend operation.

func (*PoolExtendResp) Descriptor deprecated 

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

Deprecated: Use PoolExtendResp.ProtoReflect.Descriptor instead.

func (*PoolExtendResp) GetStatus 

func (x *PoolExtendResp) GetStatus() int32

func (*PoolExtendResp) GetTierBytes 

func (x *PoolExtendResp) GetTierBytes() []uint64

func (*PoolExtendResp) ProtoMessage 

func (*PoolExtendResp) ProtoMessage()

func (*PoolExtendResp) ProtoReflect 

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

func (*PoolExtendResp) Reset 

func (x *PoolExtendResp) Reset()

func (*PoolExtendResp) String 

func (x *PoolExtendResp) String() string

type PoolGetPropReq 

type PoolGetPropReq struct {
	Sys        string          `protobuf:"bytes,1,opt,name=sys,proto3" json:"sys,omitempty"` // DAOS system identifier
	Id         string          `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`   // uuid or label of pool to query
	Properties []*PoolProperty `protobuf:"bytes,3,rep,name=properties,proto3" json:"properties,omitempty"`
	SvcRanks   []uint32        `protobuf:"varint,4,rep,packed,name=svc_ranks,json=svcRanks,proto3" json:"svc_ranks,omitempty"` // List of pool service ranks
	// contains filtered or unexported fields
}

PoolGetPropReq represents a request to get pool properties.

func (*PoolGetPropReq) Descriptor deprecated 

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

Deprecated: Use PoolGetPropReq.ProtoReflect.Descriptor instead.

func (*PoolGetPropReq) GetId 

func (x *PoolGetPropReq) GetId() string

func (*PoolGetPropReq) GetProperties 

func (x *PoolGetPropReq) GetProperties() []*PoolProperty

func (*PoolGetPropReq) GetSvcRanks 

func (x *PoolGetPropReq) GetSvcRanks() []uint32

func (*PoolGetPropReq) GetSys 

func (x *PoolGetPropReq) GetSys() string

func (*PoolGetPropReq) ProtoMessage 

func (*PoolGetPropReq) ProtoMessage()

func (*PoolGetPropReq) ProtoReflect 

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

func (*PoolGetPropReq) Reset 

func (x *PoolGetPropReq) Reset()

func (*PoolGetPropReq) SetSvcRanks 

func (r *PoolGetPropReq) SetSvcRanks(rl []uint32)

SetSvcRanks sets the request's Pool Service Ranks.

func (*PoolGetPropReq) SetUUID 

func (r *PoolGetPropReq) SetUUID(id uuid.UUID)

SetUUID sets the request's ID to a UUID.

func (*PoolGetPropReq) String 

func (x *PoolGetPropReq) String() string

type PoolGetPropResp 

type PoolGetPropResp struct {
	Status     int32           `protobuf:"varint,1,opt,name=status,proto3" json:"status,omitempty"` // DAOS error code
	Properties []*PoolProperty `protobuf:"bytes,2,rep,name=properties,proto3" json:"properties,omitempty"`
	// contains filtered or unexported fields
}

PoolGetPropResp represents the result of getting pool properties.

func (*PoolGetPropResp) Descriptor deprecated 

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

Deprecated: Use PoolGetPropResp.ProtoReflect.Descriptor instead.

func (*PoolGetPropResp) GetProperties 

func (x *PoolGetPropResp) GetProperties() []*PoolProperty

func (*PoolGetPropResp) GetStatus 

func (x *PoolGetPropResp) GetStatus() int32

func (*PoolGetPropResp) ProtoMessage 

func (*PoolGetPropResp) ProtoMessage()

func (*PoolGetPropResp) ProtoReflect 

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

func (*PoolGetPropResp) Reset 

func (x *PoolGetPropResp) Reset()

func (*PoolGetPropResp) String 

func (x *PoolGetPropResp) String() string

type PoolMonitorReq 

type PoolMonitorReq struct {
	Sys            string `protobuf:"bytes,1,opt,name=sys,proto3" json:"sys,omitempty"`                       // DAOS system identifier
	PoolUUID       string `protobuf:"bytes,2,opt,name=poolUUID,proto3" json:"poolUUID,omitempty"`             // Pool UUID associated with the Pool Handle
	PoolHandleUUID string `protobuf:"bytes,3,opt,name=poolHandleUUID,proto3" json:"poolHandleUUID,omitempty"` // Pool Handle UUID for the connection
	Jobid          string `protobuf:"bytes,4,opt,name=jobid,proto3" json:"jobid,omitempty"`                   // Job ID to associate instance with.
	// contains filtered or unexported fields
}

func (*PoolMonitorReq) Descriptor deprecated 

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

Deprecated: Use PoolMonitorReq.ProtoReflect.Descriptor instead.

func (*PoolMonitorReq) GetJobid 

func (x *PoolMonitorReq) GetJobid() string

func (*PoolMonitorReq) GetPoolHandleUUID 

func (x *PoolMonitorReq) GetPoolHandleUUID() string

func (*PoolMonitorReq) GetPoolUUID 

func (x *PoolMonitorReq) GetPoolUUID() string

func (*PoolMonitorReq) GetSys 

func (x *PoolMonitorReq) GetSys() string

func (*PoolMonitorReq) ProtoMessage 

func (*PoolMonitorReq) ProtoMessage()

func (*PoolMonitorReq) ProtoReflect 

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

func (*PoolMonitorReq) Reset 

func (x *PoolMonitorReq) Reset()

func (*PoolMonitorReq) String 

func (x *PoolMonitorReq) String() string

type PoolProperty 

type PoolProperty struct {
	Number uint32 `protobuf:"varint,1,opt,name=number,proto3" json:"number,omitempty"` // pool property number
	// Types that are assignable to Value:
	//
	//	*PoolProperty_Strval
	//	*PoolProperty_Numval
	Value isPoolProperty_Value `protobuf_oneof:"value"`
	// contains filtered or unexported fields
}

func (*PoolProperty) Descriptor deprecated 

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

Deprecated: Use PoolProperty.ProtoReflect.Descriptor instead.

func (*PoolProperty) GetNumber 

func (x *PoolProperty) GetNumber() uint32

func (*PoolProperty) GetNumval 

func (x *PoolProperty) GetNumval() uint64

func (*PoolProperty) GetStrval 

func (x *PoolProperty) GetStrval() string

func (*PoolProperty) GetValue 

func (m *PoolProperty) GetValue() isPoolProperty_Value

func (*PoolProperty) ProtoMessage 

func (*PoolProperty) ProtoMessage()

func (*PoolProperty) ProtoReflect 

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

func (*PoolProperty) Reset 

func (x *PoolProperty) Reset()

func (*PoolProperty) SetValueNumber 

func (p *PoolProperty) SetValueNumber(numVal uint64)

SetValueNumber sets the Value field to a uint64.

func (*PoolProperty) SetValueString 

func (p *PoolProperty) SetValueString(strVal string)

SetValueString sets the Value field to a string.

func (*PoolProperty) String 

func (x *PoolProperty) String() string

func (*PoolProperty) UnmarshalJSON 

func (p *PoolProperty) UnmarshalJSON(b []byte) error

type PoolProperty_Numval 

type PoolProperty_Numval struct {
	Numval uint64 `protobuf:"varint,3,opt,name=numval,proto3,oneof"` // pool property numeric value
}

type PoolProperty_Strval 

type PoolProperty_Strval struct {
	Strval string `protobuf:"bytes,2,opt,name=strval,proto3,oneof"` // pool property string value
}

type PoolQueryReq 

type PoolQueryReq struct {
	Sys       string   `protobuf:"bytes,1,opt,name=sys,proto3" json:"sys,omitempty"` // DAOS system identifier
	Id        string   `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	SvcRanks  []uint32 `protobuf:"varint,3,rep,packed,name=svc_ranks,json=svcRanks,proto3" json:"svc_ranks,omitempty"` // List of pool service ranks
	QueryMask uint64   `protobuf:"varint,4,opt,name=query_mask,json=queryMask,proto3" json:"query_mask,omitempty"`     // Bitmask of pool query options
	// contains filtered or unexported fields
}

PoolQueryReq represents a pool query request.

func (*PoolQueryReq) Descriptor deprecated 

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

Deprecated: Use PoolQueryReq.ProtoReflect.Descriptor instead.

func (*PoolQueryReq) GetId 

func (x *PoolQueryReq) GetId() string

func (*PoolQueryReq) GetQueryMask 

func (x *PoolQueryReq) GetQueryMask() uint64

func (*PoolQueryReq) GetSvcRanks 

func (x *PoolQueryReq) GetSvcRanks() []uint32

func (*PoolQueryReq) GetSys 

func (x *PoolQueryReq) GetSys() string

func (*PoolQueryReq) ProtoMessage 

func (*PoolQueryReq) ProtoMessage()

func (*PoolQueryReq) ProtoReflect 

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

func (*PoolQueryReq) Reset 

func (x *PoolQueryReq) Reset()

func (*PoolQueryReq) SetSvcRanks 

func (r *PoolQueryReq) SetSvcRanks(rl []uint32)

SetSvcRanks sets the request's Pool Service Ranks.

func (*PoolQueryReq) SetUUID 

func (r *PoolQueryReq) SetUUID(id uuid.UUID)

SetUUID sets the request's ID to a UUID.

func (*PoolQueryReq) String 

func (x *PoolQueryReq) String() string

type PoolQueryResp 

type PoolQueryResp struct {
	Status           int32                `protobuf:"varint,1,opt,name=status,proto3" json:"status,omitempty"`                                                // DAOS error code
	Uuid             string               `protobuf:"bytes,2,opt,name=uuid,proto3" json:"uuid,omitempty"`                                                     // pool uuid
	Label            string               `protobuf:"bytes,3,opt,name=label,proto3" json:"label,omitempty"`                                                   // pool label
	TotalTargets     uint32               `protobuf:"varint,4,opt,name=total_targets,json=totalTargets,proto3" json:"total_targets,omitempty"`                // total targets in pool
	ActiveTargets    uint32               `protobuf:"varint,5,opt,name=active_targets,json=activeTargets,proto3" json:"active_targets,omitempty"`             // active targets in pool
	DisabledTargets  uint32               `protobuf:"varint,6,opt,name=disabled_targets,json=disabledTargets,proto3" json:"disabled_targets,omitempty"`       // number of disabled targets in pool
	Rebuild          *PoolRebuildStatus   `protobuf:"bytes,7,opt,name=rebuild,proto3" json:"rebuild,omitempty"`                                               // pool rebuild status
	TierStats        []*StorageUsageStats `protobuf:"bytes,8,rep,name=tier_stats,json=tierStats,proto3" json:"tier_stats,omitempty"`                          // storage tiers usage stats
	Version          uint32               `protobuf:"varint,10,opt,name=version,proto3" json:"version,omitempty"`                                             // latest pool map version
	Leader           uint32               `protobuf:"varint,11,opt,name=leader,proto3" json:"leader,omitempty"`                                               // current raft leader (2.4)
	EnabledRanks     string               `protobuf:"bytes,12,opt,name=enabled_ranks,json=enabledRanks,proto3" json:"enabled_ranks,omitempty"`                // optional set of ranks enabled
	DisabledRanks    string               `protobuf:"bytes,13,opt,name=disabled_ranks,json=disabledRanks,proto3" json:"disabled_ranks,omitempty"`             // optional set of ranks disabled
	TotalEngines     uint32               `protobuf:"varint,14,opt,name=total_engines,json=totalEngines,proto3" json:"total_engines,omitempty"`               // total engines in pool
	PoolLayoutVer    uint32               `protobuf:"varint,15,opt,name=pool_layout_ver,json=poolLayoutVer,proto3" json:"pool_layout_ver,omitempty"`          // current pool global version
	UpgradeLayoutVer uint32               `protobuf:"varint,16,opt,name=upgrade_layout_ver,json=upgradeLayoutVer,proto3" json:"upgrade_layout_ver,omitempty"` // latest pool global version to upgrade
	State            PoolServiceState     `protobuf:"varint,17,opt,name=state,proto3,enum=mgmt.PoolServiceState" json:"state,omitempty"`                      // pool state
	SvcLdr           uint32               `protobuf:"varint,18,opt,name=svc_ldr,json=svcLdr,proto3" json:"svc_ldr,omitempty"`                                 // current raft leader (2.6+)
	SvcReps          []uint32             `protobuf:"varint,19,rep,packed,name=svc_reps,json=svcReps,proto3" json:"svc_reps,omitempty"`                       // service replica ranks
	QueryMask        uint64               `protobuf:"varint,20,opt,name=query_mask,json=queryMask,proto3" json:"query_mask,omitempty"`                        // Bitmask of pool query options used
	MemFileBytes     uint64               `protobuf:"varint,21,opt,name=mem_file_bytes,json=memFileBytes,proto3" json:"mem_file_bytes,omitempty"`             // per-pool accumulated value of memory file sizes
	DeadRanks        string               `protobuf:"bytes,22,opt,name=dead_ranks,json=deadRanks,proto3" json:"dead_ranks,omitempty"`                         // optional set of dead ranks
	// contains filtered or unexported fields
}

PoolQueryResp represents a pool query response.

func (*PoolQueryResp) Descriptor deprecated 

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

Deprecated: Use PoolQueryResp.ProtoReflect.Descriptor instead.

func (*PoolQueryResp) GetActiveTargets 

func (x *PoolQueryResp) GetActiveTargets() uint32

func (*PoolQueryResp) GetDeadRanks 

func (x *PoolQueryResp) GetDeadRanks() string

func (*PoolQueryResp) GetDisabledRanks 

func (x *PoolQueryResp) GetDisabledRanks() string

func (*PoolQueryResp) GetDisabledTargets 

func (x *PoolQueryResp) GetDisabledTargets() uint32

func (*PoolQueryResp) GetEnabledRanks 

func (x *PoolQueryResp) GetEnabledRanks() string

func (*PoolQueryResp) GetLabel 

func (x *PoolQueryResp) GetLabel() string

func (*PoolQueryResp) GetLeader 

func (x *PoolQueryResp) GetLeader() uint32

func (*PoolQueryResp) GetMemFileBytes 

func (x *PoolQueryResp) GetMemFileBytes() uint64

func (*PoolQueryResp) GetPoolLayoutVer 

func (x *PoolQueryResp) GetPoolLayoutVer() uint32

func (*PoolQueryResp) GetQueryMask 

func (x *PoolQueryResp) GetQueryMask() uint64

func (*PoolQueryResp) GetRebuild 

func (x *PoolQueryResp) GetRebuild() *PoolRebuildStatus

func (*PoolQueryResp) GetState 

func (x *PoolQueryResp) GetState() PoolServiceState

func (*PoolQueryResp) GetStatus 

func (x *PoolQueryResp) GetStatus() int32

func (*PoolQueryResp) GetSvcLdr 

func (x *PoolQueryResp) GetSvcLdr() uint32

func (*PoolQueryResp) GetSvcReps 

func (x *PoolQueryResp) GetSvcReps() []uint32

func (*PoolQueryResp) GetTierStats 

func (x *PoolQueryResp) GetTierStats() []*StorageUsageStats

func (*PoolQueryResp) GetTotalEngines 

func (x *PoolQueryResp) GetTotalEngines() uint32

func (*PoolQueryResp) GetTotalTargets 

func (x *PoolQueryResp) GetTotalTargets() uint32

func (*PoolQueryResp) GetUpgradeLayoutVer 

func (x *PoolQueryResp) GetUpgradeLayoutVer() uint32

func (*PoolQueryResp) GetUuid 

func (x *PoolQueryResp) GetUuid() string

func (*PoolQueryResp) GetVersion 

func (x *PoolQueryResp) GetVersion() uint32

func (*PoolQueryResp) ProtoMessage 

func (*PoolQueryResp) ProtoMessage()

func (*PoolQueryResp) ProtoReflect 

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

func (*PoolQueryResp) Reset 

func (x *PoolQueryResp) Reset()

func (*PoolQueryResp) String 

func (x *PoolQueryResp) String() string

type PoolQueryTargetInfo 

type PoolQueryTargetInfo struct {
	Type  PoolQueryTargetInfo_TargetType  `protobuf:"varint,1,opt,name=type,proto3,enum=mgmt.PoolQueryTargetInfo_TargetType" json:"type,omitempty"`    // Target type jsee enum daos_target_type_t
	State PoolQueryTargetInfo_TargetState `protobuf:"varint,2,opt,name=state,proto3,enum=mgmt.PoolQueryTargetInfo_TargetState" json:"state,omitempty"` // target state see enum daos_target_state_t
	// TODO: target performance data
	Space        []*StorageTargetUsage `protobuf:"bytes,3,rep,name=space,proto3" json:"space,omitempty"`                                      // this target's usage per storage tier
	MemFileBytes uint64                `protobuf:"varint,4,opt,name=mem_file_bytes,json=memFileBytes,proto3" json:"mem_file_bytes,omitempty"` // per-target value of memory file size
	// contains filtered or unexported fields
}

PoolQueryTargetInfo represents pool target query info for a single target. The RPC response type (PoolQueryTargetResponse) contains a sequence of these.

func (*PoolQueryTargetInfo) Descriptor deprecated 

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

Deprecated: Use PoolQueryTargetInfo.ProtoReflect.Descriptor instead.

func (*PoolQueryTargetInfo) GetMemFileBytes 

func (x *PoolQueryTargetInfo) GetMemFileBytes() uint64

func (*PoolQueryTargetInfo) GetSpace 

func (x *PoolQueryTargetInfo) GetSpace() []*StorageTargetUsage

func (*PoolQueryTargetInfo) GetState 

func (x *PoolQueryTargetInfo) GetState() PoolQueryTargetInfo_TargetState

func (*PoolQueryTargetInfo) GetType 

func (x *PoolQueryTargetInfo) GetType() PoolQueryTargetInfo_TargetType

func (*PoolQueryTargetInfo) ProtoMessage 

func (*PoolQueryTargetInfo) ProtoMessage()

func (*PoolQueryTargetInfo) ProtoReflect 

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

func (*PoolQueryTargetInfo) Reset 

func (x *PoolQueryTargetInfo) Reset()

func (*PoolQueryTargetInfo) String 

func (x *PoolQueryTargetInfo) String() string

type PoolQueryTargetInfo_TargetState 

type PoolQueryTargetInfo_TargetState int32
const (
	PoolQueryTargetInfo_STATE_UNKNOWN PoolQueryTargetInfo_TargetState = 0
	PoolQueryTargetInfo_DOWN_OUT      PoolQueryTargetInfo_TargetState = 1 // Not available
	PoolQueryTargetInfo_DOWN          PoolQueryTargetInfo_TargetState = 2 // Not available, may need rebuild
	PoolQueryTargetInfo_UP            PoolQueryTargetInfo_TargetState = 3 // Up
	PoolQueryTargetInfo_UP_IN         PoolQueryTargetInfo_TargetState = 4 // Up and running
	PoolQueryTargetInfo_NEW           PoolQueryTargetInfo_TargetState = 5 // Intermediate state for pool map change
	PoolQueryTargetInfo_DRAIN         PoolQueryTargetInfo_TargetState = 6 // Being drained
)

func (PoolQueryTargetInfo_TargetState) Descriptor 

func (PoolQueryTargetInfo_TargetState) Descriptor() protoreflect.EnumDescriptor

func (PoolQueryTargetInfo_TargetState) Enum 

func (x PoolQueryTargetInfo_TargetState) Enum() *PoolQueryTargetInfo_TargetState

func (PoolQueryTargetInfo_TargetState) EnumDescriptor deprecated 

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

Deprecated: Use PoolQueryTargetInfo_TargetState.Descriptor instead.

func (PoolQueryTargetInfo_TargetState) Number 

func (x PoolQueryTargetInfo_TargetState) Number() protoreflect.EnumNumber

func (PoolQueryTargetInfo_TargetState) String 

func (x PoolQueryTargetInfo_TargetState) String() string

func (PoolQueryTargetInfo_TargetState) Type 

func (PoolQueryTargetInfo_TargetState) Type() protoreflect.EnumType

type PoolQueryTargetInfo_TargetType 

type PoolQueryTargetInfo_TargetType int32
const (
	PoolQueryTargetInfo_UNKNOWN PoolQueryTargetInfo_TargetType = 0
	PoolQueryTargetInfo_HDD     PoolQueryTargetInfo_TargetType = 1 // Rotating disk
	PoolQueryTargetInfo_SSD     PoolQueryTargetInfo_TargetType = 2 // Flash-based
	PoolQueryTargetInfo_PM      PoolQueryTargetInfo_TargetType = 3 // Persistent memory
	PoolQueryTargetInfo_VM      PoolQueryTargetInfo_TargetType = 4 // Volatile memory
)

func (PoolQueryTargetInfo_TargetType) Descriptor 

func (PoolQueryTargetInfo_TargetType) Descriptor() protoreflect.EnumDescriptor

func (PoolQueryTargetInfo_TargetType) Enum 

func (x PoolQueryTargetInfo_TargetType) Enum() *PoolQueryTargetInfo_TargetType

func (PoolQueryTargetInfo_TargetType) EnumDescriptor deprecated 

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

Deprecated: Use PoolQueryTargetInfo_TargetType.Descriptor instead.

func (PoolQueryTargetInfo_TargetType) Number 

func (x PoolQueryTargetInfo_TargetType) Number() protoreflect.EnumNumber

func (PoolQueryTargetInfo_TargetType) String 

func (x PoolQueryTargetInfo_TargetType) String() string

func (PoolQueryTargetInfo_TargetType) Type 

func (PoolQueryTargetInfo_TargetType) Type() protoreflect.EnumType

type PoolQueryTargetReq 

type PoolQueryTargetReq struct {
	Sys      string   `protobuf:"bytes,1,opt,name=sys,proto3" json:"sys,omitempty"`                                   // DAOS system identifier
	Id       string   `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`                                     // Pool label or UUID
	Rank     uint32   `protobuf:"varint,3,opt,name=rank,proto3" json:"rank,omitempty"`                                // Engine rank with targets to query
	Targets  []uint32 `protobuf:"varint,4,rep,packed,name=targets,proto3" json:"targets,omitempty"`                   // indices of targets to be queried
	SvcRanks []uint32 `protobuf:"varint,5,rep,packed,name=svc_ranks,json=svcRanks,proto3" json:"svc_ranks,omitempty"` // List of pool service ranks
	// contains filtered or unexported fields
}

PoolQueryTargetReq represents a pool query target(s) request.

func (*PoolQueryTargetReq) Descriptor deprecated 

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

Deprecated: Use PoolQueryTargetReq.ProtoReflect.Descriptor instead.

func (*PoolQueryTargetReq) GetId 

func (x *PoolQueryTargetReq) GetId() string

func (*PoolQueryTargetReq) GetRank 

func (x *PoolQueryTargetReq) GetRank() uint32

func (*PoolQueryTargetReq) GetSvcRanks 

func (x *PoolQueryTargetReq) GetSvcRanks() []uint32

func (*PoolQueryTargetReq) GetSys 

func (x *PoolQueryTargetReq) GetSys() string

func (*PoolQueryTargetReq) GetTargets 

func (x *PoolQueryTargetReq) GetTargets() []uint32

func (*PoolQueryTargetReq) ProtoMessage 

func (*PoolQueryTargetReq) ProtoMessage()

func (*PoolQueryTargetReq) ProtoReflect 

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

func (*PoolQueryTargetReq) Reset 

func (x *PoolQueryTargetReq) Reset()

func (*PoolQueryTargetReq) SetSvcRanks 

func (r *PoolQueryTargetReq) SetSvcRanks(rl []uint32)

SetSvcRanks sets the request's Pool Service Ranks.

func (*PoolQueryTargetReq) SetUUID 

func (r *PoolQueryTargetReq) SetUUID(id uuid.UUID)

SetUUID sets the request's ID to a UUID.

func (*PoolQueryTargetReq) String 

func (x *PoolQueryTargetReq) String() string

type PoolQueryTargetResp 

type PoolQueryTargetResp struct {
	Status int32                  `protobuf:"varint,1,opt,name=status,proto3" json:"status,omitempty"` // DAOS error code
	Infos  []*PoolQueryTargetInfo `protobuf:"bytes,2,rep,name=infos,proto3" json:"infos,omitempty"`    // Per-target information
	// contains filtered or unexported fields
}

PoolQueryTargetResp represents a pool target query response

func (*PoolQueryTargetResp) Descriptor deprecated 

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

Deprecated: Use PoolQueryTargetResp.ProtoReflect.Descriptor instead.

func (*PoolQueryTargetResp) GetInfos 

func (x *PoolQueryTargetResp) GetInfos() []*PoolQueryTargetInfo

func (*PoolQueryTargetResp) GetStatus 

func (x *PoolQueryTargetResp) GetStatus() int32

func (*PoolQueryTargetResp) ProtoMessage 

func (*PoolQueryTargetResp) ProtoMessage()

func (*PoolQueryTargetResp) ProtoReflect 

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

func (*PoolQueryTargetResp) Reset 

func (x *PoolQueryTargetResp) Reset()

func (*PoolQueryTargetResp) String 

func (x *PoolQueryTargetResp) String() string

type PoolRebuildStatus 

type PoolRebuildStatus struct {
	Status  int32                   `protobuf:"varint,1,opt,name=status,proto3" json:"status,omitempty"` // DAOS error code
	State   PoolRebuildStatus_State `protobuf:"varint,2,opt,name=state,proto3,enum=mgmt.PoolRebuildStatus_State" json:"state,omitempty"`
	Objects uint64                  `protobuf:"varint,3,opt,name=objects,proto3" json:"objects,omitempty"`
	Records uint64                  `protobuf:"varint,4,opt,name=records,proto3" json:"records,omitempty"`
	// contains filtered or unexported fields
}

PoolRebuildStatus represents a pool's rebuild status.

func (*PoolRebuildStatus) Descriptor deprecated 

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

Deprecated: Use PoolRebuildStatus.ProtoReflect.Descriptor instead.

func (*PoolRebuildStatus) GetObjects 

func (x *PoolRebuildStatus) GetObjects() uint64

func (*PoolRebuildStatus) GetRecords 

func (x *PoolRebuildStatus) GetRecords() uint64

func (*PoolRebuildStatus) GetState 

func (x *PoolRebuildStatus) GetState() PoolRebuildStatus_State

func (*PoolRebuildStatus) GetStatus 

func (x *PoolRebuildStatus) GetStatus() int32

func (*PoolRebuildStatus) ProtoMessage 

func (*PoolRebuildStatus) ProtoMessage()

func (*PoolRebuildStatus) ProtoReflect 

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

func (*PoolRebuildStatus) Reset 

func (x *PoolRebuildStatus) Reset()

func (*PoolRebuildStatus) String 

func (x *PoolRebuildStatus) String() string

type PoolRebuildStatus_State 

type PoolRebuildStatus_State int32
const (
	PoolRebuildStatus_IDLE PoolRebuildStatus_State = 0
	PoolRebuildStatus_DONE PoolRebuildStatus_State = 1
	PoolRebuildStatus_BUSY PoolRebuildStatus_State = 2
)

func (PoolRebuildStatus_State) Descriptor 

func (PoolRebuildStatus_State) Descriptor() protoreflect.EnumDescriptor

func (PoolRebuildStatus_State) Enum 

func (x PoolRebuildStatus_State) Enum() *PoolRebuildStatus_State

func (PoolRebuildStatus_State) EnumDescriptor deprecated 

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

Deprecated: Use PoolRebuildStatus_State.Descriptor instead.

func (PoolRebuildStatus_State) Number 

func (x PoolRebuildStatus_State) Number() protoreflect.EnumNumber

func (PoolRebuildStatus_State) String 

func (x PoolRebuildStatus_State) String() string

func (PoolRebuildStatus_State) Type 

func (PoolRebuildStatus_State) Type() protoreflect.EnumType

type PoolReintegrateReq 

type PoolReintegrateReq struct {
	Sys       string   `protobuf:"bytes,1,opt,name=sys,proto3" json:"sys,omitempty"`                                      // DAOS system identifier
	Id        string   `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`                                        // uuid or label of pool to add target up to
	Rank      uint32   `protobuf:"varint,3,opt,name=rank,proto3" json:"rank,omitempty"`                                   // target to move to the up state
	TargetIdx []uint32 `protobuf:"varint,4,rep,packed,name=target_idx,json=targetIdx,proto3" json:"target_idx,omitempty"` // target ranks
	SvcRanks  []uint32 `protobuf:"varint,5,rep,packed,name=svc_ranks,json=svcRanks,proto3" json:"svc_ranks,omitempty"`    // List of pool service ranks
	TierBytes []uint64 `protobuf:"varint,6,rep,packed,name=tier_bytes,json=tierBytes,proto3" json:"tier_bytes,omitempty"` // Size in bytes of storage tiers
	MemRatio  float32  `protobuf:"fixed32,7,opt,name=mem_ratio,json=memRatio,proto3" json:"mem_ratio,omitempty"`          // Fraction of meta-blob-sz to use as mem-file-sz
	// contains filtered or unexported fields
}

PoolReintegrateReq supplies pool identifier, rank, and target_idxs.

func (*PoolReintegrateReq) Descriptor deprecated 

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

Deprecated: Use PoolReintegrateReq.ProtoReflect.Descriptor instead.

func (*PoolReintegrateReq) GetId 

func (x *PoolReintegrateReq) GetId() string

func (*PoolReintegrateReq) GetMemRatio 

func (x *PoolReintegrateReq) GetMemRatio() float32

func (*PoolReintegrateReq) GetRank 

func (x *PoolReintegrateReq) GetRank() uint32

func (*PoolReintegrateReq) GetSvcRanks 

func (x *PoolReintegrateReq) GetSvcRanks() []uint32

func (*PoolReintegrateReq) GetSys 

func (x *PoolReintegrateReq) GetSys() string

func (*PoolReintegrateReq) GetTargetIdx 

func (x *PoolReintegrateReq) GetTargetIdx() []uint32

func (*PoolReintegrateReq) GetTierBytes 

func (x *PoolReintegrateReq) GetTierBytes() []uint64

func (*PoolReintegrateReq) ProtoMessage 

func (*PoolReintegrateReq) ProtoMessage()

func (*PoolReintegrateReq) ProtoReflect 

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

func (*PoolReintegrateReq) Reset 

func (x *PoolReintegrateReq) Reset()

func (*PoolReintegrateReq) SetSvcRanks 

func (r *PoolReintegrateReq) SetSvcRanks(rl []uint32)

SetSvcRanks sets the request's Pool Service Ranks.

func (*PoolReintegrateReq) SetUUID 

func (r *PoolReintegrateReq) SetUUID(id uuid.UUID)

SetUUID sets the request's ID to a UUID.

func (*PoolReintegrateReq) String 

func (x *PoolReintegrateReq) String() string

type PoolReintegrateResp 

type PoolReintegrateResp struct {
	Status int32 `protobuf:"varint,1,opt,name=status,proto3" json:"status,omitempty"` // DAOS error code
	// contains filtered or unexported fields
}

PoolReintegrateResp returns resultant state of Reintegrate operation.

func (*PoolReintegrateResp) Descriptor deprecated 

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

Deprecated: Use PoolReintegrateResp.ProtoReflect.Descriptor instead.

func (*PoolReintegrateResp) GetStatus 

func (x *PoolReintegrateResp) GetStatus() int32

func (*PoolReintegrateResp) ProtoMessage 

func (*PoolReintegrateResp) ProtoMessage()

func (*PoolReintegrateResp) ProtoReflect 

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

func (*PoolReintegrateResp) Reset 

func (x *PoolReintegrateResp) Reset()

func (*PoolReintegrateResp) String 

func (x *PoolReintegrateResp) String() string

type PoolServiceState 

type PoolServiceState int32
const (
	PoolServiceState_Creating   PoolServiceState = 0 // pool service is being created
	PoolServiceState_Ready      PoolServiceState = 1 // pool service is ready to be used
	PoolServiceState_Destroying PoolServiceState = 2 // pool service is being destroyed
	PoolServiceState_Degraded   PoolServiceState = 3 // pool service is degraded
	PoolServiceState_Unknown    PoolServiceState = 4 // pool service is Unknown state
)

func (PoolServiceState) Descriptor 

func (PoolServiceState) Descriptor() protoreflect.EnumDescriptor

func (PoolServiceState) Enum 

func (x PoolServiceState) Enum() *PoolServiceState

func (PoolServiceState) EnumDescriptor deprecated 

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

Deprecated: Use PoolServiceState.Descriptor instead.

func (PoolServiceState) Number 

func (x PoolServiceState) Number() protoreflect.EnumNumber

func (PoolServiceState) String 

func (x PoolServiceState) String() string

func (PoolServiceState) Type 

func (PoolServiceState) Type() protoreflect.EnumType

type PoolSetPropReq 

type PoolSetPropReq struct {
	Sys        string          `protobuf:"bytes,1,opt,name=sys,proto3" json:"sys,omitempty"` // DAOS system identifier
	Id         string          `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`   // uuid or label of pool to modify
	Properties []*PoolProperty `protobuf:"bytes,3,rep,name=properties,proto3" json:"properties,omitempty"`
	SvcRanks   []uint32        `protobuf:"varint,4,rep,packed,name=svc_ranks,json=svcRanks,proto3" json:"svc_ranks,omitempty"` // List of pool service ranks
	// contains filtered or unexported fields
}

PoolSetPropReq represents a request to set pool properties.

func (*PoolSetPropReq) Descriptor deprecated 

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

Deprecated: Use PoolSetPropReq.ProtoReflect.Descriptor instead.

func (*PoolSetPropReq) GetId 

func (x *PoolSetPropReq) GetId() string

func (*PoolSetPropReq) GetProperties 

func (x *PoolSetPropReq) GetProperties() []*PoolProperty

func (*PoolSetPropReq) GetSvcRanks 

func (x *PoolSetPropReq) GetSvcRanks() []uint32

func (*PoolSetPropReq) GetSys 

func (x *PoolSetPropReq) GetSys() string

func (*PoolSetPropReq) ProtoMessage 

func (*PoolSetPropReq) ProtoMessage()

func (*PoolSetPropReq) ProtoReflect 

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

func (*PoolSetPropReq) Reset 

func (x *PoolSetPropReq) Reset()

func (*PoolSetPropReq) SetSvcRanks 

func (r *PoolSetPropReq) SetSvcRanks(rl []uint32)

SetSvcRanks sets the request's Pool Service Ranks.

func (*PoolSetPropReq) SetUUID 

func (r *PoolSetPropReq) SetUUID(id uuid.UUID)

SetUUID sets the request's ID to a UUID.

func (*PoolSetPropReq) String 

func (x *PoolSetPropReq) String() string

type PoolSetPropResp 

type PoolSetPropResp struct {
	Status int32 `protobuf:"varint,1,opt,name=status,proto3" json:"status,omitempty"` // DAOS error code
	// contains filtered or unexported fields
}

PoolSetPropResp represents the result of setting pool properties.

func (*PoolSetPropResp) Descriptor deprecated 

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

Deprecated: Use PoolSetPropResp.ProtoReflect.Descriptor instead.

func (*PoolSetPropResp) GetStatus 

func (x *PoolSetPropResp) GetStatus() int32

func (*PoolSetPropResp) ProtoMessage 

func (*PoolSetPropResp) ProtoMessage()

func (*PoolSetPropResp) ProtoReflect 

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

func (*PoolSetPropResp) Reset 

func (x *PoolSetPropResp) Reset()

func (*PoolSetPropResp) String 

func (x *PoolSetPropResp) String() string

type PoolUpgradeReq 

type PoolUpgradeReq struct {
	Sys      string   `protobuf:"bytes,1,opt,name=sys,proto3" json:"sys,omitempty"` // DAOS system identifier
	Id       string   `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	SvcRanks []uint32 `protobuf:"varint,3,rep,packed,name=svc_ranks,json=svcRanks,proto3" json:"svc_ranks,omitempty"` // List of pool service ranks
	// contains filtered or unexported fields
}

PoolUpgradeReq upgrades the disk format of an existing pool to the latest version.

func (*PoolUpgradeReq) Descriptor deprecated 

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

Deprecated: Use PoolUpgradeReq.ProtoReflect.Descriptor instead.

func (*PoolUpgradeReq) GetId 

func (x *PoolUpgradeReq) GetId() string

func (*PoolUpgradeReq) GetSvcRanks 

func (x *PoolUpgradeReq) GetSvcRanks() []uint32

func (*PoolUpgradeReq) GetSys 

func (x *PoolUpgradeReq) GetSys() string

func (*PoolUpgradeReq) ProtoMessage 

func (*PoolUpgradeReq) ProtoMessage()

func (*PoolUpgradeReq) ProtoReflect 

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

func (*PoolUpgradeReq) Reset 

func (x *PoolUpgradeReq) Reset()

func (*PoolUpgradeReq) SetSvcRanks 

func (r *PoolUpgradeReq) SetSvcRanks(rl []uint32)

SetSvcRanks sets the request's Pool Service Ranks.

func (*PoolUpgradeReq) SetUUID 

func (r *PoolUpgradeReq) SetUUID(id uuid.UUID)

SetUUID sets the request's ID to a UUID.

func (*PoolUpgradeReq) String 

func (x *PoolUpgradeReq) String() string

type PoolUpgradeResp 

type PoolUpgradeResp struct {
	Status int32 `protobuf:"varint,1,opt,name=status,proto3" json:"status,omitempty"` // DAOS error code
	// contains filtered or unexported fields
}

PoolUpgradeResp returns resultant state of upgrade operation.

func (*PoolUpgradeResp) Descriptor deprecated 

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

Deprecated: Use PoolUpgradeResp.ProtoReflect.Descriptor instead.

func (*PoolUpgradeResp) GetStatus 

func (x *PoolUpgradeResp) GetStatus() int32

func (*PoolUpgradeResp) ProtoMessage 

func (*PoolUpgradeResp) ProtoMessage()

func (*PoolUpgradeResp) ProtoReflect 

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

func (*PoolUpgradeResp) Reset 

func (x *PoolUpgradeResp) Reset()

func (*PoolUpgradeResp) String 

func (x *PoolUpgradeResp) String() string

type PrepShutdownReq 

type PrepShutdownReq struct {
	Rank uint32 `protobuf:"varint,1,opt,name=rank,proto3" json:"rank,omitempty"` // DAOS I/O Engine unique identifier.
	// contains filtered or unexported fields
}

func (*PrepShutdownReq) Descriptor deprecated 

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

Deprecated: Use PrepShutdownReq.ProtoReflect.Descriptor instead.

func (*PrepShutdownReq) GetRank 

func (x *PrepShutdownReq) GetRank() uint32

func (*PrepShutdownReq) ProtoMessage 

func (*PrepShutdownReq) ProtoMessage()

func (*PrepShutdownReq) ProtoReflect 

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

func (*PrepShutdownReq) Reset 

func (x *PrepShutdownReq) Reset()

func (*PrepShutdownReq) String 

func (x *PrepShutdownReq) String() string

type SetRankReq 

type SetRankReq struct {
	Rank       uint32 `protobuf:"varint,1,opt,name=rank,proto3" json:"rank,omitempty"`                               // DAOS I/O Engine unique identifier.
	MapVersion uint32 `protobuf:"varint,2,opt,name=map_version,json=mapVersion,proto3" json:"map_version,omitempty"` // System map version in which the rank joined the system.
	// contains filtered or unexported fields
}

func (*SetRankReq) Descriptor deprecated 

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

Deprecated: Use SetRankReq.ProtoReflect.Descriptor instead.

func (*SetRankReq) GetMapVersion 

func (x *SetRankReq) GetMapVersion() uint32

func (*SetRankReq) GetRank 

func (x *SetRankReq) GetRank() uint32

func (*SetRankReq) ProtoMessage 

func (*SetRankReq) ProtoMessage()

func (*SetRankReq) ProtoReflect 

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

func (*SetRankReq) Reset 

func (x *SetRankReq) Reset()

func (*SetRankReq) String 

func (x *SetRankReq) String() string

type StorageMediaType 

type StorageMediaType int32
const (
	StorageMediaType_SCM  StorageMediaType = 0
	StorageMediaType_NVME StorageMediaType = 1
)

func (StorageMediaType) Descriptor 

func (StorageMediaType) Descriptor() protoreflect.EnumDescriptor

func (StorageMediaType) Enum 

func (x StorageMediaType) Enum() *StorageMediaType

func (StorageMediaType) EnumDescriptor deprecated 

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

Deprecated: Use StorageMediaType.Descriptor instead.

func (StorageMediaType) Number 

func (x StorageMediaType) Number() protoreflect.EnumNumber

func (StorageMediaType) String 

func (x StorageMediaType) String() string

func (StorageMediaType) Type 

func (StorageMediaType) Type() protoreflect.EnumType

type StorageTargetUsage 

type StorageTargetUsage struct {
	Total     uint64           `protobuf:"varint,1,opt,name=total,proto3" json:"total,omitempty"`                                                     // total space in bytes
	Free      uint64           `protobuf:"varint,2,opt,name=free,proto3" json:"free,omitempty"`                                                       // free space in bytes
	MediaType StorageMediaType `protobuf:"varint,3,opt,name=media_type,json=mediaType,proto3,enum=mgmt.StorageMediaType" json:"media_type,omitempty"` // see daos_media_type_t (e.g., SCM, NVME)
	// contains filtered or unexported fields
}

StorageTargetUsage represent's a target's capacity and usage

func (*StorageTargetUsage) Descriptor deprecated 

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

Deprecated: Use StorageTargetUsage.ProtoReflect.Descriptor instead.

func (*StorageTargetUsage) GetFree 

func (x *StorageTargetUsage) GetFree() uint64

func (*StorageTargetUsage) GetMediaType 

func (x *StorageTargetUsage) GetMediaType() StorageMediaType

func (*StorageTargetUsage) GetTotal 

func (x *StorageTargetUsage) GetTotal() uint64

func (*StorageTargetUsage) ProtoMessage 

func (*StorageTargetUsage) ProtoMessage()

func (*StorageTargetUsage) ProtoReflect 

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

func (*StorageTargetUsage) Reset 

func (x *StorageTargetUsage) Reset()

func (*StorageTargetUsage) String 

func (x *StorageTargetUsage) String() string

type StorageUsageStats 

type StorageUsageStats struct {
	Total     uint64           `protobuf:"varint,1,opt,name=total,proto3" json:"total,omitempty"`
	Free      uint64           `protobuf:"varint,2,opt,name=free,proto3" json:"free,omitempty"`
	Min       uint64           `protobuf:"varint,3,opt,name=min,proto3" json:"min,omitempty"`
	Max       uint64           `protobuf:"varint,4,opt,name=max,proto3" json:"max,omitempty"`
	Mean      uint64           `protobuf:"varint,5,opt,name=mean,proto3" json:"mean,omitempty"`
	MediaType StorageMediaType `protobuf:"varint,6,opt,name=media_type,json=mediaType,proto3,enum=mgmt.StorageMediaType" json:"media_type,omitempty"`
	// contains filtered or unexported fields
}

StorageUsageStats represents usage statistics for a storage subsystem.

func (*StorageUsageStats) Descriptor deprecated 

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

Deprecated: Use StorageUsageStats.ProtoReflect.Descriptor instead.

func (*StorageUsageStats) GetFree 

func (x *StorageUsageStats) GetFree() uint64

func (*StorageUsageStats) GetMax 

func (x *StorageUsageStats) GetMax() uint64

func (*StorageUsageStats) GetMean 

func (x *StorageUsageStats) GetMean() uint64

func (*StorageUsageStats) GetMediaType 

func (x *StorageUsageStats) GetMediaType() StorageMediaType

func (*StorageUsageStats) GetMin 

func (x *StorageUsageStats) GetMin() uint64

func (*StorageUsageStats) GetTotal 

func (x *StorageUsageStats) GetTotal() uint64

func (*StorageUsageStats) ProtoMessage 

func (*StorageUsageStats) ProtoMessage()

func (*StorageUsageStats) ProtoReflect 

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

func (*StorageUsageStats) Reset 

func (x *StorageUsageStats) Reset()

func (*StorageUsageStats) String 

func (x *StorageUsageStats) String() string

type SystemCleanupReq 

type SystemCleanupReq struct {
	Sys     string `protobuf:"bytes,1,opt,name=sys,proto3" json:"sys,omitempty"`         // DAOS system identifier
	Machine string `protobuf:"bytes,2,opt,name=machine,proto3" json:"machine,omitempty"` // Name of the machine to cleanup resources for.
	// contains filtered or unexported fields
}

SystemCleanupReq supplies the machinename.

func (*SystemCleanupReq) Descriptor deprecated 

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

Deprecated: Use SystemCleanupReq.ProtoReflect.Descriptor instead.

func (*SystemCleanupReq) GetMachine 

func (x *SystemCleanupReq) GetMachine() string

func (*SystemCleanupReq) GetSys 

func (x *SystemCleanupReq) GetSys() string

func (*SystemCleanupReq) ProtoMessage 

func (*SystemCleanupReq) ProtoMessage()

func (*SystemCleanupReq) ProtoReflect 

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

func (*SystemCleanupReq) Reset 

func (x *SystemCleanupReq) Reset()

func (*SystemCleanupReq) String 

func (x *SystemCleanupReq) String() string

type SystemCleanupResp 

type SystemCleanupResp struct {
	Results []*SystemCleanupResp_CleanupResult `protobuf:"bytes,1,rep,name=results,proto3" json:"results,omitempty"` // Results and Status for individual pools that are cleanedup.
	// contains filtered or unexported fields
}

SystemCleanupResp returns resultant state of cleanup operation.

func (*SystemCleanupResp) Descriptor deprecated 

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

Deprecated: Use SystemCleanupResp.ProtoReflect.Descriptor instead.

func (*SystemCleanupResp) GetResults 

func (x *SystemCleanupResp) GetResults() []*SystemCleanupResp_CleanupResult

func (*SystemCleanupResp) ProtoMessage 

func (*SystemCleanupResp) ProtoMessage()

func (*SystemCleanupResp) ProtoReflect 

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

func (*SystemCleanupResp) Reset 

func (x *SystemCleanupResp) Reset()

func (*SystemCleanupResp) String 

func (x *SystemCleanupResp) String() string

type SystemCleanupResp_CleanupResult 

type SystemCleanupResp_CleanupResult struct {
	Status int32  `protobuf:"varint,1,opt,name=status,proto3" json:"status,omitempty"`              // Status of the evict on the specific pool
	Msg    string `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`                     // Error message if status indicates an error
	PoolId string `protobuf:"bytes,3,opt,name=pool_id,json=poolId,proto3" json:"pool_id,omitempty"` // uuid of pool
	Count  uint32 `protobuf:"varint,4,opt,name=count,proto3" json:"count,omitempty"`                // number of pool handles cleaned up
	// contains filtered or unexported fields
}

func (*SystemCleanupResp_CleanupResult) Descriptor deprecated 

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

Deprecated: Use SystemCleanupResp_CleanupResult.ProtoReflect.Descriptor instead.

func (*SystemCleanupResp_CleanupResult) GetCount 

func (x *SystemCleanupResp_CleanupResult) GetCount() uint32

func (*SystemCleanupResp_CleanupResult) GetMsg 

func (x *SystemCleanupResp_CleanupResult) GetMsg() string

func (*SystemCleanupResp_CleanupResult) GetPoolId 

func (x *SystemCleanupResp_CleanupResult) GetPoolId() string

func (*SystemCleanupResp_CleanupResult) GetStatus 

func (x *SystemCleanupResp_CleanupResult) GetStatus() int32

func (*SystemCleanupResp_CleanupResult) ProtoMessage 

func (*SystemCleanupResp_CleanupResult) ProtoMessage()

func (*SystemCleanupResp_CleanupResult) ProtoReflect 

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

func (*SystemCleanupResp_CleanupResult) Reset 

func (x *SystemCleanupResp_CleanupResult) Reset()

func (*SystemCleanupResp_CleanupResult) String 

func (x *SystemCleanupResp_CleanupResult) String() string

type SystemDrainReq 

type SystemDrainReq struct {
	Sys   string `protobuf:"bytes,1,opt,name=sys,proto3" json:"sys,omitempty"`     // DAOS system name
	Ranks string `protobuf:"bytes,2,opt,name=ranks,proto3" json:"ranks,omitempty"` // rankset to drain on all pools
	Hosts string `protobuf:"bytes,3,opt,name=hosts,proto3" json:"hosts,omitempty"` // hostset to drain on all pools
	// contains filtered or unexported fields
}

SystemDrainReq supplies system-drain parameters.

func (*SystemDrainReq) Descriptor deprecated 

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

Deprecated: Use SystemDrainReq.ProtoReflect.Descriptor instead.

func (*SystemDrainReq) GetHosts 

func (x *SystemDrainReq) GetHosts() string

func (*SystemDrainReq) GetRanks 

func (x *SystemDrainReq) GetRanks() string

func (*SystemDrainReq) GetSys 

func (x *SystemDrainReq) GetSys() string

func (*SystemDrainReq) ProtoMessage 

func (*SystemDrainReq) ProtoMessage()

func (*SystemDrainReq) ProtoReflect 

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

func (*SystemDrainReq) Reset 

func (x *SystemDrainReq) Reset()

func (*SystemDrainReq) String 

func (x *SystemDrainReq) String() string

type SystemDrainResp 

type SystemDrainResp struct {
	Results []*SystemDrainResp_DrainResult `protobuf:"bytes,1,rep,name=results,proto3" json:"results,omitempty"` // Results for pool-ranks drain calls.
	// contains filtered or unexported fields
}

SystemDrainResp returns status of system-drain request.

func (*SystemDrainResp) Descriptor deprecated 

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

Deprecated: Use SystemDrainResp.ProtoReflect.Descriptor instead.

func (*SystemDrainResp) GetResults 

func (x *SystemDrainResp) GetResults() []*SystemDrainResp_DrainResult

func (*SystemDrainResp) ProtoMessage 

func (*SystemDrainResp) ProtoMessage()

func (*SystemDrainResp) ProtoReflect 

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

func (*SystemDrainResp) Reset 

func (x *SystemDrainResp) Reset()

func (*SystemDrainResp) String 

func (x *SystemDrainResp) String() string

type SystemDrainResp_DrainResult 

type SystemDrainResp_DrainResult struct {
	Status int32  `protobuf:"varint,1,opt,name=status,proto3" json:"status,omitempty"`              // Status of the evict on the specific pool
	Msg    string `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`                     // Error message if status indicates an error
	PoolId string `protobuf:"bytes,3,opt,name=pool_id,json=poolId,proto3" json:"pool_id,omitempty"` // Label or uuid of pool
	Ranks  string `protobuf:"bytes,4,opt,name=ranks,proto3" json:"ranks,omitempty"`                 // Rank-set that has encountered this result
	// contains filtered or unexported fields
}

func (*SystemDrainResp_DrainResult) Descriptor deprecated 

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

Deprecated: Use SystemDrainResp_DrainResult.ProtoReflect.Descriptor instead.

func (*SystemDrainResp_DrainResult) GetMsg 

func (x *SystemDrainResp_DrainResult) GetMsg() string

func (*SystemDrainResp_DrainResult) GetPoolId 

func (x *SystemDrainResp_DrainResult) GetPoolId() string

func (*SystemDrainResp_DrainResult) GetRanks 

func (x *SystemDrainResp_DrainResult) GetRanks() string

func (*SystemDrainResp_DrainResult) GetStatus 

func (x *SystemDrainResp_DrainResult) GetStatus() int32

func (*SystemDrainResp_DrainResult) ProtoMessage 

func (*SystemDrainResp_DrainResult) ProtoMessage()

func (*SystemDrainResp_DrainResult) ProtoReflect 

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

func (*SystemDrainResp_DrainResult) Reset 

func (x *SystemDrainResp_DrainResult) Reset()

func (*SystemDrainResp_DrainResult) String 

func (x *SystemDrainResp_DrainResult) String() string

type SystemEraseReq 

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

SystemEraseReq supplies system erase parameters.

func (*SystemEraseReq) Descriptor deprecated 

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

Deprecated: Use SystemEraseReq.ProtoReflect.Descriptor instead.

func (*SystemEraseReq) GetSys 

func (x *SystemEraseReq) GetSys() string

func (*SystemEraseReq) ProtoMessage 

func (*SystemEraseReq) ProtoMessage()

func (*SystemEraseReq) ProtoReflect 

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

func (*SystemEraseReq) Reset 

func (x *SystemEraseReq) Reset()

func (*SystemEraseReq) String 

func (x *SystemEraseReq) String() string

type SystemEraseResp 

type SystemEraseResp struct {
	Results []*shared.RankResult `protobuf:"bytes,1,rep,name=results,proto3" json:"results,omitempty"`
	// contains filtered or unexported fields
}

func (*SystemEraseResp) Descriptor deprecated 

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

Deprecated: Use SystemEraseResp.ProtoReflect.Descriptor instead.

func (*SystemEraseResp) GetResults 

func (x *SystemEraseResp) GetResults() []*shared.RankResult

func (*SystemEraseResp) ProtoMessage 

func (*SystemEraseResp) ProtoMessage()

func (*SystemEraseResp) ProtoReflect 

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

func (*SystemEraseResp) Reset 

func (x *SystemEraseResp) Reset()

func (*SystemEraseResp) String 

func (x *SystemEraseResp) String() string

type SystemExcludeReq 

type SystemExcludeReq struct {
	Sys   string `protobuf:"bytes,1,opt,name=sys,proto3" json:"sys,omitempty"`      // DAOS system name
	Ranks string `protobuf:"bytes,2,opt,name=ranks,proto3" json:"ranks,omitempty"`  // rankset to exclude
	Hosts string `protobuf:"bytes,3,opt,name=hosts,proto3" json:"hosts,omitempty"`  // hostset to exclude
	Clear bool   `protobuf:"varint,4,opt,name=clear,proto3" json:"clear,omitempty"` // Clear excluded state
	// contains filtered or unexported fields
}

SystemExcludeReq supplies system exclude parameters.

func (*SystemExcludeReq) Descriptor deprecated 

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

Deprecated: Use SystemExcludeReq.ProtoReflect.Descriptor instead.

func (*SystemExcludeReq) GetClear 

func (x *SystemExcludeReq) GetClear() bool

func (*SystemExcludeReq) GetHosts 

func (x *SystemExcludeReq) GetHosts() string

func (*SystemExcludeReq) GetRanks 

func (x *SystemExcludeReq) GetRanks() string

func (*SystemExcludeReq) GetSys 

func (x *SystemExcludeReq) GetSys() string

func (*SystemExcludeReq) ProtoMessage 

func (*SystemExcludeReq) ProtoMessage()

func (*SystemExcludeReq) ProtoReflect 

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

func (*SystemExcludeReq) Reset 

func (x *SystemExcludeReq) Reset()

func (*SystemExcludeReq) String 

func (x *SystemExcludeReq) String() string

type SystemExcludeResp 

type SystemExcludeResp struct {
	Results []*shared.RankResult `protobuf:"bytes,1,rep,name=results,proto3" json:"results,omitempty"`
	// contains filtered or unexported fields
}

SystemExcludeResp returns status of exclude request.

func (*SystemExcludeResp) Descriptor deprecated 

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

Deprecated: Use SystemExcludeResp.ProtoReflect.Descriptor instead.

func (*SystemExcludeResp) GetResults 

func (x *SystemExcludeResp) GetResults() []*shared.RankResult

func (*SystemExcludeResp) ProtoMessage 

func (*SystemExcludeResp) ProtoMessage()

func (*SystemExcludeResp) ProtoReflect 

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

func (*SystemExcludeResp) Reset 

func (x *SystemExcludeResp) Reset()

func (*SystemExcludeResp) String 

func (x *SystemExcludeResp) String() string

type SystemGetAttrReq 

type SystemGetAttrReq struct {
	Sys  string   `protobuf:"bytes,1,opt,name=sys,proto3" json:"sys,omitempty"`
	Keys []string `protobuf:"bytes,2,rep,name=keys,proto3" json:"keys,omitempty"`
	// contains filtered or unexported fields
}

SystemGetAttrReq contains a request to get one or more attributes by key. If no keys are supplied, all attributes are returned in the response.

func (*SystemGetAttrReq) Descriptor deprecated 

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

Deprecated: Use SystemGetAttrReq.ProtoReflect.Descriptor instead.

func (*SystemGetAttrReq) GetKeys 

func (x *SystemGetAttrReq) GetKeys() []string

func (*SystemGetAttrReq) GetSys 

func (x *SystemGetAttrReq) GetSys() string

func (*SystemGetAttrReq) ProtoMessage 

func (*SystemGetAttrReq) ProtoMessage()

func (*SystemGetAttrReq) ProtoReflect 

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

func (*SystemGetAttrReq) Reset 

func (x *SystemGetAttrReq) Reset()

func (*SystemGetAttrReq) String 

func (x *SystemGetAttrReq) String() string

type SystemGetAttrResp 

type SystemGetAttrResp struct {
	Attributes map[string]string `` /* 161-byte string literal not displayed */
	// contains filtered or unexported fields
}

SystemGetAttrResp contains a list of attribute key/value pairs.

func (*SystemGetAttrResp) Descriptor deprecated 

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

Deprecated: Use SystemGetAttrResp.ProtoReflect.Descriptor instead.

func (*SystemGetAttrResp) GetAttributes 

func (x *SystemGetAttrResp) GetAttributes() map[string]string

func (*SystemGetAttrResp) ProtoMessage 

func (*SystemGetAttrResp) ProtoMessage()

func (*SystemGetAttrResp) ProtoReflect 

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

func (*SystemGetAttrResp) Reset 

func (x *SystemGetAttrResp) Reset()

func (*SystemGetAttrResp) String 

func (x *SystemGetAttrResp) String() string

type SystemGetPropReq 

type SystemGetPropReq struct {
	Sys  string   `protobuf:"bytes,1,opt,name=sys,proto3" json:"sys,omitempty"`
	Keys []string `protobuf:"bytes,2,rep,name=keys,proto3" json:"keys,omitempty"`
	// contains filtered or unexported fields
}

SystemGetPropReq contains a request to get one or more properties by key. If no keys are supplied, all properties are returned in the response.

func (*SystemGetPropReq) Descriptor deprecated 

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

Deprecated: Use SystemGetPropReq.ProtoReflect.Descriptor instead.

func (*SystemGetPropReq) GetKeys 

func (x *SystemGetPropReq) GetKeys() []string

func (*SystemGetPropReq) GetSys 

func (x *SystemGetPropReq) GetSys() string

func (*SystemGetPropReq) ProtoMessage 

func (*SystemGetPropReq) ProtoMessage()

func (*SystemGetPropReq) ProtoReflect 

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

func (*SystemGetPropReq) Reset 

func (x *SystemGetPropReq) Reset()

func (*SystemGetPropReq) String 

func (x *SystemGetPropReq) String() string

type SystemGetPropResp 

type SystemGetPropResp struct {
	Properties map[string]string `` /* 161-byte string literal not displayed */
	// contains filtered or unexported fields
}

SystemGetPropResp contains a list of property key/value pairs.

func (*SystemGetPropResp) Descriptor deprecated 

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

Deprecated: Use SystemGetPropResp.ProtoReflect.Descriptor instead.

func (*SystemGetPropResp) GetProperties 

func (x *SystemGetPropResp) GetProperties() map[string]string

func (*SystemGetPropResp) ProtoMessage 

func (*SystemGetPropResp) ProtoMessage()

func (*SystemGetPropResp) ProtoReflect 

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

func (*SystemGetPropResp) Reset 

func (x *SystemGetPropResp) Reset()

func (*SystemGetPropResp) String 

func (x *SystemGetPropResp) String() string

type SystemMember 

type SystemMember struct {
	Addr           string `protobuf:"bytes,1,opt,name=addr,proto3" json:"addr,omitempty"`
	Uuid           string `protobuf:"bytes,2,opt,name=uuid,proto3" json:"uuid,omitempty"`
	Rank           uint32 `protobuf:"varint,3,opt,name=rank,proto3" json:"rank,omitempty"`
	Incarnation    uint64 `protobuf:"varint,4,opt,name=incarnation,proto3" json:"incarnation,omitempty"`
	State          string `protobuf:"bytes,5,opt,name=state,proto3" json:"state,omitempty"`
	FabricUri      string `protobuf:"bytes,6,opt,name=fabric_uri,json=fabricUri,proto3" json:"fabric_uri,omitempty"`
	FabricContexts uint32 `protobuf:"varint,7,opt,name=fabric_contexts,json=fabricContexts,proto3" json:"fabric_contexts,omitempty"`
	// ancillary info e.g. error msg or reason for state change
	Info                string   `protobuf:"bytes,8,opt,name=info,proto3" json:"info,omitempty"`
	FaultDomain         string   `protobuf:"bytes,9,opt,name=fault_domain,json=faultDomain,proto3" json:"fault_domain,omitempty"`
	LastUpdate          string   `protobuf:"bytes,10,opt,name=last_update,json=lastUpdate,proto3" json:"last_update,omitempty"`
	SecondaryFabricUris []string `protobuf:"bytes,11,rep,name=secondary_fabric_uris,json=secondaryFabricUris,proto3" json:"secondary_fabric_uris,omitempty"`
	// contains filtered or unexported fields
}

SystemMember refers to a data-plane instance that is a member of DAOS system running on host with the control-plane listening at "Addr".

func (*SystemMember) Descriptor deprecated 

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

Deprecated: Use SystemMember.ProtoReflect.Descriptor instead.

func (*SystemMember) GetAddr 

func (x *SystemMember) GetAddr() string

func (*SystemMember) GetFabricContexts 

func (x *SystemMember) GetFabricContexts() uint32

func (*SystemMember) GetFabricUri 

func (x *SystemMember) GetFabricUri() string

func (*SystemMember) GetFaultDomain 

func (x *SystemMember) GetFaultDomain() string

func (*SystemMember) GetIncarnation 

func (x *SystemMember) GetIncarnation() uint64

func (*SystemMember) GetInfo 

func (x *SystemMember) GetInfo() string

func (*SystemMember) GetLastUpdate 

func (x *SystemMember) GetLastUpdate() string

func (*SystemMember) GetRank 

func (x *SystemMember) GetRank() uint32

func (*SystemMember) GetSecondaryFabricUris 

func (x *SystemMember) GetSecondaryFabricUris() []string

func (*SystemMember) GetState 

func (x *SystemMember) GetState() string

func (*SystemMember) GetUuid 

func (x *SystemMember) GetUuid() string

func (*SystemMember) ProtoMessage 

func (*SystemMember) ProtoMessage()

func (*SystemMember) ProtoReflect 

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

func (*SystemMember) Reset 

func (x *SystemMember) Reset()

func (*SystemMember) String 

func (x *SystemMember) String() string

type SystemQueryReq 

type SystemQueryReq struct {
	Sys       string `protobuf:"bytes,1,opt,name=sys,proto3" json:"sys,omitempty"`                               // DAOS system name
	Ranks     string `protobuf:"bytes,2,opt,name=ranks,proto3" json:"ranks,omitempty"`                           // rankset to query
	Hosts     string `protobuf:"bytes,3,opt,name=hosts,proto3" json:"hosts,omitempty"`                           // hostset to query
	StateMask uint32 `protobuf:"varint,4,opt,name=state_mask,json=stateMask,proto3" json:"state_mask,omitempty"` // bitmask defining desired member states
	// contains filtered or unexported fields
}

SystemQueryReq supplies system query parameters.

func (*SystemQueryReq) Descriptor deprecated 

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

Deprecated: Use SystemQueryReq.ProtoReflect.Descriptor instead.

func (*SystemQueryReq) GetHosts 

func (x *SystemQueryReq) GetHosts() string

func (*SystemQueryReq) GetRanks 

func (x *SystemQueryReq) GetRanks() string

func (*SystemQueryReq) GetStateMask 

func (x *SystemQueryReq) GetStateMask() uint32

func (*SystemQueryReq) GetSys 

func (x *SystemQueryReq) GetSys() string

func (*SystemQueryReq) ProtoMessage 

func (*SystemQueryReq) ProtoMessage()

func (*SystemQueryReq) ProtoReflect 

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

func (*SystemQueryReq) Reset 

func (x *SystemQueryReq) Reset()

func (*SystemQueryReq) String 

func (x *SystemQueryReq) String() string

type SystemQueryResp 

type SystemQueryResp struct {
	Members     []*SystemMember `protobuf:"bytes,1,rep,name=members,proto3" json:"members,omitempty"`
	Absentranks string          `protobuf:"bytes,2,opt,name=absentranks,proto3" json:"absentranks,omitempty"`                     // rankset missing from membership
	Absenthosts string          `protobuf:"bytes,3,opt,name=absenthosts,proto3" json:"absenthosts,omitempty"`                     // hostset missing from membership
	DataVersion uint64          `protobuf:"varint,4,opt,name=data_version,json=dataVersion,proto3" json:"data_version,omitempty"` // Version of the system database.
	Providers   []string        `protobuf:"bytes,5,rep,name=providers,proto3" json:"providers,omitempty"`                         // Providers supported by system in configured order
	// contains filtered or unexported fields
}

SystemQueryResp returns active system members.

func (*SystemQueryResp) Descriptor deprecated 

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

Deprecated: Use SystemQueryResp.ProtoReflect.Descriptor instead.

func (*SystemQueryResp) GetAbsenthosts 

func (x *SystemQueryResp) GetAbsenthosts() string

func (*SystemQueryResp) GetAbsentranks 

func (x *SystemQueryResp) GetAbsentranks() string

func (*SystemQueryResp) GetDataVersion 

func (x *SystemQueryResp) GetDataVersion() uint64

func (*SystemQueryResp) GetMembers 

func (x *SystemQueryResp) GetMembers() []*SystemMember

func (*SystemQueryResp) GetProviders 

func (x *SystemQueryResp) GetProviders() []string

func (*SystemQueryResp) ProtoMessage 

func (*SystemQueryResp) ProtoMessage()

func (*SystemQueryResp) ProtoReflect 

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

func (*SystemQueryResp) Reset 

func (x *SystemQueryResp) Reset()

func (*SystemQueryResp) String 

func (x *SystemQueryResp) String() string

type SystemSetAttrReq 

type SystemSetAttrReq struct {
	Sys        string            `protobuf:"bytes,1,opt,name=sys,proto3" json:"sys,omitempty"`
	Attributes map[string]string `` /* 161-byte string literal not displayed */
	// contains filtered or unexported fields
}

SystemSetAttrReq contains a request to set one or more system properties.

func (*SystemSetAttrReq) Descriptor deprecated 

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

Deprecated: Use SystemSetAttrReq.ProtoReflect.Descriptor instead.

func (*SystemSetAttrReq) GetAttributes 

func (x *SystemSetAttrReq) GetAttributes() map[string]string

func (*SystemSetAttrReq) GetSys 

func (x *SystemSetAttrReq) GetSys() string

func (*SystemSetAttrReq) ProtoMessage 

func (*SystemSetAttrReq) ProtoMessage()

func (*SystemSetAttrReq) ProtoReflect 

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

func (*SystemSetAttrReq) Reset 

func (x *SystemSetAttrReq) Reset()

func (*SystemSetAttrReq) String 

func (x *SystemSetAttrReq) String() string

type SystemSetPropReq 

type SystemSetPropReq struct {
	Sys        string            `protobuf:"bytes,1,opt,name=sys,proto3" json:"sys,omitempty"`
	Properties map[string]string `` /* 161-byte string literal not displayed */
	// contains filtered or unexported fields
}

SystemSetPropReq contains a request to set one or more system properties.

func (*SystemSetPropReq) Descriptor deprecated 

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

Deprecated: Use SystemSetPropReq.ProtoReflect.Descriptor instead.

func (*SystemSetPropReq) GetProperties 

func (x *SystemSetPropReq) GetProperties() map[string]string

func (*SystemSetPropReq) GetSys 

func (x *SystemSetPropReq) GetSys() string

func (*SystemSetPropReq) ProtoMessage 

func (*SystemSetPropReq) ProtoMessage()

func (*SystemSetPropReq) ProtoReflect 

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

func (*SystemSetPropReq) Reset 

func (x *SystemSetPropReq) Reset()

func (*SystemSetPropReq) String 

func (x *SystemSetPropReq) String() string

type SystemStartReq 

type SystemStartReq struct {
	Sys       string `protobuf:"bytes,1,opt,name=sys,proto3" json:"sys,omitempty"`                               // DAOS system name
	Ranks     string `protobuf:"bytes,2,opt,name=ranks,proto3" json:"ranks,omitempty"`                           // rankset to query
	Hosts     string `protobuf:"bytes,3,opt,name=hosts,proto3" json:"hosts,omitempty"`                           // hostset to query
	CheckMode bool   `protobuf:"varint,4,opt,name=check_mode,json=checkMode,proto3" json:"check_mode,omitempty"` // start ranks in check mode
	// contains filtered or unexported fields
}

SystemStartReq supplies system restart parameters.

func (*SystemStartReq) Descriptor deprecated 

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

Deprecated: Use SystemStartReq.ProtoReflect.Descriptor instead.

func (*SystemStartReq) GetCheckMode 

func (x *SystemStartReq) GetCheckMode() bool

func (*SystemStartReq) GetHosts 

func (x *SystemStartReq) GetHosts() string

func (*SystemStartReq) GetRanks 

func (x *SystemStartReq) GetRanks() string

func (*SystemStartReq) GetSys 

func (x *SystemStartReq) GetSys() string

func (*SystemStartReq) ProtoMessage 

func (*SystemStartReq) ProtoMessage()

func (*SystemStartReq) ProtoReflect 

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

func (*SystemStartReq) Reset 

func (x *SystemStartReq) Reset()

func (*SystemStartReq) String 

func (x *SystemStartReq) String() string

type SystemStartResp 

type SystemStartResp struct {
	Results     []*shared.RankResult `protobuf:"bytes,1,rep,name=results,proto3" json:"results,omitempty"`
	Absentranks string               `protobuf:"bytes,2,opt,name=absentranks,proto3" json:"absentranks,omitempty"` // rankset missing from membership
	Absenthosts string               `protobuf:"bytes,3,opt,name=absenthosts,proto3" json:"absenthosts,omitempty"` // hostset missing from membership
	// contains filtered or unexported fields
}

SystemStartResp returns status of restart attempt and results of attempts to start system members.

func (*SystemStartResp) Descriptor deprecated 

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

Deprecated: Use SystemStartResp.ProtoReflect.Descriptor instead.

func (*SystemStartResp) GetAbsenthosts 

func (x *SystemStartResp) GetAbsenthosts() string

func (*SystemStartResp) GetAbsentranks 

func (x *SystemStartResp) GetAbsentranks() string

func (*SystemStartResp) GetResults 

func (x *SystemStartResp) GetResults() []*shared.RankResult

func (*SystemStartResp) ProtoMessage 

func (*SystemStartResp) ProtoMessage()

func (*SystemStartResp) ProtoReflect 

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

func (*SystemStartResp) Reset 

func (x *SystemStartResp) Reset()

func (*SystemStartResp) String 

func (x *SystemStartResp) String() string

type SystemStopReq 

type SystemStopReq struct {
	Sys   string `protobuf:"bytes,1,opt,name=sys,proto3" json:"sys,omitempty"`    // DAOS system name
	Prep  bool   `protobuf:"varint,2,opt,name=prep,proto3" json:"prep,omitempty"` // indicates that the prep stage should be performed
	Kill  bool   `protobuf:"varint,3,opt,name=kill,proto3" json:"kill,omitempty"` // indicates that the kill stage should be performed
	Force bool   `protobuf:"varint,4,opt,name=force,proto3" json:"force,omitempty"`
	Ranks string `protobuf:"bytes,5,opt,name=ranks,proto3" json:"ranks,omitempty"` // rankset to query
	Hosts string `protobuf:"bytes,6,opt,name=hosts,proto3" json:"hosts,omitempty"` // hostset to query
	// contains filtered or unexported fields
}

SystemStopReq supplies system shutdown parameters.

func (*SystemStopReq) Descriptor deprecated 

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

Deprecated: Use SystemStopReq.ProtoReflect.Descriptor instead.

func (*SystemStopReq) GetForce 

func (x *SystemStopReq) GetForce() bool

func (*SystemStopReq) GetHosts 

func (x *SystemStopReq) GetHosts() string

func (*SystemStopReq) GetKill 

func (x *SystemStopReq) GetKill() bool

func (*SystemStopReq) GetPrep 

func (x *SystemStopReq) GetPrep() bool

func (*SystemStopReq) GetRanks 

func (x *SystemStopReq) GetRanks() string

func (*SystemStopReq) GetSys 

func (x *SystemStopReq) GetSys() string

func (*SystemStopReq) ProtoMessage 

func (*SystemStopReq) ProtoMessage()

func (*SystemStopReq) ProtoReflect 

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

func (*SystemStopReq) Reset 

func (x *SystemStopReq) Reset()

func (*SystemStopReq) String 

func (x *SystemStopReq) String() string

type SystemStopResp 

type SystemStopResp struct {
	Results     []*shared.RankResult `protobuf:"bytes,1,rep,name=results,proto3" json:"results,omitempty"`
	Absentranks string               `protobuf:"bytes,2,opt,name=absentranks,proto3" json:"absentranks,omitempty"` // rankset missing from membership
	Absenthosts string               `protobuf:"bytes,3,opt,name=absenthosts,proto3" json:"absenthosts,omitempty"` // hostset missing from membership
	// contains filtered or unexported fields
}

SystemStopResp returns status of shutdown attempt and results of attempts to stop system members.

func (*SystemStopResp) Descriptor deprecated 

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

Deprecated: Use SystemStopResp.ProtoReflect.Descriptor instead.

func (*SystemStopResp) GetAbsenthosts 

func (x *SystemStopResp) GetAbsenthosts() string

func (*SystemStopResp) GetAbsentranks 

func (x *SystemStopResp) GetAbsentranks() string

func (*SystemStopResp) GetResults 

func (x *SystemStopResp) GetResults() []*shared.RankResult

func (*SystemStopResp) ProtoMessage 

func (*SystemStopResp) ProtoMessage()

func (*SystemStopResp) ProtoReflect 

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

func (*SystemStopResp) Reset 

func (x *SystemStopResp) Reset()

func (*SystemStopResp) String 

func (x *SystemStopResp) String() string

type UnimplementedMgmtSvcServer 

type UnimplementedMgmtSvcServer struct {
}

UnimplementedMgmtSvcServer must be embedded to have forward compatible implementations.

func (UnimplementedMgmtSvcServer) ClusterEvent 

func (UnimplementedMgmtSvcServer) ClusterEvent(context.Context, *shared.ClusterEventReq) (*shared.ClusterEventResp, error)

func (UnimplementedMgmtSvcServer) ContSetOwner 

func (UnimplementedMgmtSvcServer) ContSetOwner(context.Context, *ContSetOwnerReq) (*DaosResp, error)

func (UnimplementedMgmtSvcServer) FaultInjectMgmtPoolFault 

func (UnimplementedMgmtSvcServer) FaultInjectMgmtPoolFault(context.Context, *chk.Fault) (*DaosResp, error)

func (UnimplementedMgmtSvcServer) FaultInjectPoolFault 

func (UnimplementedMgmtSvcServer) FaultInjectPoolFault(context.Context, *chk.Fault) (*DaosResp, error)

func (UnimplementedMgmtSvcServer) FaultInjectReport 

func (UnimplementedMgmtSvcServer) FaultInjectReport(context.Context, *chk.CheckReport) (*DaosResp, error)

func (UnimplementedMgmtSvcServer) GetAttachInfo 

func (UnimplementedMgmtSvcServer) GetAttachInfo(context.Context, *GetAttachInfoReq) (*GetAttachInfoResp, error)

func (UnimplementedMgmtSvcServer) Join 

func (UnimplementedMgmtSvcServer) Join(context.Context, *JoinReq) (*JoinResp, error)

func (UnimplementedMgmtSvcServer) LeaderQuery 

func (UnimplementedMgmtSvcServer) LeaderQuery(context.Context, *LeaderQueryReq) (*LeaderQueryResp, error)

func (UnimplementedMgmtSvcServer) ListContainers 

func (UnimplementedMgmtSvcServer) ListContainers(context.Context, *ListContReq) (*ListContResp, error)

func (UnimplementedMgmtSvcServer) ListPools 

func (UnimplementedMgmtSvcServer) ListPools(context.Context, *ListPoolsReq) (*ListPoolsResp, error)

func (UnimplementedMgmtSvcServer) PoolCreate 

func (UnimplementedMgmtSvcServer) PoolCreate(context.Context, *PoolCreateReq) (*PoolCreateResp, error)

func (UnimplementedMgmtSvcServer) PoolDeleteACL 

func (UnimplementedMgmtSvcServer) PoolDeleteACL(context.Context, *DeleteACLReq) (*ACLResp, error)

func (UnimplementedMgmtSvcServer) PoolDestroy 

func (UnimplementedMgmtSvcServer) PoolDestroy(context.Context, *PoolDestroyReq) (*PoolDestroyResp, error)

func (UnimplementedMgmtSvcServer) PoolDrain 

func (UnimplementedMgmtSvcServer) PoolDrain(context.Context, *PoolDrainReq) (*PoolDrainResp, error)

func (UnimplementedMgmtSvcServer) PoolEvict 

func (UnimplementedMgmtSvcServer) PoolEvict(context.Context, *PoolEvictReq) (*PoolEvictResp, error)

func (UnimplementedMgmtSvcServer) PoolExclude 

func (UnimplementedMgmtSvcServer) PoolExclude(context.Context, *PoolExcludeReq) (*PoolExcludeResp, error)

func (UnimplementedMgmtSvcServer) PoolExtend 

func (UnimplementedMgmtSvcServer) PoolExtend(context.Context, *PoolExtendReq) (*PoolExtendResp, error)

func (UnimplementedMgmtSvcServer) PoolGetACL 

func (UnimplementedMgmtSvcServer) PoolGetACL(context.Context, *GetACLReq) (*ACLResp, error)

func (UnimplementedMgmtSvcServer) PoolGetProp 

func (UnimplementedMgmtSvcServer) PoolGetProp(context.Context, *PoolGetPropReq) (*PoolGetPropResp, error)

func (UnimplementedMgmtSvcServer) PoolOverwriteACL 

func (UnimplementedMgmtSvcServer) PoolOverwriteACL(context.Context, *ModifyACLReq) (*ACLResp, error)

func (UnimplementedMgmtSvcServer) PoolQuery 

func (UnimplementedMgmtSvcServer) PoolQuery(context.Context, *PoolQueryReq) (*PoolQueryResp, error)

func (UnimplementedMgmtSvcServer) PoolQueryTarget 

func (UnimplementedMgmtSvcServer) PoolQueryTarget(context.Context, *PoolQueryTargetReq) (*PoolQueryTargetResp, error)

func (UnimplementedMgmtSvcServer) PoolReintegrate 

func (UnimplementedMgmtSvcServer) PoolReintegrate(context.Context, *PoolReintegrateReq) (*PoolReintegrateResp, error)

func (UnimplementedMgmtSvcServer) PoolSetProp 

func (UnimplementedMgmtSvcServer) PoolSetProp(context.Context, *PoolSetPropReq) (*PoolSetPropResp, error)

func (UnimplementedMgmtSvcServer) PoolUpdateACL 

func (UnimplementedMgmtSvcServer) PoolUpdateACL(context.Context, *ModifyACLReq) (*ACLResp, error)

func (UnimplementedMgmtSvcServer) PoolUpgrade 

func (UnimplementedMgmtSvcServer) PoolUpgrade(context.Context, *PoolUpgradeReq) (*PoolUpgradeResp, error)

func (UnimplementedMgmtSvcServer) SystemCheckDisable 

func (UnimplementedMgmtSvcServer) SystemCheckDisable(context.Context, *CheckDisableReq) (*DaosResp, error)

func (UnimplementedMgmtSvcServer) SystemCheckEnable 

func (UnimplementedMgmtSvcServer) SystemCheckEnable(context.Context, *CheckEnableReq) (*DaosResp, error)

func (UnimplementedMgmtSvcServer) SystemCheckGetPolicy 

func (UnimplementedMgmtSvcServer) SystemCheckGetPolicy(context.Context, *CheckGetPolicyReq) (*CheckGetPolicyResp, error)

func (UnimplementedMgmtSvcServer) SystemCheckQuery 

func (UnimplementedMgmtSvcServer) SystemCheckQuery(context.Context, *CheckQueryReq) (*CheckQueryResp, error)

func (UnimplementedMgmtSvcServer) SystemCheckRepair 

func (UnimplementedMgmtSvcServer) SystemCheckRepair(context.Context, *CheckActReq) (*CheckActResp, error)

func (UnimplementedMgmtSvcServer) SystemCheckSetPolicy 

func (UnimplementedMgmtSvcServer) SystemCheckSetPolicy(context.Context, *CheckSetPolicyReq) (*DaosResp, error)

func (UnimplementedMgmtSvcServer) SystemCheckStart 

func (UnimplementedMgmtSvcServer) SystemCheckStart(context.Context, *CheckStartReq) (*CheckStartResp, error)

func (UnimplementedMgmtSvcServer) SystemCheckStop 

func (UnimplementedMgmtSvcServer) SystemCheckStop(context.Context, *CheckStopReq) (*CheckStopResp, error)

func (UnimplementedMgmtSvcServer) SystemCleanup 

func (UnimplementedMgmtSvcServer) SystemCleanup(context.Context, *SystemCleanupReq) (*SystemCleanupResp, error)

func (UnimplementedMgmtSvcServer) SystemDrain 

func (UnimplementedMgmtSvcServer) SystemDrain(context.Context, *SystemDrainReq) (*SystemDrainResp, error)

func (UnimplementedMgmtSvcServer) SystemErase 

func (UnimplementedMgmtSvcServer) SystemErase(context.Context, *SystemEraseReq) (*SystemEraseResp, error)

func (UnimplementedMgmtSvcServer) SystemExclude 

func (UnimplementedMgmtSvcServer) SystemExclude(context.Context, *SystemExcludeReq) (*SystemExcludeResp, error)

func (UnimplementedMgmtSvcServer) SystemGetAttr 

func (UnimplementedMgmtSvcServer) SystemGetAttr(context.Context, *SystemGetAttrReq) (*SystemGetAttrResp, error)

func (UnimplementedMgmtSvcServer) SystemGetProp 

func (UnimplementedMgmtSvcServer) SystemGetProp(context.Context, *SystemGetPropReq) (*SystemGetPropResp, error)

func (UnimplementedMgmtSvcServer) SystemQuery 

func (UnimplementedMgmtSvcServer) SystemQuery(context.Context, *SystemQueryReq) (*SystemQueryResp, error)

func (UnimplementedMgmtSvcServer) SystemSetAttr 

func (UnimplementedMgmtSvcServer) SystemSetAttr(context.Context, *SystemSetAttrReq) (*DaosResp, error)

func (UnimplementedMgmtSvcServer) SystemSetProp 

func (UnimplementedMgmtSvcServer) SystemSetProp(context.Context, *SystemSetPropReq) (*DaosResp, error)

func (UnimplementedMgmtSvcServer) SystemStart 

func (UnimplementedMgmtSvcServer) SystemStart(context.Context, *SystemStartReq) (*SystemStartResp, error)

func (UnimplementedMgmtSvcServer) SystemStop 

func (UnimplementedMgmtSvcServer) SystemStop(context.Context, *SystemStopReq) (*SystemStopResp, error)

type UnsafeMgmtSvcServer 

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

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

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