orchestrator

Documentation

Index

• Constants
• func NewGlobalState(ctx context.Context, orchestratorClient *redis.Client, job *libOrch.Job, ...) *globalState
• func Run(standalone bool, funcMode bool)
• type ExecutionList

Constants

const (
	JOB_USER_UPDATES_CHANNEL  = "jobUserUpdates"
	NO_CREDITS_ABORT_CHANNEL  = "noCreditsAbort"
	FUNC_ERROR_ABORT_CHANNEL  = "funcErrorAbort"
	OUT_OF_TIME_ABORT_CHANNEL = "outOfTimeAbort"
)

Functions

func NewGlobalState

func NewGlobalState(ctx context.Context, orchestratorClient *redis.Client, job *libOrch.Job,
	orchestratorId string, creditsClient *redis.Client, standalone bool,
	funcAuthClient libOrch.FunctionAuthClient, funcMode, independentWorkerRedisHosts bool) *globalState

func Run

func Run(standalone bool, funcMode bool)

Types

type ExecutionList

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