mgmt

package
v1.0.0 Latest Latest
Warning

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

 Go to latest Published: Jun 12, 2020 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Overview

(C) Copyright 2019 Intel Corporation.

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at 

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

GOVERNMENT LICENSE RIGHTS-OPEN SOURCE SOFTWARE The Government's rights to use, modify, reproduce, release, perform, display, or disclose this software are subject to the terms of the Apache License as provided in Contract No. 8F-30005. Any reproduction of computer software, computer software documentation, or portions thereof marked with this legend must also reproduce the markings.

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,
}
View Source 
var PoolRebuildStatus_State_name = map[int32]string{
	0: "IDLE",
	1: "DONE",
	2: "BUSY",
}
View Source 
var PoolRebuildStatus_State_value = map[string]int32{
	"IDLE": 0,
	"DONE": 1,
	"BUSY": 2,
}

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"`
	OwnerUser            string   `protobuf:"bytes,3,opt,name=ownerUser,proto3" json:"ownerUser,omitempty"`
	OwnerGroup           string   `protobuf:"bytes,4,opt,name=ownerGroup,proto3" json:"ownerGroup,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) GetOwnerGroup added in v0.9.0 

func (m *ACLResp) GetOwnerGroup() string

func (*ACLResp) GetOwnerUser added in v0.9.0 

func (m *ACLResp) GetOwnerUser() 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 (m *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 (m *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 (m *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 (m *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 (m *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 (m *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 DevStateReq added in v0.9.0 

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

func (*DevStateReq) Descriptor added in v0.9.0 

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

func (*DevStateReq) GetDevUuid added in v0.9.0 

func (m *DevStateReq) GetDevUuid() string

func (*DevStateReq) ProtoMessage added in v0.9.0 

func (*DevStateReq) ProtoMessage()

func (*DevStateReq) Reset added in v0.9.0 

func (m *DevStateReq) Reset()

func (*DevStateReq) String added in v0.9.0 

func (m *DevStateReq) String() string

func (*DevStateReq) XXX_DiscardUnknown added in v0.9.0 

func (m *DevStateReq) XXX_DiscardUnknown()

func (*DevStateReq) XXX_Marshal added in v0.9.0 

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

func (*DevStateReq) XXX_Merge added in v0.9.0 

func (m *DevStateReq) XXX_Merge(src proto.Message)

func (*DevStateReq) XXX_Size added in v0.9.0 

func (m *DevStateReq) XXX_Size() int

func (*DevStateReq) XXX_Unmarshal added in v0.9.0 

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

type DevStateResp added in v0.9.0 

type DevStateResp 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"`
	DevState             string   `protobuf:"bytes,3,opt,name=dev_state,json=devState,proto3" json:"dev_state,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DevStateResp) Descriptor added in v0.9.0 

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

func (*DevStateResp) GetDevState added in v0.9.0 

func (m *DevStateResp) GetDevState() string

func (*DevStateResp) GetDevUuid added in v0.9.0 

func (m *DevStateResp) GetDevUuid() string

func (*DevStateResp) GetStatus added in v0.9.0 

func (m *DevStateResp) GetStatus() int32

func (*DevStateResp) ProtoMessage added in v0.9.0 

func (*DevStateResp) ProtoMessage()

func (*DevStateResp) Reset added in v0.9.0 

func (m *DevStateResp) Reset()

func (*DevStateResp) String added in v0.9.0 

func (m *DevStateResp) String() string

func (*DevStateResp) XXX_DiscardUnknown added in v0.9.0 

func (m *DevStateResp) XXX_DiscardUnknown()

func (*DevStateResp) XXX_Marshal added in v0.9.0 

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

func (*DevStateResp) XXX_Merge added in v0.9.0 

func (m *DevStateResp) XXX_Merge(src proto.Message)

func (*DevStateResp) XXX_Size added in v0.9.0 

func (m *DevStateResp) XXX_Size() int

func (*DevStateResp) XXX_Unmarshal added in v0.9.0 

func (m *DevStateResp) 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 (m *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 (m *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 (m *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 (m *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 (m *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 (m *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 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 (m *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 (m *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 ListContReq added in v0.9.0 

type ListContReq 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:"-"`
}

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

func (*ListContReq) Descriptor added in v0.9.0 

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

func (*ListContReq) GetUuid added in v0.9.0 

func (m *ListContReq) GetUuid() string

func (*ListContReq) ProtoMessage added in v0.9.0 

func (*ListContReq) ProtoMessage()

func (*ListContReq) Reset added in v0.9.0 

func (m *ListContReq) Reset()

func (*ListContReq) String added in v0.9.0 

func (m *ListContReq) String() string

