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 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      io.Storage
	DumpFs       afero.Fs
	FdStore      *sync.Map
}

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]