executor

Documentation

Index

• type Executor
  • func CreateExecutor(opts ...ExecutorOption) (*Executor, error)
  • func (e *Executor) FetchJobLogs(process *core.Process, containerID string) error
  • func (e *Executor) ServeForEver() error
  • func (e *Executor) Shutdown() error
• type ExecutorOption
  • func WithAddDebugLogs(addDebugLogs bool) ExecutorOption
  • func WithColoniesInsecure(insecure bool) ExecutorOption
  • func WithColoniesServerHost(host string) ExecutorOption
  • func WithColoniesServerPort(port int) ExecutorOption
  • func WithColonyName(name string) ExecutorOption
  • func WithColonyPrvKey(prvkey string) ExecutorOption
  • func WithExecutorID(executorID string) ExecutorOption
  • func WithExecutorName(executorName string) ExecutorOption
  • func WithExecutorPrvKey(key string) ExecutorOption
  • func WithExecutorType(executorType string) ExecutorOption
  • func WithFsDir(fsDir string) ExecutorOption
  • func WithGPU(gpu bool) ExecutorOption
  • func WithHardwareCPU(hwCPU string) ExecutorOption
  • func WithHardwareGPUCount(hwGPUCount int) ExecutorOption
  • func WithHardwareGPUMemory(hwGPUMem string) ExecutorOption
  • func WithHardwareGPUName(hwGPUName string) ExecutorOption
  • func WithHardwareGPUNodesCount(hwGPUNodesCount int) ExecutorOption
  • func WithHardwareMemory(hwMem string) ExecutorOption
  • func WithHardwareModel(hwModel string) ExecutorOption
  • func WithHardwareNodes(hwNodes int) ExecutorOption
  • func WithHardwareStorage(hwStorage string) ExecutorOption
  • func WithK8sNamespace(namespace string) ExecutorOption
  • func WithK8sPVC(pvc string) ExecutorOption
  • func WithLat(lat float64) ExecutorOption
  • func WithLocDesc(locDesc string) ExecutorOption
  • func WithLong(long float64) ExecutorOption
  • func WithParallelContainers(parallelContainers bool) ExecutorOption
  • func WithSoftwareName(swName string) ExecutorOption
  • func WithSoftwareType(swType string) ExecutorOption
  • func WithSoftwareVersion(swVersion string) ExecutorOption
  • func WithVerbose(verbose bool) ExecutorOption

Types

type Executor

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

func CreateExecutor

func CreateExecutor(opts ...ExecutorOption) (*Executor, error)

func (*Executor) FetchJobLogs

func (e *Executor) FetchJobLogs(process *core.Process, containerID string) error

func (*Executor) ServeForEver

func (e *Executor) ServeForEver() error

func (*Executor) Shutdown

func (e *Executor) Shutdown() error

type ExecutorOption

type ExecutorOption func(*Executor)

func WithAddDebugLogs

func WithAddDebugLogs(addDebugLogs bool) ExecutorOption

func WithColoniesInsecure

func WithColoniesInsecure(insecure bool) ExecutorOption

func WithColoniesServerHost

func WithColoniesServerHost(host string) ExecutorOption

func WithColoniesServerPort

func WithColoniesServerPort(port int) ExecutorOption

func WithColonyName

func WithColonyName(name string) ExecutorOption

func WithColonyPrvKey

func WithColonyPrvKey(prvkey string) ExecutorOption

func WithExecutorID

func WithExecutorID(executorID string) ExecutorOption

func WithExecutorName

func WithExecutorName(executorName string) ExecutorOption

func WithExecutorPrvKey

func WithExecutorPrvKey(key string) ExecutorOption

func WithExecutorType

func WithExecutorType(executorType string) ExecutorOption

func WithFsDir

func WithFsDir(fsDir string) ExecutorOption

func WithGPU

func WithGPU(gpu bool) ExecutorOption

func WithHardwareCPU

func WithHardwareCPU(hwCPU string) ExecutorOption

func WithHardwareGPUCount

func WithHardwareGPUCount(hwGPUCount int) ExecutorOption

func WithHardwareGPUMemory

func WithHardwareGPUMemory(hwGPUMem string) ExecutorOption

func WithHardwareGPUName

func WithHardwareGPUName(hwGPUName string) ExecutorOption

func WithHardwareGPUNodesCount

func WithHardwareGPUNodesCount(hwGPUNodesCount int) ExecutorOption

func WithHardwareMemory

func WithHardwareMemory(hwMem string) ExecutorOption

func WithHardwareModel

func WithHardwareModel(hwModel string) ExecutorOption

func WithHardwareNodes

func WithHardwareNodes(hwNodes int) ExecutorOption

func WithHardwareStorage

func WithHardwareStorage(hwStorage string) ExecutorOption

func WithK8sNamespace

func WithK8sNamespace(namespace string) ExecutorOption

func WithK8sPVC

func WithK8sPVC(pvc string) ExecutorOption

func WithLat

func WithLat(lat float64) ExecutorOption

func WithLocDesc

func WithLocDesc(locDesc string) ExecutorOption

func WithLong

func WithLong(long float64) ExecutorOption

func WithParallelContainers

func WithParallelContainers(parallelContainers bool) ExecutorOption

func WithSoftwareName

func WithSoftwareName(swName string) ExecutorOption

func WithSoftwareType

func WithSoftwareType(swType string) ExecutorOption

func WithSoftwareVersion

func WithSoftwareVersion(swVersion string) ExecutorOption

func WithVerbose

func WithVerbose(verbose bool) ExecutorOption