Documentation
¶
Index ¶
- 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 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 CreateTestFile(colonyID string) *core.File
- func CreateTestFileWithID(id string, colonyID string, now time.Time) *core.File
- 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
- func CreateTestProcess(colonyID string) *core.Process
- func CreateTestProcessWithEnv(colonyID string, env map[string]string) *core.Process
- func CreateTestProcessWithTargets(colonyID string, targetExecutorIDs []string) *core.Process
- func CreateTestProcessWithType(colonyID string, executorType string) *core.Process
- 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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CalcAvgProcessingTime ¶
func CalcAvgWaitingTime ¶
func CalcRetries ¶
func CalcUtilization ¶
This function assumes that the processes are sorted so that the oldest process is at index 0
func CreateTestExecutor ¶ added in v1.0.1
func CreateTestExecutorWithID ¶ added in v1.0.1
func CreateTestExecutorWithKey ¶ added in v1.0.1
func CreateTestExecutorWithType ¶ added in v1.0.1
func CreateTestFile ¶ added in v1.5.0
func CreateTestFileWithID ¶ added in v1.5.0
func CreateTestFunctionSpec ¶ added in v1.0.1
func CreateTestFunctionSpec(colonyID string) *core.FunctionSpec
func CreateTestFunctionSpecWithEnv ¶ added in v1.0.1
func CreateTestFunctionSpecWithEnv(colonyID string, env map[string]string) *core.FunctionSpec
func CreateTestFunctionSpecWithTargets ¶ added in v1.0.1
func CreateTestFunctionSpecWithTargets(colonyID string, targetExecutorIDs []string) *core.FunctionSpec
func CreateTestFunctionSpecWithType ¶ added in v1.0.1
func CreateTestFunctionSpecWithType(colonyID string, executorType string) *core.FunctionSpec
func CreateTestProcess ¶
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.