Documentation
¶
Index ¶
- func GetAddressAndDialer(endpoint string) (string, func(ctx context.Context, addr string) (net.Conn, error), error)
- func NewRemoteRuntimeService(endpoint string, connectionTimeout time.Duration) (internalapi.RuntimeService, error)
- type Config
- type ERDMADevicePlugin
- func (m *ERDMADevicePlugin) Allocate(ctx context.Context, r *pluginapi.AllocateRequest) (*pluginapi.AllocateResponse, error)
- func (m *ERDMADevicePlugin) GetDevicePluginOptions(context.Context, *pluginapi.Empty) (*pluginapi.DevicePluginOptions, error)
- func (m *ERDMADevicePlugin) GetPreferredAllocation(context.Context, *pluginapi.PreferredAllocationRequest) (*pluginapi.PreferredAllocationResponse, error)
- func (m *ERDMADevicePlugin) ListAndWatch(e *pluginapi.Empty, s pluginapi.DevicePlugin_ListAndWatchServer) error
- func (m *ERDMADevicePlugin) PreStartContainer(ctx context.Context, req *pluginapi.PreStartContainerRequest) (*pluginapi.PreStartContainerResponse, error)
- func (m *ERDMADevicePlugin) Register(request pluginapi.RegisterRequest) error
- func (m *ERDMADevicePlugin) Serve()
- func (m *ERDMADevicePlugin) Start() error
- func (m *ERDMADevicePlugin) Stop() error
- type Linux
- type Namespace
- type RuntimeSpec
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GetAddressAndDialer ¶
func GetAddressAndDialer(endpoint string) (string, func(ctx context.Context, addr string) (net.Conn, error), error)
GetAddressAndDialer returns the address parsed from the given endpoint and a context dialer.
func NewRemoteRuntimeService ¶
func NewRemoteRuntimeService(endpoint string, connectionTimeout time.Duration) (internalapi.RuntimeService, error)
Types ¶
type ERDMADevicePlugin ¶
ERDMADevicePlugin implements the Kubernetes device plugin API
func NewERDMADevicePlugin ¶
func NewERDMADevicePlugin(devices []*types.ERdmaDeviceInfo, allocAllDevices bool, devicepluginPreStart bool) (*ERDMADevicePlugin, error)
NewERDMADevicePlugin returns an initialized ERDMADevicePlugin
func (*ERDMADevicePlugin) Allocate ¶
func (m *ERDMADevicePlugin) Allocate(ctx context.Context, r *pluginapi.AllocateRequest) (*pluginapi.AllocateResponse, error)
Allocate which return list of devices.
func (*ERDMADevicePlugin) GetDevicePluginOptions ¶
func (m *ERDMADevicePlugin) GetDevicePluginOptions(context.Context, *pluginapi.Empty) (*pluginapi.DevicePluginOptions, error)
GetDevicePluginOptions return device plugin options
func (*ERDMADevicePlugin) GetPreferredAllocation ¶
func (m *ERDMADevicePlugin) GetPreferredAllocation(context.Context, *pluginapi.PreferredAllocationRequest) (*pluginapi.PreferredAllocationResponse, error)
func (*ERDMADevicePlugin) ListAndWatch ¶
func (m *ERDMADevicePlugin) ListAndWatch(e *pluginapi.Empty, s pluginapi.DevicePlugin_ListAndWatchServer) error
ListAndWatch lists devices and update that list according to the health status
func (*ERDMADevicePlugin) PreStartContainer ¶
func (m *ERDMADevicePlugin) PreStartContainer(ctx context.Context, req *pluginapi.PreStartContainerRequest) (*pluginapi.PreStartContainerResponse, error)
PreStartContainer return container prestart hook
func (*ERDMADevicePlugin) Register ¶
func (m *ERDMADevicePlugin) Register(request pluginapi.RegisterRequest) error
Register registers the device plugin for the given resourceName with Kubelet.
func (*ERDMADevicePlugin) Serve ¶
func (m *ERDMADevicePlugin) Serve()
Serve starts the gRPC server and register the device plugin to Kubelet
func (*ERDMADevicePlugin) Start ¶
func (m *ERDMADevicePlugin) Start() error
Start starts the gRPC server of the device plugin
func (*ERDMADevicePlugin) Stop ¶
func (m *ERDMADevicePlugin) Stop() error
Stop stops the gRPC server
type RuntimeSpec ¶
type RuntimeSpec struct {
Linux Linux `json:"linux"`
}