utils

Jan 5, 2024

Changes in this version

+ func ProgressBar(trackers int) progress.Writer

+ type WorkerPool struct

+ func NewWorkerPool(workers int) *WorkerPool

+ func (pool *WorkerPool) Call(f func(arg interface{}) error, a interface{}) chan error

+ func (pool *WorkerPool) Start() *WorkerPool

+ func (pool *WorkerPool) Stop()

Nov 30, 2023

Changes in this version

+ func CreateTestUser(colonyID string, name string) *core.User

+ func CreateTestUserWithKey(colonyID string, name string) (*core.User, string, error)

Aug 12, 2023

Changes in this version

+ func CreateTestFile(colonyID string) *core.File

+ func CreateTestFileWithID(id string, colonyID string, now time.Time) *core.File

Mar 16, 2023

Changes in this version

+ func CreateTestExecutor(colonyID string) *core.Executor

+ func CreateTestExecutorWithID(colonyID string, executorID string) *core.Executor

+ func CreateTestExecutorWithKey(colonyID string) (*core.Executor, string, error)

+ func CreateTestExecutorWithType(colonyID string, executorType string) *core.Executor

+ func CreateTestFunctionSpec(colonyID string) *core.FunctionSpec

+ func CreateTestFunctionSpecWithEnv(colonyID string, env map[string]string) *core.FunctionSpec

+ func CreateTestFunctionSpecWithTargets(colonyID string, targetExecutorIDs []string) *core.FunctionSpec

+ func CreateTestFunctionSpecWithType(colonyID string, executorType string) *core.FunctionSpec

Jan 5, 2023

Changes in this version

+ func CalcAvgProcessingTime(processes []*core.Process) float64

+ func CalcAvgWaitingTime(processes []*core.Process) float64

+ func CalcRetries(processes []*core.Process) int

+ func CalcUtilization(processes []*core.Process) float64

+ func Compress(rootDir string, src string, buf io.Writer) error

+ func CreateTestColonyWithKey() (*core.Colony, string, error)

+ func CreateTestProcess(colonyID string) *core.Process

+ func CreateTestProcessSpec(colonyID string) *core.ProcessSpec

+ func CreateTestProcessSpecWithEnv(colonyID string, env map[string]string) *core.ProcessSpec

+ func CreateTestProcessSpecWithTargets(colonyID string, targetRuntimeIDs []string) *core.ProcessSpec

+ func CreateTestProcessSpecWithType(colonyID string, runtimeType string) *core.ProcessSpec

+ func CreateTestProcessWithEnv(colonyID string, env map[string]string) *core.Process

+ func CreateTestProcessWithTargets(colonyID string, targetRuntimeIDs []string) *core.Process

+ func CreateTestProcessWithType(colonyID string, runtimeType string) *core.Process

+ func CreateTestRuntime(colonyID string) *core.Runtime

+ func CreateTestRuntimeWithID(colonyID string, runtimeID string) *core.Runtime

+ func CreateTestRuntimeWithKey(colonyID string) (*core.Runtime, string, error)

+ func CreateTestRuntimeWithType(colonyID string, runtimeType string) *core.Runtime

+ func Decompress(src io.Reader, dst string) error

+ func FakeCron(t *testing.T, colonyID string) *core.Cron

+ func FakeGenerator(t *testing.T, colonyID string) *core.Generator

+ func FakeGeneratorSingleProcess(t *testing.T, colonyID string) *core.Generator

+ func FakeSingleCron(t *testing.T, colonyID string) *core.Cron