mgmt

package
v0.8.0 Latest Latest
Warning

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

 Go to latest Published: Dec 17, 2019 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

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

Functions

func RegisterMgmtSvcServer 

func RegisterMgmtSvcServer(s *grpc.Server, srv MgmtSvcServer)

Types

type ACLResp 

type ACLResp struct {
	Status               int32    `protobuf:"varint,1,opt,name=status,proto3" json:"status,omitempty"`
	ACL                  []string `protobuf:"bytes,2,rep,name=ACL,proto3" json:"ACL,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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

func (*ACLResp) Descriptor 

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

func (*ACLResp) GetACL 

func (m *ACLResp) GetACL() []string

func (*ACLResp) GetStatus 

func (m *ACLResp) GetStatus() int32

func (*ACLResp) ProtoMessage 

func (*ACLResp) ProtoMessage()

func (*ACLResp) Reset 

func (m *ACLResp) Reset()

func (*ACLResp) String 

func (m *ACLResp) String() string

func (*ACLResp) XXX_DiscardUnknown 

func (m *ACLResp) XXX_DiscardUnknown()

func (*ACLResp) XXX_Marshal 

func (m *ACLResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ACLResp) XXX_Merge 

func (dst *ACLResp) XXX_Merge(src proto.Message)

func (*ACLResp) XXX_Size 

func (m *ACLResp) XXX_Size() int

func (*ACLResp) XXX_Unmarshal 

func (m *ACLResp) XXX_Unmarshal(b []byte) error

type BioHealthReq 

type BioHealthReq struct {
	DevUuid              string   `protobuf:"bytes,1,opt,name=dev_uuid,json=devUuid,proto3" json:"dev_uuid,omitempty"`
	TgtId                string   `protobuf:"bytes,2,opt,name=tgt_id,json=tgtId,proto3" json:"tgt_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*BioHealthReq) Descriptor 

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

func (*BioHealthReq) GetDevUuid 

func (m *BioHealthReq) GetDevUuid() string

func (*BioHealthReq) GetTgtId 

func (m *BioHealthReq) GetTgtId() string

func (*BioHealthReq) ProtoMessage 

func (*BioHealthReq) ProtoMessage()

func (*BioHealthReq) Reset 

func (m *BioHealthReq) Reset()

func (*BioHealthReq) String 

func (m *BioHealthReq) String() string

func (*BioHealthReq) XXX_DiscardUnknown 

func (m *BioHealthReq) XXX_DiscardUnknown()

func (*BioHealthReq) XXX_Marshal 

func (m *BioHealthReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BioHealthReq) XXX_Merge 

func (dst *BioHealthReq) XXX_Merge(src proto.Message)

func (*BioHealthReq) XXX_Size 

func (m *BioHealthReq) XXX_Size() int

func (*BioHealthReq) XXX_Unmarshal 

func (m *BioHealthReq) XXX_Unmarshal(b []byte) error

type BioHealthResp 

type BioHealthResp struct {
	Status               int32    `protobuf:"varint,1,opt,name=status,proto3" json:"status,omitempty"`
	DevUuid              string   `protobuf:"bytes,2,opt,name=dev_uuid,json=devUuid,proto3" json:"dev_uuid,omitempty"`
	ErrorCount           uint64   `protobuf:"varint,3,opt,name=error_count,json=errorCount,proto3" json:"error_count,omitempty"`
	Temperature          uint32   `protobuf:"varint,4,opt,name=temperature,proto3" json:"temperature,omitempty"`
	MediaErrors          uint64   `protobuf:"varint,5,opt,name=media_errors,json=mediaErrors,proto3" json:"media_errors,omitempty"`
	ReadErrs             uint32   `protobuf:"varint,6,opt,name=read_errs,json=readErrs,proto3" json:"read_errs,omitempty"`
	WriteErrs            uint32   `protobuf:"varint,7,opt,name=write_errs,json=writeErrs,proto3" json:"write_errs,omitempty"`
	UnmapErrs            uint32   `protobuf:"varint,8,opt,name=unmap_errs,json=unmapErrs,proto3" json:"unmap_errs,omitempty"`
	ChecksumErrs         uint32   `protobuf:"varint,9,opt,name=checksum_errs,json=checksumErrs,proto3" json:"checksum_errs,omitempty"`
	Temp                 bool     `protobuf:"varint,10,opt,name=temp,proto3" json:"temp,omitempty"`
	Spare                bool     `protobuf:"varint,11,opt,name=spare,proto3" json:"spare,omitempty"`
	Readonly             bool     `protobuf:"varint,12,opt,name=readonly,proto3" json:"readonly,omitempty"`
	DeviceReliability    bool     `protobuf:"varint,13,opt,name=device_reliability,json=deviceReliability,proto3" json:"device_reliability,omitempty"`
	VolatileMemory       bool     `protobuf:"varint,14,opt,name=volatile_memory,json=volatileMemory,proto3" json:"volatile_memory,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*BioHealthResp) Descriptor 

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

func (*BioHealthResp) GetChecksumErrs 

func (m *BioHealthResp) GetChecksumErrs() uint32

func (*BioHealthResp) GetDevUuid 

func (m *BioHealthResp) GetDevUuid() string

func (*BioHealthResp) GetDeviceReliability 

func (m *BioHealthResp) GetDeviceReliability() bool

func (*BioHealthResp) GetErrorCount 

func (m *BioHealthResp) GetErrorCount() uint64

func (*BioHealthResp) GetMediaErrors 

func (m *BioHealthResp) GetMediaErrors() uint64

func (*BioHealthResp) GetReadErrs 

func (m *BioHealthResp) GetReadErrs() uint32

func (*BioHealthResp) GetReadonly 

func (m *BioHealthResp) GetReadonly() bool

func (*BioHealthResp) GetSpare 

func (m *BioHealthResp) GetSpare() bool

func (*BioHealthResp) GetStatus 

func (m *BioHealthResp) GetStatus() int32

func (*BioHealthResp) GetTemp 

func (m *BioHealthResp) GetTemp() bool

func (*BioHealthResp) GetTemperature 

func (m *BioHealthResp) GetTemperature() uint32

func (*BioHealthResp) GetUnmapErrs 

func (m *BioHealthResp) GetUnmapErrs() uint32

func (*BioHealthResp) GetVolatileMemory 

func (m *BioHealthResp) GetVolatileMemory() bool

func (*BioHealthResp) GetWriteErrs 

func (m *BioHealthResp) GetWriteErrs() uint32

func (*BioHealthResp) ProtoMessage 

func (*BioHealthResp) ProtoMessage()

func (*BioHealthResp) Reset 

func (m *BioHealthResp) Reset()

func (*BioHealthResp) String 

func (m *BioHealthResp) String() string

func (*BioHealthResp) XXX_DiscardUnknown 

func (m *BioHealthResp) XXX_DiscardUnknown()

func (*BioHealthResp) XXX_Marshal 

func (m *BioHealthResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BioHealthResp) XXX_Merge 

func (dst *BioHealthResp) XXX_Merge(src proto.Message)

func (*BioHealthResp) XXX_Size 

func (m *BioHealthResp) XXX_Size() int

func (*BioHealthResp) XXX_Unmarshal 

func (m *BioHealthResp) XXX_Unmarshal(b []byte) error

type CreateMsReq 

type CreateMsReq struct {
	Bootstrap            bool     `protobuf:"varint,1,opt,name=bootstrap,proto3" json:"bootstrap,omitempty"`
	Uuid                 string   `protobuf:"bytes,2,opt,name=uuid,proto3" json:"uuid,omitempty"`
	Addr                 string   `protobuf:"bytes,3,opt,name=addr,proto3" json:"addr,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CreateMsReq) Descriptor 

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

func (*CreateMsReq) GetAddr 

func (m *CreateMsReq) GetAddr() string

func (*CreateMsReq) GetBootstrap 

func (m *CreateMsReq) GetBootstrap() bool

func (*CreateMsReq) GetUuid 

func (m *CreateMsReq) GetUuid() string

func (*CreateMsReq) ProtoMessage 

func (*CreateMsReq) ProtoMessage()

func (*CreateMsReq) Reset 

func (m *CreateMsReq) Reset()

func (*CreateMsReq) String 

func (m *CreateMsReq) String() string

func (*CreateMsReq) XXX_DiscardUnknown 

func (m *CreateMsReq) XXX_DiscardUnknown()

func (*CreateMsReq) XXX_Marshal 

func (m *CreateMsReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateMsReq) XXX_Merge 

func (dst *CreateMsReq) XXX_Merge(src proto.Message)

func (*CreateMsReq) XXX_Size 

func (m *CreateMsReq) XXX_Size() int

func (*CreateMsReq) XXX_Unmarshal 

func (m *CreateMsReq) XXX_Unmarshal(b []byte) error

type DaosResp 

type DaosResp struct {
	Status               int32    `protobuf:"varint,1,opt,name=status,proto3" json:"status,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Generic response just containing DER from IO server.

func (*DaosResp) Descriptor 

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

func (*DaosResp) GetStatus 

func (m *DaosResp) GetStatus() int32

func (*DaosResp) ProtoMessage 

func (*DaosResp) ProtoMessage()

func (*DaosResp) Reset 

func (m *DaosResp) Reset()

func (*DaosResp) String 

func (m *DaosResp) String() string

func (*DaosResp) XXX_DiscardUnknown 

func (m *DaosResp) XXX_DiscardUnknown()

func (*DaosResp) XXX_Marshal 

func (m *DaosResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DaosResp) XXX_Merge 

func (dst *DaosResp) XXX_Merge(src proto.Message)

func (*DaosResp) XXX_Size 

func (m *DaosResp) XXX_Size() int

func (*DaosResp) XXX_Unmarshal 

func (m *DaosResp) XXX_Unmarshal(b []byte) error

type DeleteACLReq 

type DeleteACLReq struct {
	Uuid                 string   `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
	Principal            string   `protobuf:"bytes,2,opt,name=principal,proto3" json:"principal,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Delete a principal's entry from the ACL

func (*DeleteACLReq) Descriptor 

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

func (*DeleteACLReq) GetPrincipal 

func (m *DeleteACLReq) GetPrincipal() string

func (*DeleteACLReq) GetUuid 

func (m *DeleteACLReq) GetUuid() string

func (*DeleteACLReq) ProtoMessage 

func (*DeleteACLReq) ProtoMessage()

func (*DeleteACLReq) Reset 

func (m *DeleteACLReq) Reset()

func (*DeleteACLReq) String 

func (m *DeleteACLReq) String() string

func (*DeleteACLReq) XXX_DiscardUnknown 

func (m *DeleteACLReq) XXX_DiscardUnknown()

func (*DeleteACLReq) XXX_Marshal 

func (m *DeleteACLReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeleteACLReq) XXX_Merge 

func (dst *DeleteACLReq) XXX_Merge(src proto.Message)

func (*DeleteACLReq) XXX_Size 

func (m *DeleteACLReq) XXX_Size() int

func (*DeleteACLReq) XXX_Unmarshal 

func (m *DeleteACLReq) XXX_Unmarshal(b []byte) error

type GetACLReq 

type GetACLReq struct {
	Uuid                 string   `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Request to fetch an ACL

func (*GetACLReq) Descriptor 

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

func (*GetACLReq) GetUuid 

func (m *GetACLReq) GetUuid() string

func (*GetACLReq) ProtoMessage 

func (*GetACLReq) ProtoMessage()

func (*GetACLReq) Reset 

func (m *GetACLReq) Reset()

func (*GetACLReq) String 

func (m *GetACLReq) String() string

func (*GetACLReq) XXX_DiscardUnknown 

func (m *GetACLReq) XXX_DiscardUnknown()

func (*GetACLReq) XXX_Marshal 

func (m *GetACLReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetACLReq) XXX_Merge 

func (dst *GetACLReq) XXX_Merge(src proto.Message)

func (*GetACLReq) XXX_Size 

func (m *GetACLReq) XXX_Size() int

func (*GetACLReq) XXX_Unmarshal 

func (m *GetACLReq) XXX_Unmarshal(b []byte) error

type GetAttachInfoReq 

type GetAttachInfoReq struct {
	Sys                  string   `protobuf:"bytes,1,opt,name=sys,proto3" json:"sys,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetAttachInfoReq) Descriptor 

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

func (*GetAttachInfoReq) GetSys 

func (m *GetAttachInfoReq) GetSys() string

func (*GetAttachInfoReq) ProtoMessage 

func (*GetAttachInfoReq) ProtoMessage()

func (*GetAttachInfoReq) Reset 

func (m *GetAttachInfoReq) Reset()

func (*GetAttachInfoReq) String 

func (m *GetAttachInfoReq) String() string

func (*GetAttachInfoReq) XXX_DiscardUnknown 

func (m *GetAttachInfoReq) XXX_DiscardUnknown()

func (*GetAttachInfoReq) XXX_Marshal 

func (m *GetAttachInfoReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetAttachInfoReq) XXX_Merge 

func (dst *GetAttachInfoReq) XXX_Merge(src proto.Message)

func (*GetAttachInfoReq) XXX_Size 

func (m *GetAttachInfoReq) XXX_Size() int

func (*GetAttachInfoReq) XXX_Unmarshal 

func (m *GetAttachInfoReq) XXX_Unmarshal(b []byte) error

type GetAttachInfoResp 

type GetAttachInfoResp struct {
	Status               int32                    `protobuf:"varint,1,opt,name=status,proto3" json:"status,omitempty"`
	Psrs                 []*GetAttachInfoResp_Psr `protobuf:"bytes,2,rep,name=psrs,proto3" json:"psrs,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                 `json:"-"`
	XXX_unrecognized     []byte                   `json:"-"`
	XXX_sizecache        int32                    `json:"-"`
}

func (*GetAttachInfoResp) Descriptor 

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

func (*GetAttachInfoResp) GetPsrs 

func (m *GetAttachInfoResp) GetPsrs() []*GetAttachInfoResp_Psr

func (*GetAttachInfoResp) GetStatus 

func (m *GetAttachInfoResp) GetStatus() int32

func (*GetAttachInfoResp) ProtoMessage 

func (*GetAttachInfoResp) ProtoMessage()

func (*GetAttachInfoResp) Reset 

func (m *GetAttachInfoResp) Reset()

func (*GetAttachInfoResp) String 

func (m *GetAttachInfoResp) String() string

func (*GetAttachInfoResp) XXX_DiscardUnknown 

func (m *GetAttachInfoResp) XXX_DiscardUnknown()

func (*GetAttachInfoResp) XXX_Marshal 

func (m *GetAttachInfoResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetAttachInfoResp) XXX_Merge 

func (dst *GetAttachInfoResp) XXX_Merge(src proto.Message)

func (*GetAttachInfoResp) XXX_Size 

func (m *GetAttachInfoResp) XXX_Size() int

func (*GetAttachInfoResp) XXX_Unmarshal 

func (m *GetAttachInfoResp) XXX_Unmarshal(b []byte) error

type GetAttachInfoResp_Psr 

type GetAttachInfoResp_Psr 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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetAttachInfoResp_Psr) Descriptor 

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

func (*GetAttachInfoResp_Psr) GetRank 

func (m *GetAttachInfoResp_Psr) GetRank() uint32

func (*GetAttachInfoResp_Psr) GetUri 

func (m *GetAttachInfoResp_Psr) GetUri() string

func (*GetAttachInfoResp_Psr) ProtoMessage 

func (*GetAttachInfoResp_Psr) ProtoMessage()

func (*GetAttachInfoResp_Psr) Reset 

func (m *GetAttachInfoResp_Psr) Reset()

func (*GetAttachInfoResp_Psr) String 

func (m *GetAttachInfoResp_Psr) String() string

func (*GetAttachInfoResp_Psr) XXX_DiscardUnknown 

func (m *GetAttachInfoResp_Psr) XXX_DiscardUnknown()

func (*GetAttachInfoResp_Psr) XXX_Marshal 

func (m *GetAttachInfoResp_Psr) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetAttachInfoResp_Psr) XXX_Merge 

func (dst *GetAttachInfoResp_Psr) XXX_Merge(src proto.Message)

func (*GetAttachInfoResp_Psr) XXX_Size 

func (m *GetAttachInfoResp_Psr) XXX_Size() int

func (*GetAttachInfoResp_Psr) XXX_Unmarshal 

func (m *GetAttachInfoResp_Psr) XXX_Unmarshal(b []byte) error

type JoinReq 

type JoinReq struct {
	Uuid                 string   `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
	Rank                 uint32   `protobuf:"varint,2,opt,name=rank,proto3" json:"rank,omitempty"`
	Uri                  string   `protobuf:"bytes,3,opt,name=uri,proto3" json:"uri,omitempty"`
	Nctxs                uint32   `protobuf:"varint,4,opt,name=nctxs,proto3" json:"nctxs,omitempty"`
	Addr                 string   `protobuf:"bytes,5,opt,name=addr,proto3" json:"addr,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*JoinReq) Descriptor 

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

func (*JoinReq) GetAddr 

func (m *JoinReq) GetAddr() string

func (*JoinReq) GetNctxs 

func (m *JoinReq) GetNctxs() uint32

func (*JoinReq) GetRank 

func (m *JoinReq) GetRank() uint32

func (*JoinReq) GetUri 

func (m *JoinReq) GetUri() string

func (*JoinReq) GetUuid 

func (m *JoinReq) GetUuid() string

func (*JoinReq) ProtoMessage 

func (*JoinReq) ProtoMessage()

func (*JoinReq) Reset 

func (m *JoinReq) Reset()

func (*JoinReq) String 

func (m *JoinReq) String() string

func (*JoinReq) XXX_DiscardUnknown 

func (m *JoinReq) XXX_DiscardUnknown()

func (*JoinReq) XXX_Marshal 

func (m *JoinReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*JoinReq) XXX_Merge 

func (dst *JoinReq) XXX_Merge(src proto.Message)

func (*JoinReq) XXX_Size 

func (m *JoinReq) XXX_Size() int

func (*JoinReq) XXX_Unmarshal 

func (m *JoinReq) XXX_Unmarshal(b []byte) error

type JoinResp 

type JoinResp struct {
	Status               int32          `protobuf:"varint,1,opt,name=status,proto3" json:"status,omitempty"`
	Rank                 uint32         `protobuf:"varint,2,opt,name=rank,proto3" json:"rank,omitempty"`
	State                JoinResp_State `protobuf:"varint,3,opt,name=state,proto3,enum=mgmt.JoinResp_State" json:"state,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*JoinResp) Descriptor 

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

func (*JoinResp) GetRank 

func (m *JoinResp) GetRank() uint32

func (*JoinResp) GetState 

func (m *JoinResp) GetState() JoinResp_State

func (*JoinResp) GetStatus 

func (m *JoinResp) GetStatus() int32

func (*JoinResp) ProtoMessage 

func (*JoinResp) ProtoMessage()

func (*JoinResp) Reset 

func (m *JoinResp) Reset()

func (*JoinResp) String 

func (m *JoinResp) String() string

func (*JoinResp) XXX_DiscardUnknown 

func (m *JoinResp) XXX_DiscardUnknown()

func (*JoinResp) XXX_Marshal 

func (m *JoinResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*JoinResp) XXX_Merge 

func (dst *JoinResp) XXX_Merge(src proto.Message)

func (*JoinResp) XXX_Size 

func (m *JoinResp) XXX_Size() int

func (*JoinResp) XXX_Unmarshal 

func (m *JoinResp) XXX_Unmarshal(b []byte) error

type JoinResp_State 

type JoinResp_State int32
const (
	JoinResp_IN  JoinResp_State = 0
	JoinResp_OUT JoinResp_State = 1
)

func (JoinResp_State) EnumDescriptor 

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

func (JoinResp_State) String 

func (x JoinResp_State) String() string

type KillRankReq 

type KillRankReq struct {
	Force                bool     `protobuf:"varint,1,opt,name=force,proto3" json:"force,omitempty"`
	Rank                 uint32   `protobuf:"varint,2,opt,name=rank,proto3" json:"rank,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*KillRankReq) Descriptor 

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

func (*KillRankReq) GetForce 

func (m *KillRankReq) GetForce() bool

func (*KillRankReq) GetRank 

func (m *KillRankReq) GetRank() uint32

func (*KillRankReq) ProtoMessage 

func (*KillRankReq) ProtoMessage()

func (*KillRankReq) Reset 

func (m *KillRankReq) Reset()

func (*KillRankReq) String 

func (m *KillRankReq) String() string

func (*KillRankReq) XXX_DiscardUnknown 

func (m *KillRankReq) XXX_DiscardUnknown()

func (*KillRankReq) XXX_Marshal 

func (m *KillRankReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*KillRankReq) XXX_Merge 

func (dst *KillRankReq) XXX_Merge(src proto.Message)

func (*KillRankReq) XXX_Size 

func (m *KillRankReq) XXX_Size() int

func (*KillRankReq) XXX_Unmarshal 

func (m *KillRankReq) XXX_Unmarshal(b []byte) error

type LeaderQueryReq added in v0.8.0 

type LeaderQueryReq struct {
	System               string   `protobuf:"bytes,1,opt,name=system,proto3" json:"system,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*LeaderQueryReq) Descriptor added in v0.8.0 

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

func (*LeaderQueryReq) GetSystem added in v0.8.0 

func (m *LeaderQueryReq) GetSystem() string

func (*LeaderQueryReq) ProtoMessage added in v0.8.0 

func (*LeaderQueryReq) ProtoMessage()

func (*LeaderQueryReq) Reset added in v0.8.0 

func (m *LeaderQueryReq) Reset()

func (*LeaderQueryReq) String added in v0.8.0 

func (m *LeaderQueryReq) String() string

func (*LeaderQueryReq) XXX_DiscardUnknown added in v0.8.0 

func (m *LeaderQueryReq) XXX_DiscardUnknown()

func (*LeaderQueryReq) XXX_Marshal added in v0.8.0 

func (m *LeaderQueryReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LeaderQueryReq) XXX_Merge added in v0.8.0 

func (dst *LeaderQueryReq) XXX_Merge(src proto.Message)

func (*LeaderQueryReq) XXX_Size added in v0.8.0 

func (m *LeaderQueryReq) XXX_Size() int

func (*LeaderQueryReq) XXX_Unmarshal added in v0.8.0 

func (m *LeaderQueryReq) XXX_Unmarshal(b []byte) error

type LeaderQueryResp added in v0.8.0 

type LeaderQueryResp struct {
	CurrentLeader        string   `protobuf:"bytes,1,opt,name=currentLeader,proto3" json:"currentLeader,omitempty"`
	Replicas             []string `protobuf:"bytes,2,rep,name=replicas,proto3" json:"replicas,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*LeaderQueryResp) Descriptor added in v0.8.0 

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

func (*LeaderQueryResp) GetCurrentLeader added in v0.8.0 

func (m *LeaderQueryResp) GetCurrentLeader() string

func (*LeaderQueryResp) GetReplicas added in v0.8.0 

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

func (*LeaderQueryResp) ProtoMessage added in v0.8.0 

func (*LeaderQueryResp) ProtoMessage()

func (*LeaderQueryResp) Reset added in v0.8.0 

func (m *LeaderQueryResp) Reset()

func (*LeaderQueryResp) String added in v0.8.0 

func (m *LeaderQueryResp) String() string

func (*LeaderQueryResp) XXX_DiscardUnknown added in v0.8.0 

func (m *LeaderQueryResp) XXX_DiscardUnknown()

func (*LeaderQueryResp) XXX_Marshal added in v0.8.0 

func (m *LeaderQueryResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LeaderQueryResp) XXX_Merge added in v0.8.0 

func (dst *LeaderQueryResp) XXX_Merge(src proto.Message)

func (*LeaderQueryResp) XXX_Size added in v0.8.0 

func (m *LeaderQueryResp) XXX_Size() int

func (*LeaderQueryResp) XXX_Unmarshal added in v0.8.0 

func (m *LeaderQueryResp) XXX_Unmarshal(b []byte) error

type ListPoolsReq 

type ListPoolsReq struct {
	Sys                  string   `protobuf:"bytes,1,opt,name=sys,proto3" json:"sys,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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

func (*ListPoolsReq) Descriptor 

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

func (*ListPoolsReq) GetSys 

func (m *ListPoolsReq) GetSys() string

func (*ListPoolsReq) ProtoMessage 

func (*ListPoolsReq) ProtoMessage()

func (*ListPoolsReq) Reset 

func (m *ListPoolsReq) Reset()

func (*ListPoolsReq) String 

func (m *ListPoolsReq) String() string

func (*ListPoolsReq) XXX_DiscardUnknown 

func (m *ListPoolsReq) XXX_DiscardUnknown()

func (*ListPoolsReq) XXX_Marshal 

func (m *ListPoolsReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListPoolsReq) XXX_Merge 

func (dst *ListPoolsReq) XXX_Merge(src proto.Message)

func (*ListPoolsReq) XXX_Size 

func (m *ListPoolsReq) XXX_Size() int

func (*ListPoolsReq) XXX_Unmarshal 

func (m *ListPoolsReq) XXX_Unmarshal(b []byte) error

type ListPoolsResp 

type ListPoolsResp struct {
	Status               int32                 `protobuf:"varint,1,opt,name=status,proto3" json:"status,omitempty"`
	Pools                []*ListPoolsResp_Pool `protobuf:"bytes,2,rep,name=pools,proto3" json:"pools,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

ListPoolsResp returns the list of pools in the system.

func (*ListPoolsResp) Descriptor 

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

func (*ListPoolsResp) GetPools 

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

func (*ListPoolsResp) GetStatus 

func (m *ListPoolsResp) GetStatus() int32

func (*ListPoolsResp) ProtoMessage 

func (*ListPoolsResp) ProtoMessage()

func (*ListPoolsResp) Reset 

func (m *ListPoolsResp) Reset()

func (*ListPoolsResp) String 

func (m *ListPoolsResp) String() string

func (*ListPoolsResp) XXX_DiscardUnknown 

func (m *ListPoolsResp) XXX_DiscardUnknown()

func (*ListPoolsResp) XXX_Marshal 

func (m *ListPoolsResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListPoolsResp) XXX_Merge 

func (dst *ListPoolsResp) XXX_Merge(src proto.Message)

func (*ListPoolsResp) XXX_Size 

func (m *ListPoolsResp) XXX_Size() int

func (*ListPoolsResp) XXX_Unmarshal 

func (m *ListPoolsResp) XXX_Unmarshal(b []byte) error

type ListPoolsResp_Pool 

type ListPoolsResp_Pool struct {
	Uuid                 string   `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
	Svcreps              []uint32 `protobuf:"varint,2,rep,packed,name=svcreps,proto3" json:"svcreps,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ListPoolsResp_Pool) Descriptor 

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

func (*ListPoolsResp_Pool) GetSvcreps 

func (m *ListPoolsResp_Pool) GetSvcreps() []uint32

func (*ListPoolsResp_Pool) GetUuid 

func (m *ListPoolsResp_Pool) GetUuid() string

func (*ListPoolsResp_Pool) ProtoMessage 

func (*ListPoolsResp_Pool) ProtoMessage()

func (*ListPoolsResp_Pool) Reset 

func (m *ListPoolsResp_Pool) Reset()

func (*ListPoolsResp_Pool) String 

func (m *ListPoolsResp_Pool) String() string

func (*ListPoolsResp_Pool) XXX_DiscardUnknown 

func (m *ListPoolsResp_Pool) XXX_DiscardUnknown()

func (*ListPoolsResp_Pool) XXX_Marshal 

func (m *ListPoolsResp_Pool) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListPoolsResp_Pool) XXX_Merge 

func (dst *ListPoolsResp_Pool) XXX_Merge(src proto.Message)

func (*ListPoolsResp_Pool) XXX_Size 

func (m *ListPoolsResp_Pool) XXX_Size() int

func (*ListPoolsResp_Pool) XXX_Unmarshal 

func (m *ListPoolsResp_Pool) XXX_Unmarshal(b []byte) error

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)
	// 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)
	// 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)
	// Get BIO device health information.
	BioHealthQuery(ctx context.Context, in *BioHealthReq, opts ...grpc.CallOption) (*BioHealthResp, error)
	// Get SMD device list.
	SmdListDevs(ctx context.Context, in *SmdDevReq, opts ...grpc.CallOption) (*SmdDevResp, error)
	// Get SMD pool list.
	SmdListPools(ctx context.Context, in *SmdPoolReq, opts ...grpc.CallOption) (*SmdPoolResp, error)
	// Prepare DAOS IO server identified by rank for controlled shutdown.
	PrepShutdown(ctx context.Context, in *PrepShutdownReq, opts ...grpc.CallOption) (*DaosResp, error)
	// Kill DAOS IO server identified by rank.
	KillRank(ctx context.Context, in *KillRankReq, opts ...grpc.CallOption) (*DaosResp, error)
	// List all pools in a DAOS system: basic info: UUIDs, service ranks.
	ListPools(ctx context.Context, in *ListPoolsReq, opts ...grpc.CallOption) (*ListPoolsResp, error)
}

MgmtSvcClient is the client API for MgmtSvc service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewMgmtSvcClient 

func NewMgmtSvcClient(cc *grpc.ClientConn) MgmtSvcClient

type MgmtSvcServer 

type MgmtSvcServer interface {
	// Join the server described by JoinReq to the system.
	Join(context.Context, *JoinReq) (*JoinResp, 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)
	// 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)
	// Get BIO device health information.
	BioHealthQuery(context.Context, *BioHealthReq) (*BioHealthResp, error)
	// Get SMD device list.
	SmdListDevs(context.Context, *SmdDevReq) (*SmdDevResp, error)
	// Get SMD pool list.
	SmdListPools(context.Context, *SmdPoolReq) (*SmdPoolResp, error)
	// Prepare DAOS IO server identified by rank for controlled shutdown.
	PrepShutdown(context.Context, *PrepShutdownReq) (*DaosResp, error)
	// Kill DAOS IO server identified by rank.
	KillRank(context.Context, *KillRankReq) (*DaosResp, error)
	// List all pools in a DAOS system: basic info: UUIDs, service ranks.
	ListPools(context.Context, *ListPoolsReq) (*ListPoolsResp, error)
}

MgmtSvcServer is the server API for MgmtSvc service.

type ModifyACLReq 

type ModifyACLReq struct {
	Uuid                 string   `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
	ACL                  []string `protobuf:"bytes,2,rep,name=ACL,proto3" json:"ACL,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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

func (*ModifyACLReq) Descriptor 

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

func (*ModifyACLReq) GetACL 

func (m *ModifyACLReq) GetACL() []string

func (*ModifyACLReq) GetUuid 

func (m *ModifyACLReq) GetUuid() string

func (*ModifyACLReq) ProtoMessage 

func (*ModifyACLReq) ProtoMessage()

func (*ModifyACLReq) Reset 

func (m *ModifyACLReq) Reset()

func (*ModifyACLReq) String 

func (m *ModifyACLReq) String() string

func (*ModifyACLReq) XXX_DiscardUnknown 

func (m *ModifyACLReq) XXX_DiscardUnknown()

func (*ModifyACLReq) XXX_Marshal 

func (m *ModifyACLReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ModifyACLReq) XXX_Merge 

func (dst *ModifyACLReq) XXX_Merge(src proto.Message)

func (*ModifyACLReq) XXX_Size 

func (m *ModifyACLReq) XXX_Size() int

func (*ModifyACLReq) XXX_Unmarshal 

func (m *ModifyACLReq) XXX_Unmarshal(b []byte) error

type PoolCreateReq 

type PoolCreateReq struct {
	Scmbytes             uint64   `protobuf:"varint,1,opt,name=scmbytes,proto3" json:"scmbytes,omitempty"`
	Nvmebytes            uint64   `protobuf:"varint,2,opt,name=nvmebytes,proto3" json:"nvmebytes,omitempty"`
	Ranks                []uint32 `protobuf:"varint,3,rep,packed,name=ranks,proto3" json:"ranks,omitempty"`
	Numsvcreps           uint32   `protobuf:"varint,4,opt,name=numsvcreps,proto3" json:"numsvcreps,omitempty"`
	User                 string   `protobuf:"bytes,5,opt,name=user,proto3" json:"user,omitempty"`
	Usergroup            string   `protobuf:"bytes,6,opt,name=usergroup,proto3" json:"usergroup,omitempty"`
	Uuid                 string   `protobuf:"bytes,7,opt,name=uuid,proto3" json:"uuid,omitempty"`
	Sys                  string   `protobuf:"bytes,8,opt,name=sys,proto3" json:"sys,omitempty"`
	Acl                  []string `protobuf:"bytes,9,rep,name=acl,proto3" json:"acl,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

PoolCreateReq supplies new pool parameters.

func (*PoolCreateReq) Descriptor 

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

func (*PoolCreateReq) GetAcl 

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

func (*PoolCreateReq) GetNumsvcreps 

func (m *PoolCreateReq) GetNumsvcreps() uint32

func (*PoolCreateReq) GetNvmebytes 

func (m *PoolCreateReq) GetNvmebytes() uint64

func (*PoolCreateReq) GetRanks 

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

func (*PoolCreateReq) GetScmbytes 

func (m *PoolCreateReq) GetScmbytes() uint64

func (*PoolCreateReq) GetSys 

func (m *PoolCreateReq) GetSys() string

func (*PoolCreateReq) GetUser 

func (m *PoolCreateReq) GetUser() string

func (*PoolCreateReq) GetUsergroup 

func (m *PoolCreateReq) GetUsergroup() string

func (*PoolCreateReq) GetUuid 

func (m *PoolCreateReq) GetUuid() string

func (*PoolCreateReq) ProtoMessage 

func (*PoolCreateReq) ProtoMessage()

func (*PoolCreateReq) Reset 

func (m *PoolCreateReq) Reset()

func (*PoolCreateReq) String 

func (m *PoolCreateReq) String() string

func (*PoolCreateReq) XXX_DiscardUnknown 

func (m *PoolCreateReq) XXX_DiscardUnknown()

func (*PoolCreateReq) XXX_Marshal 

func (m *PoolCreateReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PoolCreateReq) XXX_Merge 

func (dst *PoolCreateReq) XXX_Merge(src proto.Message)

func (*PoolCreateReq) XXX_Size 

func (m *PoolCreateReq) XXX_Size() int

func (*PoolCreateReq) XXX_Unmarshal 

func (m *PoolCreateReq) XXX_Unmarshal(b []byte) error

type PoolCreateResp 

type PoolCreateResp struct {
	Status               int32    `protobuf:"varint,1,opt,name=status,proto3" json:"status,omitempty"`
	Svcreps              []uint32 `protobuf:"varint,2,rep,packed,name=svcreps,proto3" json:"svcreps,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

PoolCreateResp returns created pool uuid and ranks.

func (*PoolCreateResp) Descriptor 

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

func (*PoolCreateResp) GetStatus 

func (m *PoolCreateResp) GetStatus() int32

func (*PoolCreateResp) GetSvcreps 

func (m *PoolCreateResp) GetSvcreps() []uint32

func (*PoolCreateResp) ProtoMessage 

func (*PoolCreateResp) ProtoMessage()

func (*PoolCreateResp) Reset 

func (m *PoolCreateResp) Reset()

func (*PoolCreateResp) String 

func (m *PoolCreateResp) String() string

func (*PoolCreateResp) XXX_DiscardUnknown 

func (m *PoolCreateResp) XXX_DiscardUnknown()

func (*PoolCreateResp) XXX_Marshal 

func (m *PoolCreateResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PoolCreateResp) XXX_Merge 

func (dst *PoolCreateResp) XXX_Merge(src proto.Message)

func (*PoolCreateResp) XXX_Size 

func (m *PoolCreateResp) XXX_Size() int

func (*PoolCreateResp) XXX_Unmarshal 

func (m *PoolCreateResp) XXX_Unmarshal(b []byte) error

type PoolDestroyReq 

type PoolDestroyReq struct {
	Uuid                 string   `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
	Sys                  string   `protobuf:"bytes,2,opt,name=sys,proto3" json:"sys,omitempty"`
	Force                bool     `protobuf:"varint,3,opt,name=force,proto3" json:"force,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

PoolDestroyReq supplies pool identifier and force flag.

func (*PoolDestroyReq) Descriptor 

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

func (*PoolDestroyReq) GetForce 

func (m *PoolDestroyReq) GetForce() bool

func (*PoolDestroyReq) GetSys 

func (m *PoolDestroyReq) GetSys() string

func (*PoolDestroyReq) GetUuid 

func (m *PoolDestroyReq) GetUuid() string

func (*PoolDestroyReq) ProtoMessage 

func (*PoolDestroyReq) ProtoMessage()

func (*PoolDestroyReq) Reset 

func (m *PoolDestroyReq) Reset()

func (*PoolDestroyReq) String 

func (m *PoolDestroyReq) String() string

func (*PoolDestroyReq) XXX_DiscardUnknown 

func (m *PoolDestroyReq) XXX_DiscardUnknown()

func (*PoolDestroyReq) XXX_Marshal 

func (m *PoolDestroyReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PoolDestroyReq) XXX_Merge 

func (dst *PoolDestroyReq) XXX_Merge(src proto.Message)

func (*PoolDestroyReq) XXX_Size 

func (m *PoolDestroyReq) XXX_Size() int

func (*PoolDestroyReq) XXX_Unmarshal 

func (m *PoolDestroyReq) XXX_Unmarshal(b []byte) error

type PoolDestroyResp 

type PoolDestroyResp struct {
	Status               int32    `protobuf:"varint,1,opt,name=status,proto3" json:"status,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

PoolDestroyResp returns resultant state of destroy operation.

func (*PoolDestroyResp) Descriptor 

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

func (*PoolDestroyResp) GetStatus 

func (m *PoolDestroyResp) GetStatus() int32

func (*PoolDestroyResp) ProtoMessage 

func (*PoolDestroyResp) ProtoMessage()

func (*PoolDestroyResp) Reset 

func (m *PoolDestroyResp) Reset()

func (*PoolDestroyResp) String 

func (m *PoolDestroyResp) String() string

func (*PoolDestroyResp) XXX_DiscardUnknown 

func (m *PoolDestroyResp) XXX_DiscardUnknown()

func (*PoolDestroyResp) XXX_Marshal 

func (m *PoolDestroyResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PoolDestroyResp) XXX_Merge 

func (dst *PoolDestroyResp) XXX_Merge(src proto.Message)

func (*PoolDestroyResp) XXX_Size 

func (m *PoolDestroyResp) XXX_Size() int

func (*PoolDestroyResp) XXX_Unmarshal 

func (m *PoolDestroyResp) XXX_Unmarshal(b []byte) error

type PrepShutdownReq added in v0.8.0 

type PrepShutdownReq struct {
	Rank                 uint32   `protobuf:"varint,1,opt,name=rank,proto3" json:"rank,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PrepShutdownReq) Descriptor added in v0.8.0 

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

func (*PrepShutdownReq) GetRank added in v0.8.0 

func (m *PrepShutdownReq) GetRank() uint32

func (*PrepShutdownReq) ProtoMessage added in v0.8.0 

func (*PrepShutdownReq) ProtoMessage()

func (*PrepShutdownReq) Reset added in v0.8.0 

func (m *PrepShutdownReq) Reset()

func (*PrepShutdownReq) String added in v0.8.0 

func (m *PrepShutdownReq) String() string

func (*PrepShutdownReq) XXX_DiscardUnknown added in v0.8.0 

func (m *PrepShutdownReq) XXX_DiscardUnknown()

func (*PrepShutdownReq) XXX_Marshal added in v0.8.0 

func (m *PrepShutdownReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PrepShutdownReq) XXX_Merge added in v0.8.0 

func (dst *PrepShutdownReq) XXX_Merge(src proto.Message)

func (*PrepShutdownReq) XXX_Size added in v0.8.0 

func (m *PrepShutdownReq) XXX_Size() int

func (*PrepShutdownReq) XXX_Unmarshal added in v0.8.0 

func (m *PrepShutdownReq) XXX_Unmarshal(b []byte) error

type SetRankReq 

type SetRankReq struct {
	Rank                 uint32   `protobuf:"varint,1,opt,name=rank,proto3" json:"rank,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SetRankReq) Descriptor 

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

func (*SetRankReq) GetRank 

func (m *SetRankReq) GetRank() uint32

func (*SetRankReq) ProtoMessage 

func (*SetRankReq) ProtoMessage()

func (*SetRankReq) Reset 

func (m *SetRankReq) Reset()

func (*SetRankReq) String 

func (m *SetRankReq) String() string

func (*SetRankReq) XXX_DiscardUnknown 

func (m *SetRankReq) XXX_DiscardUnknown()

func (*SetRankReq) XXX_Marshal 

func (m *SetRankReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SetRankReq) XXX_Merge 

func (dst *SetRankReq) XXX_Merge(src proto.Message)

func (*SetRankReq) XXX_Size 

func (m *SetRankReq) XXX_Size() int

func (*SetRankReq) XXX_Unmarshal 

func (m *SetRankReq) XXX_Unmarshal(b []byte) error

type SmdDevReq 

type SmdDevReq struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SmdDevReq) Descriptor 

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

func (*SmdDevReq) ProtoMessage 

func (*SmdDevReq) ProtoMessage()

func (*SmdDevReq) Reset 

func (m *SmdDevReq) Reset()

func (*SmdDevReq) String 

func (m *SmdDevReq) String() string

func (*SmdDevReq) XXX_DiscardUnknown 

func (m *SmdDevReq) XXX_DiscardUnknown()

func (*SmdDevReq) XXX_Marshal 

func (m *SmdDevReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SmdDevReq) XXX_Merge 

func (dst *SmdDevReq) XXX_Merge(src proto.Message)

func (*SmdDevReq) XXX_Size 

func (m *SmdDevReq) XXX_Size() int

func (*SmdDevReq) XXX_Unmarshal 

func (m *SmdDevReq) XXX_Unmarshal(b []byte) error

type SmdDevResp 

type SmdDevResp struct {
	Status               int32                `protobuf:"varint,1,opt,name=status,proto3" json:"status,omitempty"`
	Devices              []*SmdDevResp_Device `protobuf:"bytes,2,rep,name=devices,proto3" json:"devices,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*SmdDevResp) Descriptor 

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

func (*SmdDevResp) GetDevices 

func (m *SmdDevResp) GetDevices() []*SmdDevResp_Device

func (*SmdDevResp) GetStatus 

func (m *SmdDevResp) GetStatus() int32

func (*SmdDevResp) ProtoMessage 

func (*SmdDevResp) ProtoMessage()

func (*SmdDevResp) Reset 

func (m *SmdDevResp) Reset()

func (*SmdDevResp) String 

func (m *SmdDevResp) String() string

func (*SmdDevResp) XXX_DiscardUnknown 

func (m *SmdDevResp) XXX_DiscardUnknown()

func (*SmdDevResp) XXX_Marshal 

func (m *SmdDevResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SmdDevResp) XXX_Merge 

func (dst *SmdDevResp) XXX_Merge(src proto.Message)

func (*SmdDevResp) XXX_Size 

func (m *SmdDevResp) XXX_Size() int

func (*SmdDevResp) XXX_Unmarshal 

func (m *SmdDevResp) XXX_Unmarshal(b []byte) error

type SmdDevResp_Device 

type SmdDevResp_Device struct {
	Uuid                 string   `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
	TgtIds               []int32  `protobuf:"varint,2,rep,packed,name=tgt_ids,json=tgtIds,proto3" json:"tgt_ids,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SmdDevResp_Device) Descriptor 

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

func (*SmdDevResp_Device) GetTgtIds 

func (m *SmdDevResp_Device) GetTgtIds() []int32

func (*SmdDevResp_Device) GetUuid 

func (m *SmdDevResp_Device) GetUuid() string

func (*SmdDevResp_Device) ProtoMessage 

func (*SmdDevResp_Device) ProtoMessage()

func (*SmdDevResp_Device) Reset 

func (m *SmdDevResp_Device) Reset()

func (*SmdDevResp_Device) String 

func (m *SmdDevResp_Device) String() string

func (*SmdDevResp_Device) XXX_DiscardUnknown 

func (m *SmdDevResp_Device) XXX_DiscardUnknown()

func (*SmdDevResp_Device) XXX_Marshal 

func (m *SmdDevResp_Device) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SmdDevResp_Device) XXX_Merge 

func (dst *SmdDevResp_Device) XXX_Merge(src proto.Message)

func (*SmdDevResp_Device) XXX_Size 

func (m *SmdDevResp_Device) XXX_Size() int

func (*SmdDevResp_Device) XXX_Unmarshal 

func (m *SmdDevResp_Device) XXX_Unmarshal(b []byte) error

type SmdPoolReq 

type SmdPoolReq struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SmdPoolReq) Descriptor 

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

func (*SmdPoolReq) ProtoMessage 

func (*SmdPoolReq) ProtoMessage()

func (*SmdPoolReq) Reset 

func (m *SmdPoolReq) Reset()

func (*SmdPoolReq) String 

func (m *SmdPoolReq) String() string

func (*SmdPoolReq) XXX_DiscardUnknown 

func (m *SmdPoolReq) XXX_DiscardUnknown()

func (*SmdPoolReq) XXX_Marshal 

func (m *SmdPoolReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SmdPoolReq) XXX_Merge 

func (dst *SmdPoolReq) XXX_Merge(src proto.Message)

func (*SmdPoolReq) XXX_Size 

func (m *SmdPoolReq) XXX_Size() int

func (*SmdPoolReq) XXX_Unmarshal 

func (m *SmdPoolReq) XXX_Unmarshal(b []byte) error

type SmdPoolResp 

type SmdPoolResp struct {
	Status               int32               `protobuf:"varint,1,opt,name=status,proto3" json:"status,omitempty"`
	Pools                []*SmdPoolResp_Pool `protobuf:"bytes,2,rep,name=pools,proto3" json:"pools,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*SmdPoolResp) Descriptor 

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

func (*SmdPoolResp) GetPools 

func (m *SmdPoolResp) GetPools() []*SmdPoolResp_Pool

func (*SmdPoolResp) GetStatus 

func (m *SmdPoolResp) GetStatus() int32

func (*SmdPoolResp) ProtoMessage 

func (*SmdPoolResp) ProtoMessage()

func (*SmdPoolResp) Reset 

func (m *SmdPoolResp) Reset()

func (*SmdPoolResp) String 

func (m *SmdPoolResp) String() string

func (*SmdPoolResp) XXX_DiscardUnknown 

func (m *SmdPoolResp) XXX_DiscardUnknown()

func (*SmdPoolResp) XXX_Marshal 

func (m *SmdPoolResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SmdPoolResp) XXX_Merge 

func (dst *SmdPoolResp) XXX_Merge(src proto.Message)

func (*SmdPoolResp) XXX_Size 

func (m *SmdPoolResp) XXX_Size() int

func (*SmdPoolResp) XXX_Unmarshal 

func (m *SmdPoolResp) XXX_Unmarshal(b []byte) error

type SmdPoolResp_Pool 

type SmdPoolResp_Pool struct {
	Uuid                 string   `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
	TgtIds               []int32  `protobuf:"varint,2,rep,packed,name=tgt_ids,json=tgtIds,proto3" json:"tgt_ids,omitempty"`
	Blobs                []uint64 `protobuf:"varint,3,rep,packed,name=blobs,proto3" json:"blobs,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SmdPoolResp_Pool) Descriptor 

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

func (*SmdPoolResp_Pool) GetBlobs 

func (m *SmdPoolResp_Pool) GetBlobs() []uint64

func (*SmdPoolResp_Pool) GetTgtIds 

func (m *SmdPoolResp_Pool) GetTgtIds() []int32

func (*SmdPoolResp_Pool) GetUuid 

func (m *SmdPoolResp_Pool) GetUuid() string

func (*SmdPoolResp_Pool) ProtoMessage 

func (*SmdPoolResp_Pool) ProtoMessage()

func (*SmdPoolResp_Pool) Reset 

func (m *SmdPoolResp_Pool) Reset()

func (*SmdPoolResp_Pool) String 

func (m *SmdPoolResp_Pool) String() string

func (*SmdPoolResp_Pool) XXX_DiscardUnknown 

func (m *SmdPoolResp_Pool) XXX_DiscardUnknown()

func (*SmdPoolResp_Pool) XXX_Marshal 

func (m *SmdPoolResp_Pool) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SmdPoolResp_Pool) XXX_Merge 

func (dst *SmdPoolResp_Pool) XXX_Merge(src proto.Message)

func (*SmdPoolResp_Pool) XXX_Size 

func (m *SmdPoolResp_Pool) XXX_Size() int

func (*SmdPoolResp_Pool) XXX_Unmarshal 

func (m *SmdPoolResp_Pool) XXX_Unmarshal(b []byte) error

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.