shared

package
v0.0.0-...-11b6d5e Latest Latest
Warning

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

 Go to latest Published: Feb 19, 2025 License: BSD-2-Clause-Patent Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_shared_event_proto protoreflect.FileDescriptor
View Source 
var File_shared_ranks_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type ClusterEventReq 

type ClusterEventReq struct {
	Sequence uint64    `protobuf:"varint,1,opt,name=sequence,proto3" json:"sequence,omitempty"` // Sequence identifier for RAS events.
	Event    *RASEvent `protobuf:"bytes,2,opt,name=event,proto3" json:"event,omitempty"`        // RAS event.
	// contains filtered or unexported fields
}

ClusterEventReq communicates occurrence of a RAS event in the DAOS system.

func (*ClusterEventReq) Descriptor deprecated 

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

Deprecated: Use ClusterEventReq.ProtoReflect.Descriptor instead.

func (*ClusterEventReq) GetEvent 

func (x *ClusterEventReq) GetEvent() *RASEvent

func (*ClusterEventReq) GetSequence 

func (x *ClusterEventReq) GetSequence() uint64

func (*ClusterEventReq) ProtoMessage 

func (*ClusterEventReq) ProtoMessage()

func (*ClusterEventReq) ProtoReflect 

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

func (*ClusterEventReq) Reset 

func (x *ClusterEventReq) Reset()

func (*ClusterEventReq) String 

func (x *ClusterEventReq) String() string

type ClusterEventResp 

type ClusterEventResp struct {
	Sequence uint64 `protobuf:"varint,1,opt,name=sequence,proto3" json:"sequence,omitempty"` // Sequence identifier for RAS events.
	Status   int32  `protobuf:"varint,2,opt,name=status,proto3" json:"status,omitempty"`     // DAOS error code.
	// contains filtered or unexported fields
}

ClusterEventResp acknowledges receipt of an event notification.

func (*ClusterEventResp) Descriptor deprecated 

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

Deprecated: Use ClusterEventResp.ProtoReflect.Descriptor instead.

func (*ClusterEventResp) GetSequence 

func (x *ClusterEventResp) GetSequence() uint64

func (*ClusterEventResp) GetStatus 

func (x *ClusterEventResp) GetStatus() int32

func (*ClusterEventResp) ProtoMessage 

func (*ClusterEventResp) ProtoMessage()

func (*ClusterEventResp) ProtoReflect 

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

func (*ClusterEventResp) Reset 

func (x *ClusterEventResp) Reset()

func (*ClusterEventResp) String 

func (x *ClusterEventResp) String() string

type RASEvent 

type RASEvent struct {
	Id          uint32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`                              // Unique event identifier, 64-char.
	Msg         string `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`                             // Human readable message describing event.
	Timestamp   string `protobuf:"bytes,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`                 // Fully qualified timestamp (us) incl timezone.
	Type        uint32 `protobuf:"varint,4,opt,name=type,proto3" json:"type,omitempty"`                          // Event type.
	Severity    uint32 `protobuf:"varint,5,opt,name=severity,proto3" json:"severity,omitempty"`                  // Event severity.
	Hostname    string `protobuf:"bytes,6,opt,name=hostname,proto3" json:"hostname,omitempty"`                   // (optional) Hostname of node involved in event.
	Rank        uint32 `protobuf:"varint,7,opt,name=rank,proto3" json:"rank,omitempty"`                          // (optional) DAOS rank involved in event.
	Incarnation uint64 `protobuf:"varint,8,opt,name=incarnation,proto3" json:"incarnation,omitempty"`            // (optional) Incarnation of DAOS rank involved in event.
	HwId        string `protobuf:"bytes,9,opt,name=hw_id,json=hwId,proto3" json:"hw_id,omitempty"`               // (optional) Hardware component involved in event.
	ProcId      uint64 `protobuf:"varint,10,opt,name=proc_id,json=procId,proto3" json:"proc_id,omitempty"`       // (optional) Process involved in event.
	ThreadId    uint64 `protobuf:"varint,11,opt,name=thread_id,json=threadId,proto3" json:"thread_id,omitempty"` // (optional) Thread involved in event.
	JobId       string `protobuf:"bytes,12,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`           // (optional) Job involved in event.
	PoolUuid    string `protobuf:"bytes,13,opt,name=pool_uuid,json=poolUuid,proto3" json:"pool_uuid,omitempty"`  // (optional) Pool UUID involved in event.
	ContUuid    string `protobuf:"bytes,14,opt,name=cont_uuid,json=contUuid,proto3" json:"cont_uuid,omitempty"`  // (optional) Container UUID involved in event.
	ObjId       string `protobuf:"bytes,15,opt,name=obj_id,json=objId,proto3" json:"obj_id,omitempty"`           // (optional) Object involved in event.
	CtlOp       string `protobuf:"bytes,16,opt,name=ctl_op,json=ctlOp,proto3" json:"ctl_op,omitempty"`           // (optional) Recommended automatic action.
	// Types that are assignable to ExtendedInfo:
	//	*RASEvent_StrInfo
	//	*RASEvent_EngineStateInfo
	//	*RASEvent_PoolSvcInfo
	ExtendedInfo isRASEvent_ExtendedInfo `protobuf_oneof:"extended_info"`
	// contains filtered or unexported fields
}

