srv

package
v0.0.0-...-23518fa Latest Latest
Warning

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

 Go to latest Published: Jan 13, 2025 License: BSD-2-Clause-Patent Imports: 5 Imported by: 4

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_srv_srv_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type CheckDeregPoolReq 

type CheckDeregPoolReq struct {
	Seq  uint64 `protobuf:"varint,1,opt,name=seq,proto3" json:"seq,omitempty"`  // DAOS Check event sequence, unique for the instance.
	Uuid string `protobuf:"bytes,2,opt,name=uuid,proto3" json:"uuid,omitempty"` // The pool to be deregistered.
	// contains filtered or unexported fields
}

Deregister pool from MS.

func (*CheckDeregPoolReq) Descriptor deprecated 

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

Deprecated: Use CheckDeregPoolReq.ProtoReflect.Descriptor instead.

func (*CheckDeregPoolReq) GetSeq 

func (x *CheckDeregPoolReq) GetSeq() uint64

func (*CheckDeregPoolReq) GetUuid 

func (x *CheckDeregPoolReq) GetUuid() string

func (*CheckDeregPoolReq) ProtoMessage 

func (*CheckDeregPoolReq) ProtoMessage()

func (*CheckDeregPoolReq) ProtoReflect 

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

func (*CheckDeregPoolReq) Reset 

func (x *CheckDeregPoolReq) Reset()

func (*CheckDeregPoolReq) String 

func (x *CheckDeregPoolReq) String() string

type CheckDeregPoolResp 

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

func (*CheckDeregPoolResp) Descriptor deprecated 

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

Deprecated: Use CheckDeregPoolResp.ProtoReflect.Descriptor instead.

func (*CheckDeregPoolResp) GetStatus 

func (x *CheckDeregPoolResp) GetStatus() int32

func (*CheckDeregPoolResp) ProtoMessage 

func (*CheckDeregPoolResp) ProtoMessage()

func (*CheckDeregPoolResp) ProtoReflect 

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

func (*CheckDeregPoolResp) Reset 

func (x *CheckDeregPoolResp) Reset()

func (*CheckDeregPoolResp) String 

func (x *CheckDeregPoolResp) String() string

type CheckListPoolReq 

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

List all the known pools from MS.

func (*CheckListPoolReq) Descriptor deprecated 

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

Deprecated: Use CheckListPoolReq.ProtoReflect.Descriptor instead.

func (*CheckListPoolReq) ProtoMessage 

func (*CheckListPoolReq) ProtoMessage()

func (*CheckListPoolReq) ProtoReflect 

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

func (*CheckListPoolReq) Reset 

func (x *CheckListPoolReq) Reset()

func (*CheckListPoolReq) String 

func (x *CheckListPoolReq) String() string

type CheckListPoolResp 

type CheckListPoolResp struct {
	Status int32                        `protobuf:"varint,1,opt,name=status,proto3" json:"status,omitempty"` // DAOS error code.
	Pools  []*CheckListPoolResp_OnePool `protobuf:"bytes,2,rep,name=pools,proto3" json:"pools,omitempty"`    // The list of pools.
	// contains filtered or unexported fields
}

func (*CheckListPoolResp) Descriptor deprecated 

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

Deprecated: Use CheckListPoolResp.ProtoReflect.Descriptor instead.

func (*CheckListPoolResp) GetPools 

func (x *CheckListPoolResp) GetPools() []*CheckListPoolResp_OnePool

func (*CheckListPoolResp) GetStatus 

func (x *CheckListPoolResp) GetStatus() int32

func (*CheckListPoolResp) ProtoMessage 

func (*CheckListPoolResp) ProtoMessage()

func (*CheckListPoolResp) ProtoReflect 

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

func (*CheckListPoolResp) Reset 

func (x *CheckListPoolResp) Reset()

func (*CheckListPoolResp) String 

func (x *CheckListPoolResp) String() string

type CheckListPoolResp_OnePool 

type CheckListPoolResp_OnePool struct {
	Uuid    string   `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`               // Pool UUID.
	Label   string   `protobuf:"bytes,2,opt,name=label,proto3" json:"label,omitempty"`             // Pool label.
	Svcreps []uint32 `protobuf:"varint,3,rep,packed,name=svcreps,proto3" json:"svcreps,omitempty"` // Pool service replica ranks.
	// contains filtered or unexported fields
}

