Help us shape the future of Go! Take the 2026 Go Developer Survey

proto

package
v1.2.2 Latest Latest
Warning

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

Go to latest
Published: Nov 24, 2021 License: MPL-2.0 Imports: 10 Imported by: 20

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterDevicePluginServer

func RegisterDevicePluginServer(s *grpc.Server, srv DevicePluginServer)

Types

type ContainerReservation

type ContainerReservation struct {
	// List of environment variable to be set
	Envs map[string]string `` /* 149-byte string literal not displayed */
	// Mounts for the task.
	Mounts []*Mount `protobuf:"bytes,2,rep,name=mounts,proto3" json:"mounts,omitempty"`
	// Devices for the task.
	Devices              []*DeviceSpec `protobuf:"bytes,3,rep,name=devices,proto3" json:"devices,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

ContainerReservation returns how to mount the device into a container that shares the host OS.

func (*ContainerReservation) Descriptor

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

func (*ContainerReservation) GetDevices

func (m *ContainerReservation) GetDevices() []*DeviceSpec

func (*ContainerReservation) GetEnvs

func (m *ContainerReservation) GetEnvs() map[string]string

func (*ContainerReservation) GetMounts

func (m *ContainerReservation) GetMounts() []*Mount

func (*ContainerReservation) ProtoMessage

func (*ContainerReservation) ProtoMessage()

func (*ContainerReservation) Reset

func (m *ContainerReservation) Reset()

func (*ContainerReservation) String

func (m *ContainerReservation) String() string

func (*ContainerReservation) XXX_DiscardUnknown

func (m *ContainerReservation) XXX_DiscardUnknown()

func (*ContainerReservation) XXX_Marshal

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

func (*ContainerReservation) XXX_Merge

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

func (*ContainerReservation) XXX_Size

func (m *ContainerReservation) XXX_Size() int

func (*ContainerReservation) XXX_Unmarshal

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

type DetectedDevice

type DetectedDevice struct {
	// ID is the ID of the device. This ID is used during allocation and must be
	// stable across restarts of the device driver.
	// buf:lint:ignore FIELD_LOWER_SNAKE_CASE
	ID string `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty"`
	// Health of the device.
	Healthy bool `protobuf:"varint,2,opt,name=healthy,proto3" json:"healthy,omitempty"`
	// health_description allows the device plugin to optionally
	// annotate the health field with a human readable reason.
	HealthDescription string `protobuf:"bytes,3,opt,name=health_description,json=healthDescription,proto3" json:"health_description,omitempty"`
	// hw_locality is optionally set to expose hardware locality information for
	// more optimal placement decisions.
	HwLocality           *DeviceLocality `protobuf:"bytes,4,opt,name=hw_locality,json=hwLocality,proto3" json:"hw_locality,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

DetectedDevice is a single detected device.

func (*DetectedDevice) Descriptor

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

func (*DetectedDevice) GetHealthDescription

func (m *DetectedDevice) GetHealthDescription() string

func (*DetectedDevice) GetHealthy

func (m *DetectedDevice) GetHealthy() bool

func (*DetectedDevice) GetHwLocality

func (m *DetectedDevice) GetHwLocality() *DeviceLocality

func (*DetectedDevice) GetID

func (m *DetectedDevice) GetID() string

func (*DetectedDevice) ProtoMessage

func (*DetectedDevice) ProtoMessage()

func (*DetectedDevice) Reset

func (m *DetectedDevice) Reset()

func (*DetectedDevice) String

func (m *DetectedDevice) String() string

func (*DetectedDevice) XXX_DiscardUnknown

func (m *DetectedDevice) XXX_DiscardUnknown()

func (*DetectedDevice) XXX_Marshal

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

func (*DetectedDevice) XXX_Merge

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

func (*DetectedDevice) XXX_Size

func (m *DetectedDevice) XXX_Size() int

func (*DetectedDevice) XXX_Unmarshal

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

type DeviceGroup

type DeviceGroup struct {
	// vendor is the name of the vendor of the device
	Vendor string `protobuf:"bytes,1,opt,name=vendor,proto3" json:"vendor,omitempty"`
	// device_type is the type of the device (gpu, fpga, etc).
	DeviceType string `protobuf:"bytes,2,opt,name=device_type,json=deviceType,proto3" json:"device_type,omitempty"`
	// device_name is the name of the device.
	DeviceName string `protobuf:"bytes,3,opt,name=device_name,json=deviceName,proto3" json:"device_name,omitempty"`
	// devices is the set of devices detected by the plugin.
	Devices []*DetectedDevice `protobuf:"bytes,4,rep,name=devices,proto3" json:"devices,omitempty"`
	// attributes allows adding attributes to be used for constraints or
	// affinities.
	Attributes           map[string]*proto1.Attribute `` /* 161-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                     `json:"-"`
	XXX_unrecognized     []byte                       `json:"-"`
	XXX_sizecache        int32                        `json:"-"`
}

DeviceGroup is a group of devices that share a vendor, device type and name.

func (*DeviceGroup) Descriptor

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

func (*DeviceGroup) GetAttributes

func (m *DeviceGroup) GetAttributes() map[string]*proto1.Attribute

func (*DeviceGroup) GetDeviceName

func (m *DeviceGroup) GetDeviceName() string

func (*DeviceGroup) GetDeviceType

func (m *DeviceGroup) GetDeviceType() string

func (*DeviceGroup) GetDevices

func (m *DeviceGroup) GetDevices() []*DetectedDevice

func (*DeviceGroup) GetVendor

func (m *DeviceGroup) GetVendor() string

func (*DeviceGroup) ProtoMessage

func (*DeviceGroup) ProtoMessage()

func (*DeviceGroup) Reset

func (m *DeviceGroup) Reset()

func (*DeviceGroup) String

func (m *DeviceGroup) String() string

func (*DeviceGroup) XXX_DiscardUnknown

func (m *DeviceGroup) XXX_DiscardUnknown()

func (*DeviceGroup) XXX_Marshal

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

func (*DeviceGroup) XXX_Merge

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

func (*DeviceGroup) XXX_Size

func (m *DeviceGroup) XXX_Size() int

func (*DeviceGroup) XXX_Unmarshal

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

type DeviceGroupStats

type DeviceGroupStats struct {
	Vendor string `protobuf:"bytes,1,opt,name=vendor,proto3" json:"vendor,omitempty"`
	Type   string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	Name   string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	// instance_stats is a mapping of each device ID to its statistics.
	InstanceStats        map[string]*DeviceStats `` /* 188-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
	XXX_unrecognized     []byte                  `json:"-"`
	XXX_sizecache        int32                   `json:"-"`
}

DeviceGroupStats contains statistics for each device of a particular device group, identified by the vendor, type and name of the device.

func (*DeviceGroupStats) Descriptor

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

func (*DeviceGroupStats) GetInstanceStats

func (m *DeviceGroupStats) GetInstanceStats() map[string]*DeviceStats

func (*DeviceGroupStats) GetName

func (m *DeviceGroupStats) GetName() string

func (*DeviceGroupStats) GetType

func (m *DeviceGroupStats) GetType() string

func (*DeviceGroupStats) GetVendor

func (m *DeviceGroupStats) GetVendor() string

func (*DeviceGroupStats) ProtoMessage

func (*DeviceGroupStats) ProtoMessage()

func (*DeviceGroupStats) Reset

func (m *DeviceGroupStats) Reset()

func (*DeviceGroupStats) String

func (m *DeviceGroupStats) String() string

func (*DeviceGroupStats) XXX_DiscardUnknown

func (m *DeviceGroupStats) XXX_DiscardUnknown()

func (*DeviceGroupStats) XXX_Marshal

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

func (*DeviceGroupStats) XXX_Merge

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

func (*DeviceGroupStats) XXX_Size

func (m *DeviceGroupStats) XXX_Size() int

func (*DeviceGroupStats) XXX_Unmarshal

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

type DeviceLocality

type DeviceLocality struct {
	// pci_bus_id is the PCI bus ID for the device. If reported, it
	// allows Nomad to make NUMA aware optimizations.
	PciBusId             string   `protobuf:"bytes,1,opt,name=pci_bus_id,json=pciBusId,proto3" json:"pci_bus_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

DeviceLocality is used to expose HW locality information about a device.

func (*DeviceLocality) Descriptor

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

func (*DeviceLocality) GetPciBusId

func (m *DeviceLocality) GetPciBusId() string

func (*DeviceLocality) ProtoMessage

func (*DeviceLocality) ProtoMessage()

func (*DeviceLocality) Reset

func (m *DeviceLocality) Reset()

func (*DeviceLocality) String

func (m *DeviceLocality) String() string

func (*DeviceLocality) XXX_DiscardUnknown

func (m *DeviceLocality) XXX_DiscardUnknown()

func (*DeviceLocality) XXX_Marshal

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

func (*DeviceLocality) XXX_Merge

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

func (*DeviceLocality) XXX_Size

func (m *DeviceLocality) XXX_Size() int

func (*DeviceLocality) XXX_Unmarshal

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

type DevicePluginClient

type DevicePluginClient interface {
	// Fingerprint allows the device plugin to return a set of
	// detected devices and provide a mechanism to update the state of
	// the device.
	Fingerprint(ctx context.Context, in *FingerprintRequest, opts ...grpc.CallOption) (DevicePlugin_FingerprintClient, error)
	// Reserve is called by the client before starting an allocation
	// that requires access to the plugin’s devices. The plugin can use
	// this to run any setup steps and provides the mounting details to
	// the Nomad client
	Reserve(ctx context.Context, in *ReserveRequest, opts ...grpc.CallOption) (*ReserveResponse, error)
	// Stats returns a stream of device statistics.
	Stats(ctx context.Context, in *StatsRequest, opts ...grpc.CallOption) (DevicePlugin_StatsClient, error)
}

DevicePluginClient is the client API for DevicePlugin service.

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

type DevicePluginServer

type DevicePluginServer interface {
	// Fingerprint allows the device plugin to return a set of
	// detected devices and provide a mechanism to update the state of
	// the device.
	Fingerprint(*FingerprintRequest, DevicePlugin_FingerprintServer) error
	// Reserve is called by the client before starting an allocation
	// that requires access to the plugin’s devices. The plugin can use
	// this to run any setup steps and provides the mounting details to
	// the Nomad client
	Reserve(context.Context, *ReserveRequest) (*ReserveResponse, error)
	// Stats returns a stream of device statistics.
	Stats(*StatsRequest, DevicePlugin_StatsServer) error
}

DevicePluginServer is the server API for DevicePlugin service.

type DevicePlugin_FingerprintClient

type DevicePlugin_FingerprintClient interface {
	Recv() (*FingerprintResponse, error)
	grpc.ClientStream
}

type DevicePlugin_FingerprintServer

type DevicePlugin_FingerprintServer interface {
	Send(*FingerprintResponse) error
	grpc.ServerStream
}

type DevicePlugin_StatsClient

type DevicePlugin_StatsClient interface {
	Recv() (*StatsResponse, error)
	grpc.ClientStream
}

type DevicePlugin_StatsServer

type DevicePlugin_StatsServer interface {
	Send(*StatsResponse) error
	grpc.ServerStream
}

type DeviceSpec

type DeviceSpec struct {
	// Path of the device within the task.
	TaskPath string `protobuf:"bytes,1,opt,name=task_path,json=taskPath,proto3" json:"task_path,omitempty"`
	// Path of the device on the host.
	HostPath string `protobuf:"bytes,2,opt,name=host_path,json=hostPath,proto3" json:"host_path,omitempty"`
	// Cgroups permissions of the device, candidates are one or more of
	// * r - allows task to read from the specified device.
	// * w - allows task to write to the specified device.
	// * m - allows task to create device files that do not yet exist
	Permissions          string   `protobuf:"bytes,3,opt,name=permissions,proto3" json:"permissions,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

DeviceSpec specifies a host device to mount into a task.

func (*DeviceSpec) Descriptor

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

func (*DeviceSpec) GetHostPath

func (m *DeviceSpec) GetHostPath() string

func (*DeviceSpec) GetPermissions

func (m *DeviceSpec) GetPermissions() string

func (*DeviceSpec) GetTaskPath

func (m *DeviceSpec) GetTaskPath() string

func (*DeviceSpec) ProtoMessage

func (*DeviceSpec) ProtoMessage()

func (*DeviceSpec) Reset

func (m *DeviceSpec) Reset()

func (*DeviceSpec) String

func (m *DeviceSpec) String() string

func (*DeviceSpec) XXX_DiscardUnknown

func (m *DeviceSpec) XXX_DiscardUnknown()

func (*DeviceSpec) XXX_Marshal

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

func (*DeviceSpec) XXX_Merge

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

func (*DeviceSpec) XXX_Size

func (m *DeviceSpec) XXX_Size() int

func (*DeviceSpec) XXX_Unmarshal

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

type DeviceStats

type DeviceStats struct {
	// summary exposes a single summary metric that should be the most
	// informative to users.
	Summary *proto1.StatValue `protobuf:"bytes,1,opt,name=summary,proto3" json:"summary,omitempty"`
	// stats contains the verbose statistics for the device.
	Stats *proto1.StatObject `protobuf:"bytes,2,opt,name=stats,proto3" json:"stats,omitempty"`
	// timestamp is the time the statistics were collected.
	Timestamp            *timestamp.Timestamp `protobuf:"bytes,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

DeviceStats is the statistics for an individual device

func (*DeviceStats) Descriptor

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

func (*DeviceStats) GetStats

func (m *DeviceStats) GetStats() *proto1.StatObject

func (*DeviceStats) GetSummary

func (m *DeviceStats) GetSummary() *proto1.StatValue

func (*DeviceStats) GetTimestamp

func (m *DeviceStats) GetTimestamp() *timestamp.Timestamp

func (*DeviceStats) ProtoMessage

func (*DeviceStats) ProtoMessage()

func (*DeviceStats) Reset

func (m *DeviceStats) Reset()

func (*DeviceStats) String

func (m *DeviceStats) String() string

func (*DeviceStats) XXX_DiscardUnknown

func (m *DeviceStats) XXX_DiscardUnknown()

func (*DeviceStats) XXX_Marshal

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

func (*DeviceStats) XXX_Merge

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

func (*DeviceStats) XXX_Size

func (m *DeviceStats) XXX_Size() int

func (*DeviceStats) XXX_Unmarshal

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

type FingerprintRequest

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

FingerprintRequest is used to request for devices to be fingerprinted.

func (*FingerprintRequest) Descriptor

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

func (*FingerprintRequest) ProtoMessage

func (*FingerprintRequest) ProtoMessage()

func (*FingerprintRequest) Reset

func (m *FingerprintRequest) Reset()

func (*FingerprintRequest) String

func (m *FingerprintRequest) String() string

func (*FingerprintRequest) XXX_DiscardUnknown

func (m *FingerprintRequest) XXX_DiscardUnknown()

func (*FingerprintRequest) XXX_Marshal

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

func (*FingerprintRequest) XXX_Merge

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

func (*FingerprintRequest) XXX_Size

func (m *FingerprintRequest) XXX_Size() int

func (*FingerprintRequest) XXX_Unmarshal

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

type FingerprintResponse

type FingerprintResponse struct {
	// device_group is a group of devices that share a vendor, device_type, and
	// device_name. This is returned as a set so that a single plugin could
	// potentially detect several device types and models.
	DeviceGroup          []*DeviceGroup `protobuf:"bytes,1,rep,name=device_group,json=deviceGroup,proto3" json:"device_group,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

FingerprintResponse returns a set of detected devices.

func (*FingerprintResponse) Descriptor

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

func (*FingerprintResponse) GetDeviceGroup

func (m *FingerprintResponse) GetDeviceGroup() []*DeviceGroup

func (*FingerprintResponse) ProtoMessage

func (*FingerprintResponse) ProtoMessage()

func (*FingerprintResponse) Reset

func (m *FingerprintResponse) Reset()

func (*FingerprintResponse) String

func (m *FingerprintResponse) String() string

func (*FingerprintResponse) XXX_DiscardUnknown

func (m *FingerprintResponse) XXX_DiscardUnknown()

func (*FingerprintResponse) XXX_Marshal

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

func (*FingerprintResponse) XXX_Merge

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

func (*FingerprintResponse) XXX_Size

func (m *FingerprintResponse) XXX_Size() int

func (*FingerprintResponse) XXX_Unmarshal

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

type Mount

type Mount struct {
	// Path of the mount within the task.
	TaskPath string `protobuf:"bytes,1,opt,name=task_path,json=taskPath,proto3" json:"task_path,omitempty"`
	// Path of the mount on the host.
	HostPath string `protobuf:"bytes,2,opt,name=host_path,json=hostPath,proto3" json:"host_path,omitempty"`
	// If set, the mount is read-only.
	ReadOnly             bool     `protobuf:"varint,3,opt,name=read_only,json=readOnly,proto3" json:"read_only,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Mount specifies a host volume to mount into a task. where device library or tools are installed on host and task

func (*Mount) Descriptor

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

func (*Mount) GetHostPath

func (m *Mount) GetHostPath() string

func (*Mount) GetReadOnly

func (m *Mount) GetReadOnly() bool

func (*Mount) GetTaskPath

func (m *Mount) GetTaskPath() string

func (*Mount) ProtoMessage

func (*Mount) ProtoMessage()

func (*Mount) Reset

func (m *Mount) Reset()

func (*Mount) String

func (m *Mount) String() string

func (*Mount) XXX_DiscardUnknown

func (m *Mount) XXX_DiscardUnknown()

func (*Mount) XXX_Marshal

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

func (*Mount) XXX_Merge

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

func (*Mount) XXX_Size

func (m *Mount) XXX_Size() int

func (*Mount) XXX_Unmarshal

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

type ReserveRequest

type ReserveRequest struct {
	// device_ids are the requested devices.
	DeviceIds            []string `protobuf:"bytes,1,rep,name=device_ids,json=deviceIds,proto3" json:"device_ids,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

ReserveRequest is used to ask the device driver for information on how to allocate the requested devices.

func (*ReserveRequest) Descriptor

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

func (*ReserveRequest) GetDeviceIds

func (m *ReserveRequest) GetDeviceIds() []string

func (*ReserveRequest) ProtoMessage

func (*ReserveRequest) ProtoMessage()

func (*ReserveRequest) Reset

func (m *ReserveRequest) Reset()

func (*ReserveRequest) String

func (m *ReserveRequest) String() string

func (*ReserveRequest) XXX_DiscardUnknown

func (m *ReserveRequest) XXX_DiscardUnknown()

func (*ReserveRequest) XXX_Marshal

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

func (*ReserveRequest) XXX_Merge

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

func (*ReserveRequest) XXX_Size

func (m *ReserveRequest) XXX_Size() int

func (*ReserveRequest) XXX_Unmarshal

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

type ReserveResponse

type ReserveResponse struct {
	// container_res contains information on how to mount the device
	// into a task isolated using container technologies (where the
	// host is shared)
	ContainerRes         *ContainerReservation `protobuf:"bytes,1,opt,name=container_res,json=containerRes,proto3" json:"container_res,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

ReserveResponse informs Nomad how to expose the requested devices to the the task.

func (*ReserveResponse) Descriptor

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

func (*ReserveResponse) GetContainerRes

func (m *ReserveResponse) GetContainerRes() *ContainerReservation

func (*ReserveResponse) ProtoMessage

func (*ReserveResponse) ProtoMessage()

func (*ReserveResponse) Reset

func (m *ReserveResponse) Reset()

func (*ReserveResponse) String

func (m *ReserveResponse) String() string

func (*ReserveResponse) XXX_DiscardUnknown

func (m *ReserveResponse) XXX_DiscardUnknown()

func (*ReserveResponse) XXX_Marshal

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

func (*ReserveResponse) XXX_Merge

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

func (*ReserveResponse) XXX_Size

func (m *ReserveResponse) XXX_Size() int

func (*ReserveResponse) XXX_Unmarshal

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

type StatsRequest

type StatsRequest struct {
	// collection_interval is the duration in which to collect statistics.
	CollectionInterval   *duration.Duration `protobuf:"bytes,1,opt,name=collection_interval,json=collectionInterval,proto3" json:"collection_interval,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

StatsRequest is used to parameterize the retrieval of statistics.

func (*StatsRequest) Descriptor

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

func (*StatsRequest) GetCollectionInterval

func (m *StatsRequest) GetCollectionInterval() *duration.Duration

func (*StatsRequest) ProtoMessage

func (*StatsRequest) ProtoMessage()

func (*StatsRequest) Reset

func (m *StatsRequest) Reset()

func (*StatsRequest) String

func (m *StatsRequest) String() string

func (*StatsRequest) XXX_DiscardUnknown

func (m *StatsRequest) XXX_DiscardUnknown()

func (*StatsRequest) XXX_Marshal

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

func (*StatsRequest) XXX_Merge

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

func (*StatsRequest) XXX_Size

func (m *StatsRequest) XXX_Size() int

func (*StatsRequest) XXX_Unmarshal

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

type StatsResponse

type StatsResponse struct {
	// groups contains statistics for each device group.
	Groups               []*DeviceGroupStats `protobuf:"bytes,1,rep,name=groups,proto3" json:"groups,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

StatsResponse returns the statistics for each device group.

func (*StatsResponse) Descriptor

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

func (*StatsResponse) GetGroups

func (m *StatsResponse) GetGroups() []*DeviceGroupStats

func (*StatsResponse) ProtoMessage

func (*StatsResponse) ProtoMessage()

func (*StatsResponse) Reset

func (m *StatsResponse) Reset()

func (*StatsResponse) String

func (m *StatsResponse) String() string

func (*StatsResponse) XXX_DiscardUnknown

func (m *StatsResponse) XXX_DiscardUnknown()

func (*StatsResponse) XXX_Marshal

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

func (*StatsResponse) XXX_Merge

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

func (*StatsResponse) XXX_Size

func (m *StatsResponse) XXX_Size() int

func (*StatsResponse) XXX_Unmarshal

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

type UnimplementedDevicePluginServer added in v0.11.0

type UnimplementedDevicePluginServer struct {
}

UnimplementedDevicePluginServer can be embedded to have forward compatible implementations.

func (*UnimplementedDevicePluginServer) Fingerprint added in v0.11.0

func (*UnimplementedDevicePluginServer) Reserve added in v0.11.0

func (*UnimplementedDevicePluginServer) Stats added in v0.11.0

Jump to

Keyboard shortcuts

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