process

package

v0.1.6 Latest Latest Go to latest Published: Sep 29, 2026 License: MIT Imports: 28 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/projecteru2/core

Links

Open Source Insights

Documentation ¶

Index ¶

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

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

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL