process

package

v0.2.7 Latest Latest Go to latest Published: Sep 14, 2026 License: AGPL-3.0 Imports: 17 Imported by: 0

Details

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

Repository

github.com/bitomia/realm

Links

Open Source Insights

Documentation ¶

Rendered for

Index ¶

Constants
func NewProcessDriver(c any) (common.LoadDriver, error)
type ProcessConfig
type ProcessDriver
type ProcessEntryMetadata

Constants ¶

View Source

const ProcessDriverID common.LoadDriverID = "process"

Variables ¶

This section is empty.

Functions ¶

func NewProcessDriver ¶

func NewProcessDriver(c any) (common.LoadDriver, error)

Types ¶

type ProcessConfig ¶

type ProcessConfig struct {
	StartCmd       string  `json:"start_cmd"`
	StartArgs      *string `json:"start_args,omitempty"`
	WorkingDir     *string `json:"working_dir,omitempty"`
	StopSignal     *string `json:"stop_signal,omitempty"`
	UseProcessName *bool   `json:"use_process_name,omitempty"`
}

type ProcessDriver ¶

type ProcessDriver struct {
	StopSignal *int
	// contains filtered or unexported fields
}

func (*ProcessDriver) Config ¶

func (p *ProcessDriver) Config() common.LoadDriverConfig

func (*ProcessDriver) Deprovision ¶

func (p *ProcessDriver) Deprovision(repository common.DeploymentsRepository, deployment common.Deployment) error

func (ProcessDriver) ID ¶

func (c ProcessDriver) ID() common.LoadDriverID

func (ProcessDriver) Info ¶

func (c ProcessDriver) Info() common.LoadDriverInfo

func (*ProcessDriver) Kill ¶

func (p *ProcessDriver) Kill(repository common.DeploymentsRepository, deployment common.Deployment) error

func (*ProcessDriver) Provision ¶

func (p *ProcessDriver) Provision(nodeDriver common.NodeDriver, repository common.DeploymentsRepository, loadName string) (common.DeploymentID, error)

func (*ProcessDriver) ReadStderr ¶

func (p *ProcessDriver) ReadStderr(repository common.DeploymentsRepository, deployment common.Deployment, offset int64) ([]byte, int64, error)

func (*ProcessDriver) ReadStdout ¶

func (p *ProcessDriver) ReadStdout(repository common.DeploymentsRepository, deployment common.Deployment, offset int64) ([]byte, int64, error)

func (*ProcessDriver) Start ¶

func (p *ProcessDriver) Start(repository common.DeploymentsRepository, deployment common.Deployment) error

func (*ProcessDriver) Stop ¶

func (p *ProcessDriver) Stop(repository common.DeploymentsRepository, deployment common.Deployment) error

func (*ProcessDriver) StreamStderr ¶

func (p *ProcessDriver) StreamStderr(repository common.DeploymentsRepository, deployment common.Deployment, w io.Writer) error

func (*ProcessDriver) StreamStdout ¶

func (p *ProcessDriver) StreamStdout(repository common.DeploymentsRepository, deployment common.Deployment, w io.Writer) error

func (*ProcessDriver) UpdateStatus ¶

func (p *ProcessDriver) UpdateStatus(r common.DeploymentsRepository, d common.Deployment) (common.DeploymentStatus, error)

type ProcessEntryMetadata ¶

type ProcessEntryMetadata struct {
	Pid        int    `json:"pid,omitempty"`
	StdoutPath string `json:"stdout_path,omitempty"`
	StderrPath string `json:"stderr_path,omitempty"`
}

Source Files ¶

View all Source files

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