gpupluginrpc

Documentation

Index

• Constants
• func RegisterControllerServer(serverRegistrar pluginrpc.ServerRegistrar, controllerServer ControllerServer)
• type ControllerClient
  • func NewControllerClient(client pluginrpc.Client) (ControllerClient, error)
• type ControllerHandler
• type ControllerServer
  • func NewControllerServer(handler pluginrpc.Handler, controllerHandler ControllerHandler) ControllerServer
• type ControllerSpecBuilder
  • func (s ControllerSpecBuilder) Build() (pluginrpc.Spec, error)

Constants

const (
	// ControllerFreezePath is the path of the Controller's Freeze RPC.
	ControllerFreezePath = "/gpu.Controller/Freeze"
	// ControllerUnfreezePath is the path of the Controller's Unfreeze RPC.
	ControllerUnfreezePath = "/gpu.Controller/Unfreeze"
	// ControllerDumpPath is the path of the Controller's Dump RPC.
	ControllerDumpPath = "/gpu.Controller/Dump"
	// ControllerRestorePath is the path of the Controller's Restore RPC.
	ControllerRestorePath = "/gpu.Controller/Restore"
	// ControllerHealthCheckPath is the path of the Controller's HealthCheck RPC.
	ControllerHealthCheckPath = "/gpu.Controller/HealthCheck"
	// ControllerInfoPath is the path of the Controller's Info RPC.
	ControllerInfoPath = "/gpu.Controller/Info"
	// ControllerAttachPath is the path of the Controller's Attach RPC.
	ControllerAttachPath = "/gpu.Controller/Attach"
)

Functions

func RegisterControllerServer

func RegisterControllerServer(serverRegistrar pluginrpc.ServerRegistrar, controllerServer ControllerServer)

RegisterControllerServer registers the server for the gpu.Controller service.

Types

type ControllerClient

type ControllerClient interface {
	Freeze(context.Context, *gpu.FreezeReq, ...pluginrpc.CallOption) (*gpu.FreezeResp, error)
	Unfreeze(context.Context, *gpu.UnfreezeReq, ...pluginrpc.CallOption) (*gpu.UnfreezeResp, error)
	Dump(context.Context, *gpu.DumpReq, ...pluginrpc.CallOption) (*gpu.DumpResp, error)
	Restore(context.Context, *gpu.RestoreReq, ...pluginrpc.CallOption) (*gpu.RestoreResp, error)
	HealthCheck(context.Context, *gpu.HealthCheckReq, ...pluginrpc.CallOption) (*gpu.HealthCheckResp, error)
	Info(context.Context, *gpu.InfoReq, ...pluginrpc.CallOption) (*gpu.InfoResp, error)
	// Only use if forcefully attaching to a PID, so that the Info RPC will return this PID.
	Attach(context.Context, *gpu.AttachReq, ...pluginrpc.CallOption) (*gpu.AttachResp, error)
}

ControllerClient is a client for the gpu.Controller service.

func NewControllerClient

func NewControllerClient(client pluginrpc.Client) (ControllerClient, error)

NewControllerClient constructs a client for the gpu.Controller service.

type ControllerHandler

type ControllerHandler interface {
	Freeze(context.Context, *gpu.FreezeReq) (*gpu.FreezeResp, error)
	Unfreeze(context.Context, *gpu.UnfreezeReq) (*gpu.UnfreezeResp, error)
	Dump(context.Context, *gpu.DumpReq) (*gpu.DumpResp, error)
	Restore(context.Context, *gpu.RestoreReq) (*gpu.RestoreResp, error)
	HealthCheck(context.Context, *gpu.HealthCheckReq) (*gpu.HealthCheckResp, error)
	Info(context.Context, *gpu.InfoReq) (*gpu.InfoResp, error)
	// Only use if forcefully attaching to a PID, so that the Info RPC will return this PID.
	Attach(context.Context, *gpu.AttachReq) (*gpu.AttachResp, error)
}

ControllerHandler is an implementation of the gpu.Controller service.

type ControllerServer

type ControllerServer interface {
	Freeze(context.Context, pluginrpc.HandleEnv, ...pluginrpc.HandleOption) error
	Unfreeze(context.Context, pluginrpc.HandleEnv, ...pluginrpc.HandleOption) error
	Dump(context.Context, pluginrpc.HandleEnv, ...pluginrpc.HandleOption) error
	Restore(context.Context, pluginrpc.HandleEnv, ...pluginrpc.HandleOption) error
	HealthCheck(context.Context, pluginrpc.HandleEnv, ...pluginrpc.HandleOption) error
	Info(context.Context, pluginrpc.HandleEnv, ...pluginrpc.HandleOption) error
	// Only use if forcefully attaching to a PID, so that the Info RPC will return this PID.
	Attach(context.Context, pluginrpc.HandleEnv, ...pluginrpc.HandleOption) error
}

ControllerServer serves the gpu.Controller service.

func NewControllerServer

func NewControllerServer(handler pluginrpc.Handler, controllerHandler ControllerHandler) ControllerServer

NewControllerServer constructs a server for the gpu.Controller service.

type ControllerSpecBuilder

type ControllerSpecBuilder struct {
	Freeze      []pluginrpc.ProcedureOption
	Unfreeze    []pluginrpc.ProcedureOption
	Dump        []pluginrpc.ProcedureOption
	Restore     []pluginrpc.ProcedureOption
	HealthCheck []pluginrpc.ProcedureOption
	Info        []pluginrpc.ProcedureOption
	Attach      []pluginrpc.ProcedureOption
}

ControllerSpecBuilder builds a Spec for the gpu.Controller service.

func (ControllerSpecBuilder) Build

func (s ControllerSpecBuilder) Build() (pluginrpc.Spec, error)

Build builds a Spec for the gpu.Controller service.