v1beta1

package
v1.16.15 Latest Latest
Warning

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

 Go to latest Published: Sep 2, 2020 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

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")
)
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 added in v1.16.0 

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 added in v1.16.0 

func (m *AllocateRequest) XXX_DiscardUnknown()

func (*AllocateRequest) XXX_Marshal added in v1.16.0 

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

func (*AllocateRequest) XXX_Merge added in v1.16.0 

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

func (*AllocateRequest) XXX_Size added in v1.16.0 

func (m *AllocateRequest) XXX_Size() int

func (*AllocateRequest) XXX_Unmarshal added in v1.16.0 

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 added in v1.16.0 

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 added in v1.16.0 

func (m *AllocateResponse) XXX_DiscardUnknown()

func (*AllocateResponse) XXX_Marshal added in v1.16.0 

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

func (*AllocateResponse) XXX_Merge added in v1.16.0 

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

func (*AllocateResponse) XXX_Size added in v1.16.0 

func (m *AllocateResponse) XXX_Size() int

func (*AllocateResponse) XXX_Unmarshal added in v1.16.0 

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 added in v1.16.0 

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 added in v1.16.0 

func (m *ContainerAllocateRequest) XXX_DiscardUnknown()

func (*ContainerAllocateRequest) XXX_Marshal added in v1.16.0 

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

func (*ContainerAllocateRequest) XXX_Merge added in v1.16.0 

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

func (*ContainerAllocateRequest) XXX_Size added in v1.16.0 

func (m *ContainerAllocateRequest) XXX_Size() int

func (*ContainerAllocateRequest) XXX_Unmarshal added in v1.16.0 

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 added in v1.16.0 

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 added in v1.16.0 

func (m *ContainerAllocateResponse) XXX_DiscardUnknown()

func (*ContainerAllocateResponse) XXX_Marshal added in v1.16.0 

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

func (*ContainerAllocateResponse) XXX_Merge added in v1.16.0 

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

func (*ContainerAllocateResponse) XXX_Size added in v1.16.0 

func (m *ContainerAllocateResponse) XXX_Size() int

func (*ContainerAllocateResponse) XXX_Unmarshal added in v1.16.0 

func (m *ContainerAllocateResponse) 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",
   State: "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 added in v1.16.0 

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 added in v1.16.0 

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 added in v1.16.0 

func (m *Device) XXX_DiscardUnknown()

func (*Device) XXX_Marshal added in v1.16.0 

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

func (*Device) XXX_Merge added in v1.16.0 

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

func (*Device) XXX_Size added in v1.16.0 

func (m *Device) XXX_Size() int

func (*Device) XXX_Unmarshal added in v1.16.0 

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)
	// 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 reseting 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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DevicePluginOptions) Descriptor 

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

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 added in v1.16.0 

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 added in v1.16.0 

func (m *DevicePluginOptions) XXX_DiscardUnknown()

func (*DevicePluginOptions) XXX_Marshal added in v1.16.0 

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

func (*DevicePluginOptions) XXX_Merge added in v1.16.0 

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

func (*DevicePluginOptions) XXX_Size added in v1.16.0 

func (m *DevicePluginOptions) XXX_Size() int

func (*DevicePluginOptions) XXX_Unmarshal added in v1.16.0 

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
	// 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 reseting 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 added in v1.16.0 

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 added in v1.16.0 

func (m *DeviceSpec) XXX_DiscardUnknown()

func (*DeviceSpec) XXX_Marshal added in v1.16.0 

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

func (*DeviceSpec) XXX_Merge added in v1.16.0 

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

func (*DeviceSpec) XXX_Size added in v1.16.0 

func (m *DeviceSpec) XXX_Size() int

func (*DeviceSpec) XXX_Unmarshal added in v1.16.0 

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 added in v1.16.0 

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 added in v1.16.0 

func (m *Empty) XXX_DiscardUnknown()

func (*Empty) XXX_Marshal added in v1.16.0 

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

func (*Empty) XXX_Merge added in v1.16.0 

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

func (*Empty) XXX_Size added in v1.16.0 

func (m *Empty) XXX_Size() int

func (*Empty) XXX_Unmarshal added in v1.16.0 

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 added in v1.16.0 

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 added in v1.16.0 

func (m *ListAndWatchResponse) XXX_DiscardUnknown()

func (*ListAndWatchResponse) XXX_Marshal added in v1.16.0 

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

func (*ListAndWatchResponse) XXX_Merge added in v1.16.0 

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

func (*ListAndWatchResponse) XXX_Size added in v1.16.0 

func (m *ListAndWatchResponse) XXX_Size() int

func (*ListAndWatchResponse) XXX_Unmarshal added in v1.16.0 

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 added in v1.16.0 

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 added in v1.16.0 

func (m *Mount) XXX_DiscardUnknown()

func (*Mount) XXX_Marshal added in v1.16.0 

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

func (*Mount) XXX_Merge added in v1.16.0 

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

func (*Mount) XXX_Size added in v1.16.0 

func (m *Mount) XXX_Size() int

