parallelisation

Documentation

Overview

Package parallelisation defines a module for `Concurrency`

Index

• func DetermineContextError(ctx context.Context) error
• func Parallelise(argList interface{}, action func(arg interface{}) (interface{}, error), ...) (results interface{}, err error)
• func RunActionWithParallelCheck(ctx context.Context, action func(ctx context.Context) error, ...) error
• func RunActionWithTimeout(blockingAction func(stop chan bool) error, timeout time.Duration) (err error)
• func RunActionWithTimeoutAndCancelStore(ctx context.Context, timeout time.Duration, store *CancelFunctionStore, ...) error
• func RunActionWithTimeoutAndContext(ctx context.Context, timeout time.Duration, ...) error
• func SafeSchedule(ctx context.Context, period time.Duration, offset time.Duration, ...)
• func SafeScheduleAfter(ctx context.Context, offset time.Duration, f func(context.Context, time.Time))
• func Schedule(ctx context.Context, period time.Duration, offset time.Duration, ...)
• func ScheduleAfter(ctx context.Context, offset time.Duration, f func(time.Time))
• func SleepWithContext(ctx context.Context, delay time.Duration)
• func SleepWithInterruption(stop chan bool, delay time.Duration)
• func WaitUntil(ctx context.Context, evalCondition func(ctx2 context.Context) (bool, error), ...) error
• func WaitWithContext(ctx context.Context, wg IWaiter) (err error)
• func WaitWithContextAndError(ctx context.Context, wg IErrorWaiter) (err error)
• type CancelFunctionStore
  • func NewCancelFunctionsStore() *CancelFunctionStore
  • func (s *CancelFunctionStore) Cancel()
  • func (s *CancelFunctionStore) Len() int
  • func (s *CancelFunctionStore) RegisterCancelFunction(cancel ...context.CancelFunc)
• type IErrorWaiter
• type IWaiter

Functions

func DetermineContextError

func DetermineContextError(ctx context.Context) error

DetermineContextError determines what the context error is if any.

func Parallelise

func Parallelise(argList interface{}, action func(arg interface{}) (interface{}, error), resultType reflect.Type) (results interface{}, err error)

Parallelise parallelises an action over as many goroutines as specified by the argList and retrieves all the results when all the goroutines are done.

func RunActionWithParallelCheck

func RunActionWithParallelCheck(ctx context.Context, action func(ctx context.Context) error, checkAction func(ctx context.Context) bool, checkPeriod time.Duration) error

RunActionWithParallelCheck runs an action with a check in parallel The function performing the check should return true if the check was favourable; false otherwise. If the check did not have the expected result and the whole function would be cancelled.

func RunActionWithTimeout

func RunActionWithTimeout(blockingAction func(stop chan bool) error, timeout time.Duration) (err error)

RunActionWithTimeout runs an action with timeout

func RunActionWithTimeoutAndCancelStore

func RunActionWithTimeoutAndCancelStore(ctx context.Context, timeout time.Duration, store *CancelFunctionStore, blockingAction func(context.Context) error) error

RunActionWithTimeoutAndCancelStore runs an action with timeout The cancel store is used just to register the cancel function so that it can be called on Cancel.

func RunActionWithTimeoutAndContext

func RunActionWithTimeoutAndContext(ctx context.Context, timeout time.Duration, blockingAction func(context.Context) error) error

RunActionWithTimeoutAndContext runs an action with timeout blockingAction's context will be cancelled on exit.

func SafeSchedule

func SafeSchedule(ctx context.Context, period time.Duration, offset time.Duration, f func(context.Context, time.Time))

SafeSchedule calls function `f` regularly with a `period` and an `offset`, similarly to Schedule but with context control.

func SafeScheduleAfter

func SafeScheduleAfter(ctx context.Context, offset time.Duration, f func(context.Context, time.Time))

SafeScheduleAfter calls once function `f` after `offset` similarly to ScheduleAfter but stops the function is controlled by the context

func Schedule

func Schedule(ctx context.Context, period time.Duration, offset time.Duration, f func(time.Time))

Schedule calls function `f` regularly with a `period` and an `offset`.

func ScheduleAfter

func ScheduleAfter(ctx context.Context, offset time.Duration, f func(time.Time))

ScheduleAfter calls once function `f` after `offset`

func SleepWithContext

func SleepWithContext(ctx context.Context, delay time.Duration)

SleepWithContext performs an interruptable sleep Similar to time.Sleep() but also responding to context cancellation instead of blocking for the whole length of time.

func SleepWithInterruption

func SleepWithInterruption(stop chan bool, delay time.Duration)

SleepWithInterruption performs an interruptable sleep Similar to time.Sleep() but also interrupting when requested instead of blocking for the whole length of time.

func WaitUntil

func WaitUntil(ctx context.Context, evalCondition func(ctx2 context.Context) (bool, error), pauseBetweenEvaluations time.Duration) error

WaitUntil waits for a condition evaluated by evalCondition to be verified

func WaitWithContext

func WaitWithContext(ctx context.Context, wg IWaiter) (err error)

func WaitWithContextAndError

func WaitWithContextAndError(ctx context.Context, wg IErrorWaiter) (err error)

Types

type CancelFunctionStore

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

func NewCancelFunctionsStore

func NewCancelFunctionsStore() *CancelFunctionStore

func (*CancelFunctionStore) Cancel

func (s *CancelFunctionStore) Cancel()

func (*CancelFunctionStore) Len

func (s *CancelFunctionStore) Len() int

func (*CancelFunctionStore) RegisterCancelFunction

func (s *CancelFunctionStore) RegisterCancelFunction(cancel ...context.CancelFunc)

type IErrorWaiter

type IErrorWaiter interface {
	Wait() error
}

IErrorWaiter can be used to wait on errgroups and similar types where Wait() returns an error This is used to support use in the WaitWithContextAndError function to wait but listen to contexts

type IWaiter

type IWaiter interface {
	Wait()
}

IError can be used to wait on sync WaitGroups and similar types where Wait() does not return an error This is used to support use in the WaitWithContext function to wait but listen to contexts