ch

Dec 23, 2021

Changes in this version

type TaskConfig

+ Mapping []string

Dec 23, 2021

Changes in this version

type TaskConfig

+ Mounts []string

Dec 23, 2021

Changes in this version

type TaskConfig

+ Entrypoint []string

Dec 23, 2021

Changes in this version

type TaskConfig

+ Args []string

Dec 23, 2021

Changes in this version

type TaskConfig

+ Copy []string

Dec 22, 2021

Changes in this version

type CHMount

+ Sync bool

Dec 21, 2021

Changes in this version

+ type Driver struct

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

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

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

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

+ func (d *Driver) ExecTaskStreaming(ctx context.Context, taskID string, opts *drivers.ExecOptions) (*drivers.ExitResult, error)

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

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

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

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

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

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

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

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

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

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

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

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

Dec 20, 2021

Changes in this version

type Config

+ Enabled bool

+ Runtime string

Dec 14, 2021

Changes in this version

type TaskConfig

+ Ports []string

Dec 12, 2021

Changes in this version

+ var DockerCgroupV1MeasuredMemStats = []string

+ var DockerMeasuredCPUStats = []string

+ func CalculateCPUPercent(newSample, oldSample, newTotal, oldTotal uint64, cores int) float64

Dec 9, 2021

Changes in this version

+ type CHContainer struct

+ CreateBody container.ContainerCreateCreatedBody

+ Mounts []CHMount

+ type CHMount struct

+ MountPoint string

+ Name string

+ Source string

+ Volume string

+ type DriverPlugin struct

+ func (d *DriverPlugin) Capabilities() (*drivers.Capabilities, error)

+ func (d *DriverPlugin) ConfigSchema() (*hclspec.Spec, error)

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

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

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

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

+ func (d *DriverPlugin) PluginInfo() (*base.PluginInfoResponse, error)

+ func (d *DriverPlugin) RecoverTask(handle *drivers.TaskHandle) error

+ func (d *DriverPlugin) SetConfig(cfg *base.Config) error

+ func (d *DriverPlugin) SignalTask(taskID string, signal string) error

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

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

+ func (d *DriverPlugin) TaskConfigSchema() (*hclspec.Spec, error)

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

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

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

type TaskState

+ CHContainer CHContainer

Dec 5, 2021

Changes in this version

+ func NewPlugin(logger hclog.Logger) drivers.DriverPlugin

+ type CHDriverPlugin struct

+ func (d *CHDriverPlugin) Capabilities() (*drivers.Capabilities, error)

+ func (d *CHDriverPlugin) ConfigSchema() (*hclspec.Spec, error)

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

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

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

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

+ func (d *CHDriverPlugin) PluginInfo() (*base.PluginInfoResponse, error)

+ func (d *CHDriverPlugin) RecoverTask(handle *drivers.TaskHandle) error

+ func (d *CHDriverPlugin) SetConfig(cfg *base.Config) error

+ func (d *CHDriverPlugin) SignalTask(taskID string, signal string) error

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

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

+ func (d *CHDriverPlugin) TaskConfigSchema() (*hclspec.Spec, error)

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

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

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

+ type Config struct

+ Shell string

+ type RegistryAuth struct

+ Password string

+ Username string

+ type TaskConfig struct

+ Auth RegistryAuth

+ Command string

+ Image string

+ type TaskState struct

+ ContainerID string

+ Pid int

+ ReattachConfig *structs.ReattachConfig

+ StartedAt time.Time

+ TaskConfig *drivers.TaskConfig