embedded

package
v1.9.13-beta2 Latest Latest
Warning

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

 Go to latest Published: Mar 10, 2026 License: MIT Imports: 16 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type EmbeddedDatabase 

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

func CreateEmbeddedDatabase 

func CreateEmbeddedDatabase(dataDir string) *EmbeddedDatabase

func (*EmbeddedDatabase) AddAttribute 

func (db *EmbeddedDatabase) AddAttribute(attribute core.Attribute) error

func (*EmbeddedDatabase) AddAttributes 

func (db *EmbeddedDatabase) AddAttributes(attributes []core.Attribute) error

func (*EmbeddedDatabase) AddBlueprint 

func (db *EmbeddedDatabase) AddBlueprint(blueprint *core.Blueprint) error

func (*EmbeddedDatabase) AddBlueprintDefinition 

func (db *EmbeddedDatabase) AddBlueprintDefinition(sd *core.BlueprintDefinition) error

func (*EmbeddedDatabase) AddBlueprintHistory 

func (db *EmbeddedDatabase) AddBlueprintHistory(history *core.BlueprintHistory) error

func (*EmbeddedDatabase) AddColony 

func (db *EmbeddedDatabase) AddColony(colony *core.Colony) error

func (*EmbeddedDatabase) AddCron 

func (db *EmbeddedDatabase) AddCron(cron *core.Cron) error

func (*EmbeddedDatabase) AddExecutor 

func (db *EmbeddedDatabase) AddExecutor(executor *core.Executor) error

func (*EmbeddedDatabase) AddFile 

func (db *EmbeddedDatabase) AddFile(file *core.File) error

func (*EmbeddedDatabase) AddFunction 

func (db *EmbeddedDatabase) AddFunction(function *core.Function) error

func (*EmbeddedDatabase) AddGenerator 

func (db *EmbeddedDatabase) AddGenerator(generator *core.Generator) error

func (*EmbeddedDatabase) AddGeneratorArg 

func (db *EmbeddedDatabase) AddGeneratorArg(generatorArg *core.GeneratorArg) error

func (*EmbeddedDatabase) AddLocation 

func (db *EmbeddedDatabase) AddLocation(location *core.Location) error

func (*EmbeddedDatabase) AddLog 

func (db *EmbeddedDatabase) AddLog(processID string, colonyName string, executorName string, timestamp int64, msg string) error

func (*EmbeddedDatabase) AddProcess 

func (db *EmbeddedDatabase) AddProcess(process *core.Process) error

func (*EmbeddedDatabase) AddProcessGraph 

func (db *EmbeddedDatabase) AddProcessGraph(processGraph *core.ProcessGraph) error

func (*EmbeddedDatabase) AddUser 

func (db *EmbeddedDatabase) AddUser(user *core.User) error

func (*EmbeddedDatabase) ApplyRetentionPolicy 

func (db *EmbeddedDatabase) ApplyRetentionPolicy(retentionPeriod int64) error

func (*EmbeddedDatabase) ApproveExecutor 

func (db *EmbeddedDatabase) ApproveExecutor(executor *core.Executor) error

func (*EmbeddedDatabase) Assign 

func (db *EmbeddedDatabase) Assign(executorID string, process *core.Process) error

func (*EmbeddedDatabase) ChangeColonyID 

func (db *EmbeddedDatabase) ChangeColonyID(colonyName string, oldColonyID, newColonyID string) error

func (*EmbeddedDatabase) ChangeExecutorID 

func (db *EmbeddedDatabase) ChangeExecutorID(colonyName string, oldExecutorID, newExecutorID string) error

func (*EmbeddedDatabase) ChangeUserID 

func (db *EmbeddedDatabase) ChangeUserID(colonyName string, oldUserID, newUserID string) error

func (*EmbeddedDatabase) Close 

func (db *EmbeddedDatabase) Close()

func (*EmbeddedDatabase) CountBlueprintDefinitions 

func (db *EmbeddedDatabase) CountBlueprintDefinitions() (int, error)

func (*EmbeddedDatabase) CountBlueprints 

func (db *EmbeddedDatabase) CountBlueprints() (int, error)

func (*EmbeddedDatabase) CountBlueprintsByNamespace 

func (db *EmbeddedDatabase) CountBlueprintsByNamespace(namespace string) (int, error)

func (*EmbeddedDatabase) CountCancelledProcessGraphs 

func (db *EmbeddedDatabase) CountCancelledProcessGraphs() (int, error)

func (*EmbeddedDatabase) CountCancelledProcessGraphsByColonyName 

func (db *EmbeddedDatabase) CountCancelledProcessGraphsByColonyName(colonyName string) (int, error)

func (*EmbeddedDatabase) CountCancelledProcesses 

func (db *EmbeddedDatabase) CountCancelledProcesses() (int, error)

func (*EmbeddedDatabase) CountCancelledProcessesByColonyName 

func (db *EmbeddedDatabase) CountCancelledProcessesByColonyName(colonyName string) (int, error)

func (*EmbeddedDatabase) CountColonies 

