ndm

package
Version: v1.7.1 Latest Latest
Warning

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

Go to latest
Published: Sep 24, 2021 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

Functions

func RegisterInfoServer

func RegisterInfoServer(s *grpc.Server, srv InfoServer)

func RegisterNodeServer

func RegisterNodeServer(s *grpc.Server, srv NodeServer)

Types

type BlockDevice

type BlockDevice struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Type can be Disk, Loop, LVM, etc
	Type       string   `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	Partitions []string `protobuf:"bytes,3,rep,name=partitions,proto3" json:"partitions,omitempty"` // Other fields about disk can be added here
	// contains filtered or unexported fields
}

func (*BlockDevice) Descriptor deprecated

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

Deprecated: Use BlockDevice.ProtoReflect.Descriptor instead.

func (*BlockDevice) GetName

func (x *BlockDevice) GetName() string

func (*BlockDevice) GetPartitions

func (x *BlockDevice) GetPartitions() []string

func (*BlockDevice) GetType

func (x *BlockDevice) GetType() string

func (*BlockDevice) ProtoMessage

func (*BlockDevice) ProtoMessage()

func (*BlockDevice) ProtoReflect

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

func (*BlockDevice) Reset

func (x *BlockDevice) Reset()

func (*BlockDevice) String

func (x *BlockDevice) String() string

type BlockDeviceDetails

type BlockDeviceDetails struct {
	Compliance       string `protobuf:"bytes,1,opt,name=Compliance,proto3" json:"Compliance,omitempty"`
	Vendor           string `protobuf:"bytes,2,opt,name=Vendor,proto3" json:"Vendor,omitempty"`
	Model            string `protobuf:"bytes,3,opt,name=Model,proto3" json:"Model,omitempty"`
	SerialNumber     string `protobuf:"bytes,4,opt,name=SerialNumber,proto3" json:"SerialNumber,omitempty"`
	FirmwareRevision string `protobuf:"bytes,5,opt,name=FirmwareRevision,proto3" json:"FirmwareRevision,omitempty"`
	WWN              string `protobuf:"bytes,6,opt,name=WWN,proto3" json:"WWN,omitempty"`
	Capacity         uint64 `protobuf:"varint,7,opt,name=Capacity,proto3" json:"Capacity,omitempty"`
	LBSize           uint32 `protobuf:"varint,8,opt,name=LBSize,proto3" json:"LBSize,omitempty"`
	PBSize           uint32 `protobuf:"varint,9,opt,name=PBSize,proto3" json:"PBSize,omitempty"`
	RotationRate     uint32 `protobuf:"varint,10,opt,name=RotationRate,proto3" json:"RotationRate,omitempty"`
	ATAMajorVersion  string `protobuf:"bytes,11,opt,name=ATAMajorVersion,proto3" json:"ATAMajorVersion,omitempty"`
	ATAMinorVersion  string `protobuf:"bytes,12,opt,name=ATAMinorVersion,proto3" json:"ATAMinorVersion,omitempty"`
	AtaTransport     string `protobuf:"bytes,13,opt,name=AtaTransport,proto3" json:"AtaTransport,omitempty"`
	// contains filtered or unexported fields
}

func (*BlockDeviceDetails) Descriptor deprecated

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

Deprecated: Use BlockDeviceDetails.ProtoReflect.Descriptor instead.

func (*BlockDeviceDetails) GetATAMajorVersion

func (x *BlockDeviceDetails) GetATAMajorVersion() string

func (*BlockDeviceDetails) GetATAMinorVersion

func (x *BlockDeviceDetails) GetATAMinorVersion() string

func (*BlockDeviceDetails) GetAtaTransport

func (x *BlockDeviceDetails) GetAtaTransport() string

func (*BlockDeviceDetails) GetCapacity

func (x *BlockDeviceDetails) GetCapacity() uint64

func (*BlockDeviceDetails) GetCompliance

func (x *BlockDeviceDetails) GetCompliance() string

func (*BlockDeviceDetails) GetFirmwareRevision

func (x *BlockDeviceDetails) GetFirmwareRevision() string

func (*BlockDeviceDetails) GetLBSize

func (x *BlockDeviceDetails) GetLBSize() uint32

func (*BlockDeviceDetails) GetModel

func (x *BlockDeviceDetails) GetModel() string

func (*BlockDeviceDetails) GetPBSize

func (x *BlockDeviceDetails) GetPBSize() uint32

func (*BlockDeviceDetails) GetRotationRate

func (x *BlockDeviceDetails) GetRotationRate() uint32

func (*BlockDeviceDetails) GetSerialNumber

func (x *BlockDeviceDetails) GetSerialNumber() string

func (*BlockDeviceDetails) GetVendor

func (x *BlockDeviceDetails) GetVendor() string

func (*BlockDeviceDetails) GetWWN

func (x *BlockDeviceDetails) GetWWN() string

func (*BlockDeviceDetails) ProtoMessage

func (*BlockDeviceDetails) ProtoMessage()

func (*BlockDeviceDetails) ProtoReflect

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

func (*BlockDeviceDetails) Reset

func (x *BlockDeviceDetails) Reset()

func (*BlockDeviceDetails) String

func (x *BlockDeviceDetails) String() string

type BlockDevices

type BlockDevices struct {
	Blockdevices []*BlockDevice `protobuf:"bytes,1,rep,name=blockdevices,proto3" json:"blockdevices,omitempty"`
	// contains filtered or unexported fields
}

func (*BlockDevices) Descriptor deprecated

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

Deprecated: Use BlockDevices.ProtoReflect.Descriptor instead.

func (*BlockDevices) GetBlockdevices

func (x *BlockDevices) GetBlockdevices() []*BlockDevice

func (*BlockDevices) ProtoMessage

func (*BlockDevices) ProtoMessage()

func (*BlockDevices) ProtoReflect

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

func (*BlockDevices) Reset

func (x *BlockDevices) Reset()

func (*BlockDevices) String

func (x *BlockDevices) String() string

type Hugepages

type Hugepages struct {
	Pages int32 `protobuf:"varint,1,opt,name=pages,proto3" json:"pages,omitempty"`
	// contains filtered or unexported fields
}

func (*Hugepages) Descriptor deprecated

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

Deprecated: Use Hugepages.ProtoReflect.Descriptor instead.

func (*Hugepages) GetPages

func (x *Hugepages) GetPages() int32

func (*Hugepages) ProtoMessage

func (*Hugepages) ProtoMessage()

func (*Hugepages) ProtoReflect

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

func (*Hugepages) Reset

func (x *Hugepages) Reset()

func (*Hugepages) String

func (x *Hugepages) String() string

type HugepagesResult

type HugepagesResult struct {
	Result bool `protobuf:"varint,1,opt,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}