func (*Mount) XXX_Unmarshal added in v1.16.0 

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

type NUMANode added in v1.16.0 

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 added in v1.16.0 

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

func (*NUMANode) GetID added in v1.16.0 

func (m *NUMANode) GetID() int64

func (*NUMANode) Marshal added in v1.16.0 

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

func (*NUMANode) MarshalTo added in v1.16.0 

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

func (*NUMANode) MarshalToSizedBuffer added in v1.16.0 

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

func (*NUMANode) ProtoMessage added in v1.16.0 

func (*NUMANode) ProtoMessage()

func (*NUMANode) Reset added in v1.16.0 

func (m *NUMANode) Reset()

func (*NUMANode) Size added in v1.16.0 

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

func (*NUMANode) String added in v1.16.0 

func (this *NUMANode) String() string

func (*NUMANode) Unmarshal added in v1.16.0 

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

func (*NUMANode) XXX_DiscardUnknown added in v1.16.0 

func (m *NUMANode) XXX_DiscardUnknown()

func (*NUMANode) XXX_Marshal added in v1.16.0 

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

func (*NUMANode) XXX_Merge added in v1.16.0 

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

func (*NUMANode) XXX_Size added in v1.16.0 

func (m *NUMANode) XXX_Size() int

func (*NUMANode) XXX_Unmarshal added in v1.16.0 

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 added in v1.16.0 

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 added in v1.16.0 

func (m *PreStartContainerRequest) XXX_DiscardUnknown()

func (*PreStartContainerRequest) XXX_Marshal added in v1.16.0 

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

func (*PreStartContainerRequest) XXX_Merge added in v1.16.0 

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

func (*PreStartContainerRequest) XXX_Size added in v1.16.0 

func (m *PreStartContainerRequest) XXX_Size() int

func (*PreStartContainerRequest) XXX_Unmarshal added in v1.16.0 

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 added in v1.16.0 

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 added in v1.16.0 

func (m *PreStartContainerResponse) XXX_DiscardUnknown()

func (*PreStartContainerResponse) XXX_Marshal added in v1.16.0 

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

func (*PreStartContainerResponse) XXX_Merge added in v1.16.0 

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

func (*PreStartContainerResponse) XXX_Size added in v1.16.0 

func (m *PreStartContainerResponse) XXX_Size() int

func (*PreStartContainerResponse) XXX_Unmarshal added in v1.16.0 

func (m *PreStartContainerResponse) 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 added in v1.16.0 

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 added in v1.16.0 

func (m *RegisterRequest) XXX_DiscardUnknown()

func (*RegisterRequest) XXX_Marshal added in v1.16.0 

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

func (*RegisterRequest) XXX_Merge added in v1.16.0 

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

func (*RegisterRequest) XXX_Size added in v1.16.0 

func (m *RegisterRequest) XXX_Size() int

func (*RegisterRequest) XXX_Unmarshal added in v1.16.0 

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 added in v1.16.0 

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 added in v1.16.0 

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

func (*TopologyInfo) GetNodes added in v1.16.0 

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

func (*TopologyInfo) Marshal added in v1.16.0 

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

func (*TopologyInfo) MarshalTo added in v1.16.0 

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

func (*TopologyInfo) MarshalToSizedBuffer added in v1.16.0 

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

func (*TopologyInfo) ProtoMessage added in v1.16.0 

func (*TopologyInfo) ProtoMessage()

func (*TopologyInfo) Reset added in v1.16.0 

func (m *TopologyInfo) Reset()

func (*TopologyInfo) Size added in v1.16.0 

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

func (*TopologyInfo) String added in v1.16.0 

func (this *TopologyInfo) String() string

func (*TopologyInfo) Unmarshal added in v1.16.0 

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

func (*TopologyInfo) XXX_DiscardUnknown added in v1.16.0 

func (m *TopologyInfo) XXX_DiscardUnknown()

func (*TopologyInfo) XXX_Marshal added in v1.16.0 

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

func (*TopologyInfo) XXX_Merge added in v1.16.0 

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

func (*TopologyInfo) XXX_Size added in v1.16.0 

func (m *TopologyInfo) XXX_Size() int

func (*TopologyInfo) XXX_Unmarshal added in v1.16.0 

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

type UnimplementedDevicePluginServer added in v1.16.0 

type UnimplementedDevicePluginServer struct {
}

UnimplementedDevicePluginServer can be embedded to have forward compatible implementations.

func (*UnimplementedDevicePluginServer) Allocate added in v1.16.0 

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

func (*UnimplementedDevicePluginServer) GetDevicePluginOptions added in v1.16.0 

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

func (*UnimplementedDevicePluginServer) ListAndWatch added in v1.16.0 

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

func (*UnimplementedDevicePluginServer) PreStartContainer added in v1.16.0 

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

type UnimplementedRegistrationServer added in v1.16.0 

type UnimplementedRegistrationServer struct {
}

UnimplementedRegistrationServer can be embedded to have forward compatible implementations.

func (*UnimplementedRegistrationServer) Register added in v1.16.0 

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.