instance

Documentation

Index

• Variables
• func CreateTempArchive(dir string) (string, error)
• func NewFromProto(anyInstance *any.Any, commands []*api.Command, customWorkingDir string, ...) (abstract.Instance, error)
• type PipeInstance
  • func (pi *PipeInstance) Attributes() []attribute.KeyValue
  • func (pi *PipeInstance) Close(context.Context) error
  • func (pi *PipeInstance) Run(ctx context.Context, config *runconfig.RunConfig) (err error)
  • func (pi *PipeInstance) WorkingDirectory(projectDir string, dirtyMode bool) string
• type PipeStage
  • func PipeStagesFromCommands(commands []*api.Command) ([]PipeStage, error)
• type PrebuiltInstance
  • func (prebuilt *PrebuiltInstance) Attributes() []attribute.KeyValue
  • func (prebuilt *PrebuiltInstance) Close(context.Context) error
  • func (prebuilt *PrebuiltInstance) Run(ctx context.Context, config *runconfig.RunConfig) error
  • func (prebuilt *PrebuiltInstance) WorkingDirectory(projectDir string, dirtyMode bool) string
• type UnsupportedInstance
  • func (si *UnsupportedInstance) Attributes() []attribute.KeyValue
  • func (si *UnsupportedInstance) Close(context.Context) error
  • func (si *UnsupportedInstance) Run(context.Context, *runconfig.RunConfig) error
  • func (si *UnsupportedInstance) WorkingDirectory(projectDir string, dirtyMode bool) string

Variables

var (
	ErrFailedToCreateInstance = errors.New("failed to create instance")
	ErrUnsupportedInstance    = errors.New("unsupported instance type")
)

var ErrPipeCreationFailed = errors.New("failed to create pipe instance")

Functions

func CreateTempArchive

func CreateTempArchive(dir string) (string, error)

func NewFromProto

func NewFromProto(
	anyInstance *any.Any,
	commands []*api.Command,
	customWorkingDir string,
	logger logger.Lightweight,
) (abstract.Instance, error)

Types

type PipeInstance

type PipeInstance struct {
	Stages           []PipeStage
	CPU              float32
	Memory           uint32
	CustomWorkingDir string
}

func (*PipeInstance) Attributes

func (pi *PipeInstance) Attributes() []attribute.KeyValue

func (*PipeInstance) Close

func (pi *PipeInstance) Close(context.Context) error

func (*PipeInstance) Run

func (pi *PipeInstance) Run(ctx context.Context, config *runconfig.RunConfig) (err error)

func (*PipeInstance) WorkingDirectory

func (pi *PipeInstance) WorkingDirectory(projectDir string, dirtyMode bool) string

type PipeStage

type PipeStage struct {
	Image                  string
	CommandFrom, CommandTo string
}

func PipeStagesFromCommands

func PipeStagesFromCommands(commands []*api.Command) ([]PipeStage, error)

PipeStagesFromCommands uses image hints in commands to build the stages.

type PrebuiltInstance

type PrebuiltInstance struct {
	Image      string
	Dockerfile string
	Arguments  map[string]string
}

func (*PrebuiltInstance) Attributes

func (prebuilt *PrebuiltInstance) Attributes() []attribute.KeyValue

func (*PrebuiltInstance) Close

func (prebuilt *PrebuiltInstance) Close(context.Context) error

func (*PrebuiltInstance) Run

func (prebuilt *PrebuiltInstance) Run(ctx context.Context, config *runconfig.RunConfig) error

func (*PrebuiltInstance) WorkingDirectory

func (prebuilt *PrebuiltInstance) WorkingDirectory(projectDir string, dirtyMode bool) string

type UnsupportedInstance

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

func (*UnsupportedInstance) Attributes

func (si *UnsupportedInstance) Attributes() []attribute.KeyValue

func (*UnsupportedInstance) Close

func (si *UnsupportedInstance) Close(context.Context) error

func (*UnsupportedInstance) Run

func (si *UnsupportedInstance) Run(context.Context, *runconfig.RunConfig) error

func (*UnsupportedInstance) WorkingDirectory

func (si *UnsupportedInstance) WorkingDirectory(projectDir string, dirtyMode bool) string