mgmt

package
v0.0.0-...-ff4375a Latest Latest
Warning

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

Go to latest
Published: May 21, 2024 License: BSD-2-Clause-Patent Imports: 12 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_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: "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 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
	ContUUID   string   `protobuf:"bytes,2,opt,name=contUUID,proto3" json:"contUUID,omitempty"`                         // UUID of the container
	PoolUUID   string   `protobuf:"bytes,3,opt,name=poolUUID,proto3" json:"poolUUID,omitempty"`                         // UUID of the pool that the container is in
	Owneruser  string   `protobuf:"bytes,4,opt,name=owneruser,proto3" json:"owneruser,omitempty"`                       // formatted user e.g. "bob@"
	Ownergroup string   `protobuf:"bytes,5,opt,name=ownergroup,proto3" json:"ownergroup,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 supplies new pool parameters.

func (*ContSetOwnerReq) Descriptor deprecated

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

Deprecated: Use ContSetOwnerReq.ProtoReflect.Descriptor instead.

func (*ContSetOwnerReq) GetContUUID

func (x *ContSetOwnerReq) GetContUUID() 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) GetPoolUUID

func (x *ContSetOwnerReq) GetPoolUUID() 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 ContSetOwnerResp

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

ContSetOwnerResp returns created pool uuid and ranks.

func (*ContSetOwnerResp) Descriptor deprecated

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

Deprecated: Use ContSetOwnerResp.ProtoReflect.Descriptor instead.

func (*ContSetOwnerResp) GetStatus

func (x *ContSetOwnerResp) GetStatus() int32

func (*ContSetOwnerResp) ProtoMessage

func (*ContSetOwnerResp) ProtoMessage()

func (*ContSetOwnerResp) ProtoReflect

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

func (*ContSetOwnerResp) Reset

func (x *ContSetOwnerResp) Reset()

func (*ContSetOwnerResp) String

func (x *ContSetOwnerResp) 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 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 */
	// contains filtered or unexported fields
}

func (*GetAttachInfoResp) Descriptor deprecated

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

Deprecated: Use GetAttachInfoResp.ProtoReflect.Descriptor instead.

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) 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 (*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) 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 (JoinResp_State) String

func (x JoinResp_State) String() string

func (JoinResp_State) Type

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) (*ContSetOwnerResp, 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)
	// 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) (*ContSetOwnerResp, 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)
	// 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=usergroup,proto3" json:"usergroup,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=faultDomains,proto3" json:"faultDomains,omitempty"`                 // Fault domain tree, minimal format
	Numsvcreps   uint32    `protobuf:"varint,8,opt,name=numsvcreps,proto3" json:"numsvcreps,omitempty"`                            // desired number of pool service replicas
	Totalbytes   uint64    `protobuf:"varint,9,opt,name=totalbytes,proto3" json:"totalbytes,omitempty"`                            // Total pool size in bytes (auto config)
	Tierratio    []float64 `protobuf:"fixed64,10,rep,packed,name=tierratio,proto3" json:"tierratio,omitempty"`                     // Ratio of storage tiers expressed as % of totalbytes (auto config)
	Numranks     uint32    `protobuf:"varint,11,opt,name=numranks,proto3" json:"numranks,omitempty"`                               // Number of target ranks to use (auto config)
	Ranks        []uint32  `protobuf:"varint,12,rep,packed,name=ranks,proto3" json:"ranks,omitempty"`                              // target ranks (manual config)
	Tierbytes    []uint64  `protobuf:"varint,13,rep,packed,name=tierbytes,proto3" json:"tierbytes,omitempty"`                      // Size in bytes of storage tiers (manual config)
	MetaBlobSize uint64    `protobuf:"varint,14,opt,name=meta_blob_size,json=metaBlobSize,proto3" json:"meta_blob_size,omitempty"` // Size in bytes of metadata blob on SSD (manual config)
	// 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) GetMetaBlobSize

func (x *PoolCreateReq) GetMetaBlobSize() uint64

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"`     // storage tiers allocated to pool
	MetaBlobSize uint64   `protobuf:"varint,6,opt,name=meta_blob_size,json=metaBlobSize,proto3" json:"meta_blob_size,omitempty"` // Size in bytes of metadata blob on SSD (manual config)
	// 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) GetMetaBlobSize

func (x *PoolCreateResp) GetMetaBlobSize() 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=targetidx,proto3" json:"targetidx,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=targetidx,proto3" json:"targetidx,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=tierbytes,proto3" json:"tierbytes,omitempty"`               // Size in bytes of storage tiers
	FaultDomains []uint32 `protobuf:"varint,6,rep,packed,name=faultDomains,proto3" json:"faultDomains,omitempty"`         // fault domain tree, minimal format
	// 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) 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
	IncludeEnabledRanks  bool     `protobuf:"varint,4,opt,name=include_enabled_ranks,json=includeEnabledRanks,proto3" json:"include_enabled_ranks,omitempty"`    // True if the list of enabled ranks shall be returned
	IncludeDisabledRanks bool     `protobuf:"varint,5,opt,name=include_disabled_ranks,json=includeDisabledRanks,proto3" json:"include_disabled_ranks,omitempty"` // True if the list of disabled ranks shall be returned
	// 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) GetIncludeDisabledRanks

