docker

Documentation

Index

• Variables
• type ContainerStatus
• type DockerJob
  • func New(name types.Name) (*DockerJob, error)
  • func (d *DockerJob) BatchDelete(ctx context.Context, tasks []*spec.PipelineTask) (data interface{}, err error)
  • func (d *DockerJob) Cancel(ctx context.Context, task *spec.PipelineTask) (data interface{}, err error)
  • func (d *DockerJob) Create(ctx context.Context, task *spec.PipelineTask) (data interface{}, err error)
  • func (d *DockerJob) Delete(ctx context.Context, task *spec.PipelineTask) (data interface{}, err error)
  • func (d *DockerJob) Exist(ctx context.Context, task *spec.PipelineTask) (created, started bool, err error)
  • func (d *DockerJob) GenerateDockerVolumes(job *apistructs.JobFromUser) []mount.Mount
  • func (d *DockerJob) Inspect(ctx context.Context, task *spec.PipelineTask) (apistructs.TaskInspect, error)
  • func (d *DockerJob) Kind() types.Kind
  • func (d *DockerJob) Name() types.Name
  • func (d *DockerJob) Remove(ctx context.Context, task *spec.PipelineTask) (data interface{}, err error)
  • func (d *DockerJob) Start(ctx context.Context, task *spec.PipelineTask) (data interface{}, err error)
  • func (d *DockerJob) Status(ctx context.Context, task *spec.PipelineTask) (desc apistructs.PipelineStatusDesc, err error)
  • func (d *DockerJob) Update(ctx context.Context, task *spec.PipelineTask) (interface{}, error)

Variables

var Kind = types.Kind(spec.PipelineTaskExecutorKindDocker)

Types

type ContainerStatus

type ContainerStatus string

var (
	ContainerStatusRunning    ContainerStatus = "running"
	ContainerStatusRestarting ContainerStatus = "restarting"
	ContainerStatusCreated    ContainerStatus = "created"
	ContainerStatusExited     ContainerStatus = "exited"
	ContainerStatusPaused     ContainerStatus = "paused"
	ContainerStatusRemoving   ContainerStatus = "removing"
	ContainerStatusDead       ContainerStatus = "dead"
)

docker container status

type DockerJob

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

func New

func New(name types.Name) (*DockerJob, error)

TODO: create docker client by executor-enviroment the remote docker client should be created by host, tls-veiry like client.WithHost("tcp://xxx:2375") the local docker client could be created by docker-sock env directly like clinet.FromEnv

func (*DockerJob) BatchDelete

func (d *DockerJob) BatchDelete(ctx context.Context, tasks []*spec.PipelineTask) (data interface{}, err error)

func (*DockerJob) Cancel

func (d *DockerJob) Cancel(ctx context.Context, task *spec.PipelineTask) (data interface{}, err error)

func (*DockerJob) Create

func (d *DockerJob) Create(ctx context.Context, task *spec.PipelineTask) (data interface{}, err error)

func (*DockerJob) Delete

func (d *DockerJob) Delete(ctx context.Context, task *spec.PipelineTask) (data interface{}, err error)

func (*DockerJob) Exist

func (d *DockerJob) Exist(ctx context.Context, task *spec.PipelineTask) (created, started bool, err error)

func (*DockerJob) GenerateDockerVolumes

func (d *DockerJob) GenerateDockerVolumes(job *apistructs.JobFromUser) []mount.Mount

func (*DockerJob) Inspect

func (d *DockerJob) Inspect(ctx context.Context, task *spec.PipelineTask) (apistructs.TaskInspect, error)

func (*DockerJob) Kind

func (d *DockerJob) Kind() types.Kind

func (*DockerJob) Name

func (d *DockerJob) Name() types.Name

func (*DockerJob) Remove

func (d *DockerJob) Remove(ctx context.Context, task *spec.PipelineTask) (data interface{}, err error)

func (*DockerJob) Start

func (d *DockerJob) Start(ctx context.Context, task *spec.PipelineTask) (data interface{}, err error)

func (*DockerJob) Status

func (d *DockerJob) Status(ctx context.Context, task *spec.PipelineTask) (desc apistructs.PipelineStatusDesc, err error)

func (*DockerJob) Update

func (d *DockerJob) Update(ctx context.Context, task *spec.PipelineTask) (interface{}, error)