steps

Documentation

Index

• func NewBuilder(pipeline *models.Pipeline, factory factory) *builder
• type CheckResource
  • func NewCheckResource(r *models.Resource, version versionManager, container ContainerManager) *CheckResource
  • func (c *CheckResource) Execute(stdout io.Writer, stderr io.Writer) (status.Type, error)
  • func (c *CheckResource) ID() string
• type ContainerManager
• type GetResource
  • func NewGetResource(r *models.Resource, versionManager versionManager, volumeManager VolumeManager, ...) *GetResource
  • func (g *GetResource) Execute(stdout io.Writer, stderr io.Writer) (status.Type, error)
  • func (g *GetResource) ID() string
• type PutResource
  • func NewPutResource(r *models.Resource, versionManager versionManager, volumeManager VolumeManager, ...) *PutResource
  • func (p *PutResource) Execute(stdout io.Writer, stderr io.Writer) (status.Type, error)
  • func (p *PutResource) ID() string
• type Task
  • func NewTask(step models.Step, volumeManager VolumeManager, ...) *Task
  • func (t *Task) Execute(stdout io.Writer, stderr io.Writer) (status.Type, error)
  • func (t *Task) ID() string
• type VolumeManager

Functions

func NewBuilder

func NewBuilder(pipeline *models.Pipeline, factory factory) *builder

Types

type CheckResource

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

func NewCheckResource

func NewCheckResource(
	r *models.Resource,
	version versionManager,
	container ContainerManager,
) *CheckResource

func (*CheckResource) Execute

func (c *CheckResource) Execute(stdout io.Writer, stderr io.Writer) (status.Type, error)

func (*CheckResource) ID

func (c *CheckResource) ID() string

type ContainerManager

type ContainerManager interface {
	Volume(local string, mountAs string)
	WorkingDir(dir string)
	Command(command string, args ...string)
	Image(name string, tag string)
	ImageFromOCI(directory string)
	EnvVar(name string, value string)
	Privileged(bool)
	User(string)
	Run(
		stdin io.Reader,
		stdout io.Writer,
		stderr io.Writer,
	) error
}

type GetResource

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

func NewGetResource

func NewGetResource(
	r *models.Resource,
	versionManager versionManager,
	volumeManager VolumeManager,
	containerManger ContainerManager,
	params map[string]interface{},
) *GetResource

func (*GetResource) Execute

func (g *GetResource) Execute(stdout io.Writer, stderr io.Writer) (status.Type, error)

func (*GetResource) ID

func (g *GetResource) ID() string

type PutResource

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

func NewPutResource

func NewPutResource(
	r *models.Resource,
	versionManager versionManager,
	volumeManager VolumeManager,
	containerManager ContainerManager,
	params map[string]interface{},
) *PutResource

func (*PutResource) Execute

func (p *PutResource) Execute(stdout io.Writer, stderr io.Writer) (status.Type, error)

func (*PutResource) ID

func (p *PutResource) ID() string

type Task

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

func NewTask

func NewTask(
	step models.Step,
	volumeManager VolumeManager,
	containerManager ContainerManager,
) *Task

func (*Task) Execute

func (t *Task) Execute(stdout io.Writer, stderr io.Writer) (status.Type, error)

func (*Task) ID

func (t *Task) ID() string

type VolumeManager

type VolumeManager interface {
	Get(string, bool) string
	All() map[string]string
}