func (x *PoolQueryReq) GetIncludeDisabledRanks() bool

func (*PoolQueryReq) GetIncludeEnabledRanks

func (x *PoolQueryReq) GetIncludeEnabledRanks() bool

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
	// 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) 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) GetPoolLayoutVer

func (x *PoolQueryResp) GetPoolLayoutVer() uint32

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
	// 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) GetSpace

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

func (*PoolQueryTargetInfo) GetState

func (*PoolQueryTargetInfo) GetType

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) Enum

func (PoolQueryTargetInfo_TargetState) EnumDescriptor deprecated

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

Deprecated: Use PoolQueryTargetInfo_TargetState.Descriptor instead.

func (PoolQueryTargetInfo_TargetState) Number

func (PoolQueryTargetInfo_TargetState) String

func (PoolQueryTargetInfo_TargetState) Type

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) Enum

func (PoolQueryTargetInfo_TargetType) EnumDescriptor deprecated

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

Deprecated: Use PoolQueryTargetInfo_TargetType.Descriptor instead.

func (PoolQueryTargetInfo_TargetType) Number

func (PoolQueryTargetInfo_TargetType) String

func (PoolQueryTargetInfo_TargetType) Type

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 (*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) Enum

func (PoolRebuildStatus_State) EnumDescriptor deprecated

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

Deprecated: Use PoolRebuildStatus_State.Descriptor instead.

func (PoolRebuildStatus_State) Number

func (PoolRebuildStatus_State) String

func (x PoolRebuildStatus_State) String() string

func (PoolRebuildStatus_State) Type

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=targetidx,proto3" json:"targetidx,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=tierbytes,proto3" json:"tierbytes,omitempty"`               // Size in bytes of storage tiers
	// 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) 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) Enum

func (PoolServiceState) EnumDescriptor deprecated

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

Deprecated: Use PoolServiceState.Descriptor instead.

func (PoolServiceState) Number

func (PoolServiceState) String

func (x PoolServiceState) String() string

func (PoolServiceState) Type

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) Enum

func (StorageMediaType) EnumDescriptor deprecated

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

Deprecated: Use StorageMediaType.Descriptor instead.

func (StorageMediaType) Number

func (StorageMediaType) String

func (x StorageMediaType) String() string

func (StorageMediaType) Type

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 (*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 (*SystemCleanupResp_CleanupResult) GetMsg

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 (*SystemCleanupResp_CleanupResult) Reset

func (*SystemCleanupResp_CleanupResult) 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) ContSetOwner

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) GetAttachInfo

func (UnimplementedMgmtSvcServer) Join

func (UnimplementedMgmtSvcServer) LeaderQuery

func (UnimplementedMgmtSvcServer) ListContainers

func (UnimplementedMgmtSvcServer) ListPools

func (UnimplementedMgmtSvcServer) PoolCreate

func (UnimplementedMgmtSvcServer) PoolDeleteACL

func (UnimplementedMgmtSvcServer) PoolDestroy

func (UnimplementedMgmtSvcServer) PoolDrain

func (UnimplementedMgmtSvcServer) PoolEvict

func (UnimplementedMgmtSvcServer) PoolExclude

func (UnimplementedMgmtSvcServer) PoolExtend

func (UnimplementedMgmtSvcServer) PoolGetACL

func (UnimplementedMgmtSvcServer) PoolGetProp

func (UnimplementedMgmtSvcServer) PoolOverwriteACL

func (UnimplementedMgmtSvcServer) PoolQuery

func (UnimplementedMgmtSvcServer) PoolQueryTarget

func (UnimplementedMgmtSvcServer) PoolReintegrate

func (UnimplementedMgmtSvcServer) PoolSetProp

func (UnimplementedMgmtSvcServer) PoolUpdateACL

func (UnimplementedMgmtSvcServer) PoolUpgrade

func (UnimplementedMgmtSvcServer) SystemCheckDisable

func (UnimplementedMgmtSvcServer) SystemCheckEnable

func (UnimplementedMgmtSvcServer) SystemCheckGetPolicy

func (UnimplementedMgmtSvcServer) SystemCheckQuery

func (UnimplementedMgmtSvcServer) SystemCheckRepair

func (UnimplementedMgmtSvcServer) SystemCheckSetPolicy

func (UnimplementedMgmtSvcServer) SystemCheckStart

func (UnimplementedMgmtSvcServer) SystemCheckStop

func (UnimplementedMgmtSvcServer) SystemCleanup

func (UnimplementedMgmtSvcServer) SystemErase

func (UnimplementedMgmtSvcServer) SystemExclude

func (UnimplementedMgmtSvcServer) SystemGetAttr

func (UnimplementedMgmtSvcServer) SystemGetProp

func (UnimplementedMgmtSvcServer) SystemQuery

func (UnimplementedMgmtSvcServer) SystemSetAttr

func (UnimplementedMgmtSvcServer) SystemSetProp

func (UnimplementedMgmtSvcServer) SystemStart

func (UnimplementedMgmtSvcServer) SystemStop

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.

Jump to

Keyboard shortcuts

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