core

Jan 7, 2024

Changes in this version

+ func IsProjectEqual(project1 Project, project2 Project) bool

+ func IsProjectsEqual(projects1 map[string]Project, projects2 map[string]Project) bool

Jan 5, 2024

Changes in this version

type Conditions

+ ExecutorNames []string

type Function

+ ExecutorType string

type Log

+ ExecutorName string

Dec 11, 2023

Changes in this version

+ func ConvertFileDataArrayToJSON(fileDataArr []*FileData) (string, error)

+ func IsFileDataArraysEqual(fileDataArr1 []*FileData, fileDataArr2 []*FileData) bool

+ type FileData struct

+ Checksum string

+ Name string

+ S3Filename string

+ Size int64

+ func ConvertJSONToFileData(jsonString string) (*FileData, error)

+ func ConvertJSONToFileDataArray(jsonString string) ([]*FileData, error)

+ func (fileData *FileData) Equals(fileData2 *FileData) bool

+ func (fileData *FileData) ToJSON() (string, error)

Dec 4, 2023

Changes in this version

+ type Allocations struct

+ Projects map[string]Project

type Executor

+ Allocations Allocations

+ type Project struct

+ AllocatedCPU int64

+ AllocatedGPU int64

+ AllocatedStorage int64

+ UsedCPU int64

+ UsedGPU int64

+ UsedStorage int64

Dec 3, 2023

Changes in this version

type Cron

+ InitiatorID string

+ InitiatorName string

type Generator

+ InitiatorID string

+ InitiatorName string

type Process

+ InitiatorID string

+ InitiatorName string

type ProcessGraph

+ InitiatorID string

+ InitiatorName string

Nov 30, 2023

Changes in this version

+ func ConvertUserArrayToJSON(users []*User) (string, error)

+ func IsUserArraysEqual(users1 []*User, users2 []*User) bool

type Attribute

+ TargetColonyName string

type Conditions

+ ColonyName string

type Cron

+ ColonyName string

type Executor

+ ColonyName string

+ func (executor *Executor) SetColonyName(colonyName string)

type File

+ ColonyName string

type Function

+ ColonyName string

+ ExecutorName string

type Generator

+ ColonyName string

type GeneratorArg

+ ColonyName string

type Log

+ ColonyName string

type ProcessGraph

+ ColonyName string

type Snapshot

+ ColonyName string

+ type User struct

+ ColonyName string

+ Email string

+ ID string

+ Name string

+ Phone string

+ func ConvertJSONToUser(jsonString string) (*User, error)

+ func ConvertJSONToUserArray(jsonString string) ([]*User, error)

+ func CreateUser(colonyName string, userID string, name string, email string, phone string) *User

+ func (user *User) Equals(user2 *User) bool

+ func (user *User) ToJSON() (string, error)

type WorkflowSpec

+ ColonyName string

Oct 11, 2023

Changes in this version

type ConflictResolution

+ OnClose OnClose

+ OnStart OnStart

+ type OnClose struct

+ KeepLocal bool

+ type OnStart struct

+ KeepLocal bool

Oct 10, 2023

Changes in this version

+ type ConflictResolution struct

+ KeepLocal bool

type SyncDirMount

+ ConflictResolution ConflictResolution

Oct 10, 2023

Changes in this version

+ type Filesystem struct

+ Mount string

+ SnapshotMounts []SnapshotMount

+ SyncDirMounts []SyncDirMount

+ type SnapshotMount struct

+ Dir string

+ KeepFiles bool

+ KeepSnaphot bool

+ Label string

+ SnapshotID string

+ type SyncDirMount struct

+ Dir string

+ KeepFiles bool

+ Label string

Sep 10, 2023

Changes in this version

type Conditions

+ ProcessesPerNode int

Sep 9, 2023

Changes in this version

type Conditions

+ CPU string

+ GPU GPU

+ Memory string

+ Nodes int

+ Processes int

