Documentation ¶
Overview ¶
Package oim is a generated protocol buffer package.
It is generated from these files:
oim.proto
It has these top-level messages:
SetValueRequest Value SetValueReply GetValuesRequest GetValuesReply MapVolumeRequest MallocParams CephParams MapVolumeReply PCIAddress SCSIDisk UnmapVolumeRequest UnmapVolumeReply ProvisionMallocBDevRequest ProvisionMallocBDevReply CheckMallocBDevRequest CheckMallocBDevReply
Index ¶
- Variables
- func RegisterControllerServer(s *grpc.Server, srv ControllerServer)
- func RegisterRegistryServer(s *grpc.Server, srv RegistryServer)
- type CephParams
- func (*CephParams) Descriptor() ([]byte, []int)
- func (m *CephParams) GetImage() string
- func (m *CephParams) GetMonitors() string
- func (m *CephParams) GetPool() string
- func (m *CephParams) GetSecret() string
- func (m *CephParams) GetUserId() string
- func (m *CephParams) Marshal() (dAtA []byte, err error)
- func (m *CephParams) MarshalTo(dAtA []byte) (int, error)
- func (*CephParams) ProtoMessage()
- func (m *CephParams) Reset()
- func (m *CephParams) Size() (n int)
- func (m *CephParams) String() string
- func (m *CephParams) Unmarshal(dAtA []byte) error
- type CheckMallocBDevReply
- func (*CheckMallocBDevReply) Descriptor() ([]byte, []int)
- func (m *CheckMallocBDevReply) Marshal() (dAtA []byte, err error)
- func (m *CheckMallocBDevReply) MarshalTo(dAtA []byte) (int, error)
- func (*CheckMallocBDevReply) ProtoMessage()
- func (m *CheckMallocBDevReply) Reset()
- func (m *CheckMallocBDevReply) Size() (n int)
- func (m *CheckMallocBDevReply) String() string
- func (m *CheckMallocBDevReply) Unmarshal(dAtA []byte) error
- type CheckMallocBDevRequest
- func (*CheckMallocBDevRequest) Descriptor() ([]byte, []int)
- func (m *CheckMallocBDevRequest) GetBdevName() string
- func (m *CheckMallocBDevRequest) Marshal() (dAtA []byte, err error)
- func (m *CheckMallocBDevRequest) MarshalTo(dAtA []byte) (int, error)
- func (*CheckMallocBDevRequest) ProtoMessage()
- func (m *CheckMallocBDevRequest) Reset()
- func (m *CheckMallocBDevRequest) Size() (n int)
- func (m *CheckMallocBDevRequest) String() string
- func (m *CheckMallocBDevRequest) Unmarshal(dAtA []byte) error
- type ControllerClient
- type ControllerServer
- type GetValuesReply
- func (*GetValuesReply) Descriptor() ([]byte, []int)
- func (m *GetValuesReply) GetValues() []*Value
- func (m *GetValuesReply) Marshal() (dAtA []byte, err error)
- func (m *GetValuesReply) MarshalTo(dAtA []byte) (int, error)
- func (*GetValuesReply) ProtoMessage()
- func (m *GetValuesReply) Reset()
- func (m *GetValuesReply) Size() (n int)
- func (m *GetValuesReply) String() string
- func (m *GetValuesReply) Unmarshal(dAtA []byte) error
- type GetValuesRequest
- func (*GetValuesRequest) Descriptor() ([]byte, []int)
- func (m *GetValuesRequest) GetPath() string
- func (m *GetValuesRequest) Marshal() (dAtA []byte, err error)
- func (m *GetValuesRequest) MarshalTo(dAtA []byte) (int, error)
- func (*GetValuesRequest) ProtoMessage()
- func (m *GetValuesRequest) Reset()
- func (m *GetValuesRequest) Size() (n int)
- func (m *GetValuesRequest) String() string
- func (m *GetValuesRequest) Unmarshal(dAtA []byte) error
- type MallocParams
- func (*MallocParams) Descriptor() ([]byte, []int)
- func (m *MallocParams) Marshal() (dAtA []byte, err error)
- func (m *MallocParams) MarshalTo(dAtA []byte) (int, error)
- func (*MallocParams) ProtoMessage()
- func (m *MallocParams) Reset()
- func (m *MallocParams) Size() (n int)
- func (m *MallocParams) String() string
- func (m *MallocParams) Unmarshal(dAtA []byte) error
- type MapVolumeReply
- func (*MapVolumeReply) Descriptor() ([]byte, []int)
- func (m *MapVolumeReply) GetPciAddress() *PCIAddress
- func (m *MapVolumeReply) GetScsiDisk() *SCSIDisk
- func (m *MapVolumeReply) Marshal() (dAtA []byte, err error)
- func (m *MapVolumeReply) MarshalTo(dAtA []byte) (int, error)
- func (*MapVolumeReply) ProtoMessage()
- func (m *MapVolumeReply) Reset()
- func (m *MapVolumeReply) Size() (n int)
- func (m *MapVolumeReply) String() string
- func (m *MapVolumeReply) Unmarshal(dAtA []byte) error
- type MapVolumeRequest
- func (*MapVolumeRequest) Descriptor() ([]byte, []int)
- func (m *MapVolumeRequest) GetCeph() *CephParams
- func (m *MapVolumeRequest) GetMalloc() *MallocParams
- func (m *MapVolumeRequest) GetParams() isMapVolumeRequest_Params
- func (m *MapVolumeRequest) GetVolumeId() string
- func (m *MapVolumeRequest) Marshal() (dAtA []byte, err error)
- func (m *MapVolumeRequest) MarshalTo(dAtA []byte) (int, error)
- func (*MapVolumeRequest) ProtoMessage()
- func (m *MapVolumeRequest) Reset()
- func (m *MapVolumeRequest) Size() (n int)
- func (m *MapVolumeRequest) String() string
- func (m *MapVolumeRequest) Unmarshal(dAtA []byte) error
- func (*MapVolumeRequest) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)
- type MapVolumeRequest_Ceph
- type MapVolumeRequest_Malloc
- type PCIAddress
- func (*PCIAddress) Descriptor() ([]byte, []int)
- func (m *PCIAddress) GetBus() uint32
- func (m *PCIAddress) GetDevice() uint32
- func (m *PCIAddress) GetDomain() uint32
- func (m *PCIAddress) GetFunction() uint32
- func (m *PCIAddress) Marshal() (dAtA []byte, err error)
- func (m *PCIAddress) MarshalTo(dAtA []byte) (int, error)
- func (*PCIAddress) ProtoMessage()
- func (m *PCIAddress) Reset()
- func (m *PCIAddress) Size() (n int)
- func (m *PCIAddress) String() string
- func (m *PCIAddress) Unmarshal(dAtA []byte) error
- type ProvisionMallocBDevReply
- func (*ProvisionMallocBDevReply) Descriptor() ([]byte, []int)
- func (m *ProvisionMallocBDevReply) Marshal() (dAtA []byte, err error)
- func (m *ProvisionMallocBDevReply) MarshalTo(dAtA []byte) (int, error)
- func (*ProvisionMallocBDevReply) ProtoMessage()
- func (m *ProvisionMallocBDevReply) Reset()
- func (m *ProvisionMallocBDevReply) Size() (n int)
- func (m *ProvisionMallocBDevReply) String() string
- func (m *ProvisionMallocBDevReply) Unmarshal(dAtA []byte) error
- type ProvisionMallocBDevRequest
- func (*ProvisionMallocBDevRequest) Descriptor() ([]byte, []int)
- func (m *ProvisionMallocBDevRequest) GetBdevName() string
- func (m *ProvisionMallocBDevRequest) GetSize_() int64
- func (m *ProvisionMallocBDevRequest) Marshal() (dAtA []byte, err error)
- func (m *ProvisionMallocBDevRequest) MarshalTo(dAtA []byte) (int, error)
- func (*ProvisionMallocBDevRequest) ProtoMessage()
- func (m *ProvisionMallocBDevRequest) Reset()
- func (m *ProvisionMallocBDevRequest) Size() (n int)
- func (m *ProvisionMallocBDevRequest) String() string
- func (m *ProvisionMallocBDevRequest) Unmarshal(dAtA []byte) error
- type RegistryClient
- type RegistryServer
- type SCSIDisk
- func (*SCSIDisk) Descriptor() ([]byte, []int)
- func (m *SCSIDisk) GetLun() uint32
- func (m *SCSIDisk) GetTarget() uint32
- func (m *SCSIDisk) Marshal() (dAtA []byte, err error)
- func (m *SCSIDisk) MarshalTo(dAtA []byte) (int, error)
- func (*SCSIDisk) ProtoMessage()
- func (m *SCSIDisk) Reset()
- func (m *SCSIDisk) Size() (n int)
- func (m *SCSIDisk) String() string
- func (m *SCSIDisk) Unmarshal(dAtA []byte) error
- type SetValueReply
- func (*SetValueReply) Descriptor() ([]byte, []int)
- func (m *SetValueReply) Marshal() (dAtA []byte, err error)
- func (m *SetValueReply) MarshalTo(dAtA []byte) (int, error)
- func (*SetValueReply) ProtoMessage()
- func (m *SetValueReply) Reset()
- func (m *SetValueReply) Size() (n int)
- func (m *SetValueReply) String() string
- func (m *SetValueReply) Unmarshal(dAtA []byte) error
- type SetValueRequest
- func (*SetValueRequest) Descriptor() ([]byte, []int)
- func (m *SetValueRequest) GetValue() *Value
- func (m *SetValueRequest) Marshal() (dAtA []byte, err error)
- func (m *SetValueRequest) MarshalTo(dAtA []byte) (int, error)
- func (*SetValueRequest) ProtoMessage()
- func (m *SetValueRequest) Reset()
- func (m *SetValueRequest) Size() (n int)
- func (m *SetValueRequest) String() string
- func (m *SetValueRequest) Unmarshal(dAtA []byte) error
- type UnmapVolumeReply
- func (*UnmapVolumeReply) Descriptor() ([]byte, []int)
- func (m *UnmapVolumeReply) Marshal() (dAtA []byte, err error)
- func (m *UnmapVolumeReply) MarshalTo(dAtA []byte) (int, error)
- func (*UnmapVolumeReply) ProtoMessage()
- func (m *UnmapVolumeReply) Reset()
- func (m *UnmapVolumeReply) Size() (n int)
- func (m *UnmapVolumeReply) String() string
- func (m *UnmapVolumeReply) Unmarshal(dAtA []byte) error
- type UnmapVolumeRequest
- func (*UnmapVolumeRequest) Descriptor() ([]byte, []int)
- func (m *UnmapVolumeRequest) GetVolumeId() string
- func (m *UnmapVolumeRequest) Marshal() (dAtA []byte, err error)
- func (m *UnmapVolumeRequest) MarshalTo(dAtA []byte) (int, error)
- func (*UnmapVolumeRequest) ProtoMessage()
- func (m *UnmapVolumeRequest) Reset()
- func (m *UnmapVolumeRequest) Size() (n int)
- func (m *UnmapVolumeRequest) String() string
- func (m *UnmapVolumeRequest) Unmarshal(dAtA []byte) error
- type Value
- func (*Value) Descriptor() ([]byte, []int)
- func (m *Value) GetPath() string
- func (m *Value) GetValue() string
- func (m *Value) Marshal() (dAtA []byte, err error)
- func (m *Value) MarshalTo(dAtA []byte) (int, error)
- func (*Value) ProtoMessage()
- func (m *Value) Reset()
- func (m *Value) Size() (n int)
- func (m *Value) String() string
- func (m *Value) Unmarshal(dAtA []byte) error
Constants ¶
This section is empty.
Variables ¶
var ( ErrInvalidLengthOim = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowOim = fmt.Errorf("proto: integer overflow") )
Functions ¶
func RegisterControllerServer ¶
func RegisterControllerServer(s *grpc.Server, srv ControllerServer)
func RegisterRegistryServer ¶
func RegisterRegistryServer(s *grpc.Server, srv RegistryServer)
Types ¶
type CephParams ¶
type CephParams struct { // The user id (like "admin", but not "client.admin"). // Can be left out, the default in Ceph is "admin". UserId string `protobuf:"bytes,1,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"` // The "key" value from a Ceph keyring for the user. Secret string `protobuf:"bytes,2,opt,name=secret,proto3" json:"secret,omitempty"` // Comma-separated list of addr:port values. Monitors string `protobuf:"bytes,3,opt,name=monitors,proto3" json:"monitors,omitempty"` // Pool name Pool string `protobuf:"bytes,4,opt,name=pool,proto3" json:"pool,omitempty"` // Image name Image string `protobuf:"bytes,5,opt,name=image,proto3" json:"image,omitempty"` }
Defines a Ceph block device.
func (*CephParams) Descriptor ¶
func (*CephParams) Descriptor() ([]byte, []int)
func (*CephParams) GetImage ¶
func (m *CephParams) GetImage() string
func (*CephParams) GetMonitors ¶
func (m *CephParams) GetMonitors() string
func (*CephParams) GetPool ¶
func (m *CephParams) GetPool() string
func (*CephParams) GetSecret ¶
func (m *CephParams) GetSecret() string
func (*CephParams) GetUserId ¶
func (m *CephParams) GetUserId() string
func (*CephParams) Marshal ¶
func (m *CephParams) Marshal() (dAtA []byte, err error)
func (*CephParams) ProtoMessage ¶
func (*CephParams) ProtoMessage()
func (*CephParams) Reset ¶
func (m *CephParams) Reset()
func (*CephParams) Size ¶
func (m *CephParams) Size() (n int)
func (*CephParams) String ¶
func (m *CephParams) String() string
func (*CephParams) Unmarshal ¶
func (m *CephParams) Unmarshal(dAtA []byte) error
type CheckMallocBDevReply ¶
type CheckMallocBDevReply struct { }
func (*CheckMallocBDevReply) Descriptor ¶
func (*CheckMallocBDevReply) Descriptor() ([]byte, []int)
func (*CheckMallocBDevReply) Marshal ¶
func (m *CheckMallocBDevReply) Marshal() (dAtA []byte, err error)
func (*CheckMallocBDevReply) MarshalTo ¶
func (m *CheckMallocBDevReply) MarshalTo(dAtA []byte) (int, error)
func (*CheckMallocBDevReply) ProtoMessage ¶
func (*CheckMallocBDevReply) ProtoMessage()
func (*CheckMallocBDevReply) Reset ¶
func (m *CheckMallocBDevReply) Reset()
func (*CheckMallocBDevReply) Size ¶
func (m *CheckMallocBDevReply) Size() (n int)
func (*CheckMallocBDevReply) String ¶
func (m *CheckMallocBDevReply) String() string
func (*CheckMallocBDevReply) Unmarshal ¶
func (m *CheckMallocBDevReply) Unmarshal(dAtA []byte) error
type CheckMallocBDevRequest ¶
type CheckMallocBDevRequest struct { // The name of an existing BDev. BdevName string `protobuf:"bytes,1,opt,name=bdev_name,json=bdevName,proto3" json:"bdev_name,omitempty"` }
func (*CheckMallocBDevRequest) Descriptor ¶
func (*CheckMallocBDevRequest) Descriptor() ([]byte, []int)
func (*CheckMallocBDevRequest) GetBdevName ¶
func (m *CheckMallocBDevRequest) GetBdevName() string
func (*CheckMallocBDevRequest) Marshal ¶
func (m *CheckMallocBDevRequest) Marshal() (dAtA []byte, err error)
func (*CheckMallocBDevRequest) MarshalTo ¶
func (m *CheckMallocBDevRequest) MarshalTo(dAtA []byte) (int, error)
func (*CheckMallocBDevRequest) ProtoMessage ¶
func (*CheckMallocBDevRequest) ProtoMessage()
func (*CheckMallocBDevRequest) Reset ¶
func (m *CheckMallocBDevRequest) Reset()
func (*CheckMallocBDevRequest) Size ¶
func (m *CheckMallocBDevRequest) Size() (n int)
func (*CheckMallocBDevRequest) String ¶
func (m *CheckMallocBDevRequest) String() string
func (*CheckMallocBDevRequest) Unmarshal ¶
func (m *CheckMallocBDevRequest) Unmarshal(dAtA []byte) error
type ControllerClient ¶
type ControllerClient interface { // Makes a volume available via the accelerator hardware. // The call must be idempotent: when a caller is unsure whether // a call was executed or what the result was, MapVolume // can be called again and will succeed without changing // anything. MapVolume(ctx context.Context, in *MapVolumeRequest, opts ...grpc.CallOption) (*MapVolumeReply, error) // Removes access to the volume. // Also idempotent. UnmapVolume(ctx context.Context, in *UnmapVolumeRequest, opts ...grpc.CallOption) (*UnmapVolumeReply, error) // Creates or deletes (when size is zero) an // in-memory BDev for testing. ProvisionMallocBDev(ctx context.Context, in *ProvisionMallocBDevRequest, opts ...grpc.CallOption) (*ProvisionMallocBDevReply, error) // Checks that the BDev exists. Returns // gRPC NOT_FOUND status if not. CheckMallocBDev(ctx context.Context, in *CheckMallocBDevRequest, opts ...grpc.CallOption) (*CheckMallocBDevReply, error) }
func NewControllerClient ¶
func NewControllerClient(cc *grpc.ClientConn) ControllerClient
type ControllerServer ¶
type ControllerServer interface { // Makes a volume available via the accelerator hardware. // The call must be idempotent: when a caller is unsure whether // a call was executed or what the result was, MapVolume // can be called again and will succeed without changing // anything. MapVolume(context.Context, *MapVolumeRequest) (*MapVolumeReply, error) // Removes access to the volume. // Also idempotent. UnmapVolume(context.Context, *UnmapVolumeRequest) (*UnmapVolumeReply, error) // Creates or deletes (when size is zero) an // in-memory BDev for testing. ProvisionMallocBDev(context.Context, *ProvisionMallocBDevRequest) (*ProvisionMallocBDevReply, error) // Checks that the BDev exists. Returns // gRPC NOT_FOUND status if not. CheckMallocBDev(context.Context, *CheckMallocBDevRequest) (*CheckMallocBDevReply, error) }
type GetValuesReply ¶
type GetValuesReply struct { // All current registry DB values. Values []*Value `protobuf:"bytes,1,rep,name=values" json:"values,omitempty"` }
func (*GetValuesReply) Descriptor ¶
func (*GetValuesReply) Descriptor() ([]byte, []int)
func (*GetValuesReply) GetValues ¶
func (m *GetValuesReply) GetValues() []*Value
func (*GetValuesReply) Marshal ¶
func (m *GetValuesReply) Marshal() (dAtA []byte, err error)
func (*GetValuesReply) ProtoMessage ¶
func (*GetValuesReply) ProtoMessage()
func (*GetValuesReply) Reset ¶
func (m *GetValuesReply) Reset()
func (*GetValuesReply) Size ¶
func (m *GetValuesReply) Size() (n int)
func (*GetValuesReply) String ¶
func (m *GetValuesReply) String() string
func (*GetValuesReply) Unmarshal ¶
func (m *GetValuesReply) Unmarshal(dAtA []byte) error
type GetValuesRequest ¶
type GetValuesRequest struct { // Return all values beneath or at the given path, // all values when empty. Path string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"` }
func (*GetValuesRequest) Descriptor ¶
func (*GetValuesRequest) Descriptor() ([]byte, []int)
func (*GetValuesRequest) GetPath ¶
func (m *GetValuesRequest) GetPath() string
func (*GetValuesRequest) Marshal ¶
func (m *GetValuesRequest) Marshal() (dAtA []byte, err error)
func (*GetValuesRequest) ProtoMessage ¶
func (*GetValuesRequest) ProtoMessage()
func (*GetValuesRequest) Reset ¶
func (m *GetValuesRequest) Reset()
func (*GetValuesRequest) Size ¶
func (m *GetValuesRequest) Size() (n int)
func (*GetValuesRequest) String ¶
func (m *GetValuesRequest) String() string
func (*GetValuesRequest) Unmarshal ¶
func (m *GetValuesRequest) Unmarshal(dAtA []byte) error
type MallocParams ¶
type MallocParams struct { }
For testing purposes, an existing Malloc BDev can be used. It needs to be provisioned separately to ensure that its data survives multiple Map/Unmap operations. It's name must be <volume_id>.
func (*MallocParams) Descriptor ¶
func (*MallocParams) Descriptor() ([]byte, []int)
func (*MallocParams) Marshal ¶
func (m *MallocParams) Marshal() (dAtA []byte, err error)
func (*MallocParams) ProtoMessage ¶
func (*MallocParams) ProtoMessage()
func (*MallocParams) Reset ¶
func (m *MallocParams) Reset()
func (*MallocParams) Size ¶
func (m *MallocParams) Size() (n int)
func (*MallocParams) String ¶
func (m *MallocParams) String() string
func (*MallocParams) Unmarshal ¶
func (m *MallocParams) Unmarshal(dAtA []byte) error
type MapVolumeReply ¶
type MapVolumeReply struct { // The PCI address (domain/bus/device/function, extended BDF). // A controller which does not know its own PCI address can // return a an address with all fields set to 0xFFFF. PciAddress *PCIAddress `protobuf:"bytes,1,opt,name=pci_address,json=pciAddress" json:"pci_address,omitempty"` // The SCSI target and LUN. Only present for disks attached // via a SCSI controller. ScsiDisk *SCSIDisk `protobuf:"bytes,2,opt,name=scsi_disk,json=scsiDisk" json:"scsi_disk,omitempty"` }
The reply must tell the caller enough about the mapped volume to find it in /sys/dev/block.
func (*MapVolumeReply) Descriptor ¶
func (*MapVolumeReply) Descriptor() ([]byte, []int)
func (*MapVolumeReply) GetPciAddress ¶
func (m *MapVolumeReply) GetPciAddress() *PCIAddress
func (*MapVolumeReply) GetScsiDisk ¶
func (m *MapVolumeReply) GetScsiDisk() *SCSIDisk
func (*MapVolumeReply) Marshal ¶
func (m *MapVolumeReply) Marshal() (dAtA []byte, err error)
func (*MapVolumeReply) ProtoMessage ¶
func (*MapVolumeReply) ProtoMessage()
func (*MapVolumeReply) Reset ¶
func (m *MapVolumeReply) Reset()
func (*MapVolumeReply) Size ¶
func (m *MapVolumeReply) Size() (n int)
func (*MapVolumeReply) String ¶
func (m *MapVolumeReply) String() string
func (*MapVolumeReply) Unmarshal ¶
func (m *MapVolumeReply) Unmarshal(dAtA []byte) error
type MapVolumeRequest ¶
type MapVolumeRequest struct { // An identifier for the volume that must be unique // among all volumes mapped by the OIM controller. // All calls with the same identifier must have the // same parameters. VolumeId string `protobuf:"bytes,1,opt,name=volume_id,json=volumeId,proto3" json:"volume_id,omitempty"` // These parameters define how to access the volume. // // Types that are valid to be assigned to Params: // *MapVolumeRequest_Malloc // *MapVolumeRequest_Ceph Params isMapVolumeRequest_Params `protobuf_oneof:"params"` }
func (*MapVolumeRequest) Descriptor ¶
func (*MapVolumeRequest) Descriptor() ([]byte, []int)
func (*MapVolumeRequest) GetCeph ¶
func (m *MapVolumeRequest) GetCeph() *CephParams
func (*MapVolumeRequest) GetMalloc ¶
func (m *MapVolumeRequest) GetMalloc() *MallocParams
func (*MapVolumeRequest) GetParams ¶
func (m *MapVolumeRequest) GetParams() isMapVolumeRequest_Params
func (*MapVolumeRequest) GetVolumeId ¶
func (m *MapVolumeRequest) GetVolumeId() string
func (*MapVolumeRequest) Marshal ¶
func (m *MapVolumeRequest) Marshal() (dAtA []byte, err error)
func (*MapVolumeRequest) ProtoMessage ¶
func (*MapVolumeRequest) ProtoMessage()
func (*MapVolumeRequest) Reset ¶
func (m *MapVolumeRequest) Reset()
func (*MapVolumeRequest) Size ¶
func (m *MapVolumeRequest) Size() (n int)
func (*MapVolumeRequest) String ¶
func (m *MapVolumeRequest) String() string
func (*MapVolumeRequest) Unmarshal ¶
func (m *MapVolumeRequest) Unmarshal(dAtA []byte) error
func (*MapVolumeRequest) XXX_OneofFuncs ¶
func (*MapVolumeRequest) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})
XXX_OneofFuncs is for the internal use of the proto package.
type MapVolumeRequest_Ceph ¶
type MapVolumeRequest_Ceph struct {
Ceph *CephParams `protobuf:"bytes,3,opt,name=ceph,oneof"`
}
func (*MapVolumeRequest_Ceph) MarshalTo ¶
func (m *MapVolumeRequest_Ceph) MarshalTo(dAtA []byte) (int, error)
func (*MapVolumeRequest_Ceph) Size ¶
func (m *MapVolumeRequest_Ceph) Size() (n int)
type MapVolumeRequest_Malloc ¶
type MapVolumeRequest_Malloc struct {
Malloc *MallocParams `protobuf:"bytes,2,opt,name=malloc,oneof"`
}
func (*MapVolumeRequest_Malloc) MarshalTo ¶
func (m *MapVolumeRequest_Malloc) MarshalTo(dAtA []byte) (int, error)
func (*MapVolumeRequest_Malloc) Size ¶
func (m *MapVolumeRequest_Malloc) Size() (n int)
type PCIAddress ¶
type PCIAddress struct { // Domain number. Domain uint32 `protobuf:"varint,1,opt,name=domain,proto3" json:"domain,omitempty"` // Bus number. Bus uint32 `protobuf:"varint,2,opt,name=bus,proto3" json:"bus,omitempty"` // Device number. Device uint32 `protobuf:"varint,3,opt,name=device,proto3" json:"device,omitempty"` // Function number. Function uint32 `protobuf:"varint,4,opt,name=function,proto3" json:"function,omitempty"` }
Each field can be marked as unknown or unset with 0xFFFF. This leads to nicer code than the other workarounds for missing optional scalars (.google.protobuf.UInt32Value or oneof).
func (*PCIAddress) Descriptor ¶
func (*PCIAddress) Descriptor() ([]byte, []int)
func (*PCIAddress) GetBus ¶
func (m *PCIAddress) GetBus() uint32
func (*PCIAddress) GetDevice ¶
func (m *PCIAddress) GetDevice() uint32
func (*PCIAddress) GetDomain ¶
func (m *PCIAddress) GetDomain() uint32
func (*PCIAddress) GetFunction ¶
func (m *PCIAddress) GetFunction() uint32
func (*PCIAddress) Marshal ¶
func (m *PCIAddress) Marshal() (dAtA []byte, err error)
func (*PCIAddress) ProtoMessage ¶
func (*PCIAddress) ProtoMessage()
func (*PCIAddress) Reset ¶
func (m *PCIAddress) Reset()
func (*PCIAddress) Size ¶
func (m *PCIAddress) Size() (n int)
func (*PCIAddress) String ¶
func (m *PCIAddress) String() string
func (*PCIAddress) Unmarshal ¶
func (m *PCIAddress) Unmarshal(dAtA []byte) error
type ProvisionMallocBDevReply ¶
type ProvisionMallocBDevReply struct { }
func (*ProvisionMallocBDevReply) Descriptor ¶
func (*ProvisionMallocBDevReply) Descriptor() ([]byte, []int)
func (*ProvisionMallocBDevReply) Marshal ¶
func (m *ProvisionMallocBDevReply) Marshal() (dAtA []byte, err error)
func (*ProvisionMallocBDevReply) MarshalTo ¶
func (m *ProvisionMallocBDevReply) MarshalTo(dAtA []byte) (int, error)
func (*ProvisionMallocBDevReply) ProtoMessage ¶
func (*ProvisionMallocBDevReply) ProtoMessage()
func (*ProvisionMallocBDevReply) Reset ¶
func (m *ProvisionMallocBDevReply) Reset()
func (*ProvisionMallocBDevReply) Size ¶
func (m *ProvisionMallocBDevReply) Size() (n int)
func (*ProvisionMallocBDevReply) String ¶
func (m *ProvisionMallocBDevReply) String() string
func (*ProvisionMallocBDevReply) Unmarshal ¶
func (m *ProvisionMallocBDevReply) Unmarshal(dAtA []byte) error
type ProvisionMallocBDevRequest ¶
type ProvisionMallocBDevRequest struct { // The desired name of the new BDev. BdevName string `protobuf:"bytes,1,opt,name=bdev_name,json=bdevName,proto3" json:"bdev_name,omitempty"` // The desired size in bytes. Must be a multiple of 512. Size_ int64 `protobuf:"varint,2,opt,name=size,proto3" json:"size,omitempty"` }
func (*ProvisionMallocBDevRequest) Descriptor ¶
func (*ProvisionMallocBDevRequest) Descriptor() ([]byte, []int)
func (*ProvisionMallocBDevRequest) GetBdevName ¶
func (m *ProvisionMallocBDevRequest) GetBdevName() string
func (*ProvisionMallocBDevRequest) GetSize_ ¶
func (m *ProvisionMallocBDevRequest) GetSize_() int64
func (*ProvisionMallocBDevRequest) Marshal ¶
func (m *ProvisionMallocBDevRequest) Marshal() (dAtA []byte, err error)
func (*ProvisionMallocBDevRequest) MarshalTo ¶
func (m *ProvisionMallocBDevRequest) MarshalTo(dAtA []byte) (int, error)
func (*ProvisionMallocBDevRequest) ProtoMessage ¶
func (*ProvisionMallocBDevRequest) ProtoMessage()
func (*ProvisionMallocBDevRequest) Reset ¶
func (m *ProvisionMallocBDevRequest) Reset()
func (*ProvisionMallocBDevRequest) Size ¶
func (m *ProvisionMallocBDevRequest) Size() (n int)
func (*ProvisionMallocBDevRequest) String ¶
func (m *ProvisionMallocBDevRequest) String() string
func (*ProvisionMallocBDevRequest) Unmarshal ¶
func (m *ProvisionMallocBDevRequest) Unmarshal(dAtA []byte) error
type RegistryClient ¶
type RegistryClient interface { // Set or overwrite a registry DB entry. SetValue(ctx context.Context, in *SetValueRequest, opts ...grpc.CallOption) (*SetValueReply, error) // Retrieves registry DB entries. GetValues(ctx context.Context, in *GetValuesRequest, opts ...grpc.CallOption) (*GetValuesReply, error) }
func NewRegistryClient ¶
func NewRegistryClient(cc *grpc.ClientConn) RegistryClient
type RegistryServer ¶
type RegistryServer interface { // Set or overwrite a registry DB entry. SetValue(context.Context, *SetValueRequest) (*SetValueReply, error) // Retrieves registry DB entries. GetValues(context.Context, *GetValuesRequest) (*GetValuesReply, error) }
type SCSIDisk ¶
type SCSIDisk struct { Target uint32 `protobuf:"varint,1,opt,name=target,proto3" json:"target,omitempty"` Lun uint32 `protobuf:"varint,2,opt,name=lun,proto3" json:"lun,omitempty"` }
func (*SCSIDisk) Descriptor ¶
func (*SCSIDisk) ProtoMessage ¶
func (*SCSIDisk) ProtoMessage()
type SetValueReply ¶
type SetValueReply struct { }
func (*SetValueReply) Descriptor ¶
func (*SetValueReply) Descriptor() ([]byte, []int)
func (*SetValueReply) Marshal ¶
func (m *SetValueReply) Marshal() (dAtA []byte, err error)
func (*SetValueReply) ProtoMessage ¶
func (*SetValueReply) ProtoMessage()
func (*SetValueReply) Reset ¶
func (m *SetValueReply) Reset()
func (*SetValueReply) Size ¶
func (m *SetValueReply) Size() (n int)
func (*SetValueReply) String ¶
func (m *SetValueReply) String() string
func (*SetValueReply) Unmarshal ¶
func (m *SetValueReply) Unmarshal(dAtA []byte) error
type SetValueRequest ¶
type SetValueRequest struct {
Value *Value `protobuf:"bytes,1,opt,name=value" json:"value,omitempty"`
}
func (*SetValueRequest) Descriptor ¶
func (*SetValueRequest) Descriptor() ([]byte, []int)
func (*SetValueRequest) GetValue ¶
func (m *SetValueRequest) GetValue() *Value
func (*SetValueRequest) Marshal ¶
func (m *SetValueRequest) Marshal() (dAtA []byte, err error)
func (*SetValueRequest) ProtoMessage ¶
func (*SetValueRequest) ProtoMessage()
func (*SetValueRequest) Reset ¶
func (m *SetValueRequest) Reset()
func (*SetValueRequest) Size ¶
func (m *SetValueRequest) Size() (n int)
func (*SetValueRequest) String ¶
func (m *SetValueRequest) String() string
func (*SetValueRequest) Unmarshal ¶
func (m *SetValueRequest) Unmarshal(dAtA []byte) error
type UnmapVolumeReply ¶
type UnmapVolumeReply struct { }
func (*UnmapVolumeReply) Descriptor ¶
func (*UnmapVolumeReply) Descriptor() ([]byte, []int)
func (*UnmapVolumeReply) Marshal ¶
func (m *UnmapVolumeReply) Marshal() (dAtA []byte, err error)
func (*UnmapVolumeReply) ProtoMessage ¶
func (*UnmapVolumeReply) ProtoMessage()
func (*UnmapVolumeReply) Reset ¶
func (m *UnmapVolumeReply) Reset()
func (*UnmapVolumeReply) Size ¶
func (m *UnmapVolumeReply) Size() (n int)
func (*UnmapVolumeReply) String ¶
func (m *UnmapVolumeReply) String() string
func (*UnmapVolumeReply) Unmarshal ¶
func (m *UnmapVolumeReply) Unmarshal(dAtA []byte) error
type UnmapVolumeRequest ¶
type UnmapVolumeRequest struct { // The volume ID that was used when mapping the volume. VolumeId string `protobuf:"bytes,1,opt,name=volume_id,json=volumeId,proto3" json:"volume_id,omitempty"` }
func (*UnmapVolumeRequest) Descriptor ¶
func (*UnmapVolumeRequest) Descriptor() ([]byte, []int)
func (*UnmapVolumeRequest) GetVolumeId ¶
func (m *UnmapVolumeRequest) GetVolumeId() string
func (*UnmapVolumeRequest) Marshal ¶
func (m *UnmapVolumeRequest) Marshal() (dAtA []byte, err error)
func (*UnmapVolumeRequest) MarshalTo ¶
func (m *UnmapVolumeRequest) MarshalTo(dAtA []byte) (int, error)
func (*UnmapVolumeRequest) ProtoMessage ¶
func (*UnmapVolumeRequest) ProtoMessage()
func (*UnmapVolumeRequest) Reset ¶
func (m *UnmapVolumeRequest) Reset()
func (*UnmapVolumeRequest) Size ¶
func (m *UnmapVolumeRequest) Size() (n int)
func (*UnmapVolumeRequest) String ¶
func (m *UnmapVolumeRequest) String() string
func (*UnmapVolumeRequest) Unmarshal ¶
func (m *UnmapVolumeRequest) Unmarshal(dAtA []byte) error
type Value ¶
type Value struct { // A value is referenced by a set of path elements, // separated by slashes. Leading and trailing slashes // are ignored, repeated slashes treated like a single // slash. "." and ".." are invalid path elements. Path string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"` // The value itself is also a string. Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"` }
A single registry DB entry.
func (*Value) Descriptor ¶
func (*Value) ProtoMessage ¶
func (*Value) ProtoMessage()