process

package
v0.1.4 Latest Latest
Warning

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

 Go to latest Published: Sep 3, 2026 License: MIT Imports: 28 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	// Prefix is the node endpoint scheme this engine serves.
	Prefix = "process://"
	Type   = "process"
)

Variables

This section is empty.

Functions

func MakeClient 

func MakeClient(_ context.Context, config coretypes.Config, nodename, endpoint string) (engine.API, error)

Types

type Engine 

type Engine struct {
	// contains filtered or unexported fields
}

Engine runs bare processes as systemd transient units over SSH.

func (*Engine) BuildContent 

func (e *Engine) BuildContent(context.Context, coresource.Source, *enginetypes.BuildContentOptions) (string, io.Reader, error)

func (*Engine) BuildRefs 

func (e *Engine) BuildRefs(_ context.Context, opts *enginetypes.BuildRefOptions) []string

func (*Engine) CloseConn 

func (e *Engine) CloseConn() error

func (*Engine) ExecExitCode 

func (e *Engine) ExecExitCode(_ context.Context, _, execID string) (int, error)

func (*Engine) ExecResize 

func (e *Engine) ExecResize(_ context.Context, execID string, height, width uint) error

func (*Engine) Execute 

func (e *Engine) Execute(ctx context.Context, ID string, config *enginetypes.ExecConfig) (execID string, stdout, stderr io.ReadCloser, stdin io.WriteCloser, err error)

func (*Engine) GetParams 

func (e *Engine) GetParams() *enginetypes.Params

func (*Engine) ImageBuild 

func (e *Engine) ImageBuild(context.Context, io.Reader, []string, string) (io.ReadCloser, error)

func (*Engine) ImageBuildCachePrune 

func (e *Engine) ImageBuildCachePrune(context.Context, bool) (uint64, error)

func (*Engine) ImageBuildFromExist 

func (e *Engine) ImageBuildFromExist(ctx context.Context, ID string, refs []string, _ string) (string, error)

func (*Engine) ImageList 

func (e *Engine) ImageList(ctx context.Context, image string) ([]*enginetypes.Image, error)

func (*Engine) ImageLocalDigests 

func (e *Engine) ImageLocalDigests(ctx context.Context, image string) ([]string, error)

func (*Engine) ImagePull 

func (e *Engine) ImagePull(ctx context.Context, ref string, _ bool) (io.ReadCloser, error)

func (*Engine) ImagePush 

func (e *Engine) ImagePush(context.Context, string) (io.ReadCloser, error)

ImagePush has nothing left to send: ImageBuildFromExist pushes the artifact as it builds it.

func (*Engine) ImageRemoteDigest 

func (e *Engine) ImageRemoteDigest(ctx context.Context, image string) (string, error)

func (*Engine) ImageRemove 

func (e *Engine) ImageRemove(ctx context.Context, image string, _, _ bool) ([]string, error)

func (*Engine) ImagesPrune 

func (e *Engine) ImagesPrune(ctx context.Context) error

func (*Engine) Info 

func (e *Engine) Info(ctx context.Context) (*enginetypes.Info, error)

func (*Engine) NetworkConnect 

func (e *Engine) NetworkConnect(context.Context, string, string, string, string) ([]string, error)

func (*Engine) NetworkDisconnect 

func (e *Engine) NetworkDisconnect(context.Context, string, string, bool) error

func (*Engine) NetworkList 

func (e *Engine) NetworkList(context.Context, []string) ([]*enginetypes.Network, error)

func (*Engine) Ping 

func (e *Engine) Ping(ctx context.Context) error

func (*Engine) RawEngine 

func (e *Engine) RawEngine(context.Context, *enginetypes.RawEngineOptions) (*enginetypes.RawEngineResult, error)

func (*Engine) VerifyNode added in v0.1.4 

func (e *Engine) VerifyNode(ctx context.Context) error

func (*Engine) VirtualizationAttach 

func (e *Engine) VirtualizationAttach(ctx context.Context, ID string, _, stdin bool) (io.ReadCloser, io.ReadCloser, io.WriteCloser, error)

func (*Engine) VirtualizationCopyChunkTo 

func (e *Engine) VirtualizationCopyChunkTo(ctx context.Context, ID, target string, _ int64, content io.Reader, uid, gid int, mode int64) error

func (*Engine) VirtualizationCopyFrom 

func (e *Engine) VirtualizationCopyFrom(ctx context.Context, ID, path string) (content []byte, uid, gid int, mode int64, err error)

func (*Engine) VirtualizationCreate 

func (e *Engine) VirtualizationCreate(ctx context.Context, opts *enginetypes.VirtualizationCreateOptions) (*enginetypes.VirtualizationCreated, error)

func (*Engine) VirtualizationInspect 

func (e *Engine) VirtualizationInspect(ctx context.Context, ID string) (*enginetypes.VirtualizationInfo, error)

func (*Engine) VirtualizationLogs 

func (e *Engine) VirtualizationLogs(ctx context.Context, opts *enginetypes.VirtualizationLogStreamOptions) (stdout, stderr io.ReadCloser, err error)

func (*Engine) VirtualizationRemove 

func (e *Engine) VirtualizationRemove(ctx context.Context, ID string, _, force bool) error

func (*Engine) VirtualizationResize 

func (e *Engine) VirtualizationResize(context.Context, string, uint, uint) error

func (*Engine) VirtualizationResume 

func (e *Engine) VirtualizationResume(ctx context.Context, ID string) error

func (*Engine) VirtualizationStart 

func (e *Engine) VirtualizationStart(ctx context.Context, ID string) error

func (*Engine) VirtualizationStop 

func (e *Engine) VirtualizationStop(ctx context.Context, ID string, gracefulTimeout time.Duration) error

func (*Engine) VirtualizationSuspend 

func (e *Engine) VirtualizationSuspend(ctx context.Context, ID string) error

func (*Engine) VirtualizationUpdateResource 

func (e *Engine) VirtualizationUpdateResource(ctx context.Context, ID string, engineParams resourcetypes.Resources) error

func (*Engine) VirtualizationWait 

func (e *Engine) VirtualizationWait(ctx context.Context, ID, _ string) (*enginetypes.VirtualizationWaitResult, error)

type RawArgs 

type RawArgs struct {
	Raw      bool `json:"raw"`       // run on the host filesystem, without an overlay root
	TasksMax int  `json:"tasks_max"` // cgroup v2 pids.max
}

RawArgs carries process-specific workload options through core untouched.

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.