zone

package

v0.0.0-...-7bed7bb Latest Latest Go to latest Published: Apr 9, 2020 License: MPL-2.0 Imports: 23 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/cneira/nomad-zones-driver

Documentation ¶

Index ¶

Constants
func NewZoneDriver(logger hclog.Logger) drivers.DriverPlugin
func RemoveDuplicatesFromSlice(s []string) []string
type Config
type Driver
type TaskConfig
type TaskState

Constants ¶

View Source

const (
	IpTypeShared    = 1
	IpTypeExclusive = 2
)

Variables ¶

This section is empty.

Functions ¶

func NewZoneDriver ¶

func NewZoneDriver(logger hclog.Logger) drivers.DriverPlugin

func RemoveDuplicatesFromSlice ¶

func RemoveDuplicatesFromSlice(s []string) []string

Types ¶

type Config ¶

type Config struct {
}

Config is the driver configuration set by the SetConfig RPC call

type Driver ¶

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

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) 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(ctx context.Context) 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 {
	Zonepath        string               `codec:"Zonepath"`
	HostId          string               `codec:"HostId"`
	Brand           string               `codec:"Brand"`
	Docker          string               `codec:"Docker"`
	Autoboot        string               `codec:"Autoboot"`
	SchedulingClass string               `codec:"SchedulingClass"`
	CpuShares       string               `codec:"CpuShares"`
	CappedMemory    string               `codec:"CappedMemory"`
	LockedMemory    string               `codec:"LockedMemory"`
	SwapMemory      string               `codec:"SwapMemory"`
	ShmMemory       string               `codec:"ShmMemory"`
	DedicatedCpu    string               `codec:"DedicatedCpu"`
	SemIds          string               `codec:"SemIds"`
	ShmIds          string               `codec:"ShmIds"`
	MsgIds          string               `codec:"MsgIds"`
	Lwps            string               `codec:"Lwps"`
	Envars          string               `codec:"Envars"`
	IpType          string               `codec:"IpType"`
	Networks        []zconfig.Network    `codec:"Networks"`
	Attributes      []zconfig.Attribute  `codec:"Attributes"`
	FileSystems     []zconfig.FileSystem `codec:"FileSystems"`
	Devices         []zconfig.Device     `codec:"Devices"`
}

TaskConfig is the driver configuration of a task within a job

type TaskState ¶

type TaskState struct {
	TaskConfig    *drivers.TaskConfig
	ContainerName string
	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