host

Documentation

Index

• func Docker() (*client.Client, error)
• type HostExec
• type HostExecutor
  • func NewHostExecutor() *HostExecutor
  • func (h *HostExecutor) PrepareEnviron(envs map[string]string) []string
  • func (h *HostExecutor) PrepareWorkspace(payload *letter.StartPipelinePayload) (string, error)
  • func (h *HostExecutor) RunFlow(ctx context.Context, runtime *Runtime, f *flow.Flow) error
  • func (h *HostExecutor) RunJob(stopCtx context.Context, runtime *Runtime, f *flow.Flow, j *flow.Job) error
  • func (h *HostExecutor) RunStep(stopCtx context.Context, runtime *Runtime, f *flow.Flow, j *flow.Job, ...) error
  • func (h *HostExecutor) Start(stopCtx context.Context, payload *letter.StartPipelinePayload, ...) error
• type Runtime
  • func NewRuntime(workspace string, envs map[string]string, rawWriter io.WriteCloser) *Runtime

Functions

func Docker

func Docker() (*client.Client, error)

Types

type HostExec

type HostExec struct {
	*exec.Cmd
}

type HostExecutor

type HostExecutor struct {
}

func NewHostExecutor

func NewHostExecutor() *HostExecutor

func (*HostExecutor) PrepareEnviron

func (h *HostExecutor) PrepareEnviron(envs map[string]string) []string

func (*HostExecutor) PrepareWorkspace

func (h *HostExecutor) PrepareWorkspace(payload *letter.StartPipelinePayload) (string, error)

func (*HostExecutor) RunFlow

func (h *HostExecutor) RunFlow(ctx context.Context, runtime *Runtime, f *flow.Flow) error

func (*HostExecutor) RunJob

func (h *HostExecutor) RunJob(stopCtx context.Context, runtime *Runtime, f *flow.Flow, j *flow.Job) error

func (*HostExecutor) RunStep

func (h *HostExecutor) RunStep(stopCtx context.Context, runtime *Runtime, f *flow.Flow, j *flow.Job, s *flow.Step) error

func (*HostExecutor) Start

func (h *HostExecutor) Start(stopCtx context.Context, payload *letter.StartPipelinePayload, raw io.WriteCloser) error

type Runtime

type Runtime struct {
	Workspace string
	Envs      map[string]string
	RawWriter io.WriteCloser
}

func NewRuntime

func NewRuntime(workspace string, envs map[string]string, rawWriter io.WriteCloser) *Runtime