+ Storage string

+ WallTime int64

type GPU

+ Memory string

+ NodeCount int

type Hardware

+ Nodes int

Aug 19, 2023

Changes in this version

type FunctionSpec

+ Filesystem []*SyncDir

+ type SyncDir struct

+ Dir string

+ Label string

+ SnapshotID string

+ SyncOnCompletion bool

Aug 12, 2023

Changes in this version

+ func ConvertFileArrayToJSON(files []*File) (string, error)

+ func ConvertLabelArrayToJSON(labels []*Label) (string, error)

+ func ConvertSnapshotArrayToJSON(snapshots []*Snapshot) (string, error)

+ func IsFileArraysEqual(files1 []*File, files2 []*File) bool

+ func IsLabelArraysEqual(labels1 []*Label, labels2 []*Label) bool

+ func IsSnapshotArraysEqual(snapshots1 []*Snapshot, snapshots2 []*Snapshot) bool

+ type File struct

+ Added time.Time

+ Checksum string

+ ChecksumAlg string

+ ColonyID string

+ ID string

+ Label string

+ Name string

+ Reference Reference

+ SequenceNumber int64

+ Size int64

+ func ConvertJSONToFile(jsonString string) (*File, error)

+ func ConvertJSONToFileArray(jsonString string) ([]*File, error)

+ func (file *File) Equals(file2 *File) bool

+ func (file *File) ToJSON() (string, error)

+ type Label struct

+ Files int

+ Name string

+ func ConvertJSONToLabel(jsonString string) (*Label, error)

+ func ConvertJSONToLabelArray(jsonString string) ([]*Label, error)

+ func (label *Label) Equals(label2 *Label) bool

+ func (label *Label) ToJSON() (string, error)

+ type Reference struct

+ Protocol string

+ S3Object S3Object

+ type S3Object struct

+ AccessKey string

+ Bucket string

+ EncryptionAlg string

+ EncryptionKey string

+ Object string

+ Port int

+ Region string

+ SecretKey string

+ Server string

+ TLS bool

+ type Snapshot struct

+ Added time.Time

+ ColonyID string

+ FileIDs []string

+ ID string

+ Label string

+ Name string

+ func ConvertJSONToSnapshot(jsonString string) (*Snapshot, error)

+ func ConvertJSONToSnapshotsArray(jsonString string) ([]*Snapshot, error)

+ func (snapshot *Snapshot) Equals(snapshot2 *Snapshot) bool

+ func (snapshot *Snapshot) ToJSON() (string, error)

Aug 6, 2023

Changes in this version

+ func ConvertLogArrayToJSON(logs []Log) (string, error)

+ func IsLogArraysEqual(logs1 []Log, logs2 []Log) bool

+ type Capabilities struct

+ Hardware Hardware

+ Software Software

type Executor

+ Capabilities Capabilities

+ type GPU struct

+ Count int

+ Name string

+ type Hardware struct

+ CPU string

+ GPU GPU

+ Memory string

+ Model string

+ Storage string

type Location

+ Description string

+ type Log struct

+ ColonyID string

+ ExecutorID string

+ Message string

+ ProcessID string

+ Timestamp int64

+ func ConvertJSONToLog(jsonString string) (Log, error)

+ func ConvertJSONToLogArray(jsonString string) ([]Log, error)

+ func (log *Log) Equals(log2 Log) bool

+ func (log *Log) ToJSON() (string, error)

+ type Software struct

+ Name string

+ Type string

+ Version string

Jul 2, 2023

Changes in this version

type FunctionSpec

+ KwArgs map[string]interface{}

Jun 5, 2023

Changes in this version

+ type ColoniesError struct

+ Message string

+ Status int

+ func (e *ColoniesError) Error() string

May 7, 2023

Changes in this version

+ const NOTSET

type Attribute

+ State int

type Generator

+ FirstPack time.Time

+ Timeout int

Mar 16, 2023

Changes in this version

+ func ConvertExecutorArrayToJSON(executors []*Executor) (string, error)

+ func ConvertFunctionArrayToJSON(functions []*Function) (string, error)

+ func IsExecutorArraysEqual(executors1 []*Executor, executors2 []*Executor) bool

+ func IsFunctionArraysEqual(functions1 []*Function, functions2 []*Function) bool

type Conditions

+ ExecutorIDs []string

+ ExecutorType string

+ type Executor struct

+ ColonyID string

+ CommissionTime time.Time

+ ID string

+ LastHeardFromTime time.Time

+ Location Location

+ Name string

+ RequireFuncReg bool

+ State int

+ Type string

+ func ConvertJSONToExecutor(jsonString string) (*Executor, error)

+ func ConvertJSONToExecutorArray(jsonString string) ([]*Executor, error)

+ func CreateExecutor(id string, executorType string, name string, colonyID string, ...) *Executor

+ func CreateExecutorFromDB(id string, executorType string, name string, colonyID string, state int, ...) *Executor

+ func (executor *Executor) Approve()

+ func (executor *Executor) Equals(executor2 *Executor) bool

+ func (executor *Executor) IsApproved() bool

+ func (executor *Executor) IsPending() bool

+ func (executor *Executor) IsRejected() bool

+ func (executor *Executor) Reject()

+ func (executor *Executor) SetColonyID(colonyID string)

+ func (executor *Executor) SetID(id string)

+ func (executor *Executor) ToJSON() (string, error)

+ type Function struct

+ Args []string

+ AvgExecTime float64

+ AvgWaitTime float64

+ ColonyID string

+ Counter int

+ Desc string

+ ExecutorID string

+ FuncName string

+ FunctionID string

+ MaxExecTime float64

+ MaxWaitTime float64

+ MinExecTime float64

+ MinWaitTime float64

+ func ConvertJSONToFunction(jsonString string) (*Function, error)

+ func ConvertJSONToFunctionArray(jsonString string) ([]*Function, error)

+ func CreateFunction(functionID string, executorID string, colonyID string, funcName string, ...) *Function

+ func (function *Function) Equals(function2 *Function) bool

+ func (function *Function) ToJSON() (string, error)

+ type FunctionSpec struct

+ Args []interface{}

+ Conditions Conditions

+ Env map[string]string

+ FuncName string

+ Label string

+ MaxExecTime int

+ MaxRetries int

+ MaxWaitTime int

+ NodeName string

+ Priority int

+ func ConvertJSONToFunctionSpec(jsonString string) (*FunctionSpec, error)

+ func CreateEmptyFunctionSpec() *FunctionSpec

+ func CreateFunctionSpec(nodeName string, funcName string, args []interface{}, colonyID string, ...) *FunctionSpec

+ func (funcSpec *FunctionSpec) AddDependency(dependency string)

+ func (funcSpec *FunctionSpec) Equals(funcSpec2 *FunctionSpec) bool

+ func (funcSpec *FunctionSpec) ToJSON() (string, error)

type Process

+ AssignedExecutorID string

+ FunctionSpec FunctionSpec

+ PriorityTime int64

+ func (process *Process) SetAssignedExecutorID(executorID string)

type Statistics

+ Executors int

type WorkflowSpec

+ FunctionSpecs []FunctionSpec

+ func (workflowSpec *WorkflowSpec) AddFunctionSpec(funcSpec *FunctionSpec)

Jan 5, 2023

Changes in this version

+ const APPROVED

+ const ENV

+ const ERR

+ const FAILED

+ const IN

+ const OUT

+ const PENDING

+ const REJECTED

+ const RUNNING

+ const SUCCESS

+ const WAITING

+ func ConvertColonyArrayToJSON(colonies []*Colony) (string, error)

+ func ConvertCronArrayToJSON(crons []*Cron) (string, error)

+ func ConvertGeneratorArrayToJSON(generators []*Generator) (string, error)

+ func ConvertProcessArrayToJSON(processes []*Process) (string, error)

+ func ConvertProcessGraphArrayToJSON(processGraphs []*ProcessGraph) (string, error)

+ func ConvertRuntimeArrayToJSON(runtimes []*Runtime) (string, error)

+ func GenerateRandomID() string

+ func IsAttributeArraysEqual(attributes1 []Attribute, attributes2 []Attribute) bool

+ func IsColonyArraysEqual(colonies1 []*Colony, colonies2 []*Colony) bool

+ func IsCronArraysEqual(crons1 []*Cron, crons2 []*Cron) bool

+ func IsGeneratorArraysEqual(generators1 []*Generator, generators2 []*Generator) bool

+ func IsProcessArraysEqual(processes1 []*Process, processes2 []*Process) bool

+ func IsProcessGraphArraysEqual(processGraphs1 []*ProcessGraph, processGraphs2 []*ProcessGraph) bool

+ func IsRuntimeArraysEqual(runtimes1 []*Runtime, runtimes2 []*Runtime) bool

+ type Attribute struct

+ AttributeType int

+ ID string

+ Key string

+ TargetColonyID string

+ TargetID string

+ TargetProcessGraphID string

+ Value string

+ func ConvertJSONToAttribute(jsonString string) (Attribute, error)

+ func CreateAttribute(targetID string, targetColonyID string, targetProcessGraphID string, ...) Attribute

+ func (attribute *Attribute) Equals(attribute2 Attribute) bool

+ func (attribute *Attribute) GenerateID()

+ func (attribute *Attribute) SetValue(value string)

+ func (attribute *Attribute) ToJSON() (string, error)

+ type Code struct

+ Bundle []byte

+ ID string

+ Name string

+ Script string

+ type Colony struct

+ ID string

+ Name string

+ func ConvertJSONToColony(jsonString string) (*Colony, error)

+ func ConvertJSONToColonyArray(jsonString string) ([]*Colony, error)

+ func CreateColony(id string, name string) *Colony

+ func (colony *Colony) Equals(colony2 *Colony) bool

+ func (colony *Colony) SetID(id string)

+ func (colony *Colony) ToJSON() (string, error)

+ type Conditions struct

+ ColonyID string

+ Dependencies []string

+ RuntimeIDs []string

+ RuntimeType string

+ type Cron struct

+ CheckerPeriod int

+ ColonyID string

+ CronExpression string

+ ID string

+ Interval int

+ LastRun time.Time

+ Name string

+ NextRun time.Time

+ PrevProcessGraphID string

+ Random bool

+ WaitForPrevProcessGraph bool

+ WorkflowSpec string

+ func ConvertJSONToCron(jsonString string) (*Cron, error)

+ func ConvertJSONToCronArray(jsonString string) ([]*Cron, error)

+ func CreateCron(colonyID string, name string, cronExpression string, interval int, random bool, ...) *Cron

+ func (cron *Cron) Equals(cron2 *Cron) bool

+ func (cron *Cron) HasExpired() bool

+ func (cron *Cron) ToJSON() (string, error)

+ type Data struct

+ Label string

+ type Edge struct

+ Animated bool

+ ID string

+ Source string

+ Target string

+ type Failure struct

+ Message string

+ Status int

+ func ConvertJSONToFailure(jsonString string) (*Failure, error)

+ func CreateFailure(status int, message string) *Failure

+ func (failure *Failure) Equals(failure2 *Failure) bool

+ func (failure *Failure) ToJSON() (string, error)

+ type Generator struct

+ CheckerPeriod int

+ ColonyID string

+ ID string

+ LastRun time.Time

+ Name string

+ QueueSize int

+ Trigger int

+ WorkflowSpec string

+ func ConvertJSONToGenerator(jsonString string) (*Generator, error)

+ func ConvertJSONToGeneratorArray(jsonString string) ([]*Generator, error)

+ func CreateGenerator(colonyID string, name string, workflowSpec string, trigger int) *Generator

+ func (generator *Generator) Equals(generator2 *Generator) bool

+ func (generator *Generator) ToJSON() (string, error)

+ type GeneratorArg struct

+ Arg string

+ ColonyID string

+ GeneratorID string

+ ID string

+ func CreateGeneratorArg(generatorID string, colonyID string, arg string) *GeneratorArg

+ type Location struct

+ Lat float64

+ Long float64

+ type Node struct

+ Data Data

+ ID string

+ Position Position

+ Style Style

+ Type string

+ type Position struct

+ X int

+ Y int

+ type Process struct

+ AssignedRuntimeID string

+ Attributes []Attribute

+ Children []string

+ EndTime time.Time

+ Errors []string

+ ExecDeadline time.Time

+ ID string

+ Input []string

+ IsAssigned bool

+ Output []string

+ Parents []string

+ ProcessGraphID string

+ ProcessSpec ProcessSpec

+ Retries int

+ StartTime time.Time

+ State int

+ SubmissionTime time.Time

+ WaitDeadline time.Time

+ WaitForParents bool

+ func ConvertJSONToProcess(jsonString string) (*Process, error)

+ func ConvertJSONToProcessArray(jsonString string) ([]*Process, error)

+ func CreateProcess(processSpec *ProcessSpec) *Process

+ func CreateProcessFromDB(processSpec *ProcessSpec, id string, assignedRuntimeID string, isAssigned bool, ...) *Process

+ func (process *Process) AddChild(childID string)

+ func (process *Process) AddParent(parentID string)

+ func (process *Process) Assign()

+ func (process *Process) Clone() *Process

+ func (process *Process) Equals(process2 *Process) bool

+ func (process *Process) ProcessingTime() time.Duration

+ func (process *Process) SetAssignedRuntimeID(runtimeID string)

+ func (process *Process) SetAttributes(attributes []Attribute)

+ func (process *Process) SetEndTime(endTime time.Time)

+ func (process *Process) SetProcessGraphID(processGraphID string)

+ func (process *Process) SetStartTime(startTime time.Time)

+ func (process *Process) SetState(state int)

+ func (process *Process) SetSubmissionTime(submissionTime time.Time)

+ func (process *Process) ToJSON() (string, error)

+ func (process *Process) Unassign()

+ func (process *Process) WaitingTime() time.Duration

+ type ProcessGraph struct

+ ColonyID string

+ Edges []Edge

+ EndTime time.Time

+ ID string

+ Nodes []Node

+ ProcessIDs []string

+ Roots []string

+ StartTime time.Time

+ State int

+ SubmissionTime time.Time

+ func ConvertJSONToProcessGraph(jsonString string) (*ProcessGraph, error)

+ func ConvertJSONToProcessGraphArray(jsonString string) ([]*ProcessGraph, error)

+ func ConvertJSONToProcessGraphWithStorage(jsonString string) (*ProcessGraph, error)

+ func CreateProcessGraph(colonyID string) (*ProcessGraph, error)

+ func (graph *ProcessGraph) AddRoot(processID string)

+ func (graph *ProcessGraph) Depth(childProcessID string) (int, error)

+ func (graph *ProcessGraph) Equals(graph2 *ProcessGraph) bool

+ func (graph *ProcessGraph) FailedProcesses() (int, error)

+ func (graph *ProcessGraph) GetRoot(childProcessID string) (*Process, error)

+ func (graph *ProcessGraph) Iterate(visitFunc func(process *Process) error) error

+ func (graph *ProcessGraph) Leaves() ([]string, error)

+ func (graph *ProcessGraph) Processes() (int, error)

+ func (graph *ProcessGraph) Resolve() error

+ func (graph *ProcessGraph) RunningProcesses() (int, error)

+ func (graph *ProcessGraph) SetStorage(storage ProcessGraphStorage)