func (db *EmbeddedDatabase) CountColonies() (int, error)

func (*EmbeddedDatabase) CountExecutors 

func (db *EmbeddedDatabase) CountExecutors() (int, error)

func (*EmbeddedDatabase) CountExecutorsByColonyName 

func (db *EmbeddedDatabase) CountExecutorsByColonyName(colonyName string) (int, error)

func (*EmbeddedDatabase) CountExecutorsByColonyNameAndState 

func (db *EmbeddedDatabase) CountExecutorsByColonyNameAndState(colonyName string, state int) (int, error)

func (*EmbeddedDatabase) CountFailedProcessGraphs 

func (db *EmbeddedDatabase) CountFailedProcessGraphs() (int, error)

func (*EmbeddedDatabase) CountFailedProcessGraphsByColonyName 

func (db *EmbeddedDatabase) CountFailedProcessGraphsByColonyName(colonyName string) (int, error)

func (*EmbeddedDatabase) CountFailedProcesses 

func (db *EmbeddedDatabase) CountFailedProcesses() (int, error)

func (*EmbeddedDatabase) CountFailedProcessesByColonyName 

func (db *EmbeddedDatabase) CountFailedProcessesByColonyName(colonyName string) (int, error)

func (*EmbeddedDatabase) CountFiles 

func (db *EmbeddedDatabase) CountFiles(colonyName string) (int, error)

func (*EmbeddedDatabase) CountFilesWithLabel 

func (db *EmbeddedDatabase) CountFilesWithLabel(colonyName string, label string) (int, error)

func (*EmbeddedDatabase) CountGeneratorArgs 

func (db *EmbeddedDatabase) CountGeneratorArgs(generatorID string) (int, error)

func (*EmbeddedDatabase) CountLogs 

func (db *EmbeddedDatabase) CountLogs(colonyName string) (int, error)

func (*EmbeddedDatabase) CountProcesses 

func (db *EmbeddedDatabase) CountProcesses() (int, error)

func (*EmbeddedDatabase) CountRunningProcessGraphs 

func (db *EmbeddedDatabase) CountRunningProcessGraphs() (int, error)

func (*EmbeddedDatabase) CountRunningProcessGraphsByColonyName 

func (db *EmbeddedDatabase) CountRunningProcessGraphsByColonyName(colonyName string) (int, error)

func (*EmbeddedDatabase) CountRunningProcesses 

func (db *EmbeddedDatabase) CountRunningProcesses() (int, error)

func (*EmbeddedDatabase) CountRunningProcessesByColonyName 

func (db *EmbeddedDatabase) CountRunningProcessesByColonyName(colonyName string) (int, error)

func (*EmbeddedDatabase) CountSuccessfulProcessGraphs 

func (db *EmbeddedDatabase) CountSuccessfulProcessGraphs() (int, error)

func (*EmbeddedDatabase) CountSuccessfulProcessGraphsByColonyName 

func (db *EmbeddedDatabase) CountSuccessfulProcessGraphsByColonyName(colonyName string) (int, error)

func (*EmbeddedDatabase) CountSuccessfulProcesses 

func (db *EmbeddedDatabase) CountSuccessfulProcesses() (int, error)

func (*EmbeddedDatabase) CountSuccessfulProcessesByColonyName 

func (db *EmbeddedDatabase) CountSuccessfulProcessesByColonyName(colonyName string) (int, error)

func (*EmbeddedDatabase) CountWaitingProcessGraphs 

func (db *EmbeddedDatabase) CountWaitingProcessGraphs() (int, error)

func (*EmbeddedDatabase) CountWaitingProcessGraphsByColonyName 

func (db *EmbeddedDatabase) CountWaitingProcessGraphsByColonyName(colonyName string) (int, error)

func (*EmbeddedDatabase) CountWaitingProcesses 

func (db *EmbeddedDatabase) CountWaitingProcesses() (int, error)

func (*EmbeddedDatabase) CountWaitingProcessesByColonyName 

func (db *EmbeddedDatabase) CountWaitingProcessesByColonyName(colonyName string) (int, error)

func (*EmbeddedDatabase) CreateSnapshot 

func (db *EmbeddedDatabase) CreateSnapshot(colonyName string, label string, name string) (*core.Snapshot, error)

func (*EmbeddedDatabase) Drop 

func (db *EmbeddedDatabase) Drop() error

func (*EmbeddedDatabase) FindAllCrons 

func (db *EmbeddedDatabase) FindAllCrons() ([]*core.Cron, error)

func (*EmbeddedDatabase) FindAllGenerators 

func (db *EmbeddedDatabase) FindAllGenerators() ([]*core.Generator, error)

func (*EmbeddedDatabase) FindAllRunningProcesses 

func (db *EmbeddedDatabase) FindAllRunningProcesses() ([]*core.Process, error)

func (*EmbeddedDatabase) FindAllWaitingProcesses 

func (db *EmbeddedDatabase) FindAllWaitingProcesses() ([]*core.Process, error)

func (*EmbeddedDatabase) FindCancelledProcessGraphs 