func (*CheckListPoolResp_OnePool) Descriptor deprecated 

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

Deprecated: Use CheckListPoolResp_OnePool.ProtoReflect.Descriptor instead.

func (*CheckListPoolResp_OnePool) GetLabel 

func (x *CheckListPoolResp_OnePool) GetLabel() string

func (*CheckListPoolResp_OnePool) GetSvcreps 

func (x *CheckListPoolResp_OnePool) GetSvcreps() []uint32

func (*CheckListPoolResp_OnePool) GetUuid 

func (x *CheckListPoolResp_OnePool) GetUuid() string

func (*CheckListPoolResp_OnePool) ProtoMessage 

func (*CheckListPoolResp_OnePool) ProtoMessage()

func (*CheckListPoolResp_OnePool) ProtoReflect 

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

func (*CheckListPoolResp_OnePool) Reset 

func (x *CheckListPoolResp_OnePool) Reset()

func (*CheckListPoolResp_OnePool) String 

func (x *CheckListPoolResp_OnePool) String() string

type CheckRegPoolReq 

type CheckRegPoolReq struct {
	Seq     uint64   `protobuf:"varint,1,opt,name=seq,proto3" json:"seq,omitempty"`                // DAOS Check event sequence, unique for the instance.
	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.
	Svcreps []uint32 `protobuf:"varint,4,rep,packed,name=svcreps,proto3" json:"svcreps,omitempty"` // Pool service replica ranks.
	// contains filtered or unexported fields
}

Register pool to MS.

func (*CheckRegPoolReq) Descriptor deprecated 

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

Deprecated: Use CheckRegPoolReq.ProtoReflect.Descriptor instead.

func (*CheckRegPoolReq) GetLabel 

func (x *CheckRegPoolReq) GetLabel() string

func (*CheckRegPoolReq) GetSeq 

func (x *CheckRegPoolReq) GetSeq() uint64

func (*CheckRegPoolReq) GetSvcreps 

func (x *CheckRegPoolReq) GetSvcreps() []uint32

func (*CheckRegPoolReq) GetUuid 

func (x *CheckRegPoolReq) GetUuid() string

func (*CheckRegPoolReq) ProtoMessage 

func (*CheckRegPoolReq) ProtoMessage()

func (*CheckRegPoolReq) ProtoReflect 

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

func (*CheckRegPoolReq) Reset 

func (x *CheckRegPoolReq) Reset()

func (*CheckRegPoolReq) String 

func (x *CheckRegPoolReq) String() string

type CheckRegPoolResp 

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

func (*CheckRegPoolResp) Descriptor deprecated 

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

Deprecated: Use CheckRegPoolResp.ProtoReflect.Descriptor instead.

func (*CheckRegPoolResp) GetStatus 

func (x *CheckRegPoolResp) GetStatus() int32

func (*CheckRegPoolResp) ProtoMessage 

func (*CheckRegPoolResp) ProtoMessage()

func (*CheckRegPoolResp) ProtoReflect 

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

func (*CheckRegPoolResp) Reset 

func (x *CheckRegPoolResp) Reset()

func (*CheckRegPoolResp) String 

func (x *CheckRegPoolResp) String() string

type CheckReportReq 

type CheckReportReq struct {
	Report *chk.CheckReport `protobuf:"bytes,1,opt,name=report,proto3" json:"report,omitempty"` // Report payload
	// contains filtered or unexported fields
}

func (*CheckReportReq) Descriptor deprecated 

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

Deprecated: Use CheckReportReq.ProtoReflect.Descriptor instead.

func (*CheckReportReq) GetReport 

func (x *CheckReportReq) GetReport() *chk.CheckReport

func (*CheckReportReq) ProtoMessage 

func (*CheckReportReq) ProtoMessage()

func (*CheckReportReq) ProtoReflect 

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

func (*CheckReportReq) Reset 

func (x *CheckReportReq) Reset()

func (*CheckReportReq) String 

func (x *CheckReportReq) String() string

type CheckReportResp 

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

func (*CheckReportResp) Descriptor deprecated 

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

Deprecated: Use CheckReportResp.ProtoReflect.Descriptor instead.

func (*CheckReportResp) GetStatus 

func (x *CheckReportResp) GetStatus() int32

func (*CheckReportResp) ProtoMessage 

func (*CheckReportResp) ProtoMessage()

func (*CheckReportResp) ProtoReflect 

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

func (*CheckReportResp) Reset 

func (x *CheckReportResp) Reset()

func (*CheckReportResp) String 

func (x *CheckReportResp) String() string

type GetPoolSvcReq 

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

func (*GetPoolSvcReq) Descriptor deprecated 

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

Deprecated: Use GetPoolSvcReq.ProtoReflect.Descriptor instead.

func (*GetPoolSvcReq) GetUuid 

func (x *GetPoolSvcReq) GetUuid() string

func (*GetPoolSvcReq) ProtoMessage 

func (*GetPoolSvcReq) ProtoMessage()

func (*GetPoolSvcReq) ProtoReflect 

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

func (*GetPoolSvcReq) Reset 

func (x *GetPoolSvcReq) Reset()

func (*GetPoolSvcReq) String 

func (x *GetPoolSvcReq) String() string

type GetPoolSvcResp 

type GetPoolSvcResp struct {
	Status  int32    `protobuf:"varint,1,opt,name=status,proto3" json:"status,omitempty"`          // DAOS error code
	Svcreps []uint32 `protobuf:"varint,2,rep,packed,name=svcreps,proto3" json:"svcreps,omitempty"` // Pool service replica ranks
	// contains filtered or unexported fields
}

func (*GetPoolSvcResp) Descriptor deprecated 

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

Deprecated: Use GetPoolSvcResp.ProtoReflect.Descriptor instead.

func (*GetPoolSvcResp) GetStatus 

func (x *GetPoolSvcResp) GetStatus() int32

func (*GetPoolSvcResp) GetSvcreps 

func (x *GetPoolSvcResp) GetSvcreps() []uint32

func (*GetPoolSvcResp) ProtoMessage 

func (*GetPoolSvcResp) ProtoMessage()

func (*GetPoolSvcResp) ProtoReflect 

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

func (*GetPoolSvcResp) Reset 

func (x *GetPoolSvcResp) Reset()

func (*GetPoolSvcResp) String 

func (x *GetPoolSvcResp) String() string

type ListPoolsReq 

type ListPoolsReq struct {
	IncludeAll bool `protobuf:"varint,1,opt,name=include_all,json=includeAll,proto3" json:"include_all,omitempty"` // Include all pools in response, regardless of state
	// contains filtered or unexported fields
}

func (*ListPoolsReq) Descriptor deprecated 

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

Deprecated: Use ListPoolsReq.ProtoReflect.Descriptor instead.

func (*ListPoolsReq) GetIncludeAll 

func (x *ListPoolsReq) GetIncludeAll() bool

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 {
	Pools []*ListPoolsResp_Pool `protobuf:"bytes,1,rep,name=pools,proto3" json:"pools,omitempty"` // List of pools
	// contains filtered or unexported fields
}

func (*ListPoolsResp) Descriptor deprecated 

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

Deprecated: Use ListPoolsResp.ProtoReflect.Descriptor instead.

func (*ListPoolsResp) GetPools 

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

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"`               // Pool UUID
	Label   string   `protobuf:"bytes,2,opt,name=label,proto3" json:"label,omitempty"`             // Pool label
	Svcreps []uint32 `protobuf:"varint,3,rep,packed,name=svcreps,proto3" json:"svcreps,omitempty"` // Pool service ranks
	// 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) 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 NotifyReadyReq 

