executor

Documentation

Overview

Package main generated by go-bindata.// sources: wait-for-it.sh

Index

• func Asset(name string) ([]byte, error)
• func AssetDir(name string) ([]string, error)
• func AssetInfo(name string) (os.FileInfo, error)
• func AssetNames() []string
• func MustAsset(name string) []byte
• func RestoreAsset(dir, name string) error
• func RestoreAssets(dir, name string) error
• type BaseExecutor
  • func (b *BaseExecutor) CacheDir() (input string, output string)
  • func (b *BaseExecutor) Close()
  • func (b *BaseExecutor) CmdIn() *domain.ShellIn
  • func (b *BaseExecutor) GetResult() *domain.ShellOut
  • func (b *BaseExecutor) IsInteracting() bool
  • func (b *BaseExecutor) Kill()
  • func (b *BaseExecutor) Stdout() <-chan string
  • func (b *BaseExecutor) TtyId() string
  • func (b *BaseExecutor) TtyIn() chan<- string
  • func (b *BaseExecutor) TtyOut() <-chan string
• type Executor
  • func NewExecutor(options Options) Executor
• type Options

Functions

func Asset

func Asset(name string) ([]byte, error)

Asset loads and returns the asset for the given name. It returns an error if the asset could not be found or could not be loaded.

func AssetDir

func AssetDir(name string) ([]string, error)

AssetDir returns the file names below a certain directory embedded in the file by go-bindata. For example if you run go-bindata on data/... and data contains the following hierarchy:

data/
  foo.txt
  img/
    a.png
    b.png

then AssetDir("data") would return []string{"foo.txt", "img"} AssetDir("data/img") would return []string{"a.png", "b.png"} AssetDir("foo.txt") and AssetDir("nonexistent") would return an error AssetDir("") will return []string{"data"}.

func AssetInfo

func AssetInfo(name string) (os.FileInfo, error)

AssetInfo loads and returns the asset info for the given name. It returns an error if the asset could not be found or could not be loaded.

func AssetNames

func AssetNames() []string

AssetNames returns the names of the assets.

func MustAsset

func MustAsset(name string) []byte

MustAsset is like Asset but panics when Asset would return an error. It simplifies safe initialization of global variables.

func RestoreAsset

func RestoreAsset(dir, name string) error

RestoreAsset restores an asset under the given directory

func RestoreAssets

func RestoreAssets(dir, name string) error

RestoreAssets restores an asset under the given directory recursively

Types

type BaseExecutor

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

func (*BaseExecutor) CacheDir

func (b *BaseExecutor) CacheDir() (input string, output string)

func (*BaseExecutor) Close

func (b *BaseExecutor) Close()

func (*BaseExecutor) CmdIn

func (b *BaseExecutor) CmdIn() *domain.ShellIn

func (*BaseExecutor) GetResult

func (b *BaseExecutor) GetResult() *domain.ShellOut

func (*BaseExecutor) IsInteracting

func (b *BaseExecutor) IsInteracting() bool

func (*BaseExecutor) Kill

func (b *BaseExecutor) Kill()

func (*BaseExecutor) Stdout

func (b *BaseExecutor) Stdout() <-chan string

func (*BaseExecutor) TtyId

func (b *BaseExecutor) TtyId() string

func (*BaseExecutor) TtyIn

func (b *BaseExecutor) TtyIn() chan<- string

func (*BaseExecutor) TtyOut

func (b *BaseExecutor) TtyOut() <-chan string

type Executor

type Executor interface {
	Init() error

	CacheDir() (string, string)

	CmdIn() *domain.ShellIn

	StartTty(ttyId string, onStarted func(ttyId string)) error

	StopTty()

	TtyId() string

	TtyIn() chan<- string

	TtyOut() <-chan string // b64 out

	IsInteracting() bool

	Start() error

	Stdout() <-chan string // b64 log

	Kill()

	Close()

	GetResult() *domain.ShellOut
}

func NewExecutor

func NewExecutor(options Options) Executor

type Options

type Options struct {
	K8s *domain.K8sConfig

	AgentId                   string
	Parent                    context.Context
	Workspace                 string
	WorkspaceFromDockerVolume bool
	PluginDir                 string
	CacheSrcDir               string
	Cmd                       *domain.ShellIn
	Vars                      domain.Variables
	SecretVars                domain.Variables
	ConfigVars                domain.Variables
	Volumes                   []*domain.DockerVolume
}