func (db *EmbeddedDatabase) FindCancelledProcessGraphs(colonyName string, count int) ([]*core.ProcessGraph, error)

func (*EmbeddedDatabase) FindCancelledProcesses 

func (db *EmbeddedDatabase) FindCancelledProcesses(colonyName string, executorType string, label string, initiator string, count int) ([]*core.Process, error)

func (*EmbeddedDatabase) FindCandidates 

func (db *EmbeddedDatabase) FindCandidates(colonyName string, executorType string, executorLocationName string, cpu int64, memory int64, storage int64, nodes int, processes int, processesPerNode int, count int) ([]*core.Process, error)

func (*EmbeddedDatabase) FindCandidatesByName 

func (db *EmbeddedDatabase) FindCandidatesByName(colonyName string, executorName string, executorType string, executorLocationName string, cpu int64, memory int64, storage int64, nodes int, processes int, processesPerNode int, count int) ([]*core.Process, error)

func (*EmbeddedDatabase) FindCronsByColonyName 

func (db *EmbeddedDatabase) FindCronsByColonyName(colonyName string, count int) ([]*core.Cron, error)

func (*EmbeddedDatabase) FindFailedProcessGraphs 

func (db *EmbeddedDatabase) FindFailedProcessGraphs(colonyName string, count int) ([]*core.ProcessGraph, error)

func (*EmbeddedDatabase) FindFailedProcesses 

func (db *EmbeddedDatabase) FindFailedProcesses(colonyName string, executorType string, label string, initiator string, count int) ([]*core.Process, error)

func (*EmbeddedDatabase) FindGeneratorsByColonyName 

func (db *EmbeddedDatabase) FindGeneratorsByColonyName(colonyName string, count int) ([]*core.Generator, error)

func (*EmbeddedDatabase) FindProcessesByColonyName 

func (db *EmbeddedDatabase) FindProcessesByColonyName(colonyName string, seconds int, state int) ([]*core.Process, error)

func (*EmbeddedDatabase) FindProcessesByExecutorID 

func (db *EmbeddedDatabase) FindProcessesByExecutorID(colonyName string, executorID string, seconds int, state int) ([]*core.Process, error)

func (*EmbeddedDatabase) FindRunningProcessGraphs 

func (db *EmbeddedDatabase) FindRunningProcessGraphs(colonyName string, count int) ([]*core.ProcessGraph, error)

func (*EmbeddedDatabase) FindRunningProcesses 

func (db *EmbeddedDatabase) FindRunningProcesses(colonyName string, executorType string, label string, initiator string, count int) ([]*core.Process, error)

func (*EmbeddedDatabase) FindSuccessfulProcessGraphs 

func (db *EmbeddedDatabase) FindSuccessfulProcessGraphs(colonyName string, count int) ([]*core.ProcessGraph, error)

func (*EmbeddedDatabase) FindSuccessfulProcesses 

func (db *EmbeddedDatabase) FindSuccessfulProcesses(colonyName string, executorType string, label string, initiator string, count int) ([]*core.Process, error)

func (*EmbeddedDatabase) FindWaitingProcessGraphs 

func (db *EmbeddedDatabase) FindWaitingProcessGraphs(colonyName string, count int) ([]*core.ProcessGraph, error)

func (*EmbeddedDatabase) FindWaitingProcesses 

func (db *EmbeddedDatabase) FindWaitingProcesses(colonyName string, executorType string, label string, initiator string, count int) ([]*core.Process, error)

func (*EmbeddedDatabase) GetAttribute 

func (db *EmbeddedDatabase) GetAttribute(targetID string, key string, attributeType int) (core.Attribute, error)

func (*EmbeddedDatabase) GetAttributeByID 

func (db *EmbeddedDatabase) GetAttributeByID(attributeID string) (core.Attribute, error)

func (*EmbeddedDatabase) GetAttributes 

func (db *EmbeddedDatabase) GetAttributes(targetID string) ([]core.Attribute, error)

func (*EmbeddedDatabase) GetAttributesByColonyName 

func (db *EmbeddedDatabase) GetAttributesByColonyName(colonyName string) ([]core.Attribute, error)

func (*EmbeddedDatabase) GetAttributesByType 

func (db *EmbeddedDatabase) GetAttributesByType(targetID string, attributeType int) ([]core.Attribute, error)

func (*EmbeddedDatabase) GetBlueprintByID 

func (db *EmbeddedDatabase) GetBlueprintByID(id string) (*core.Blueprint, error)

func (*EmbeddedDatabase) GetBlueprintByName 

func (db *EmbeddedDatabase) GetBlueprintByName(namespace, name string) (*core.Blueprint, error)

func (*EmbeddedDatabase) GetBlueprintDefinitionByID 

func (db *EmbeddedDatabase) GetBlueprintDefinitionByID(id string) (*core.BlueprintDefinition, error)

func (*EmbeddedDatabase) GetBlueprintDefinitionByKind 

func (db *EmbeddedDatabase) GetBlueprintDefinitionByKind(kind string) (*core.BlueprintDefinition, error)