func (*HugepagesResult) Descriptor deprecated

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

Deprecated: Use HugepagesResult.ProtoReflect.Descriptor instead.

func (*HugepagesResult) GetResult

func (x *HugepagesResult) GetResult() bool

func (*HugepagesResult) ProtoMessage

func (*HugepagesResult) ProtoMessage()

func (*HugepagesResult) ProtoReflect

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

func (*HugepagesResult) Reset

func (x *HugepagesResult) Reset()

func (*HugepagesResult) String

func (x *HugepagesResult) String() string

type InfoClient

type InfoClient interface {
	// FindVersion Method gets the version information of the NDM components installed
	FindVersion(ctx context.Context, in *Null, opts ...grpc.CallOption) (*VersionInfo, error)
}

InfoClient is the client API for Info service.

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

func NewInfoClient

func NewInfoClient(cc grpc.ClientConnInterface) InfoClient

type InfoServer

type InfoServer interface {
	// FindVersion Method gets the version information of the NDM components installed
	FindVersion(context.Context, *Null) (*VersionInfo, error)
}

InfoServer is the server API for Info service.

type Message

type Message struct {
	Msg string `protobuf:"bytes,1,opt,name=msg,proto3" json:"msg,omitempty"`
	// contains filtered or unexported fields
}

func (*Message) Descriptor deprecated

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

Deprecated: Use Message.ProtoReflect.Descriptor instead.

func (*Message) GetMsg

func (x *Message) GetMsg() string

func (*Message) ProtoMessage

func (*Message) ProtoMessage()

func (*Message) ProtoReflect

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

func (*Message) Reset

func (x *Message) Reset()

func (*Message) String

func (x *Message) String() string

type NodeClient

type NodeClient interface {
	// Name method is used find the name of the node on which NDM is running on
	Name(ctx context.Context, in *Null, opts ...grpc.CallOption) (*NodeName, error)
	// ListBlockDevices method is used to return all the block devices found in hierarchy by NDM
	ListBlockDevices(ctx context.Context, in *Null, opts ...grpc.CallOption) (*BlockDevices, error)
	// ISCSIStatus method returns status of ISCSI
	ISCSIStatus(ctx context.Context, in *Null, opts ...grpc.CallOption) (*Status, error)
	// ListBlockDeviceDetails method is used to find SMART info about a block device.
	// Only the name field is required for input
	ListBlockDeviceDetails(ctx context.Context, in *BlockDevice, opts ...grpc.CallOption) (*BlockDeviceDetails, error)
	// SetHugepages sets 2MB hugePages on this node.
	// Note: Calling this method doesn't guarantee that the said number of pages will be set.
	// This is because OS might not have the demanded memory. It would be best to check if this is satisfied with GetHugePages
	SetHugepages(ctx context.Context, in *Hugepages, opts ...grpc.CallOption) (*HugepagesResult, error)
	// GetHugepages gets the number of huge pages set on the node
	GetHugepages(ctx context.Context, in *Null, opts ...grpc.CallOption) (*Hugepages, error)
	// Rescan syncs etcd and NDM's local state
	Rescan(ctx context.Context, in *Null, opts ...grpc.CallOption) (*Message, error)
}

