rawexec

package

v1.6.112 Latest Latest Go to latest Published: Aug 13, 2023 License: MPL-2.0 Imports: 19 Imported by: 0

Details

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

Repository

github.com/hernad/nomad

Links

Open Source Insights

Documentation ¶

Rendered for

Index ¶

Variables
func NewRawExecDriver(ctx context.Context, logger hclog.Logger) drivers.DriverPlugin
func PluginLoader(opts map[string]string) (map[string]interface{}, error)
type Config
type Driver
type TaskConfig
type TaskState

Constants ¶

This section is empty.

Variables ¶

View Source

var (
	// PluginID is the rawexec plugin metadata registered in the plugin
	// catalog.
	PluginID = loader.PluginID{
		Name:       pluginName,
		PluginType: base.PluginTypeDriver,
	}

	// PluginConfig is the rawexec factory function registered in the
	// plugin catalog.
	PluginConfig = &loader.InternalPluginConfig{
		Config:  map[string]interface{}{},
		Factory: func(ctx context.Context, l hclog.Logger) interface{} { return NewRawExecDriver(ctx, l) },
	}
)

Functions ¶

func NewRawExecDriver ¶

func NewRawExecDriver(ctx context.Context, logger hclog.Logger) drivers.DriverPlugin

NewRawExecDriver returns a new DriverPlugin implementation

func PluginLoader ¶

func PluginLoader(opts map[string]string) (map[string]interface{}, error)

PluginLoader maps pre-0.9 client driver options to post-0.9 plugin options.

Types ¶

type Config ¶

type Config struct {
	// NoCgroups tracks whether we should use a cgroup to manage the process
	// tree
	NoCgroups bool `codec:"no_cgroups"`

	// Enabled is set to true to enable the raw_exec driver
	Enabled bool `codec:"enabled"`
}

Config is the driver configuration set by the SetConfig RPC call

type Driver ¶

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

Driver is a privileged version of the exec driver. It provides no resource isolation and just fork/execs. The Exec driver should be preferred and this should only be used when explicitly needed.

func (*Driver) Capabilities ¶

func (d *Driver) Capabilities() (*drivers.Capabilities, error)

func (*Driver) ConfigSchema ¶

func (d *Driver) ConfigSchema() (*hclspec.Spec, error)

func (*Driver) DestroyTask ¶

func (d *Driver) DestroyTask(taskID string, force bool) error

func (*Driver) ExecTask ¶

func (d *Driver) ExecTask(taskID string, cmd []string, timeout time.Duration) (*drivers.ExecTaskResult, error)

func (*Driver) ExecTaskStreamingRaw ¶ added in v0.9.2

func (d *Driver) ExecTaskStreamingRaw(ctx context.Context,
	taskID string,
	command []string,
	tty bool,
	stream drivers.ExecTaskStream) error

func (*Driver) Fingerprint ¶

func (d *Driver) Fingerprint(ctx context.Context) (<-chan *drivers.Fingerprint, error)

func (*Driver) InspectTask ¶

func (d *Driver) InspectTask(taskID string) (*drivers.TaskStatus, error)

func (*Driver) PluginInfo ¶

func (d *Driver) PluginInfo() (*base.PluginInfoResponse, error)

func (*Driver) RecoverTask ¶

func (d *Driver) RecoverTask(handle *drivers.TaskHandle) error

func (*Driver) SetConfig ¶

func (d *Driver) SetConfig(cfg *base.Config) error

func (*Driver) SignalTask ¶

func (d *Driver) SignalTask(taskID string, signal string) error

func (*Driver) StartTask ¶

func (d *Driver) StartTask(cfg *drivers.TaskConfig) (*drivers.TaskHandle, *drivers.DriverNetwork, error)

func (*Driver) StopTask ¶

func (d *Driver) StopTask(taskID string, timeout time.Duration, signal string) error

func (*Driver) TaskConfigSchema ¶

func (d *Driver) TaskConfigSchema() (*hclspec.Spec, error)

func (*Driver) TaskEvents ¶

func (d *Driver) TaskEvents(ctx context.Context) (<-chan *drivers.TaskEvent, error)

func (*Driver) TaskStats ¶

func (d *Driver) TaskStats(ctx context.Context, taskID string, interval time.Duration) (<-chan *drivers.TaskResourceUsage, error)

func (*Driver) WaitTask ¶

func (d *Driver) WaitTask(ctx context.Context, taskID string) (<-chan *drivers.ExitResult, error)

type TaskConfig ¶

type TaskConfig struct {
	Command string   `codec:"command"`
	Args    []string `codec:"args"`
}

TaskConfig is the driver configuration of a task within a job

type TaskState ¶

type TaskState struct {
	ReattachConfig *pstructs.ReattachConfig
	TaskConfig     *drivers.TaskConfig
	Pid            int
	StartedAt      time.Time
}

TaskState is the state which is encoded in the handle returned in StartTask. This information is needed to rebuild the task state and handler during recovery.

Source Files ¶

View all Source files

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