func (*EmbeddedDatabase) GetBlueprintDefinitionByName 

func (db *EmbeddedDatabase) GetBlueprintDefinitionByName(namespace, name string) (*core.BlueprintDefinition, error)

func (*EmbeddedDatabase) GetBlueprintDefinitions 

func (db *EmbeddedDatabase) GetBlueprintDefinitions() ([]*core.BlueprintDefinition, error)

func (*EmbeddedDatabase) GetBlueprintDefinitionsByGroup 

func (db *EmbeddedDatabase) GetBlueprintDefinitionsByGroup(group string) ([]*core.BlueprintDefinition, error)

func (*EmbeddedDatabase) GetBlueprintDefinitionsByNamespace 

func (db *EmbeddedDatabase) GetBlueprintDefinitionsByNamespace(namespace string) ([]*core.BlueprintDefinition, error)

func (*EmbeddedDatabase) GetBlueprintHistory 

func (db *EmbeddedDatabase) GetBlueprintHistory(blueprintID string, limit int) ([]*core.BlueprintHistory, error)

func (*EmbeddedDatabase) GetBlueprintHistoryByGeneration 

func (db *EmbeddedDatabase) GetBlueprintHistoryByGeneration(blueprintID string, generation int64) (*core.BlueprintHistory, error)

func (*EmbeddedDatabase) GetBlueprints 

func (db *EmbeddedDatabase) GetBlueprints() ([]*core.Blueprint, error)

func (*EmbeddedDatabase) GetBlueprintsByKind 

func (db *EmbeddedDatabase) GetBlueprintsByKind(kind string) ([]*core.Blueprint, error)

func (*EmbeddedDatabase) GetBlueprintsByNamespace 

func (db *EmbeddedDatabase) GetBlueprintsByNamespace(namespace string) ([]*core.Blueprint, error)

func (*EmbeddedDatabase) GetBlueprintsByNamespaceAndKind 

func (db *EmbeddedDatabase) GetBlueprintsByNamespaceAndKind(namespace, kind string) ([]*core.Blueprint, error)

func (*EmbeddedDatabase) GetBlueprintsByNamespaceKindAndLocation 

func (db *EmbeddedDatabase) GetBlueprintsByNamespaceKindAndLocation(namespace, kind, locationName string) ([]*core.Blueprint, error)

func (*EmbeddedDatabase) GetColonies 

func (db *EmbeddedDatabase) GetColonies() ([]*core.Colony, error)

func (*EmbeddedDatabase) GetColonyByID 

func (db *EmbeddedDatabase) GetColonyByID(id string) (*core.Colony, error)

func (*EmbeddedDatabase) GetColonyByName 

func (db *EmbeddedDatabase) GetColonyByName(name string) (*core.Colony, error)

func (*EmbeddedDatabase) GetCronByID 

func (db *EmbeddedDatabase) GetCronByID(cronID string) (*core.Cron, error)

func (*EmbeddedDatabase) GetCronByName 

func (db *EmbeddedDatabase) GetCronByName(colonyName string, cronName string) (*core.Cron, error)

func (*EmbeddedDatabase) GetExecutorByID 

func (db *EmbeddedDatabase) GetExecutorByID(executorID string) (*core.Executor, error)

func (*EmbeddedDatabase) GetExecutorByName 

func (db *EmbeddedDatabase) GetExecutorByName(colonyName string, executorName string) (*core.Executor, error)

func (*EmbeddedDatabase) GetExecutors 

func (db *EmbeddedDatabase) GetExecutors() ([]*core.Executor, error)

func (*EmbeddedDatabase) GetExecutorsByBlueprintID 

func (db *EmbeddedDatabase) GetExecutorsByBlueprintID(blueprintID string) ([]*core.Executor, error)

func (*EmbeddedDatabase) GetExecutorsByColonyName 

func (db *EmbeddedDatabase) GetExecutorsByColonyName(colonyName string, includeUnregistered bool) ([]*core.Executor, error)

func (*EmbeddedDatabase) GetFileByID 

func (db *EmbeddedDatabase) GetFileByID(colonyName string, fileID string) (*core.File, error)

func (*EmbeddedDatabase) GetFileByName 

func (db *EmbeddedDatabase) GetFileByName(colonyName string, label string, name string) ([]*core.File, error)

func (*EmbeddedDatabase) GetFileDataByLabel 

func (db *EmbeddedDatabase) GetFileDataByLabel(colonyName string, label string) ([]*core.FileData, error)

func (*EmbeddedDatabase) GetFileLabels 

func (db *EmbeddedDatabase) GetFileLabels(colonyName string) ([]*core.Label, error)

func (*EmbeddedDatabase) GetFileLabelsByName 

func (db *EmbeddedDatabase) GetFileLabelsByName(colonyName string, name string, exact bool) ([]*core.Label, error)

func (*EmbeddedDatabase) GetFilenamesByLabel 

func (db *EmbeddedDatabase) GetFilenamesByLabel(colonyName string, label string) ([]string, error)

