docker

Documentation

Index

• Variables
• type ComputeResource
• type Provider
  • func NewProvider() *Provider
  • func (d *Provider) Create(c *ComputeResource) (*proto.ServiceState_Handle, error)
  • func (d *Provider) DestroyTask(taskID string, force bool) error
  • func (d *Provider) Exec(taskID string, cmd []string) (*proto.ExecTaskResult, error)
  • func (d *Provider) RecoverTask(taskID string, task *proto.ServiceState_Handle) error
  • func (d *Provider) StopTask(taskID string, timeout time.Duration) error
  • func (d *Provider) WaitTask(ctx context.Context, taskID string) (<-chan *proto.ExitResult, error)

Variables

var ErrTaskNotFound = fmt.Errorf("task not found")

Types

type ComputeResource

type ComputeResource struct {
	*proto.Service
}

type Provider

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

func NewProvider

func NewProvider() *Provider

func (*Provider) Create

func (d *Provider) Create(c *ComputeResource) (*proto.ServiceState_Handle, error)

func (*Provider) DestroyTask

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

func (*Provider) Exec

func (d *Provider) Exec(taskID string, cmd []string) (*proto.ExecTaskResult, error)

func (*Provider) RecoverTask

func (d *Provider) RecoverTask(taskID string, task *proto.ServiceState_Handle) error

func (*Provider) StopTask

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

func (*Provider) WaitTask

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