RASEvent describes a RAS event in the DAOS system.

func (*RASEvent) Descriptor deprecated 

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

Deprecated: Use RASEvent.ProtoReflect.Descriptor instead.

func (*RASEvent) GetContUuid 

func (x *RASEvent) GetContUuid() string

func (*RASEvent) GetCtlOp 

func (x *RASEvent) GetCtlOp() string

func (*RASEvent) GetEngineStateInfo 

func (x *RASEvent) GetEngineStateInfo() *RASEvent_EngineStateEventInfo

func (*RASEvent) GetExtendedInfo 

func (m *RASEvent) GetExtendedInfo() isRASEvent_ExtendedInfo

func (*RASEvent) GetHostname 

func (x *RASEvent) GetHostname() string

func (*RASEvent) GetHwId 

func (x *RASEvent) GetHwId() string

func (*RASEvent) GetId 

func (x *RASEvent) GetId() uint32

func (*RASEvent) GetIncarnation 

func (x *RASEvent) GetIncarnation() uint64

func (*RASEvent) GetJobId 

func (x *RASEvent) GetJobId() string

func (*RASEvent) GetMsg 

func (x *RASEvent) GetMsg() string

func (*RASEvent) GetObjId 

func (x *RASEvent) GetObjId() string

func (*RASEvent) GetPoolSvcInfo 

func (x *RASEvent) GetPoolSvcInfo() *RASEvent_PoolSvcEventInfo

func (*RASEvent) GetPoolUuid 

func (x *RASEvent) GetPoolUuid() string

func (*RASEvent) GetProcId 

func (x *RASEvent) GetProcId() uint64

func (*RASEvent) GetRank 

func (x *RASEvent) GetRank() uint32

func (*RASEvent) GetSeverity 

func (x *RASEvent) GetSeverity() uint32

func (*RASEvent) GetStrInfo 

func (x *RASEvent) GetStrInfo() string

func (*RASEvent) GetThreadId 

func (x *RASEvent) GetThreadId() uint64

func (*RASEvent) GetTimestamp 

func (x *RASEvent) GetTimestamp() string

func (*RASEvent) GetType 

func (x *RASEvent) GetType() uint32

func (*RASEvent) ProtoMessage 

func (*RASEvent) ProtoMessage()

func (*RASEvent) ProtoReflect 

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

func (*RASEvent) Reset 

func (x *RASEvent) Reset()

func (*RASEvent) String 

func (x *RASEvent) String() string

type RASEvent_EngineStateEventInfo 

type RASEvent_EngineStateEventInfo struct {
	Instance uint32 `protobuf:"varint,1,opt,name=instance,proto3" json:"instance,omitempty"` // Control-plane harness instance index.
	Errored  bool   `protobuf:"varint,2,opt,name=errored,proto3" json:"errored,omitempty"`   // Rank in error state.
	Error    string `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`        // Message associated with error.
	// contains filtered or unexported fields
}

EngineStateEventInfo defines extended fields for state change events.

func (*RASEvent_EngineStateEventInfo) Descriptor deprecated 

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

Deprecated: Use RASEvent_EngineStateEventInfo.ProtoReflect.Descriptor instead.

func (*RASEvent_EngineStateEventInfo) GetError 

func (x *RASEvent_EngineStateEventInfo) GetError() string

func (*RASEvent_EngineStateEventInfo) GetErrored 

func (x *RASEvent_EngineStateEventInfo) GetErrored() bool

func (*RASEvent_EngineStateEventInfo) GetInstance 

func (x *RASEvent_EngineStateEventInfo) GetInstance() uint32

func (*RASEvent_EngineStateEventInfo) ProtoMessage 

func (*RASEvent_EngineStateEventInfo) ProtoMessage()

func (*RASEvent_EngineStateEventInfo) ProtoReflect 

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

func (*RASEvent_EngineStateEventInfo) Reset 

func (x *RASEvent_EngineStateEventInfo) Reset()

func (*RASEvent_EngineStateEventInfo) String 

func (x *RASEvent_EngineStateEventInfo) String() string

type RASEvent_EngineStateInfo 

type RASEvent_EngineStateInfo struct {
	EngineStateInfo *RASEvent_EngineStateEventInfo `protobuf:"bytes,18,opt,name=engine_state_info,json=engineStateInfo,proto3,oneof"`
}

type RASEvent_PoolSvcEventInfo 

type RASEvent_PoolSvcEventInfo struct {
	SvcReps []uint32 `protobuf:"varint,1,rep,packed,name=svc_reps,json=svcReps,proto3" json:"svc_reps,omitempty"` // Pool service replica ranks.
	Version uint64   `protobuf:"varint,2,opt,name=version,proto3" json:"version,omitempty"`                       // Raft leadership term.
	// contains filtered or unexported fields
}

PoolSvcEventInfo defines extended fields for pool service change events.

func (*RASEvent_PoolSvcEventInfo) Descriptor deprecated 

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

Deprecated: Use RASEvent_PoolSvcEventInfo.ProtoReflect.Descriptor instead.

func (*RASEvent_PoolSvcEventInfo) GetSvcReps 

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

func (*RASEvent_PoolSvcEventInfo) GetVersion 

func (x *RASEvent_PoolSvcEventInfo) GetVersion() uint64

func (*RASEvent_PoolSvcEventInfo) ProtoMessage 

func (*RASEvent_PoolSvcEventInfo) ProtoMessage()

func (*RASEvent_PoolSvcEventInfo) ProtoReflect 

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

func (*RASEvent_PoolSvcEventInfo) Reset 

func (x *RASEvent_PoolSvcEventInfo) Reset()

func (*RASEvent_PoolSvcEventInfo) String 

func (x *RASEvent_PoolSvcEventInfo) String() string

type RASEvent_PoolSvcInfo 

type RASEvent_PoolSvcInfo struct {
	PoolSvcInfo *RASEvent_PoolSvcEventInfo `protobuf:"bytes,19,opt,name=pool_svc_info,json=poolSvcInfo,proto3,oneof"`
}

type RASEvent_StrInfo 

type RASEvent_StrInfo struct {
	StrInfo string `protobuf:"bytes,17,opt,name=str_info,json=strInfo,proto3,oneof"` // Opaque data blob.
}

type RankResult 

type RankResult struct {
	Rank    uint32 `protobuf:"varint,1,opt,name=rank,proto3" json:"rank,omitempty"`
	Action  string `protobuf:"bytes,2,opt,name=action,proto3" json:"action,omitempty"`
	Errored bool   `protobuf:"varint,3,opt,name=errored,proto3" json:"errored,omitempty"`
	Msg     string `protobuf:"bytes,4,opt,name=msg,proto3" json:"msg,omitempty"`
	State   string `protobuf:"bytes,5,opt,name=state,proto3" json:"state,omitempty"`
	Addr    string `protobuf:"bytes,6,opt,name=addr,proto3" json:"addr,omitempty"`
	// contains filtered or unexported fields
}

func (*RankResult) Descriptor deprecated 

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

Deprecated: Use RankResult.ProtoReflect.Descriptor instead.

func (*RankResult) GetAction 

func (x *RankResult) GetAction() string

func (*RankResult) GetAddr 

func (x *RankResult) GetAddr() string

func (*RankResult) GetErrored 

func (x *RankResult) GetErrored() bool

func (*RankResult) GetMsg 

func (x *RankResult) GetMsg() string

func (*RankResult) GetRank 

func (x *RankResult) GetRank() uint32

func (*RankResult) GetState 

func (x *RankResult) GetState() string

func (*RankResult) ProtoMessage 

func (*RankResult) ProtoMessage()

func (*RankResult) ProtoReflect 

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

func (*RankResult) Reset 

func (x *RankResult) Reset()

func (*RankResult) String 

func (x *RankResult) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

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