func (*EmbeddedDatabase) GetFunctionByID 

func (db *EmbeddedDatabase) GetFunctionByID(functionID string) (*core.Function, error)

func (*EmbeddedDatabase) GetFunctionsByColonyName 

func (db *EmbeddedDatabase) GetFunctionsByColonyName(colonyName string) ([]*core.Function, error)

func (*EmbeddedDatabase) GetFunctionsByExecutorAndName 

func (db *EmbeddedDatabase) GetFunctionsByExecutorAndName(colonyName string, executorName string, name string) (*core.Function, error)

func (*EmbeddedDatabase) GetFunctionsByExecutorName 

func (db *EmbeddedDatabase) GetFunctionsByExecutorName(colonyName string, executorName string) ([]*core.Function, error)

func (*EmbeddedDatabase) GetGeneratorArgs 

func (db *EmbeddedDatabase) GetGeneratorArgs(generatorID string, count int) ([]*core.GeneratorArg, error)

func (*EmbeddedDatabase) GetGeneratorByID 

func (db *EmbeddedDatabase) GetGeneratorByID(generatorID string) (*core.Generator, error)

func (*EmbeddedDatabase) GetGeneratorByName 

func (db *EmbeddedDatabase) GetGeneratorByName(colonyName string, name string) (*core.Generator, error)

func (*EmbeddedDatabase) GetLatestFileByName 

func (db *EmbeddedDatabase) GetLatestFileByName(colonyName string, label string, name string) ([]*core.File, error)

func (*EmbeddedDatabase) GetLocationByID 

func (db *EmbeddedDatabase) GetLocationByID(locationID string) (*core.Location, error)

func (*EmbeddedDatabase) GetLocationByName 

func (db *EmbeddedDatabase) GetLocationByName(colonyName string, name string) (*core.Location, error)

func (*EmbeddedDatabase) GetLocationsByColonyName 

func (db *EmbeddedDatabase) GetLocationsByColonyName(colonyName string) ([]*core.Location, error)

func (*EmbeddedDatabase) GetLogsByExecutor 

func (db *EmbeddedDatabase) GetLogsByExecutor(executorName string, limit int) ([]*core.Log, error)

func (*EmbeddedDatabase) GetLogsByExecutorLatest 

func (db *EmbeddedDatabase) GetLogsByExecutorLatest(executorName string, limit int) ([]*core.Log, error)

func (*EmbeddedDatabase) GetLogsByExecutorSince 

func (db *EmbeddedDatabase) GetLogsByExecutorSince(executorName string, limit int, since int64) ([]*core.Log, error)

func (*EmbeddedDatabase) GetLogsByProcessID 

func (db *EmbeddedDatabase) GetLogsByProcessID(processID string, limit int) ([]*core.Log, error)

func (*EmbeddedDatabase) GetLogsByProcessIDLatest 

func (db *EmbeddedDatabase) GetLogsByProcessIDLatest(processID string, limit int) ([]*core.Log, error)

func (*EmbeddedDatabase) GetLogsByProcessIDSince 

func (db *EmbeddedDatabase) GetLogsByProcessIDSince(processID string, limit int, since int64) ([]*core.Log, error)

func (*EmbeddedDatabase) GetProcessByID 

func (db *EmbeddedDatabase) GetProcessByID(processID string) (*core.Process, error)

func (*EmbeddedDatabase) GetProcessGraphByID 

func (db *EmbeddedDatabase) GetProcessGraphByID(processGraphID string) (*core.ProcessGraph, error)

func (*EmbeddedDatabase) GetProcesses 

func (db *EmbeddedDatabase) GetProcesses() ([]*core.Process, error)

func (*EmbeddedDatabase) GetServerID 

func (db *EmbeddedDatabase) GetServerID() (string, error)

func (*EmbeddedDatabase) GetSnapshotByID 

func (db *EmbeddedDatabase) GetSnapshotByID(colonyName string, snapshotID string) (*core.Snapshot, error)

func (*EmbeddedDatabase) GetSnapshotByName 

func (db *EmbeddedDatabase) GetSnapshotByName(colonyName string, name string) (*core.Snapshot, error)

func (*EmbeddedDatabase) GetSnapshotsByColonyName 

func (db *EmbeddedDatabase) GetSnapshotsByColonyName(colonyName string) ([]*core.Snapshot, error)

func (*EmbeddedDatabase) GetUserByID 

func (db *EmbeddedDatabase) GetUserByID(colonyName string, userID string) (*core.User, error)

func (*EmbeddedDatabase) GetUserByName 

func (db *EmbeddedDatabase) GetUserByName(colonyName string, name string) (*core.User, error)

func (*EmbeddedDatabase) GetUsersByColonyName 

func (db *EmbeddedDatabase) GetUsersByColonyName(colonyName string) ([]*core.User, error)

func (*EmbeddedDatabase) Initialize 

func (db *EmbeddedDatabase) Initialize() error

func (*EmbeddedDatabase) MarkAlive 

func (db *EmbeddedDatabase) MarkAlive(executor *core.Executor) error

func (*EmbeddedDatabase) MarkCancelled 

func (db *EmbeddedDatabase) MarkCancelled(processID string) error

func (*EmbeddedDatabase) MarkFailed 

func (db *EmbeddedDatabase) MarkFailed(processID string, errs []string) error

func (*EmbeddedDatabase) MarkSuccessful 

func (db *EmbeddedDatabase) MarkSuccessful(processID string) (float64, float64, error)

func (*EmbeddedDatabase) RejectExecutor 

func (db *EmbeddedDatabase) RejectExecutor(executor *core.Executor) error

func (*EmbeddedDatabase) RemoveAllAttributes 

func (db *EmbeddedDatabase) RemoveAllAttributes() error

func (*EmbeddedDatabase) RemoveAllAttributesByColonyName 

func (db *EmbeddedDatabase) RemoveAllAttributesByColonyName(colonyName string) error

func (*EmbeddedDatabase) RemoveAllAttributesByColonyNameWithState 

func (db *EmbeddedDatabase) RemoveAllAttributesByColonyNameWithState(colonyName string, state int) error

func (*EmbeddedDatabase) RemoveAllAttributesByProcessGraphID 

func (db *EmbeddedDatabase) RemoveAllAttributesByProcessGraphID(processGraphID string) error

func (*EmbeddedDatabase) RemoveAllAttributesByTargetID 

func (db *EmbeddedDatabase) RemoveAllAttributesByTargetID(targetID string) error

func (*EmbeddedDatabase) RemoveAllAttributesInProcessGraphsByColonyName 

func (db *EmbeddedDatabase) RemoveAllAttributesInProcessGraphsByColonyName(colonyName string) error

func (*EmbeddedDatabase) RemoveAllAttributesInProcessGraphsByColonyNameWithState 

func (db *EmbeddedDatabase) RemoveAllAttributesInProcessGraphsByColonyNameWithState(colonyName string, state int) error

func (*EmbeddedDatabase) RemoveAllCancelledProcessGraphsByColonyName 

func (db *EmbeddedDatabase) RemoveAllCancelledProcessGraphsByColonyName(colonyName string) error

func (*EmbeddedDatabase) RemoveAllCancelledProcessesByColonyName 

func (db *EmbeddedDatabase) RemoveAllCancelledProcessesByColonyName(colonyName string) error

func (*EmbeddedDatabase) RemoveAllCronsByColonyName 

func (db *EmbeddedDatabase) RemoveAllCronsByColonyName(colonyName string) error

func (*EmbeddedDatabase) RemoveAllFailedProcessGraphsByColonyName 

func (db *EmbeddedDatabase) RemoveAllFailedProcessGraphsByColonyName(colonyName string) error

func (*EmbeddedDatabase) RemoveAllFailedProcessesByColonyName 

func (db *EmbeddedDatabase) RemoveAllFailedProcessesByColonyName(colonyName string) error

func (*EmbeddedDatabase) RemoveAllGeneratorArgsByColonyName 

func (db *EmbeddedDatabase) RemoveAllGeneratorArgsByColonyName(colonyName string) error

func (*EmbeddedDatabase) RemoveAllGeneratorArgsByGeneratorID 

func (db *EmbeddedDatabase) RemoveAllGeneratorArgsByGeneratorID(generatorID string) error

func (*EmbeddedDatabase) RemoveAllGeneratorsByColonyName 

func (db *EmbeddedDatabase) RemoveAllGeneratorsByColonyName(colonyName string) error

func (*EmbeddedDatabase) RemoveAllProcessGraphsByColonyName 

func (db *EmbeddedDatabase) RemoveAllProcessGraphsByColonyName(colonyName string) error

func (*EmbeddedDatabase) RemoveAllProcesses 

func (db *EmbeddedDatabase) RemoveAllProcesses() error

func (*EmbeddedDatabase) RemoveAllProcessesByColonyName 

func (db *EmbeddedDatabase) RemoveAllProcessesByColonyName(colonyName string) error

func (*EmbeddedDatabase) RemoveAllProcessesByProcessGraphID 

func (db *EmbeddedDatabase) RemoveAllProcessesByProcessGraphID(processGraphID string) error

func (*EmbeddedDatabase) RemoveAllProcessesInProcessGraphsByColonyName 

func (db *EmbeddedDatabase) RemoveAllProcessesInProcessGraphsByColonyName(colonyName string) error

func (*EmbeddedDatabase) RemoveAllRunningProcessGraphsByColonyName 

func (db *EmbeddedDatabase) RemoveAllRunningProcessGraphsByColonyName(colonyName string) error

func (*EmbeddedDatabase) RemoveAllRunningProcessesByColonyName 

func (db *EmbeddedDatabase) RemoveAllRunningProcessesByColonyName(colonyName string) error

func (*EmbeddedDatabase) RemoveAllSuccessfulProcessGraphsByColonyName 

func (db *EmbeddedDatabase) RemoveAllSuccessfulProcessGraphsByColonyName(colonyName string) error

func (*EmbeddedDatabase) RemoveAllSuccessfulProcessesByColonyName 

func (db *EmbeddedDatabase) RemoveAllSuccessfulProcessesByColonyName(colonyName string) error

func (*EmbeddedDatabase) RemoveAllWaitingProcessGraphsByColonyName 

func (db *EmbeddedDatabase) RemoveAllWaitingProcessGraphsByColonyName(colonyName string) error

func (*EmbeddedDatabase) RemoveAllWaitingProcessesByColonyName 

func (db *EmbeddedDatabase) RemoveAllWaitingProcessesByColonyName(colonyName string) error

func (*EmbeddedDatabase) RemoveAttributeByID 

func (db *EmbeddedDatabase) RemoveAttributeByID(attributeID string) error

func (*EmbeddedDatabase) RemoveAttributesByTargetID 

func (db *EmbeddedDatabase) RemoveAttributesByTargetID(targetID string, attributeType int) error

func (*EmbeddedDatabase) RemoveBlueprintByID 

func (db *EmbeddedDatabase) RemoveBlueprintByID(id string) error

func (*EmbeddedDatabase) RemoveBlueprintByName 

func (db *EmbeddedDatabase) RemoveBlueprintByName(namespace, name string) error

func (*EmbeddedDatabase) RemoveBlueprintDefinitionByID 

func (db *EmbeddedDatabase) RemoveBlueprintDefinitionByID(id string) error

func (*EmbeddedDatabase) RemoveBlueprintDefinitionByName 

func (db *EmbeddedDatabase) RemoveBlueprintDefinitionByName(namespace, name string) error

func (*EmbeddedDatabase) RemoveBlueprintHistory 

func (db *EmbeddedDatabase) RemoveBlueprintHistory(blueprintID string) error

func (*EmbeddedDatabase) RemoveBlueprintsByNamespace 

func (db *EmbeddedDatabase) RemoveBlueprintsByNamespace(namespace string) error

func (*EmbeddedDatabase) RemoveColonyByName 

func (db *EmbeddedDatabase) RemoveColonyByName(colonyName string) error

func (*EmbeddedDatabase) RemoveCronByID 

func (db *EmbeddedDatabase) RemoveCronByID(cronID string) error

func (*EmbeddedDatabase) RemoveExecutorByName 

func (db *EmbeddedDatabase) RemoveExecutorByName(colonyName string, executorName string) error

func (*EmbeddedDatabase) RemoveExecutorsByColonyName 

func (db *EmbeddedDatabase) RemoveExecutorsByColonyName(colonyName string) error

func (*EmbeddedDatabase) RemoveFileByID 

func (db *EmbeddedDatabase) RemoveFileByID(colonyName string, fileID string) error

func (*EmbeddedDatabase) RemoveFileByName 

func (db *EmbeddedDatabase) RemoveFileByName(colonyName string, label string, name string) error

func (*EmbeddedDatabase) RemoveFunctionByID 

func (db *EmbeddedDatabase) RemoveFunctionByID(functionID string) error

func (*EmbeddedDatabase) RemoveFunctionByName 

func (db *EmbeddedDatabase) RemoveFunctionByName(colonyName string, executorName string, name string) error

func (*EmbeddedDatabase) RemoveFunctions 

func (db *EmbeddedDatabase) RemoveFunctions() error

func (*EmbeddedDatabase) RemoveFunctionsByColonyName 

func (db *EmbeddedDatabase) RemoveFunctionsByColonyName(colonyName string) error

func (*EmbeddedDatabase) RemoveFunctionsByExecutorName 

func (db *EmbeddedDatabase) RemoveFunctionsByExecutorName(colonyName string, executorName string) error

func (*EmbeddedDatabase) RemoveGeneratorArgByID 

func (db *EmbeddedDatabase) RemoveGeneratorArgByID(generatorArgsID string) error

func (*EmbeddedDatabase) RemoveGeneratorByID 

func (db *EmbeddedDatabase) RemoveGeneratorByID(generatorID string) error

func (*EmbeddedDatabase) RemoveLocationByID 

func (db *EmbeddedDatabase) RemoveLocationByID(locationID string) error

func (*EmbeddedDatabase) RemoveLocationByName 

func (db *EmbeddedDatabase) RemoveLocationByName(colonyName string, name string) error

func (*EmbeddedDatabase) RemoveLocationsByColonyName 

func (db *EmbeddedDatabase) RemoveLocationsByColonyName(colonyName string) error

func (*EmbeddedDatabase) RemoveLogsByColonyName 

func (db *EmbeddedDatabase) RemoveLogsByColonyName(colonyName string) error

func (*EmbeddedDatabase) RemoveProcessByID 

func (db *EmbeddedDatabase) RemoveProcessByID(processID string) error

func (*EmbeddedDatabase) RemoveProcessGraphByID 

func (db *EmbeddedDatabase) RemoveProcessGraphByID(processGraphID string) error

func (*EmbeddedDatabase) RemoveSnapshotByID 

func (db *EmbeddedDatabase) RemoveSnapshotByID(colonyName string, snapshotID string) error

func (*EmbeddedDatabase) RemoveSnapshotByName 

func (db *EmbeddedDatabase) RemoveSnapshotByName(colonyName string, name string) error

func (*EmbeddedDatabase) RemoveSnapshotsByColonyName 

func (db *EmbeddedDatabase) RemoveSnapshotsByColonyName(colonyName string) error

func (*EmbeddedDatabase) RemoveUserByID 

func (db *EmbeddedDatabase) RemoveUserByID(colonyName string, userID string) error

func (*EmbeddedDatabase) RemoveUserByName 

func (db *EmbeddedDatabase) RemoveUserByName(colonyName string, name string) error

func (*EmbeddedDatabase) RemoveUsersByColonyName 

func (db *EmbeddedDatabase) RemoveUsersByColonyName(colonyName string) error

func (*EmbeddedDatabase) RenameColony 

func (db *EmbeddedDatabase) RenameColony(colonyName string, newName string) error

func (*EmbeddedDatabase) ResetFunctionStatsByColonyName 

func (db *EmbeddedDatabase) ResetFunctionStatsByColonyName(colonyName string) error

func (*EmbeddedDatabase) ResetProcess 

func (db *EmbeddedDatabase) ResetProcess(process *core.Process) error

func (*EmbeddedDatabase) SearchLogs 

func (db *EmbeddedDatabase) SearchLogs(colonyName string, text string, days int, count int) ([]*core.Log, error)

func (*EmbeddedDatabase) SelectAndAssign 

func (db *EmbeddedDatabase) SelectAndAssign(colonyName string, executorID string, executorName string, executorType string, executorLocation string, cpu int64, memory int64, storage int64, nodes int, processes int, processesPerNode int, count int) (*core.Process, error)

func (*EmbeddedDatabase) SetAllocations 

func (db *EmbeddedDatabase) SetAllocations(colonyName string, executorName string, allocations core.Allocations) error

func (*EmbeddedDatabase) SetChildren 

func (db *EmbeddedDatabase) SetChildren(processID string, children []string) error

func (*EmbeddedDatabase) SetErrors 

func (db *EmbeddedDatabase) SetErrors(processID string, errs []string) error

func (*EmbeddedDatabase) SetGeneratorFirstPack 

func (db *EmbeddedDatabase) SetGeneratorFirstPack(generatorID string) error

func (*EmbeddedDatabase) SetGeneratorLastRun 

func (db *EmbeddedDatabase) SetGeneratorLastRun(generatorID string) error

func (*EmbeddedDatabase) SetInput 

func (db *EmbeddedDatabase) SetInput(processID string, input []interface{}) error

func (*EmbeddedDatabase) SetOutput 

func (db *EmbeddedDatabase) SetOutput(processID string, output []interface{}) error

func (*EmbeddedDatabase) SetParents 

func (db *EmbeddedDatabase) SetParents(processID string, parents []string) error

func (*EmbeddedDatabase) SetProcessGraphState 

func (db *EmbeddedDatabase) SetProcessGraphState(processGraphID string, state int) error

func (*EmbeddedDatabase) SetProcessState 

func (db *EmbeddedDatabase) SetProcessState(processID string, state int) error

func (*EmbeddedDatabase) SetServerID 

func (db *EmbeddedDatabase) SetServerID(oldServerID, newServerID string) error

func (*EmbeddedDatabase) SetWaitForParents 

func (db *EmbeddedDatabase) SetWaitForParents(processID string, waitForParent bool) error

func (*EmbeddedDatabase) Unassign 

func (db *EmbeddedDatabase) Unassign(process *core.Process) error

func (*EmbeddedDatabase) UpdateAttribute 

func (db *EmbeddedDatabase) UpdateAttribute(attribute core.Attribute) error

func (*EmbeddedDatabase) UpdateBlueprint 

func (db *EmbeddedDatabase) UpdateBlueprint(blueprint *core.Blueprint) error

func (*EmbeddedDatabase) UpdateBlueprintDefinition 

func (db *EmbeddedDatabase) UpdateBlueprintDefinition(sd *core.BlueprintDefinition) error

func (*EmbeddedDatabase) UpdateBlueprintStatus 

func (db *EmbeddedDatabase) UpdateBlueprintStatus(id string, status map[string]interface{}) error

func (*EmbeddedDatabase) UpdateCron 

func (db *EmbeddedDatabase) UpdateCron(cronID string, nextRun time.Time, lastRun time.Time, lastProcessGraphID string) error

func (*EmbeddedDatabase) UpdateExecutorCapabilities 

func (db *EmbeddedDatabase) UpdateExecutorCapabilities(colonyName string, executorName string, capabilities core.Capabilities) error

func (*EmbeddedDatabase) UpdateFunctionStats 

func (db *EmbeddedDatabase) UpdateFunctionStats(colonyName string, executorName string, name string, counter int, minWaitTime float64, maxWaitTime float64, minExecTime float64, maxExecTime float64, avgWaitTime float64, avgExecTime float64) error

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.