NodeClient is the client API for Node service.

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

func NewNodeClient

func NewNodeClient(cc grpc.ClientConnInterface) NodeClient

type NodeName

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

func (*NodeName) Descriptor deprecated

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

Deprecated: Use NodeName.ProtoReflect.Descriptor instead.

func (*NodeName) GetNodeName

func (x *NodeName) GetNodeName() string

func (*NodeName) ProtoMessage

func (*NodeName) ProtoMessage()

func (*NodeName) ProtoReflect

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

func (*NodeName) Reset

func (x *NodeName) Reset()

func (*NodeName) String

func (x *NodeName) String() string

type NodeServer

type NodeServer interface {
	// Name method is used find the name of the node on which NDM is running on
	Name(context.Context, *Null) (*NodeName, error)
	// ListBlockDevices method is used to return all the block devices found in hierarchy by NDM
	ListBlockDevices(context.Context, *Null) (*BlockDevices, error)
	// ISCSIStatus method returns status of ISCSI
	ISCSIStatus(context.Context, *Null) (*Status, error)
	// ListBlockDeviceDetails method is used to find SMART info about a block device.
	// Only the name field is required for input
	ListBlockDeviceDetails(context.Context, *BlockDevice) (*BlockDeviceDetails, error)
	// SetHugepages sets 2MB hugePages on this node.
	// Note: Calling this method doesn't guarantee that the said number of pages will be set.
	// This is because OS might not have the demanded memory. It would be best to check if this is satisfied with GetHugePages
	SetHugepages(context.Context, *Hugepages) (*HugepagesResult, error)
	// GetHugepages gets the number of huge pages set on the node
	GetHugepages(context.Context, *Null) (*Hugepages, error)
	// Rescan syncs etcd and NDM's local state
	Rescan(context.Context, *Null) (*Message, error)
}

NodeServer is the server API for Node service.

type Null

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

func (*Null) Descriptor deprecated

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

Deprecated: Use Null.ProtoReflect.Descriptor instead.

func (*Null) ProtoMessage

func (*Null) ProtoMessage()

func (*Null) ProtoReflect

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

func (*Null) Reset

func (x *Null) Reset()

func (*Null) String

func (x *Null) String() string

type Status

type Status struct {
	Status bool `protobuf:"varint,1,opt,name=Status,proto3" json:"Status,omitempty"`
	// contains filtered or unexported fields
}

func (*Status) Descriptor deprecated

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

Deprecated: Use Status.ProtoReflect.Descriptor instead.

func (*Status) GetStatus

func (x *Status) GetStatus() bool

func (*Status) ProtoMessage

func (*Status) ProtoMessage()

func (*Status) ProtoReflect

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

func (*Status) Reset

func (x *Status) Reset()

func (*Status) String

func (x *Status) String() string

type UnimplementedInfoServer

type UnimplementedInfoServer struct {
}

UnimplementedInfoServer can be embedded to have forward compatible implementations.

func (*UnimplementedInfoServer) FindVersion

type UnimplementedNodeServer

type UnimplementedNodeServer struct {
}

UnimplementedNodeServer can be embedded to have forward compatible implementations.

func (*UnimplementedNodeServer) GetHugepages

func (*UnimplementedNodeServer) ISCSIStatus

func (*UnimplementedNodeServer) ListBlockDeviceDetails

func (*UnimplementedNodeServer) ListBlockDevices

func (*UnimplementedNodeServer) ListBlockDevices(context.Context, *Null) (*BlockDevices, error)

func (*UnimplementedNodeServer) Name

func (*UnimplementedNodeServer) Rescan

func (*UnimplementedNodeServer) SetHugepages

type VersionInfo

type VersionInfo struct {
	Version   string `protobuf:"bytes,1,opt,name=Version,proto3" json:"Version,omitempty"`
	GitCommit string `protobuf:"bytes,2,opt,name=GitCommit,proto3" json:"GitCommit,omitempty"`
	// contains filtered or unexported fields
}

func (*VersionInfo) Descriptor deprecated

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

Deprecated: Use VersionInfo.ProtoReflect.Descriptor instead.

func (*VersionInfo) GetGitCommit

func (x *VersionInfo) GetGitCommit() string

func (*VersionInfo) GetVersion

func (x *VersionInfo) GetVersion() string

func (*VersionInfo) ProtoMessage

func (*VersionInfo) ProtoMessage()

func (*VersionInfo) ProtoReflect

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

func (*VersionInfo) Reset

func (x *VersionInfo) Reset()

func (*VersionInfo) String

func (x *VersionInfo) String() string

Source Files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL