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"
)

Functions

func NewGlobalState

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

func Run

func Run(standalone bool, funcMode bool)

Types

type ExecutionList

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