v1beta1

package
v0.9.0 Latest Latest
Warning

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

 Go to latest Published: Aug 4, 2021 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Overview

Copyright @ 2021 fushaosong <fushaosong@beyondlet.com>.

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

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

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

Index

Constants

View Source 
const (
	// Healthy means that the device is healthy
	Healthy = "Healthy"
	// UnHealthy means that the device is unhealthy
	Unhealthy = "Unhealthy"

	// Current version of the API supported by kubelet
	Version = "v1beta1"
	// DevicePluginPath is the folder the Device Plugin is expecting sockets to be on
	// Only privileged pods have access to this path
	// Note: Placeholder until we find a "standard path"
	DevicePluginPath = "/var/lib/kubelet/device-plugins/"
	// KubeletSocket is the path of the Kubelet registry socket
	KubeletSocket = DevicePluginPath + "kubelet.sock"
	// Timeout duration in secs for PreStartContainer RPC
	KubeletPreStartContainerRPCTimeoutInSecs = 30
)

Variables

View Source 
var (
	ErrInvalidLengthApi        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowApi          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupApi = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var SupportedVersions = [...]string{"v1beta1"}

Functions

func RegisterDevicePluginServer 

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

func RegisterRegistrationServer 

func RegisterRegistrationServer(s *grpc.Server, srv RegistrationServer)

Types

type AllocateRequest 

type AllocateRequest struct {
	ContainerRequests    []*ContainerAllocateRequest `protobuf:"bytes,1,rep,name=container_requests,json=containerRequests,proto3" json:"container_requests,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                    `json:"-"`
	XXX_sizecache        int32                       `json:"-"`
}
  • Allocate is expected to be called during pod creation since allocation failures for any container would result in pod startup failure.
  • Allocate allows kubelet to exposes additional artifacts in a pod's environment as directed by the plugin.
  • Allocate allows Device Plugin to run device specific operations on the Devices requested

func (*AllocateRequest) Descriptor 

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

func (*AllocateRequest) GetContainerRequests 

func (m *AllocateRequest) GetContainerRequests() []*ContainerAllocateRequest

func (*AllocateRequest) Marshal 

func (m *AllocateRequest) Marshal() (dAtA []byte, err error)

func (*AllocateRequest) MarshalTo 

func (m *AllocateRequest) MarshalTo(dAtA []byte) (int, error)

func (*AllocateRequest) MarshalToSizedBuffer 

func (m *AllocateRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*AllocateRequest) ProtoMessage 

func (*AllocateRequest) ProtoMessage()

func (*AllocateRequest) Reset 

func (m *AllocateRequest) Reset()

func (*AllocateRequest) Size 

func (m *AllocateRequest) Size() (n int)

func (*AllocateRequest) String 

func (this *AllocateRequest) String() string

func (*AllocateRequest) Unmarshal 

func (m *AllocateRequest) Unmarshal(dAtA []byte) error

func (*AllocateRequest) XXX_DiscardUnknown 

func (m *AllocateRequest) XXX_DiscardUnknown()

func (*AllocateRequest) XXX_Marshal 

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

func (*AllocateRequest) XXX_Merge 

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

func (*AllocateRequest) XXX_Size 

func (m *AllocateRequest) XXX_Size() int

func (*AllocateRequest) XXX_Unmarshal 

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

type AllocateResponse 

type AllocateResponse struct {
	ContainerResponses   []*ContainerAllocateResponse `protobuf:"bytes,1,rep,name=container_responses,json=containerResponses,proto3" json:"container_responses,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                     `json:"-"`
	XXX_sizecache        int32                        `json:"-"`
}

AllocateResponse includes the artifacts that needs to be injected into a container for accessing 'deviceIDs' that were mentioned as part of 'AllocateRequest'. Failure Handling: if Kubelet sends an allocation request for dev1 and dev2. Allocation on dev1 succeeds but allocation on dev2 fails. The Device plugin should send a ListAndWatch update and fail the Allocation request

func (*AllocateResponse) Descriptor 

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

func (*AllocateResponse) GetContainerResponses 

func (m *AllocateResponse) GetContainerResponses() []*ContainerAllocateResponse

func (*AllocateResponse) Marshal 

func (m *AllocateResponse) Marshal() (dAtA []byte, err error)

func (*AllocateResponse) MarshalTo 

func (m *AllocateResponse) MarshalTo(dAtA []byte) (int, error)

func (*AllocateResponse) MarshalToSizedBuffer 

func (m *AllocateResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*AllocateResponse) ProtoMessage 

func (*AllocateResponse) ProtoMessage()

func (*AllocateResponse) Reset 

func (m *AllocateResponse) Reset()

func (*AllocateResponse) Size 

func (m *AllocateResponse) Size() (n int)

func (*AllocateResponse) String 

func (this *AllocateResponse) String() string

func (*AllocateResponse) Unmarshal 

func (m *AllocateResponse) Unmarshal(dAtA []byte) error

func (*AllocateResponse) XXX_DiscardUnknown 

func (m *AllocateResponse) XXX_DiscardUnknown()

func (*AllocateResponse) XXX_Marshal 

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

func (*AllocateResponse) XXX_Merge 

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

func (*AllocateResponse) XXX_Size 

func (m *AllocateResponse) XXX_Size() int

func (*AllocateResponse) XXX_Unmarshal 

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

type ContainerAllocateRequest 

type ContainerAllocateRequest struct {
	DevicesIDs           []string `protobuf:"bytes,1,rep,name=devicesIDs,proto3" json:"devicesIDs,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ContainerAllocateRequest) Descriptor 

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

func (*ContainerAllocateRequest) GetDevicesIDs 

func (m *ContainerAllocateRequest) GetDevicesIDs() []string

func (*ContainerAllocateRequest) Marshal 

func (m *ContainerAllocateRequest) Marshal() (dAtA []byte, err error)

func (*ContainerAllocateRequest) MarshalTo 

func (m *ContainerAllocateRequest) MarshalTo(dAtA []byte) (int, error)

func (*ContainerAllocateRequest) MarshalToSizedBuffer 

func (m *ContainerAllocateRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ContainerAllocateRequest) ProtoMessage 

func (*ContainerAllocateRequest) ProtoMessage()

func (*ContainerAllocateRequest) Reset 

func (m *ContainerAllocateRequest) Reset()

func (*ContainerAllocateRequest) Size 

func (m *ContainerAllocateRequest) Size() (n int)

func (*ContainerAllocateRequest) String 

func (this *ContainerAllocateRequest) String() string

func (*ContainerAllocateRequest) Unmarshal 

func (m *ContainerAllocateRequest) Unmarshal(dAtA []byte) error

func (*ContainerAllocateRequest) XXX_DiscardUnknown 

func (m *ContainerAllocateRequest) XXX_DiscardUnknown()

func (*ContainerAllocateRequest) XXX_Marshal 

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

func (*ContainerAllocateRequest) XXX_Merge 

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

func (*ContainerAllocateRequest) XXX_Size 

func (m *ContainerAllocateRequest) XXX_Size() int

func (*ContainerAllocateRequest) XXX_Unmarshal 

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

type ContainerAllocateResponse 

type ContainerAllocateResponse struct {
	// List of environment variable to be set in the container to access one of more devices.
	Envs map[string]string `` /* 149-byte string literal not displayed */
	// Mounts for the container.
	Mounts []*Mount `protobuf:"bytes,2,rep,name=mounts,proto3" json:"mounts,omitempty"`
	// Devices for the container.
	Devices []*DeviceSpec `protobuf:"bytes,3,rep,name=devices,proto3" json:"devices,omitempty"`
	// Container annotations to pass to the container runtime
	Annotations          map[string]string `` /* 163-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*ContainerAllocateResponse) Descriptor 

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

func (*ContainerAllocateResponse) GetAnnotations 

func (m *ContainerAllocateResponse) GetAnnotations() map[string]string

func (*ContainerAllocateResponse) GetDevices 

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

func (*ContainerAllocateResponse) GetEnvs 

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

func (*ContainerAllocateResponse) GetMounts 

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

func (*ContainerAllocateResponse) Marshal 

func (m *ContainerAllocateResponse) Marshal() (dAtA []byte, err error)

func (*ContainerAllocateResponse) MarshalTo 

func (m *ContainerAllocateResponse) MarshalTo(dAtA []byte) (int, error)

func (*ContainerAllocateResponse) MarshalToSizedBuffer 

func (m *ContainerAllocateResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ContainerAllocateResponse) ProtoMessage 

func (*ContainerAllocateResponse) ProtoMessage()

func (*ContainerAllocateResponse) Reset 

func (m *ContainerAllocateResponse) Reset()

func (*ContainerAllocateResponse) Size 

func (m *ContainerAllocateResponse) Size() (n int)

func (*ContainerAllocateResponse) String 

func (this *ContainerAllocateResponse) String() string

func (*ContainerAllocateResponse) Unmarshal 

func (m *ContainerAllocateResponse) Unmarshal(dAtA []byte) error

func (*ContainerAllocateResponse) XXX_DiscardUnknown 

func (m *ContainerAllocateResponse) XXX_DiscardUnknown()

func (*ContainerAllocateResponse) XXX_Marshal 

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

func (*ContainerAllocateResponse) XXX_Merge 

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

func (*ContainerAllocateResponse) XXX_Size 

func (m *ContainerAllocateResponse) XXX_Size() int

func (*ContainerAllocateResponse) XXX_Unmarshal 

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

type ContainerPreferredAllocationRequest 

type ContainerPreferredAllocationRequest struct {
	// List of available deviceIDs from which to choose a preferred allocation
	AvailableDeviceIDs []string `protobuf:"bytes,1,rep,name=available_deviceIDs,json=availableDeviceIDs,proto3" json:"available_deviceIDs,omitempty"`
	// List of deviceIDs that must be included in the preferred allocation
	MustIncludeDeviceIDs []string `protobuf:"bytes,2,rep,name=must_include_deviceIDs,json=mustIncludeDeviceIDs,proto3" json:"must_include_deviceIDs,omitempty"`
	// Number of devices to include in the preferred allocation
	AllocationSize       int32    `protobuf:"varint,3,opt,name=allocation_size,json=allocationSize,proto3" json:"allocation_size,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ContainerPreferredAllocationRequest) Descriptor 

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

func (*ContainerPreferredAllocationRequest) GetAllocationSize 

func (m *ContainerPreferredAllocationRequest) GetAllocationSize() int32

func (*ContainerPreferredAllocationRequest) GetAvailableDeviceIDs 

func (m *ContainerPreferredAllocationRequest) GetAvailableDeviceIDs() []string

func (*ContainerPreferredAllocationRequest) GetMustIncludeDeviceIDs 

func (m *ContainerPreferredAllocationRequest) GetMustIncludeDeviceIDs() []string

func (*ContainerPreferredAllocationRequest) Marshal 

func (m *ContainerPreferredAllocationRequest) Marshal() (dAtA []byte, err error)

func (*ContainerPreferredAllocationRequest) MarshalTo 

func (m *ContainerPreferredAllocationRequest) MarshalTo(dAtA []byte) (int, error)

func (*ContainerPreferredAllocationRequest) MarshalToSizedBuffer 

func (m *ContainerPreferredAllocationRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ContainerPreferredAllocationRequest) ProtoMessage 

func (*ContainerPreferredAllocationRequest) ProtoMessage()

func (*ContainerPreferredAllocationRequest) Reset 

func (m *ContainerPreferredAllocationRequest) Reset()

func (*ContainerPreferredAllocationRequest) Size 

func (m *ContainerPreferredAllocationRequest) Size() (n int)

func (*ContainerPreferredAllocationRequest) String 

func (this *ContainerPreferredAllocationRequest) String() string

func (*ContainerPreferredAllocationRequest) Unmarshal 

func (m *ContainerPreferredAllocationRequest) Unmarshal(dAtA []byte) error

func (*ContainerPreferredAllocationRequest) XXX_DiscardUnknown 

func (m *ContainerPreferredAllocationRequest) XXX_DiscardUnknown()

func (*ContainerPreferredAllocationRequest) XXX_Marshal 

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

func (*ContainerPreferredAllocationRequest) XXX_Merge 

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

func (*ContainerPreferredAllocationRequest) XXX_Size 

func (m *ContainerPreferredAllocationRequest) XXX_Size() int

func (*ContainerPreferredAllocationRequest) XXX_Unmarshal 

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

type ContainerPreferredAllocationResponse 

type ContainerPreferredAllocationResponse struct {
	DeviceIDs            []string `protobuf:"bytes,1,rep,name=deviceIDs,proto3" json:"deviceIDs,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ContainerPreferredAllocationResponse) Descriptor 

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

func (*ContainerPreferredAllocationResponse) GetDeviceIDs 

func (m *ContainerPreferredAllocationResponse) GetDeviceIDs() []string

func (*ContainerPreferredAllocationResponse) Marshal 

func (m *ContainerPreferredAllocationResponse) Marshal() (dAtA []byte, err error)

func (*ContainerPreferredAllocationResponse) MarshalTo 

func (m *ContainerPreferredAllocationResponse) MarshalTo(dAtA []byte) (int, error)

func (*ContainerPreferredAllocationResponse) MarshalToSizedBuffer 

func (m *ContainerPreferredAllocationResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ContainerPreferredAllocationResponse) ProtoMessage 

func (*ContainerPreferredAllocationResponse) ProtoMessage()

func (*ContainerPreferredAllocationResponse) Reset 

func (m *ContainerPreferredAllocationResponse) Reset()

func (*ContainerPreferredAllocationResponse) Size 

func (m *ContainerPreferredAllocationResponse) Size() (n int)

func (*ContainerPreferredAllocationResponse) String 

func (this *ContainerPreferredAllocationResponse) String() string

func (*ContainerPreferredAllocationResponse) Unmarshal 

func (m *ContainerPreferredAllocationResponse) Unmarshal(dAtA []byte) error

func (*ContainerPreferredAllocationResponse) XXX_DiscardUnknown 

func (m *ContainerPreferredAllocationResponse) XXX_DiscardUnknown()

func (*ContainerPreferredAllocationResponse) XXX_Marshal 

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

func (*ContainerPreferredAllocationResponse) XXX_Merge 

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

func (*ContainerPreferredAllocationResponse) XXX_Size 

func (m *ContainerPreferredAllocationResponse) XXX_Size() int

func (*ContainerPreferredAllocationResponse) XXX_Unmarshal 

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

type Device 

type Device struct {
	// A unique ID assigned by the device plugin used
	// to identify devices during the communication
	// Max length of this field is 63 characters
	ID string `protobuf:"bytes,1,opt,name=ID,json=iD,proto3" json:"ID,omitempty"`
	// Health of the device, can be healthy or unhealthy, see constants.go
	Health string `protobuf:"bytes,2,opt,name=health,proto3" json:"health,omitempty"`
	// Topology for device
	Topology             *TopologyInfo `protobuf:"bytes,3,opt,name=topology,proto3" json:"topology,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

E.g: 

struct Device {
   ID: "GPU-fef8089b-4820-abfc-e83e-94318197576e",
   Health: "Healthy",
   Topology:
     Node:
       ID: 1
}

func (*Device) Descriptor 

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

func (*Device) GetHealth 

func (m *Device) GetHealth() string

func (*Device) GetID 

func (m *Device) GetID() string

func (*Device) GetTopology 

func (m *Device) GetTopology() *TopologyInfo

func (*Device) Marshal 

func (m *Device) Marshal() (dAtA []byte, err error)

func (*Device) MarshalTo 

func (m *Device) MarshalTo(dAtA []byte) (int, error)

func (*Device) MarshalToSizedBuffer 

func (m *Device) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Device) ProtoMessage 

func (*Device) ProtoMessage()

func (*Device) Reset 

func (m *Device) Reset()

func (*Device) Size 

func (m *Device) Size() (n int)

func (*Device) String 

func (this *Device) String() string

func (*Device) Unmarshal 

func (m *Device) Unmarshal(dAtA []byte) error

func (*Device) XXX_DiscardUnknown 

func (m *Device) XXX_DiscardUnknown()

func (*Device) XXX_Marshal 

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

func (*Device) XXX_Merge 

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

func (*Device) XXX_Size 

func (m *Device) XXX_Size() int

func (*Device) XXX_Unmarshal 

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

type DevicePluginClient 

type DevicePluginClient interface {
	// GetDevicePluginOptions returns options to be communicated with Device
	// Manager
	GetDevicePluginOptions(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*DevicePluginOptions, error)
	// ListAndWatch returns a stream of List of Devices
	// Whenever a Device state change or a Device disappears, ListAndWatch
	// returns the new list
	ListAndWatch(ctx context.Context, in *Empty, opts ...grpc.CallOption) (DevicePlugin_ListAndWatchClient, error)
	// GetPreferredAllocation returns a preferred set of devices to allocate
	// from a list of available ones. The resulting preferred allocation is not
	// guaranteed to be the allocation ultimately performed by the
	// devicemanager. It is only designed to help the devicemanager make a more
	// informed allocation decision when possible.
	GetPreferredAllocation(ctx context.Context, in *PreferredAllocationRequest, opts ...grpc.CallOption) (*PreferredAllocationResponse, error)
	// Allocate is called during container creation so that the Device
	// Plugin can run device specific operations and instruct Kubelet
	// of the steps to make the Device available in the container
	Allocate(ctx context.Context, in *AllocateRequest, opts ...grpc.CallOption) (*AllocateResponse, error)
	// PreStartContainer is called, if indicated by Device Plugin during registeration phase,
	// before each container start. Device plugin can run device specific operations
	// such as resetting the device before making devices available to the container
	PreStartContainer(ctx context.Context, in *PreStartContainerRequest, opts ...grpc.CallOption) (*PreStartContainerResponse, 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 DevicePluginOptions 

type DevicePluginOptions struct {
	// Indicates if PreStartContainer call is required before each container start
	PreStartRequired bool `protobuf:"varint,1,opt,name=pre_start_required,json=preStartRequired,proto3" json:"pre_start_required,omitempty"`
	// Indicates if GetPreferredAllocation is implemented and available for calling
	GetPreferredAllocationAvailable bool     `` /* 159-byte string literal not displayed */
	XXX_NoUnkeyedLiteral            struct{} `json:"-"`
	XXX_sizecache                   int32    `json:"-"`
}

func (*DevicePluginOptions) Descriptor 

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

func (*DevicePluginOptions) GetGetPreferredAllocationAvailable 

func (m *DevicePluginOptions) GetGetPreferredAllocationAvailable() bool

func (*DevicePluginOptions) GetPreStartRequired 

func (m *DevicePluginOptions) GetPreStartRequired() bool

func (*DevicePluginOptions) Marshal 

func (m *DevicePluginOptions) Marshal() (dAtA []byte, err error)

func (*DevicePluginOptions) MarshalTo 

func (m *DevicePluginOptions) MarshalTo(dAtA []byte) (int, error)

func (*DevicePluginOptions) MarshalToSizedBuffer 

func (m *DevicePluginOptions) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DevicePluginOptions) ProtoMessage 

func (*DevicePluginOptions) ProtoMessage()

func (*DevicePluginOptions) Reset 

func (m *DevicePluginOptions) Reset()

func (*DevicePluginOptions) Size 

func (m *DevicePluginOptions) Size() (n int)

func (*DevicePluginOptions) String 

func (this *DevicePluginOptions) String() string

func (*DevicePluginOptions) Unmarshal 

func (m *DevicePluginOptions) Unmarshal(dAtA []byte) error

func (*DevicePluginOptions) XXX_DiscardUnknown 

func (m *DevicePluginOptions) XXX_DiscardUnknown()

func (*DevicePluginOptions) XXX_Marshal 

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

func (*DevicePluginOptions) XXX_Merge 

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

func (*DevicePluginOptions) XXX_Size 

func (m *DevicePluginOptions) XXX_Size() int

func (*DevicePluginOptions) XXX_Unmarshal 

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

type DevicePluginServer 

type DevicePluginServer interface {
	// GetDevicePluginOptions returns options to be communicated with Device
	// Manager
	GetDevicePluginOptions(context.Context, *Empty) (*DevicePluginOptions, error)
	// ListAndWatch returns a stream of List of Devices
	// Whenever a Device state change or a Device disappears, ListAndWatch
	// returns the new list
	ListAndWatch(*Empty, DevicePlugin_ListAndWatchServer) error
	// GetPreferredAllocation returns a preferred set of devices to allocate
	// from a list of available ones. The resulting preferred allocation is not
	// guaranteed to be the allocation ultimately performed by the
	// devicemanager. It is only designed to help the devicemanager make a more
	// informed allocation decision when possible.
	GetPreferredAllocation(context.Context, *PreferredAllocationRequest) (*PreferredAllocationResponse, error)
	// Allocate is called during container creation so that the Device
	// Plugin can run device specific operations and instruct Kubelet
	// of the steps to make the Device available in the container
	Allocate(context.Context, *AllocateRequest) (*AllocateResponse, error)
	// PreStartContainer is called, if indicated by Device Plugin during registeration phase,
	// before each container start. Device plugin can run device specific operations
	// such as resetting the device before making devices available to the container
	PreStartContainer(context.Context, *PreStartContainerRequest) (*PreStartContainerResponse, error)
}

DevicePluginServer is the server API for DevicePlugin service.

type DevicePlugin_ListAndWatchClient 

type DevicePlugin_ListAndWatchClient interface {
	Recv() (*ListAndWatchResponse, error)
	grpc.ClientStream
}

type DevicePlugin_ListAndWatchServer 

type DevicePlugin_ListAndWatchServer interface {
	Send(*ListAndWatchResponse) error
	grpc.ServerStream
}

type DeviceSpec 

type DeviceSpec struct {
	// Path of the device within the container.
	ContainerPath string `protobuf:"bytes,1,opt,name=container_path,json=containerPath,proto3" json:"container_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 container to read from the specified device.
	// * w - allows container to write to the specified device.
	// * m - allows container 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_sizecache        int32    `json:"-"`
}

DeviceSpec specifies a host device to mount into a container.

func (*DeviceSpec) Descriptor 

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

func (*DeviceSpec) GetContainerPath 

func (m *DeviceSpec) GetContainerPath() string

func (*DeviceSpec) GetHostPath 

func (m *DeviceSpec) GetHostPath() string

func (*DeviceSpec) GetPermissions 

func (m *DeviceSpec) GetPermissions() string

func (*DeviceSpec) Marshal 

func (m *DeviceSpec) Marshal() (dAtA []byte, err error)

func (*DeviceSpec) MarshalTo 

func (m *DeviceSpec) MarshalTo(dAtA []byte) (int, error)

func (*DeviceSpec) MarshalToSizedBuffer 

func (m *DeviceSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DeviceSpec) ProtoMessage 

func (*DeviceSpec) ProtoMessage()

func (*DeviceSpec) Reset 

func (m *DeviceSpec) Reset()

func (*DeviceSpec) Size 

func (m *DeviceSpec) Size() (n int)

func (*DeviceSpec) String 

func (this *DeviceSpec) String() string

func (*DeviceSpec) Unmarshal 

func (m *DeviceSpec) Unmarshal(dAtA []byte) error

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 Empty 

type Empty struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Empty) Descriptor 

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

func (*Empty) Marshal 

func (m *Empty) Marshal() (dAtA []byte, err error)

func (*Empty) MarshalTo 

func (m *Empty) MarshalTo(dAtA []byte) (int, error)

func (*Empty) MarshalToSizedBuffer 

func (m *Empty) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Empty) ProtoMessage 

func (*Empty) ProtoMessage()

func (*Empty) Reset 

func (m *Empty) Reset()

func (*Empty) Size 

func (m *Empty) Size() (n int)

func (*Empty) String 

func (this *Empty) String() string

func (*Empty) Unmarshal 

func (m *Empty) Unmarshal(dAtA []byte) error

func (*Empty) XXX_DiscardUnknown 

func (m *Empty) XXX_DiscardUnknown()

func (*Empty) XXX_Marshal 

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

func (*Empty) XXX_Merge 

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

func (*Empty) XXX_Size 

func (m *Empty) XXX_Size() int

func (*Empty) XXX_Unmarshal 

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

type ListAndWatchResponse 

type ListAndWatchResponse struct {
	Devices              []*Device `protobuf:"bytes,1,rep,name=devices,proto3" json:"devices,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

ListAndWatch returns a stream of List of Devices Whenever a Device state change or a Device disappears, ListAndWatch returns the new list

func (*ListAndWatchResponse) Descriptor 

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

func (*ListAndWatchResponse) GetDevices 

func (m *ListAndWatchResponse) GetDevices() []*Device

func (*ListAndWatchResponse) Marshal 

func (m *ListAndWatchResponse) Marshal() (dAtA []byte, err error)

func (*ListAndWatchResponse) MarshalTo 

func (m *ListAndWatchResponse) MarshalTo(dAtA []byte) (int, error)

func (*ListAndWatchResponse) MarshalToSizedBuffer 

func (m *ListAndWatchResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ListAndWatchResponse) ProtoMessage 

func (*ListAndWatchResponse) ProtoMessage()

func (*ListAndWatchResponse) Reset 

func (m *ListAndWatchResponse) Reset()

func (*ListAndWatchResponse) Size 

func (m *ListAndWatchResponse) Size() (n int)

func (*ListAndWatchResponse) String 

func (this *ListAndWatchResponse) String() string

func (*ListAndWatchResponse) Unmarshal 

func (m *ListAndWatchResponse) Unmarshal(dAtA []byte) error

func (*ListAndWatchResponse) XXX_DiscardUnknown 

func (m *ListAndWatchResponse) XXX_DiscardUnknown()

func (*ListAndWatchResponse) XXX_Marshal 

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

func (*ListAndWatchResponse) XXX_Merge 

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

func (*ListAndWatchResponse) XXX_Size 

func (m *ListAndWatchResponse) XXX_Size() int

func (*ListAndWatchResponse) XXX_Unmarshal 

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

type Mount 

type Mount struct {
	// Path of the mount within the container.
	ContainerPath string `protobuf:"bytes,1,opt,name=container_path,json=containerPath,proto3" json:"container_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_sizecache        int32    `json:"-"`
}

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

func (*Mount) Descriptor 

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

func (*Mount) GetContainerPath 

func (m *Mount) GetContainerPath() string

func (*Mount) GetHostPath 

func (m *Mount) GetHostPath() string

func (*Mount) GetReadOnly 

func (m *Mount) GetReadOnly() bool

func (*Mount) Marshal 

func (m *Mount) Marshal() (dAtA []byte, err error)

func (*Mount) MarshalTo 

func (m *Mount) MarshalTo(dAtA []byte) (int, error)

func (*Mount) MarshalToSizedBuffer 

func (m *Mount) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Mount) ProtoMessage 

func (*Mount) ProtoMessage()

func (*Mount) Reset 

func (m *Mount) Reset()

func (*Mount) Size 

func (m *Mount) Size() (n int)

func (*Mount) String 

func (this *Mount) String() string

func (*Mount) Unmarshal 

func (m *Mount) Unmarshal(dAtA []byte) error

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 NUMANode 

type NUMANode struct {
	ID                   int64    `protobuf:"varint,1,opt,name=ID,json=iD,proto3" json:"ID,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*NUMANode) Descriptor 

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

func (*NUMANode) GetID 

func (m *NUMANode) GetID() int64

func (*NUMANode) Marshal 

func (m *NUMANode) Marshal() (dAtA []byte, err error)

func (*NUMANode) MarshalTo 

func (m *NUMANode) MarshalTo(dAtA []byte) (int, error)

func (*NUMANode) MarshalToSizedBuffer 

func (m *NUMANode) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*NUMANode) ProtoMessage 

func (*NUMANode) ProtoMessage()

func (*NUMANode) Reset 

func (m *NUMANode) Reset()

func (*NUMANode) Size 

func (m *NUMANode) Size() (n int)

func (*NUMANode) String 

func (this *NUMANode) String() string

func (*NUMANode) Unmarshal 

func (m *NUMANode) Unmarshal(dAtA []byte) error

func (*NUMANode) XXX_DiscardUnknown 

func (m *NUMANode) XXX_DiscardUnknown()

func (*NUMANode) XXX_Marshal 

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

func (*NUMANode) XXX_Merge 

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

func (*NUMANode) XXX_Size 

func (m *NUMANode) XXX_Size() int

func (*NUMANode) XXX_Unmarshal 

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

type PreStartContainerRequest 

type PreStartContainerRequest struct {
	DevicesIDs           []string `protobuf:"bytes,1,rep,name=devicesIDs,proto3" json:"devicesIDs,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}
  • PreStartContainer is expected to be called before each container start if indicated by plugin during registration phase.
  • PreStartContainer allows kubelet to pass reinitialized devices to containers.
  • PreStartContainer allows Device Plugin to run device specific operations on the Devices requested

func (*PreStartContainerRequest) Descriptor 

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

func (*PreStartContainerRequest) GetDevicesIDs 

func (m *PreStartContainerRequest) GetDevicesIDs() []string

func (*PreStartContainerRequest) Marshal 

func (m *PreStartContainerRequest) Marshal() (dAtA []byte, err error)

func (*PreStartContainerRequest) MarshalTo 

func (m *PreStartContainerRequest) MarshalTo(dAtA []byte) (int, error)

func (*PreStartContainerRequest) MarshalToSizedBuffer 

func (m *PreStartContainerRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PreStartContainerRequest) ProtoMessage 

func (*PreStartContainerRequest) ProtoMessage()

func (*PreStartContainerRequest) Reset 

func (m *PreStartContainerRequest) Reset()

func (*PreStartContainerRequest) Size 

func (m *PreStartContainerRequest) Size() (n int)

func (*PreStartContainerRequest) String 

func (this *PreStartContainerRequest) String() string

func (*PreStartContainerRequest) Unmarshal 

func (m *PreStartContainerRequest) Unmarshal(dAtA []byte) error

func (*PreStartContainerRequest) XXX_DiscardUnknown 

func (m *PreStartContainerRequest) XXX_DiscardUnknown()

func (*PreStartContainerRequest) XXX_Marshal 

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

func (*PreStartContainerRequest) XXX_Merge 

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

func (*PreStartContainerRequest) XXX_Size 

func (m *PreStartContainerRequest) XXX_Size() int

func (*PreStartContainerRequest) XXX_Unmarshal 

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

type PreStartContainerResponse 

type PreStartContainerResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

PreStartContainerResponse will be send by plugin in response to PreStartContainerRequest

func (*PreStartContainerResponse) Descriptor 

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

func (*PreStartContainerResponse) Marshal 

func (m *PreStartContainerResponse) Marshal() (dAtA []byte, err error)

func (*PreStartContainerResponse) MarshalTo 

func (m *PreStartContainerResponse) MarshalTo(dAtA []byte) (int, error)

func (*PreStartContainerResponse) MarshalToSizedBuffer 

func (m *PreStartContainerResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PreStartContainerResponse) ProtoMessage 

func (*PreStartContainerResponse) ProtoMessage()

func (*PreStartContainerResponse) Reset 

func (m *PreStartContainerResponse) Reset()

func (*PreStartContainerResponse) Size 

func (m *PreStartContainerResponse) Size() (n int)

func (*PreStartContainerResponse) String 

func (this *PreStartContainerResponse) String() string

func (*PreStartContainerResponse) Unmarshal 

func (m *PreStartContainerResponse) Unmarshal(dAtA []byte) error

func (*PreStartContainerResponse) XXX_DiscardUnknown 

func (m *PreStartContainerResponse) XXX_DiscardUnknown()

func (*PreStartContainerResponse) XXX_Marshal 

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

func (*PreStartContainerResponse) XXX_Merge 

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

func (*PreStartContainerResponse) XXX_Size 

func (m *PreStartContainerResponse) XXX_Size() int

func (*PreStartContainerResponse) XXX_Unmarshal 

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

type PreferredAllocationRequest 

type PreferredAllocationRequest struct {
	ContainerRequests    []*ContainerPreferredAllocationRequest `protobuf:"bytes,1,rep,name=container_requests,json=containerRequests,proto3" json:"container_requests,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                               `json:"-"`
	XXX_sizecache        int32                                  `json:"-"`
}

PreferredAllocationRequest is passed via a call to GetPreferredAllocation() at pod admission time. The device plugin should take the list of `available_deviceIDs` and calculate a preferred allocation of size 'allocation_size' from them, making sure to include the set of devices listed in 'must_include_deviceIDs'.

func (*PreferredAllocationRequest) Descriptor 

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

func (*PreferredAllocationRequest) GetContainerRequests 

func (m *PreferredAllocationRequest) GetContainerRequests() []*ContainerPreferredAllocationRequest

func (*PreferredAllocationRequest) Marshal 

func (m *PreferredAllocationRequest) Marshal() (dAtA []byte, err error)

func (*PreferredAllocationRequest) MarshalTo 

func (m *PreferredAllocationRequest) MarshalTo(dAtA []byte) (int, error)

func (*PreferredAllocationRequest) MarshalToSizedBuffer 

func (m *PreferredAllocationRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PreferredAllocationRequest) ProtoMessage 

func (*PreferredAllocationRequest) ProtoMessage()

func (*PreferredAllocationRequest) Reset 

func (m *PreferredAllocationRequest) Reset()

func (*PreferredAllocationRequest) Size 

func (m *PreferredAllocationRequest) Size() (n int)

func (*PreferredAllocationRequest) String 

func (this *PreferredAllocationRequest) String() string

func (*PreferredAllocationRequest) Unmarshal 

func (m *PreferredAllocationRequest) Unmarshal(dAtA []byte) error

func (*PreferredAllocationRequest) XXX_DiscardUnknown 

func (m *PreferredAllocationRequest) XXX_DiscardUnknown()

func (*PreferredAllocationRequest) XXX_Marshal 

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

func (*PreferredAllocationRequest) XXX_Merge 

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

func (*PreferredAllocationRequest) XXX_Size 

func (m *PreferredAllocationRequest) XXX_Size() int

func (*PreferredAllocationRequest) XXX_Unmarshal 

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

type PreferredAllocationResponse 

type PreferredAllocationResponse struct {
	ContainerResponses   []*ContainerPreferredAllocationResponse `protobuf:"bytes,1,rep,name=container_responses,json=containerResponses,proto3" json:"container_responses,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                                `json:"-"`
	XXX_sizecache        int32                                   `json:"-"`
}

PreferredAllocationResponse returns a preferred allocation, resulting from a PreferredAllocationRequest.

func (*PreferredAllocationResponse) Descriptor 

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

func (*PreferredAllocationResponse) GetContainerResponses 

func (m *PreferredAllocationResponse) GetContainerResponses() []*ContainerPreferredAllocationResponse

func (*PreferredAllocationResponse) Marshal 

func (m *PreferredAllocationResponse) Marshal() (dAtA []byte, err error)

func (*PreferredAllocationResponse) MarshalTo 

func (m *PreferredAllocationResponse) MarshalTo(dAtA []byte) (int, error)

func (*PreferredAllocationResponse) MarshalToSizedBuffer 

func (m *PreferredAllocationResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PreferredAllocationResponse) ProtoMessage 

func (*PreferredAllocationResponse) ProtoMessage()

func (*PreferredAllocationResponse) Reset 

func (m *PreferredAllocationResponse) Reset()

func (*PreferredAllocationResponse) Size 

func (m *PreferredAllocationResponse) Size() (n int)

func (*PreferredAllocationResponse) String 

func (this *PreferredAllocationResponse) String() string

func (*PreferredAllocationResponse) Unmarshal 

func (m *PreferredAllocationResponse) Unmarshal(dAtA []byte) error

func (*PreferredAllocationResponse) XXX_DiscardUnknown 

func (m *PreferredAllocationResponse) XXX_DiscardUnknown()

func (*PreferredAllocationResponse) XXX_Marshal 

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

func (*PreferredAllocationResponse) XXX_Merge 

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

func (*PreferredAllocationResponse) XXX_Size 

func (m *PreferredAllocationResponse) XXX_Size() int

func (*PreferredAllocationResponse) XXX_Unmarshal 

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

type RegisterRequest 

type RegisterRequest struct {
	// Version of the API the Device Plugin was built against
	Version string `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
	// Name of the unix socket the device plugin is listening on
	// PATH = path.Join(DevicePluginPath, endpoint)
	Endpoint string `protobuf:"bytes,2,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
	// Schedulable resource name. As of now it's expected to be a DNS Label
	ResourceName string `protobuf:"bytes,3,opt,name=resource_name,json=resourceName,proto3" json:"resource_name,omitempty"`
	// Options to be communicated with Device Manager
	Options              *DevicePluginOptions `protobuf:"bytes,4,opt,name=options,proto3" json:"options,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*RegisterRequest) Descriptor 

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

func (*RegisterRequest) GetEndpoint 

func (m *RegisterRequest) GetEndpoint() string

func (*RegisterRequest) GetOptions 

func (m *RegisterRequest) GetOptions() *DevicePluginOptions

func (*RegisterRequest) GetResourceName 

func (m *RegisterRequest) GetResourceName() string

func (*RegisterRequest) GetVersion 

func (m *RegisterRequest) GetVersion() string

func (*RegisterRequest) Marshal 

func (m *RegisterRequest) Marshal() (dAtA []byte, err error)

func (*RegisterRequest) MarshalTo 

func (m *RegisterRequest) MarshalTo(dAtA []byte) (int, error)

func (*RegisterRequest) MarshalToSizedBuffer 

func (m *RegisterRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RegisterRequest) ProtoMessage 

func (*RegisterRequest) ProtoMessage()

func (*RegisterRequest) Reset 

func (m *RegisterRequest) Reset()

func (*RegisterRequest) Size 

func (m *RegisterRequest) Size() (n int)

func (*RegisterRequest) String 

func (this *RegisterRequest) String() string

func (*RegisterRequest) Unmarshal 

func (m *RegisterRequest) Unmarshal(dAtA []byte) error

func (*RegisterRequest) XXX_DiscardUnknown 

func (m *RegisterRequest) XXX_DiscardUnknown()

func (*RegisterRequest) XXX_Marshal 

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

func (*RegisterRequest) XXX_Merge 

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

func (*RegisterRequest) XXX_Size 

func (m *RegisterRequest) XXX_Size() int

func (*RegisterRequest) XXX_Unmarshal 

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

type RegistrationClient 

type RegistrationClient interface {
	Register(ctx context.Context, in *RegisterRequest, opts ...grpc.CallOption) (*Empty, error)
}

RegistrationClient is the client API for Registration service.

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

func NewRegistrationClient 

func NewRegistrationClient(cc *grpc.ClientConn) RegistrationClient

type RegistrationServer 

type RegistrationServer interface {
	Register(context.Context, *RegisterRequest) (*Empty, error)
}

RegistrationServer is the server API for Registration service.

type TopologyInfo 

type TopologyInfo struct {
	Nodes                []*NUMANode `protobuf:"bytes,1,rep,name=nodes,proto3" json:"nodes,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*TopologyInfo) Descriptor 

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

func (*TopologyInfo) GetNodes 

func (m *TopologyInfo) GetNodes() []*NUMANode

func (*TopologyInfo) Marshal 

func (m *TopologyInfo) Marshal() (dAtA []byte, err error)

func (*TopologyInfo) MarshalTo 

func (m *TopologyInfo) MarshalTo(dAtA []byte) (int, error)

func (*TopologyInfo) MarshalToSizedBuffer 

func (m *TopologyInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*TopologyInfo) ProtoMessage 

func (*TopologyInfo) ProtoMessage()

func (*TopologyInfo) Reset 

func (m *TopologyInfo) Reset()

func (*TopologyInfo) Size 

func (m *TopologyInfo) Size() (n int)

func (*TopologyInfo) String 

func (this *TopologyInfo) String() string

func (*TopologyInfo) Unmarshal 

func (m *TopologyInfo) Unmarshal(dAtA []byte) error

func (*TopologyInfo) XXX_DiscardUnknown 

func (m *TopologyInfo) XXX_DiscardUnknown()

func (*TopologyInfo) XXX_Marshal 

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

func (*TopologyInfo) XXX_Merge 

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

func (*TopologyInfo) XXX_Size 

func (m *TopologyInfo) XXX_Size() int

func (*TopologyInfo) XXX_Unmarshal 

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

type UnimplementedDevicePluginServer 

type UnimplementedDevicePluginServer struct {
}

UnimplementedDevicePluginServer can be embedded to have forward compatible implementations.

func (*UnimplementedDevicePluginServer) Allocate 

func (*UnimplementedDevicePluginServer) Allocate(ctx context.Context, req *AllocateRequest) (*AllocateResponse, error)

func (*UnimplementedDevicePluginServer) GetDevicePluginOptions 

func (*UnimplementedDevicePluginServer) GetDevicePluginOptions(ctx context.Context, req *Empty) (*DevicePluginOptions, error)

func (*UnimplementedDevicePluginServer) GetPreferredAllocation 

func (*UnimplementedDevicePluginServer) GetPreferredAllocation(ctx context.Context, req *PreferredAllocationRequest) (*PreferredAllocationResponse, error)

func (*UnimplementedDevicePluginServer) ListAndWatch 

func (*UnimplementedDevicePluginServer) ListAndWatch(req *Empty, srv DevicePlugin_ListAndWatchServer) error

func (*UnimplementedDevicePluginServer) PreStartContainer 

func (*UnimplementedDevicePluginServer) PreStartContainer(ctx context.Context, req *PreStartContainerRequest) (*PreStartContainerResponse, error)

type UnimplementedRegistrationServer 

type UnimplementedRegistrationServer struct {
}

UnimplementedRegistrationServer can be embedded to have forward compatible implementations.

func (*UnimplementedRegistrationServer) Register 

func (*UnimplementedRegistrationServer) Register(ctx context.Context, req *RegisterRequest) (*Empty, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.