executor

Documentation

Overview

Package executor provides the ability for Vela to integrate with different supported operating systems.

Usage:

import "github.com/go-vela/worker/executor"

Index

• Variables
• func WithContext(c context.Context, e Engine) context.Context
• func WithGinContext(c *gin.Context, e Engine)
• type Engine
  • func FromContext(c context.Context) Engine
  • func FromGinContext(c *gin.Context) Engine
  • func New(s *Setup) (Engine, error)
• type Setup
  • func (s *Setup) Darwin() (Engine, error)
  • func (s *Setup) Linux() (Engine, error)
  • func (s *Setup) Validate() error
  • func (s *Setup) Windows() (Engine, error)

Variables

var Flags = []cli.Flag{

	&cli.StringFlag{
		EnvVars: []string{"EXECUTOR_LOG_LEVEL", "VELA_LOG_LEVEL", "LOG_LEVEL"},
		Name:    "executor.log.level",
		Usage:   "sets the log level for the executor",
		Value:   "info",
	},

	&cli.StringFlag{
		EnvVars: []string{"VELA_EXECUTOR_DRIVER", "EXECUTOR_DRIVER"},
		Name:    "executor.driver",
		Usage:   "sets the driver to be used for the executor",
		Value:   constants.DriverLinux,
	},
}

Flags represents all supported command line interface (CLI) flags for the executor.

https://pkg.go.dev/github.com/urfave/cli?tab=doc#Flag

Functions

func WithContext

func WithContext(c context.Context, e Engine) context.Context

WithContext inserts the executor Engine into the context.Context.

func WithGinContext

func WithGinContext(c *gin.Context, e Engine)

WithGinContext inserts the executor Engine into the gin.Context.

Types

type Engine

type Engine interface {

	// GetBuild defines a function for the API
	// that gets the current build in execution.
	GetBuild() (*library.Build, error)
	// GetPipeline defines a function for the API
	// that gets the current pipeline in execution.
	GetPipeline() (*pipeline.Build, error)
	// GetRepo defines a function for the API
	// that gets the current repo in execution.
	GetRepo() (*library.Repo, error)
	// KillBuild defines a function for the API
	// that kills the current build in execution.
	KillBuild() (*library.Build, error)

	// CreateBuild defines a function that
	// configures the build for execution.
	CreateBuild(context.Context) error
	// PlanBuild defines a function that
	// prepares the build for execution.
	PlanBuild(context.Context) error
	// ExecBuild defines a function that
	// runs a pipeline for a build.
	ExecBuild(context.Context) error
	// DestroyBuild defines a function that
	// cleans up the build after execution.
	DestroyBuild(context.Context) error

	// PullSecret defines a function that pulls
	// the secrets for a given pipeline.
	PullSecret(context.Context) error

	// CreateService defines a function that
	// configures the service for execution.
	CreateService(context.Context, *pipeline.Container) error
	// PlanService defines a function that
	// prepares the service for execution.
	PlanService(context.Context, *pipeline.Container) error
	// ExecService defines a function that
	// runs a service.
	ExecService(context.Context, *pipeline.Container) error
	// StreamService defines a function that
	// tails the output for a service.
	StreamService(context.Context, *pipeline.Container) error
	// DestroyService defines a function that
	// cleans up the service after execution.
	DestroyService(context.Context, *pipeline.Container) error

	// CreateStage defines a function that
	// configures the stage for execution.
	CreateStage(context.Context, *pipeline.Stage) error
	// PlanStage defines a function that
	// prepares the stage for execution.
	PlanStage(context.Context, *pipeline.Stage, map[string]chan error) error
	// ExecStage defines a function that
	// runs a stage.
	ExecStage(context.Context, *pipeline.Stage, map[string]chan error) error
	// DestroyStage defines a function that
	// cleans up the stage after execution.
	DestroyStage(context.Context, *pipeline.Stage) error

	// CreateStep defines a function that
	// configures the step for execution.
	CreateStep(context.Context, *pipeline.Container) error
	// PlanStep defines a function that
	// prepares the step for execution.
	PlanStep(context.Context, *pipeline.Container) error
	// ExecStep defines a function that
	// runs a step.
	ExecStep(context.Context, *pipeline.Container) error
	// StreamStep defines a function that
	// tails the output for a step.
	StreamStep(context.Context, *pipeline.Container) error
	// DestroyStep defines a function that
	// cleans up the step after execution.
	DestroyStep(context.Context, *pipeline.Container) error
}

Engine represents the interface for Vela integrating with the different supported operating systems.

func FromContext

func FromContext(c context.Context) Engine

FromContext retrieves the executor Engine from the context.Context.

func FromGinContext

func FromGinContext(c *gin.Context) Engine

FromGinContext retrieves the executor Engine from the gin.Context.

func New

func New(s *Setup) (Engine, error)

New creates and returns a Vela engine capable of integrating with the configured executor.

Currently the following executors are supported:

* linux

type Setup

type Setup struct {

	// specifies the executor driver to use
	Driver string
	// specifies the executor hostname
	Hostname string
	// API client for sending requests to Vela
	Client *vela.Client
	// engine used for creating runtime resources
	Runtime runtime.Engine

	// resource for storing build information in Vela
	Build *library.Build
	// resource for storing pipeline information in Vela
	Pipeline *pipeline.Build
	// resource for storing repo information in Vela
	Repo *library.Repo
	// resource for storing user information in Vela
	User *library.User
}

Setup represents the configuration necessary for creating a Vela engine capable of integrating with a configured executor.

func (*Setup) Darwin

func (s *Setup) Darwin() (Engine, error)

Darwin creates and returns a Vela engine capable of integrating with a Darwin executor.

func (*Setup) Linux

func (s *Setup) Linux() (Engine, error)

Linux creates and returns a Vela engine capable of integrating with a Linux executor.

func (*Setup) Validate

func (s *Setup) Validate() error

Validate verifies the necessary fields for the provided configuration are populated correctly.

func (*Setup) Windows

func (s *Setup) Windows() (Engine, error)

Windows creates and returns a Vela engine capable of integrating with a Windows executor.