utils

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 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 FakeSingleCron(t *testing.T, colonyID string) *core.Cron

Functions

func CalcAvgProcessingTime

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

func CalcAvgWaitingTime

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

func CalcRetries

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

func CalcUtilization

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

This function assumes that the processes are sorted so that the oldest process is at index 0

func Compress

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

func CreateTestColonyWithKey

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

func CreateTestProcess

func CreateTestProcess(colonyID string) *core.Process

func CreateTestProcessSpec

func CreateTestProcessSpec(colonyID string) *core.ProcessSpec

func CreateTestProcessSpecWithEnv

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

func CreateTestProcessSpecWithTargets

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

func CreateTestProcessSpecWithType

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

func CreateTestProcessWithEnv

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

func CreateTestProcessWithTargets

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

func CreateTestProcessWithType

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

func CreateTestRuntime

func CreateTestRuntime(colonyID string) *core.Runtime

func CreateTestRuntimeWithID

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

func CreateTestRuntimeWithKey

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

func CreateTestRuntimeWithType

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

func Decompress

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

func FakeCron

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

func FakeGenerator

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

func FakeSingleCron

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