runtime

type CallbackExecutor struct {
	FakeExecutor
	// contains filtered or unexported fields
}

type Environment interface {
	// Executor returns a process executor that abstracts os.Exec
	Executor() Executor
	// Lock returns an interface for a process lock
	Lock() Lock
	// Profiler return an execution profiler
	Profiler() profiler.Profiler
	// Vars returns the environment variables
	Vars() map[string]string
	// Args returns the arguments passed to the process
	Args() []string
	// Signal returns an interface for handling signals
	Signal() Signals
}

type ExecCallback func(cmd string, args ...string) ([]byte, error)

type Executor interface {
	// Exec executes a process and waits for its completion, returning
	// the combined stdout and stdout
	Exec(cmd string, args ...string) ([]byte, error)
}

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

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

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

type FakeRuntime struct {
	FakeArgs     []string
	FakeVars     map[string]string
	FakeExecutor *FakeExecutor
	FakeProfiler *FakeProfiler
	FakeLock     *FakeLock
	FakeSignal   *FakeSignal
}

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

type Lock interface {
	// Acquire tries to acquire an execution lock to prevent concurrent executions.
	// Returns false if lock is already acquired by another process.
	Acquire() (bool, error)
	// Release releases the execution lock
	Release() error
	// Owner returns the pid of the current owner. -1 means lock is not currently owned
	Owner() int
}

type Signals interface {
	// Notify returns a channel for receiving notifications of the given signals
	Notify(...os.Signal) <-chan os.Signal
	// Reset stops receiving signal notifications in this channel.
	// If no signal is specified, all signals are cleared
	Reset(...os.Signal)
}