orchestrator

package
v0.2.8 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Feb 1, 2023 License: AGPL-3.0 Imports: 26 Imported by: 0

Documentation

Index

Constants

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

Variables

This section is empty.

Functions

func NewGlobalState

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

func Run

func Run(standalone bool)

Types

type ExecutionList

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

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL