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 (dst *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.
    	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 (dst *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 (dst *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 (dst *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 (dst *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.

              func NewDevicePluginClient

              func NewDevicePluginClient(cc *grpc.ClientConn) DevicePluginClient

              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 (dst *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 (dst *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 (dst *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 (dst *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 (dst *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 (dst *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 (dst *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 (dst *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 (dst *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

                                  Source Files