func (*ListContReq) XXX_DiscardUnknown added in v0.9.0 

func (m *ListContReq) XXX_DiscardUnknown()

func (*ListContReq) XXX_Marshal added in v0.9.0 

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

func (*ListContReq) XXX_Merge added in v0.9.0 

func (m *ListContReq) XXX_Merge(src proto.Message)

func (*ListContReq) XXX_Size added in v0.9.0 

func (m *ListContReq) XXX_Size() int

func (*ListContReq) XXX_Unmarshal added in v0.9.0 

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

type ListContResp added in v0.9.0 

type ListContResp struct {
	Status               int32                `protobuf:"varint,1,opt,name=status,proto3" json:"status,omitempty"`
	Containers           []*ListContResp_Cont `protobuf:"bytes,2,rep,name=containers,proto3" json:"containers,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*ListContResp) Descriptor added in v0.9.0 

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

func (*ListContResp) GetContainers added in v0.9.0 

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

func (*ListContResp) GetStatus added in v0.9.0 

func (m *ListContResp) GetStatus() int32

func (*ListContResp) ProtoMessage added in v0.9.0 

func (*ListContResp) ProtoMessage()

func (*ListContResp) Reset added in v0.9.0 

func (m *ListContResp) Reset()

func (*ListContResp) String added in v0.9.0 

func (m *ListContResp) String() string

func (*ListContResp) XXX_DiscardUnknown added in v0.9.0 

func (m *ListContResp) XXX_DiscardUnknown()

func (*ListContResp) XXX_Marshal added in v0.9.0 

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

func (*ListContResp) XXX_Merge added in v0.9.0 

func (m *ListContResp) XXX_Merge(src proto.Message)

func (*ListContResp) XXX_Size added in v0.9.0 

func (m *ListContResp) XXX_Size() int

func (*ListContResp) XXX_Unmarshal added in v0.9.0 

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

type ListContResp_Cont added in v0.9.0 

type ListContResp_Cont 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:"-"`
}

func (*ListContResp_Cont) Descriptor added in v0.9.0 

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

func (*ListContResp_Cont) GetUuid added in v0.9.0 

func (m *ListContResp_Cont) GetUuid() string

func (*ListContResp_Cont) ProtoMessage added in v0.9.0 

func (*ListContResp_Cont) ProtoMessage()

func (*ListContResp_Cont) Reset added in v0.9.0 

func (m *ListContResp_Cont) Reset()

func (*ListContResp_Cont) String added in v0.9.0 

func (m *ListContResp_Cont) String() string

func (*ListContResp_Cont) XXX_DiscardUnknown added in v0.9.0 

func (m *ListContResp_Cont) XXX_DiscardUnknown()

func (*ListContResp_Cont) XXX_Marshal added in v0.9.0 

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

func (*ListContResp_Cont) XXX_Merge added in v0.9.0 

func (m *ListContResp_Cont) XXX_Merge(src proto.Message)

func (*ListContResp_Cont) XXX_Size added in v0.9.0 

func (m *ListContResp_Cont) XXX_Size() int

func (*ListContResp_Cont) XXX_Unmarshal added in v0.9.0 

func (m *ListContResp_Cont) 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 (m *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 (m *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 (m *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)
	// PoolQuery queries a DAOS pool.
	PoolQuery(ctx context.Context, in *PoolQueryReq, opts ...grpc.CallOption) (*PoolQueryResp, error)
	// Set a DAOS pool property.
	PoolSetProp(ctx context.Context, in *PoolSetPropReq, opts ...grpc.CallOption) (*PoolSetPropResp, 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)
	// List all pools in a DAOS system: basic info: UUIDs, service ranks.
	ListPools(ctx context.Context, in *ListPoolsReq, opts ...grpc.CallOption) (*ListPoolsResp, error)
	// Get the current state of the device
	DevStateQuery(ctx context.Context, in *DevStateReq, opts ...grpc.CallOption) (*DevStateResp, error)
	// Set the device state of an NVMe SSD to FAULTY
	StorageSetFaulty(ctx context.Context, in *DevStateReq, opts ...grpc.CallOption) (*DevStateResp, error)
	// List all containers in a pool
	ListContainers(ctx context.Context, in *ListContReq, opts ...grpc.CallOption) (*ListContResp, error)
	// Prepare DAOS IO servers on a host for controlled shutdown. (gRPC fanout)
	PrepShutdownRanks(ctx context.Context, in *RanksReq, opts ...grpc.CallOption) (*RanksResp, error)
	// Stop DAOS IO servers on a host. (gRPC fanout)
	StopRanks(ctx context.Context, in *RanksReq, opts ...grpc.CallOption) (*RanksResp, error)
	// Ping DAOS IO servers on a host. (gRPC fanout)
	PingRanks(ctx context.Context, in *RanksReq, opts ...grpc.CallOption) (*RanksResp, error)
	// Start DAOS IO servers on a host. (gRPC fanout)
	StartRanks(ctx context.Context, in *RanksReq, opts ...grpc.CallOption) (*RanksResp, 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)
	// PoolQuery queries a DAOS pool.
	PoolQuery(context.Context, *PoolQueryReq) (*PoolQueryResp, error)
	// Set a DAOS pool property.
	PoolSetProp(context.Context, *PoolSetPropReq) (*PoolSetPropResp, 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)
	// List all pools in a DAOS system: basic info: UUIDs, service ranks.
	ListPools(context.Context, *ListPoolsReq) (*ListPoolsResp, error)
	// Get the current state of the device
	DevStateQuery(context.Context, *DevStateReq) (*DevStateResp, error)
	// Set the device state of an NVMe SSD to FAULTY
	StorageSetFaulty(context.Context, *DevStateReq) (*DevStateResp, error)
	// List all containers in a pool
	ListContainers(context.Context, *ListContReq) (*ListContResp, error)
	// Prepare DAOS IO servers on a host for controlled shutdown. (gRPC fanout)
	PrepShutdownRanks(context.Context, *RanksReq) (*RanksResp, error)
	// Stop DAOS IO servers on a host. (gRPC fanout)
	StopRanks(context.Context, *RanksReq) (*RanksResp, error)
	// Ping DAOS IO servers on a host. (gRPC fanout)
	PingRanks(context.Context, *RanksReq) (*RanksResp, error)
	// Start DAOS IO servers on a host. (gRPC fanout)
	StartRanks(context.Context, *RanksReq) (*RanksResp, 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 (m *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 PingRankReq added in v0.9.0 

type PingRankReq 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 (*PingRankReq) Descriptor added in v0.9.0 

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

func (*PingRankReq) GetRank added in v0.9.0 

func (m *PingRankReq) GetRank() uint32

func (*PingRankReq) ProtoMessage added in v0.9.0 

func (*PingRankReq) ProtoMessage()

func (*PingRankReq) Reset added in v0.9.0 

func (m *PingRankReq) Reset()

func (*PingRankReq) String added in v0.9.0 

func (m *PingRankReq) String() string

func (*PingRankReq) XXX_DiscardUnknown added in v0.9.0 

func (m *PingRankReq) XXX_DiscardUnknown()

func (*PingRankReq) XXX_Marshal added in v0.9.0 

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

func (*PingRankReq) XXX_Merge added in v0.9.0 

func (m *PingRankReq) XXX_Merge(src proto.Message)

func (*PingRankReq) XXX_Size added in v0.9.0 

func (m *PingRankReq) XXX_Size() int

func (*PingRankReq) XXX_Unmarshal added in v0.9.0 

func (m *PingRankReq) 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 (m *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 (m *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 (m *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 (m *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 PoolQueryReq added in v0.9.0 

type PoolQueryReq 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:"-"`
}

PoolQueryReq represents a pool query request.

func (*PoolQueryReq) Descriptor added in v0.9.0 

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

func (*PoolQueryReq) GetUuid added in v0.9.0 

func (m *PoolQueryReq) GetUuid() string

func (*PoolQueryReq) ProtoMessage added in v0.9.0 

func (*PoolQueryReq) ProtoMessage()

func (*PoolQueryReq) Reset added in v0.9.0 

func (m *PoolQueryReq) Reset()

func (*PoolQueryReq) String added in v0.9.0 

func (m *PoolQueryReq) String() string

func (*PoolQueryReq) XXX_DiscardUnknown added in v0.9.0 

func (m *PoolQueryReq) XXX_DiscardUnknown()

func (*PoolQueryReq) XXX_Marshal added in v0.9.0 

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

func (*PoolQueryReq) XXX_Merge added in v0.9.0 

func (m *PoolQueryReq) XXX_Merge(src proto.Message)

func (*PoolQueryReq) XXX_Size added in v0.9.0 

func (m *PoolQueryReq) XXX_Size() int

func (*PoolQueryReq) XXX_Unmarshal added in v0.9.0 

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

type PoolQueryResp added in v0.9.0 

type PoolQueryResp struct {
	Status               int32              `protobuf:"varint,1,opt,name=status,proto3" json:"status,omitempty"`
	Uuid                 string             `protobuf:"bytes,2,opt,name=uuid,proto3" json:"uuid,omitempty"`
	Totaltargets         uint32             `protobuf:"varint,3,opt,name=totaltargets,proto3" json:"totaltargets,omitempty"`
	Activetargets        uint32             `protobuf:"varint,4,opt,name=activetargets,proto3" json:"activetargets,omitempty"`
	Disabledtargets      uint32             `protobuf:"varint,5,opt,name=disabledtargets,proto3" json:"disabledtargets,omitempty"`
	Rebuild              *PoolRebuildStatus `protobuf:"bytes,6,opt,name=rebuild,proto3" json:"rebuild,omitempty"`
	Scm                  *StorageUsageStats `protobuf:"bytes,7,opt,name=scm,proto3" json:"scm,omitempty"`
	Nvme                 *StorageUsageStats `protobuf:"bytes,8,opt,name=nvme,proto3" json:"nvme,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

PoolQueryResp represents a pool query response.

func (*PoolQueryResp) Descriptor added in v0.9.0 

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

func (*PoolQueryResp) GetActivetargets added in v0.9.0 

func (m *PoolQueryResp) GetActivetargets() uint32

func (*PoolQueryResp) GetDisabledtargets added in v0.9.0 

func (m *PoolQueryResp) GetDisabledtargets() uint32

func (*PoolQueryResp) GetNvme added in v0.9.0 

func (m *PoolQueryResp) GetNvme() *StorageUsageStats

func (*PoolQueryResp) GetRebuild added in v0.9.0 

func (m *PoolQueryResp) GetRebuild() *PoolRebuildStatus

func (*PoolQueryResp) GetScm added in v0.9.0 

func (m *PoolQueryResp) GetScm() *StorageUsageStats

func (*PoolQueryResp) GetStatus added in v0.9.0 

func (m *PoolQueryResp) GetStatus() int32

func (*PoolQueryResp) GetTotaltargets added in v0.9.0 

func (m *PoolQueryResp) GetTotaltargets() uint32

func (*PoolQueryResp) GetUuid added in v0.9.0 

func (m *PoolQueryResp) GetUuid() string

func (*PoolQueryResp) ProtoMessage added in v0.9.0 

func (*PoolQueryResp) ProtoMessage()

func (*PoolQueryResp) Reset added in v0.9.0 

func (m *PoolQueryResp) Reset()

func (*PoolQueryResp) String added in v0.9.0 

func (m *PoolQueryResp) String() string

func (*PoolQueryResp) XXX_DiscardUnknown added in v0.9.0 

func (m *PoolQueryResp) XXX_DiscardUnknown()

func (*PoolQueryResp) XXX_Marshal added in v0.9.0 

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

func (*PoolQueryResp) XXX_Merge added in v0.9.0 

func (m *PoolQueryResp) XXX_Merge(src proto.Message)

func (*PoolQueryResp) XXX_Size added in v0.9.0 

func (m *PoolQueryResp) XXX_Size() int

func (*PoolQueryResp) XXX_Unmarshal added in v0.9.0 

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

type PoolRebuildStatus added in v0.9.0 

type PoolRebuildStatus struct {
	Status               int32                   `protobuf:"varint,1,opt,name=status,proto3" json:"status,omitempty"`
	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"`
	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
	XXX_unrecognized     []byte                  `json:"-"`
	XXX_sizecache        int32                   `json:"-"`
}

PoolRebuildStatus represents a pool's rebuild status.

func (*PoolRebuildStatus) Descriptor added in v0.9.0 

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

func (*PoolRebuildStatus) GetObjects added in v0.9.0 

func (m *PoolRebuildStatus) GetObjects() uint64

func (*PoolRebuildStatus) GetRecords added in v0.9.0 

func (m *PoolRebuildStatus) GetRecords() uint64

func (*PoolRebuildStatus) GetState added in v0.9.0 

func (m *PoolRebuildStatus) GetState() PoolRebuildStatus_State

func (*PoolRebuildStatus) GetStatus added in v0.9.0 

func (m *PoolRebuildStatus) GetStatus() int32

func (*PoolRebuildStatus) ProtoMessage added in v0.9.0 

func (*PoolRebuildStatus) ProtoMessage()

func (*PoolRebuildStatus) Reset added in v0.9.0 

func (m *PoolRebuildStatus) Reset()

func (*PoolRebuildStatus) String added in v0.9.0 

func (m *PoolRebuildStatus) String() string

func (*PoolRebuildStatus) XXX_DiscardUnknown added in v0.9.0 

func (m *PoolRebuildStatus) XXX_DiscardUnknown()

func (*PoolRebuildStatus) XXX_Marshal added in v0.9.0 

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

func (*PoolRebuildStatus) XXX_Merge added in v0.9.0 

func (m *PoolRebuildStatus) XXX_Merge(src proto.Message)

func (*PoolRebuildStatus) XXX_Size added in v0.9.0 

func (m *PoolRebuildStatus) XXX_Size() int

func (*PoolRebuildStatus) XXX_Unmarshal added in v0.9.0 

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

type PoolRebuildStatus_State added in v0.9.0 

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

func (PoolRebuildStatus_State) EnumDescriptor added in v0.9.0 

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

func (PoolRebuildStatus_State) String added in v0.9.0 

func (x PoolRebuildStatus_State) String() string

type PoolSetPropReq added in v0.9.0 

type PoolSetPropReq struct {
	Uuid string `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
	// Types that are valid to be assigned to Property:
	//	*PoolSetPropReq_Name
	//	*PoolSetPropReq_Number
	Property isPoolSetPropReq_Property `protobuf_oneof:"property"`
	// Types that are valid to be assigned to Value:
	//	*PoolSetPropReq_Strval
	//	*PoolSetPropReq_Numval
	Value                isPoolSetPropReq_Value `protobuf_oneof:"value"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

PoolSetPropReq represents a request to set a pool property.

func (*PoolSetPropReq) Descriptor added in v0.9.0 

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

func (*PoolSetPropReq) GetName added in v0.9.0 

func (m *PoolSetPropReq) GetName() string

func (*PoolSetPropReq) GetNumber added in v0.9.0 

func (m *PoolSetPropReq) GetNumber() uint32

func (*PoolSetPropReq) GetNumval added in v0.9.0 

func (m *PoolSetPropReq) GetNumval() uint64

func (*PoolSetPropReq) GetProperty added in v0.9.0 

func (m *PoolSetPropReq) GetProperty() isPoolSetPropReq_Property

func (*PoolSetPropReq) GetStrval added in v0.9.0 

func (m *PoolSetPropReq) GetStrval() string

func (*PoolSetPropReq) GetUuid added in v0.9.0 

func (m *PoolSetPropReq) GetUuid() string

func (*PoolSetPropReq) GetValue added in v0.9.0 

func (m *PoolSetPropReq) GetValue() isPoolSetPropReq_Value

func (*PoolSetPropReq) ProtoMessage added in v0.9.0 

func (*PoolSetPropReq) ProtoMessage()

func (*PoolSetPropReq) Reset added in v0.9.0 

func (m *PoolSetPropReq) Reset()

func (*PoolSetPropReq) SetPropertyName added in v0.9.0 

func (r *PoolSetPropReq) SetPropertyName(name string)

SetPropertyName sets the Property field to a string-based name.

func (*PoolSetPropReq) SetPropertyNumber added in v0.9.0 

func (r *PoolSetPropReq) SetPropertyNumber(number uint32)

SetPropertyNumber sets the Property field to a uint32-based number.

func (*PoolSetPropReq) SetValueNumber added in v0.9.0 

func (r *PoolSetPropReq) SetValueNumber(numVal uint64)

SetValueNumber sets the Value field to a uint64.

func (*PoolSetPropReq) SetValueString added in v0.9.0 

func (r *PoolSetPropReq) SetValueString(strVal string)

SetValueString sets the Value field to a string.

func (*PoolSetPropReq) String added in v0.9.0 

func (m *PoolSetPropReq) String() string

func (*PoolSetPropReq) XXX_DiscardUnknown added in v0.9.0 

func (m *PoolSetPropReq) XXX_DiscardUnknown()

func (*PoolSetPropReq) XXX_Marshal added in v0.9.0 

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

func (*PoolSetPropReq) XXX_Merge added in v0.9.0 

func (m *PoolSetPropReq) XXX_Merge(src proto.Message)

func (*PoolSetPropReq) XXX_OneofWrappers added in v0.9.0 

func (*PoolSetPropReq) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*PoolSetPropReq) XXX_Size added in v0.9.0 

func (m *PoolSetPropReq) XXX_Size() int

func (*PoolSetPropReq) XXX_Unmarshal added in v0.9.0 

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

type PoolSetPropReq_Name added in v0.9.0 

type PoolSetPropReq_Name struct {
	Name string `protobuf:"bytes,2,opt,name=name,proto3,oneof"`
}

type PoolSetPropReq_Number added in v0.9.0 

type PoolSetPropReq_Number struct {
	Number uint32 `protobuf:"varint,3,opt,name=number,proto3,oneof"`
}

type PoolSetPropReq_Numval added in v0.9.0 

type PoolSetPropReq_Numval struct {
	Numval uint64 `protobuf:"varint,5,opt,name=numval,proto3,oneof"`
}

type PoolSetPropReq_Strval added in v0.9.0 

type PoolSetPropReq_Strval struct {
	Strval string `protobuf:"bytes,4,opt,name=strval,proto3,oneof"`
}

type PoolSetPropResp added in v0.9.0 

type PoolSetPropResp struct {
	Status int32 `protobuf:"varint,1,opt,name=status,proto3" json:"status,omitempty"`
	// Types that are valid to be assigned to Property:
	//	*PoolSetPropResp_Name
	//	*PoolSetPropResp_Number
	Property isPoolSetPropResp_Property `protobuf_oneof:"property"`
	// Types that are valid to be assigned to Value:
	//	*PoolSetPropResp_Strval
	//	*PoolSetPropResp_Numval
	Value                isPoolSetPropResp_Value `protobuf_oneof:"value"`
	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
	XXX_unrecognized     []byte                  `json:"-"`
	XXX_sizecache        int32                   `json:"-"`
}

PoolSetPropResp represents the result of setting a property.

func (*PoolSetPropResp) Descriptor added in v0.9.0 

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

func (*PoolSetPropResp) GetName added in v0.9.0 

func (m *PoolSetPropResp) GetName() string

func (*PoolSetPropResp) GetNumber added in v0.9.0 

func (m *PoolSetPropResp) GetNumber() uint32

func (*PoolSetPropResp) GetNumval added in v0.9.0 

func (m *PoolSetPropResp) GetNumval() uint64

func (*PoolSetPropResp) GetProperty added in v0.9.0 

func (m *PoolSetPropResp) GetProperty() isPoolSetPropResp_Property

func (*PoolSetPropResp) GetStatus added in v0.9.0 

func (m *PoolSetPropResp) GetStatus() int32

func (*PoolSetPropResp) GetStrval added in v0.9.0 

func (m *PoolSetPropResp) GetStrval() string

func (*PoolSetPropResp) GetValue added in v0.9.0 

func (m *PoolSetPropResp) GetValue() isPoolSetPropResp_Value

func (*PoolSetPropResp) ProtoMessage added in v0.9.0 

func (*PoolSetPropResp) ProtoMessage()

func (*PoolSetPropResp) Reset added in v0.9.0 

func (m *PoolSetPropResp) Reset()

func (*PoolSetPropResp) String added in v0.9.0 

func (m *PoolSetPropResp) String() string

func (*PoolSetPropResp) XXX_DiscardUnknown added in v0.9.0 

func (m *PoolSetPropResp) XXX_DiscardUnknown()

func (*PoolSetPropResp) XXX_Marshal added in v0.9.0 

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

func (*PoolSetPropResp) XXX_Merge added in v0.9.0 

func (m *PoolSetPropResp) XXX_Merge(src proto.Message)

func (*PoolSetPropResp) XXX_OneofWrappers added in v0.9.0 

func (*PoolSetPropResp) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*PoolSetPropResp) XXX_Size added in v0.9.0 

func (m *PoolSetPropResp) XXX_Size() int

func (*PoolSetPropResp) XXX_Unmarshal added in v0.9.0 

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

type PoolSetPropResp_Name added in v0.9.0 

type PoolSetPropResp_Name struct {
	Name string `protobuf:"bytes,2,opt,name=name,proto3,oneof"`
}

type PoolSetPropResp_Number added in v0.9.0 

type PoolSetPropResp_Number struct {
	Number uint32 `protobuf:"varint,3,opt,name=number,proto3,oneof"`
}

type PoolSetPropResp_Numval added in v0.9.0 

type PoolSetPropResp_Numval struct {
	Numval uint64 `protobuf:"varint,5,opt,name=numval,proto3,oneof"`
}

type PoolSetPropResp_Strval added in v0.9.0 

type PoolSetPropResp_Strval struct {
	Strval string `protobuf:"bytes,4,opt,name=strval,proto3,oneof"`
}

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 (m *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 RanksReq added in v0.9.0 

type RanksReq struct {
	Ranks                []uint32 `protobuf:"varint,1,rep,packed,name=ranks,proto3" json:"ranks,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:"-"`
}

Generic request indicating which ranks to operate on. Used in gRPC fanout to operate on hosts with multiple ranks.

func (*RanksReq) Descriptor added in v0.9.0 

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

func (*RanksReq) GetForce added in v0.9.0 

func (m *RanksReq) GetForce() bool

func (*RanksReq) GetRanks added in v0.9.0 

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

func (*RanksReq) ProtoMessage added in v0.9.0 

func (*RanksReq) ProtoMessage()

func (*RanksReq) Reset added in v0.9.0 

func (m *RanksReq) Reset()

func (*RanksReq) String added in v0.9.0 

func (m *RanksReq) String() string

func (*RanksReq) XXX_DiscardUnknown added in v0.9.0 

func (m *RanksReq) XXX_DiscardUnknown()

func (*RanksReq) XXX_Marshal added in v0.9.0 

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

func (*RanksReq) XXX_Merge added in v0.9.0 

func (m *RanksReq) XXX_Merge(src proto.Message)

func (*RanksReq) XXX_Size added in v0.9.0 

func (m *RanksReq) XXX_Size() int

func (*RanksReq) XXX_Unmarshal added in v0.9.0 

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

type RanksResp added in v0.9.0 

type RanksResp struct {
	Results              []*RanksResp_RankResult `protobuf:"bytes,1,rep,name=results,proto3" json:"results,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
	XXX_unrecognized     []byte                  `json:"-"`
	XXX_sizecache        int32                   `json:"-"`
}

Generic response containing DER result from multiple ranks. Used in gRPC fanout to operate on hosts with multiple ranks.

func (*RanksResp) Descriptor added in v0.9.0 

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

func (*RanksResp) GetResults added in v0.9.0 

func (m *RanksResp) GetResults() []*RanksResp_RankResult

func (*RanksResp) ProtoMessage added in v0.9.0 

func (*RanksResp) ProtoMessage()

func (*RanksResp) Reset added in v0.9.0 

func (m *RanksResp) Reset()

func (*RanksResp) String added in v0.9.0 

func (m *RanksResp) String() string

func (*RanksResp) XXX_DiscardUnknown added in v0.9.0 

func (m *RanksResp) XXX_DiscardUnknown()

func (*RanksResp) XXX_Marshal added in v0.9.0 

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

func (*RanksResp) XXX_Merge added in v0.9.0 

func (m *RanksResp) XXX_Merge(src proto.Message)

func (*RanksResp) XXX_Size added in v0.9.0 

func (m *RanksResp) XXX_Size() int

func (*RanksResp) XXX_Unmarshal added in v0.9.0 

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

type RanksResp_RankResult added in v0.9.0 

type RanksResp_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                uint32   `protobuf:"varint,5,opt,name=state,proto3" json:"state,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Identical to ctl.system.RankResult proto message.

func (*RanksResp_RankResult) Descriptor added in v0.9.0 

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

func (*RanksResp_RankResult) GetAction added in v0.9.0 

func (m *RanksResp_RankResult) GetAction() string

func (*RanksResp_RankResult) GetErrored added in v0.9.0 

func (m *RanksResp_RankResult) GetErrored() bool

func (*RanksResp_RankResult) GetMsg added in v0.9.0 

func (m *RanksResp_RankResult) GetMsg() string

func (*RanksResp_RankResult) GetRank added in v0.9.0 

func (m *RanksResp_RankResult) GetRank() uint32

func (*RanksResp_RankResult) GetState added in v0.9.0 

func (m *RanksResp_RankResult) GetState() uint32

func (*RanksResp_RankResult) ProtoMessage added in v0.9.0 

func (*RanksResp_RankResult) ProtoMessage()

func (*RanksResp_RankResult) Reset added in v0.9.0 

func (m *RanksResp_RankResult) Reset()

func (*RanksResp_RankResult) String added in v0.9.0 

func (m *RanksResp_RankResult) String() string

func (*RanksResp_RankResult) XXX_DiscardUnknown added in v0.9.0 

func (m *RanksResp_RankResult) XXX_DiscardUnknown()

func (*RanksResp_RankResult) XXX_Marshal added in v0.9.0 

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

func (*RanksResp_RankResult) XXX_Merge added in v0.9.0 

func (m *RanksResp_RankResult) XXX_Merge(src proto.Message)

func (*RanksResp_RankResult) XXX_Size added in v0.9.0 

func (m *RanksResp_RankResult) XXX_Size() int

func (*RanksResp_RankResult) XXX_Unmarshal added in v0.9.0 

func (m *RanksResp_RankResult) 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 (m *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 (m *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 (m *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 (m *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 (m *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 (m *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 (m *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

type StorageUsageStats added in v0.9.0 

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

StorageUsageStats represents usage statistics for a storage subsystem.

func (*StorageUsageStats) Descriptor added in v0.9.0 

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

func (*StorageUsageStats) GetFree added in v0.9.0 

func (m *StorageUsageStats) GetFree() uint64

func (*StorageUsageStats) GetMax added in v0.9.0 

func (m *StorageUsageStats) GetMax() uint64

func (*StorageUsageStats) GetMean added in v0.9.0 

func (m *StorageUsageStats) GetMean() uint64

func (*StorageUsageStats) GetMin added in v0.9.0 

func (m *StorageUsageStats) GetMin() uint64

func (*StorageUsageStats) GetTotal added in v0.9.0 

func (m *StorageUsageStats) GetTotal() uint64

func (*StorageUsageStats) ProtoMessage added in v0.9.0 

func (*StorageUsageStats) ProtoMessage()

func (*StorageUsageStats) Reset added in v0.9.0 

func (m *StorageUsageStats) Reset()

func (*StorageUsageStats) String added in v0.9.0 

func (m *StorageUsageStats) String() string

func (*StorageUsageStats) XXX_DiscardUnknown added in v0.9.0 

func (m *StorageUsageStats) XXX_DiscardUnknown()

func (*StorageUsageStats) XXX_Marshal added in v0.9.0 

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

func (*StorageUsageStats) XXX_Merge added in v0.9.0 

func (m *StorageUsageStats) XXX_Merge(src proto.Message)

func (*StorageUsageStats) XXX_Size added in v0.9.0 

func (m *StorageUsageStats) XXX_Size() int

func (*StorageUsageStats) XXX_Unmarshal added in v0.9.0 

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

type UnimplementedMgmtSvcServer added in v0.9.0 

type UnimplementedMgmtSvcServer struct {
}

UnimplementedMgmtSvcServer can be embedded to have forward compatible implementations.

func (*UnimplementedMgmtSvcServer) BioHealthQuery added in v0.9.0 

func (*UnimplementedMgmtSvcServer) BioHealthQuery(ctx context.Context, req *BioHealthReq) (*BioHealthResp, error)

func (*UnimplementedMgmtSvcServer) DevStateQuery added in v0.9.0 

func (*UnimplementedMgmtSvcServer) DevStateQuery(ctx context.Context, req *DevStateReq) (*DevStateResp, error)

func (*UnimplementedMgmtSvcServer) GetAttachInfo added in v0.9.0 

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

func (*UnimplementedMgmtSvcServer) Join added in v0.9.0 

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

func (*UnimplementedMgmtSvcServer) LeaderQuery added in v0.9.0 

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

func (*UnimplementedMgmtSvcServer) ListContainers added in v0.9.0 

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

func (*UnimplementedMgmtSvcServer) ListPools added in v0.9.0 

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

func (*UnimplementedMgmtSvcServer) PingRanks added in v0.9.0 

func (*UnimplementedMgmtSvcServer) PingRanks(ctx context.Context, req *RanksReq) (*RanksResp, error)

func (*UnimplementedMgmtSvcServer) PoolCreate added in v0.9.0 

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

func (*UnimplementedMgmtSvcServer) PoolDeleteACL added in v0.9.0 

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

func (*UnimplementedMgmtSvcServer) PoolDestroy added in v0.9.0 

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

func (*UnimplementedMgmtSvcServer) PoolGetACL added in v0.9.0 

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

func (*UnimplementedMgmtSvcServer) PoolOverwriteACL added in v0.9.0 

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

func (*UnimplementedMgmtSvcServer) PoolQuery added in v0.9.0 

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

func (*UnimplementedMgmtSvcServer) PoolSetProp added in v0.9.0 

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

func (*UnimplementedMgmtSvcServer) PoolUpdateACL added in v0.9.0 

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

func (*UnimplementedMgmtSvcServer) PrepShutdownRanks added in v0.9.0 

func (*UnimplementedMgmtSvcServer) PrepShutdownRanks(ctx context.Context, req *RanksReq) (*RanksResp, error)

func (*UnimplementedMgmtSvcServer) SmdListDevs added in v0.9.0 

func (*UnimplementedMgmtSvcServer) SmdListDevs(ctx context.Context, req *SmdDevReq) (*SmdDevResp, error)

func (*UnimplementedMgmtSvcServer) SmdListPools added in v0.9.0 

func (*UnimplementedMgmtSvcServer) SmdListPools(ctx context.Context, req *SmdPoolReq) (*SmdPoolResp, error)

func (*UnimplementedMgmtSvcServer) StartRanks added in v0.9.0 

func (*UnimplementedMgmtSvcServer) StartRanks(ctx context.Context, req *RanksReq) (*RanksResp, error)

func (*UnimplementedMgmtSvcServer) StopRanks added in v0.9.0 

func (*UnimplementedMgmtSvcServer) StopRanks(ctx context.Context, req *RanksReq) (*RanksResp, error)

func (*UnimplementedMgmtSvcServer) StorageSetFaulty added in v0.9.0 

func (*UnimplementedMgmtSvcServer) StorageSetFaulty(ctx context.Context, req *DevStateReq) (*DevStateResp, 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.