script

Documentation

Index

• Constants
• type CancellableScript
• type ConcreteJobScriptProvider
  • func NewConcreteJobScriptProvider(cmdRunner boshsys.CmdRunner, fs boshsys.FileSystem, ...) ConcreteJobScriptProvider
  • func (p ConcreteJobScriptProvider) NewDrainScript(jobName string, params boshdrain.ScriptParams) CancellableScript
  • func (p ConcreteJobScriptProvider) NewParallelScript(scriptName string, scripts []Script) CancellableScript
  • func (p ConcreteJobScriptProvider) NewScript(jobName string, scriptName string, scriptEnv map[string]string) Script
• type GenericScript
  • func NewScript(fs boshsys.FileSystem, runner boshsys.CmdRunner, tag string, path string, ...) GenericScript
  • func (s GenericScript) Exists() bool
  • func (s GenericScript) Path() string
  • func (s GenericScript) Run() error
  • func (s GenericScript) Tag() string
• type JobScriptProvider
• type ParallelScript
  • func NewParallelScript(name string, scripts []Script, logger boshlog.Logger) ParallelScript
  • func (s ParallelScript) Cancel() error
  • func (s ParallelScript) Exists() bool
  • func (s ParallelScript) Path() string
  • func (s ParallelScript) Run() error
  • func (s ParallelScript) Tag() string
• type Script

Constants

const ScriptExt = ""

Types

type CancellableScript

type CancellableScript interface {
	Script
	Cancel() error
}

type ConcreteJobScriptProvider

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

func NewConcreteJobScriptProvider

func NewConcreteJobScriptProvider(
	cmdRunner boshsys.CmdRunner,
	fs boshsys.FileSystem,
	dirProvider boshdir.Provider,
	timeService clock.Clock,
	logger boshlog.Logger,
) ConcreteJobScriptProvider

func (ConcreteJobScriptProvider) NewDrainScript

func (p ConcreteJobScriptProvider) NewDrainScript(jobName string, params boshdrain.ScriptParams) CancellableScript

func (ConcreteJobScriptProvider) NewParallelScript

func (p ConcreteJobScriptProvider) NewParallelScript(scriptName string, scripts []Script) CancellableScript

func (ConcreteJobScriptProvider) NewScript

func (p ConcreteJobScriptProvider) NewScript(jobName string, scriptName string, scriptEnv map[string]string) Script

type GenericScript

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

func NewScript

func NewScript(
	fs boshsys.FileSystem,
	runner boshsys.CmdRunner,
	tag string,
	path string,
	stdoutLogPath string,
	stderrLogPath string,
	env map[string]string,
) GenericScript

func (GenericScript) Exists

func (s GenericScript) Exists() bool

func (GenericScript) Path

func (s GenericScript) Path() string

func (GenericScript) Run

func (s GenericScript) Run() error

func (GenericScript) Tag

func (s GenericScript) Tag() string

type JobScriptProvider

type JobScriptProvider interface {
	NewScript(jobName string, scriptName string, scriptEnv map[string]string) Script
	NewDrainScript(jobName string, params boshdrain.ScriptParams) CancellableScript
	NewParallelScript(scriptName string, scripts []Script) CancellableScript
}

type ParallelScript

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

func NewParallelScript

func NewParallelScript(name string, scripts []Script, logger boshlog.Logger) ParallelScript

func (ParallelScript) Cancel

func (s ParallelScript) Cancel() error

func (ParallelScript) Exists

func (s ParallelScript) Exists() bool

func (ParallelScript) Path

func (s ParallelScript) Path() string

func (ParallelScript) Run

func (s ParallelScript) Run() error

func (ParallelScript) Tag

func (s ParallelScript) Tag() string

type Script

type Script interface {
	Tag() string
	Path() string

	Exists() bool
	Run() error
}