+ func (graph *ProcessGraph) SuccessfulProcesses() (int, error)

+ func (graph *ProcessGraph) ToJSON() (string, error)

+ func (graph *ProcessGraph) UpdateProcessIDs() error

+ func (graph *ProcessGraph) WaitForParents() (int, error)

+ func (graph *ProcessGraph) WaitProcesses() (int, error)

+ type ProcessGraphStorage interface

+ GetProcessByID func(processID string) (*Process, error)

+ SetProcessGraphState func(processGraphID string, state int) error

+ SetProcessState func(processID string, state int) error

+ SetWaitForParents func(processID string, waitForParent bool) error

+ type ProcessSpec struct

+ Args []string

+ Conditions Conditions

+ Env map[string]string

+ Func string

+ MaxExecTime int

+ MaxRetries int

+ MaxWaitTime int

+ Name string

+ Priority int

+ func ConvertJSONToProcessSpec(jsonString string) (*ProcessSpec, error)

+ func CreateEmptyProcessSpec() *ProcessSpec

+ func CreateProcessSpec(name string, fn string, args []string, colonyID string, runtimeIDs []string, ...) *ProcessSpec

+ func (processSpec *ProcessSpec) AddDependency(dependency string)

+ func (processSpec *ProcessSpec) Equals(processSpec2 *ProcessSpec) bool

+ func (processSpec *ProcessSpec) ToJSON() (string, error)

+ type Runtime struct

+ CPU string

+ ColonyID string

+ CommissionTime time.Time

+ Cores int

+ GPU string

+ GPUs int

+ ID string

+ LastHeardFromTime time.Time

+ Location Location

+ Mem int

+ Name string

+ RuntimeType string

+ State int

+ func ConvertJSONToRuntime(jsonString string) (*Runtime, error)

+ func ConvertJSONToRuntimeArray(jsonString string) ([]*Runtime, error)

+ func CreateRuntime(id string, runtimeType string, name string, colonyID string, cpu string, ...) *Runtime

+ func CreateRuntimeFromDB(id string, runtimeType string, name string, colonyID string, cpu string, ...) *Runtime

+ func (runtime *Runtime) Approve()

+ func (runtime *Runtime) Equals(runtime2 *Runtime) bool

+ func (runtime *Runtime) IsApproved() bool

+ func (runtime *Runtime) IsPending() bool

+ func (runtime *Runtime) IsRejected() bool

+ func (runtime *Runtime) Reject()

+ func (runtime *Runtime) SetColonyID(colonyID string)

+ func (runtime *Runtime) SetID(id string)

+ func (runtime *Runtime) ToJSON() (string, error)

+ type Statistics struct

+ Colonies int

+ FailedProcesses int

+ FailedWorkflows int

+ RunningProcesses int

+ RunningWorkflows int

+ Runtimes int

+ SuccessfulProcesses int

+ SuccessfulWorkflows int

+ WaitingProcesses int

+ WaitingWorkflows int

+ func ConvertJSONToStatistics(jsonString string) (*Statistics, error)

+ func CreateStatistics(colonies int, runtimes int, waitingProcesses int, runningProcesses int, ...) *Statistics

+ func (stat *Statistics) Equals(stat2 *Statistics) bool

+ func (stat *Statistics) ToJSON() (string, error)

+ type Style struct

+ Background string

+ Color string

+ type WorkflowSpec struct

+ ColonyID string

+ ProcessSpecs []ProcessSpec

+ func ConvertJSONToWorkflowSpec(jsonString string) (*WorkflowSpec, error)

+ func CreateWorkflowSpec(colonyID string) *WorkflowSpec

+ func (workflowSpec *WorkflowSpec) AddProcessSpec(processSpec *ProcessSpec)

+ func (workflowSpec *WorkflowSpec) Equals(workflowSpec2 *WorkflowSpec) bool

+ func (workflowSpec *WorkflowSpec) ToJSON() (string, error)