type NotifyReadyReq struct {
	Uri              string   `protobuf:"bytes,1,opt,name=uri,proto3" json:"uri,omitempty"`                               // Primary CaRT URI
	Nctxs            uint32   `protobuf:"varint,2,opt,name=nctxs,proto3" json:"nctxs,omitempty"`                          // Number of primary CaRT contexts
	DrpcListenerSock string   `protobuf:"bytes,3,opt,name=drpcListenerSock,proto3" json:"drpcListenerSock,omitempty"`     // Path to I/O Engine's dRPC listener socket
	InstanceIdx      uint32   `protobuf:"varint,4,opt,name=instanceIdx,proto3" json:"instanceIdx,omitempty"`              // I/O Engine instance index
	Ntgts            uint32   `protobuf:"varint,5,opt,name=ntgts,proto3" json:"ntgts,omitempty"`                          // number of VOS targets allocated in I/O Engine
	Incarnation      uint64   `protobuf:"varint,6,opt,name=incarnation,proto3" json:"incarnation,omitempty"`              // HLC incarnation number
	SecondaryUris    []string `protobuf:"bytes,7,rep,name=secondaryUris,proto3" json:"secondaryUris,omitempty"`           // secondary CaRT URIs
	SecondaryNctxs   []uint32 `protobuf:"varint,8,rep,packed,name=secondaryNctxs,proto3" json:"secondaryNctxs,omitempty"` // number of CaRT contexts for each secondary provider
	CheckMode        bool     `protobuf:"varint,9,opt,name=check_mode,json=checkMode,proto3" json:"check_mode,omitempty"` // True if engine started in checker mode
	// contains filtered or unexported fields
}

func (*NotifyReadyReq) Descriptor deprecated 

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

Deprecated: Use NotifyReadyReq.ProtoReflect.Descriptor instead.

func (*NotifyReadyReq) GetCheckMode 

func (x *NotifyReadyReq) GetCheckMode() bool

func (*NotifyReadyReq) GetDrpcListenerSock 

func (x *NotifyReadyReq) GetDrpcListenerSock() string

func (*NotifyReadyReq) GetIncarnation 

func (x *NotifyReadyReq) GetIncarnation() uint64

func (*NotifyReadyReq) GetInstanceIdx 

func (x *NotifyReadyReq) GetInstanceIdx() uint32

func (*NotifyReadyReq) GetNctxs 

func (x *NotifyReadyReq) GetNctxs() uint32

func (*NotifyReadyReq) GetNtgts 

func (x *NotifyReadyReq) GetNtgts() uint32

func (*NotifyReadyReq) GetSecondaryNctxs 

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

func (*NotifyReadyReq) GetSecondaryUris 

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

func (*NotifyReadyReq) GetUri 

func (x *NotifyReadyReq) GetUri() string

func (*NotifyReadyReq) ProtoMessage 

func (*NotifyReadyReq) ProtoMessage()

func (*NotifyReadyReq) ProtoReflect 

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

func (*NotifyReadyReq) Reset 

func (x *NotifyReadyReq) Reset()

func (*NotifyReadyReq) String 

func (x *NotifyReadyReq) String() string

type PoolFindByLabelReq 

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

func (*PoolFindByLabelReq) Descriptor deprecated 

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

Deprecated: Use PoolFindByLabelReq.ProtoReflect.Descriptor instead.

func (*PoolFindByLabelReq) GetLabel 

func (x *PoolFindByLabelReq) GetLabel() string

func (*PoolFindByLabelReq) ProtoMessage 

func (*PoolFindByLabelReq) ProtoMessage()

func (*PoolFindByLabelReq) ProtoReflect 

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

func (*PoolFindByLabelReq) Reset 

func (x *PoolFindByLabelReq) Reset()

func (*PoolFindByLabelReq) String 

func (x *PoolFindByLabelReq) String() string

type PoolFindByLabelResp 

type PoolFindByLabelResp 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
	Svcreps []uint32 `protobuf:"varint,3,rep,packed,name=svcreps,proto3" json:"svcreps,omitempty"` // Pool service replica ranks
	// contains filtered or unexported fields
}

func (*PoolFindByLabelResp) Descriptor deprecated 

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

Deprecated: Use PoolFindByLabelResp.ProtoReflect.Descriptor instead.

func (*PoolFindByLabelResp) GetStatus 

func (x *PoolFindByLabelResp) GetStatus() int32

func (*PoolFindByLabelResp) GetSvcreps 

func (x *PoolFindByLabelResp) GetSvcreps() []uint32

func (*PoolFindByLabelResp) GetUuid 

func (x *PoolFindByLabelResp) GetUuid() string

func (*PoolFindByLabelResp) ProtoMessage 

func (*PoolFindByLabelResp) ProtoMessage()

func (*PoolFindByLabelResp) ProtoReflect 

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

func (*PoolFindByLabelResp) Reset 

func (x *PoolFindByLabelResp) Reset()

func (*PoolFindByLabelResp) String 

func (x *PoolFindByLabelResp) 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.