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 CreateTestExecutor(colonyName string) *core.Executor
• func CreateTestExecutorWithID(colonyName string, executorID string) *core.Executor
• func CreateTestExecutorWithKey(colonyName string) (*core.Executor, string, error)
• func CreateTestExecutorWithType(colonyName string, executorType string) *core.Executor
• func CreateTestFile(colonyName string) *core.File
• func CreateTestFileWithID(id string, colonyName string, now time.Time) *core.File
• func CreateTestFunctionSpec(colonyName string) *core.FunctionSpec
• func CreateTestFunctionSpecWithEnv(colonyID string, env map[string]string) *core.FunctionSpec
• func CreateTestFunctionSpecWithTargets(colonyID string, targetExecutorNames []string) *core.FunctionSpec
• func CreateTestFunctionSpecWithType(colonyID string, executorType string) *core.FunctionSpec
• func CreateTestProcess(colonyName string) *core.Process
• func CreateTestProcessWithEnv(colonyID string, env map[string]string) *core.Process
• func CreateTestProcessWithTargets(colonyID string, targetExecutorNames []string) *core.Process
• func CreateTestProcessWithType(colonyID string, executorType string) *core.Process
• func CreateTestUser(colonyID string, name string) *core.User
• func CreateTestUserWithKey(colonyID string, name string) (*core.User, string, error)
• func Decompress(src io.Reader, dst string) error
• func FakeCron(t *testing.T, colonyID string, initiatorID string, initiatorName string) *core.Cron
• func FakeGenerator(t *testing.T, colonyID string, initiatorID string, initiatorName string) *core.Generator
• func FakeGeneratorSingleProcess(t *testing.T, colonyID string, initiatorID string, initiatorName string) *core.Generator
• func FakeSingleCron(t *testing.T, colonyID string, initiatorID string, initiatorName string) *core.Cron
• func ProgressBar(trackers int) progress.Writer
• type WorkerPool
  • 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()

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 CreateTestExecutor

func CreateTestExecutor(colonyName string) *core.Executor

func CreateTestExecutorWithID

func CreateTestExecutorWithID(colonyName string, executorID string) *core.Executor

func CreateTestExecutorWithKey

func CreateTestExecutorWithKey(colonyName string) (*core.Executor, string, error)

func CreateTestExecutorWithType

func CreateTestExecutorWithType(colonyName string, executorType string) *core.Executor

func CreateTestFile

func CreateTestFile(colonyName string) *core.File

func CreateTestFileWithID

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

func CreateTestFunctionSpec

func CreateTestFunctionSpec(colonyName string) *core.FunctionSpec

func CreateTestFunctionSpecWithEnv

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

func CreateTestFunctionSpecWithTargets

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

func CreateTestFunctionSpecWithType

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

func CreateTestProcess

func CreateTestProcess(colonyName string) *core.Process

func CreateTestProcessWithEnv

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

func CreateTestProcessWithTargets

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

func CreateTestProcessWithType

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

func CreateTestUser

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

func CreateTestUserWithKey

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

func Decompress

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

func FakeCron

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

func FakeGenerator

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

func FakeGeneratorSingleProcess

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

func FakeSingleCron

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

func ProgressBar

func ProgressBar(trackers int) progress.Writer

Types

type WorkerPool

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

func NewWorkerPool

func NewWorkerPool(workers int) *WorkerPool

func (*WorkerPool) Call

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

func (*WorkerPool) Start

func (pool *WorkerPool) Start() *WorkerPool

func (*WorkerPool) Stop

func (pool *WorkerPool) Stop()