exec

package

v0.9.3 Latest Latest Go to latest Published: Jun 12, 2019 License: MPL-2.0 Imports: 22 Imported by: 0

Details

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

Repository

github.com/superfly/nomad

Links

Open Source Insights

Documentation ¶

Rendered for

Index ¶

Variables
func NewExecDriver(logger hclog.Logger) drivers.DriverPlugin
type Driver
type TaskConfig
type TaskState

Constants ¶

This section is empty.

Variables ¶

View Source

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

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

Functions ¶

func NewExecDriver ¶

func NewExecDriver(logger hclog.Logger) drivers.DriverPlugin

NewExecDriver returns a new DrivePlugin implementation

Types ¶

type Driver ¶

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

Driver fork/execs tasks using many of the underlying OS's isolation features where configured.

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) Shutdown ¶

func (d *Driver) Shutdown()

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