types

type Adapter ¶ added in v0.9.237

type Adapter[H any] func(H) H

An adapter is a function that takes a Handler and returns a new Handler

type Check ¶ added in v0.9.237

type Check = func(context.Context) []*daemon.HealthCheckComponent

A health check function that returns a list of components A health check if never supposed to return an error. If it wants to, it should simply add the failure information to the components.

type Checklist ¶ added in v0.9.237

type Checklist []Checks

A list of checks

func (c Checklist) Run(ctx context.Context) []*daemon.HealthCheckResult

type Checks ¶ added in v0.9.237

type Checks struct {
	Name string
	List []Check
}

Represents a named list of checks

func (c *Checks) Run(ctx context.Context) *daemon.HealthCheckResult

func (c *Checks) String() string

type Dump ¶ added in v0.9.237

type Dump = Handler[daemon.DumpReq, daemon.DumpResp]

type DumpVM ¶ added in v0.9.242

type DumpVM = Handler[daemon.DumpVMReq, daemon.DumpVMResp]

type Freeze ¶ added in v0.9.263

type Freeze = Handler[daemon.DumpReq, daemon.DumpResp]

type Handler ¶ added in v0.9.237

type Handler[REQ, RESP any] func(context.Context, Opts, *RESP, *REQ) (code func() <-chan int, err error)

func Timer[REQ, RESP any](next Handler[REQ, RESP]) Handler[REQ, RESP]

func (h Handler[REQ, RESP]) With(middleware ...Adapter[Handler[REQ, RESP]]) Handler[REQ, RESP]

type Middleware ¶ added in v0.9.237

type Middleware[H any] []Adapter[H]

A middleware is simply a chain of adapters

type Opts ¶ added in v0.9.237

type Opts struct {
	WG           *sync.WaitGroup
	CRIU         *criu.Criu
	CRIUCallback *criu.NotifyCallbackMulti
	Plugins      plugins.Manager
	Lifetime     context.Context
	Storage      cedana_io.Storage // Direct R/W access to underlying storage of the dump (use DumpFs instead)
	DumpFs       afero.Fs          // Full filesystem to use for any dump/restore operations
	FdStore      *sync.Map
	Serverless   bool // Whether the operation is being performed in serverless mode

	IO struct {
		Stdin  io.Reader
		Stdout io.Writer
		Stderr io.Writer
	}
	ExtraFiles   []*os.File
	InheritFdMap map[string]int32
}

Opts is intended to be passed by **value** to each handler, so that each handler can modify it before passing it to the next handler in the chain, without affecting the original value.

type Query ¶ added in v0.9.237

type Query = func(context.Context, *daemon.QueryReq) (*daemon.QueryResp, error)

type Restore ¶ added in v0.9.237

type Restore = Handler[daemon.RestoreReq, daemon.RestoreResp]

type RestoreVM ¶ added in v0.9.242

type RestoreVM = Handler[daemon.RestoreVMReq, daemon.RestoreVMResp]

type Run ¶ added in v0.9.237

type Run = Handler[daemon.RunReq, daemon.RunResp]

type Unfreeze ¶ added in v0.9.263

type Unfreeze = Handler[daemon.DumpReq, daemon.DumpResp]