postgresql

package
v1.8.4 Latest Latest
Warning

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

 Go to latest Published: Mar 17, 2024 License: MIT Imports: 17 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type PQDatabase 

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

func CreatePQDatabase 

func CreatePQDatabase(dbHost string, dbPort int, dbUser string, dbPassword string, dbName string, dbPrefix string, timescaleDB bool) *PQDatabase

func PrepareTests 

func PrepareTests() (*PQDatabase, error)

func PrepareTestsWithPrefix 

func PrepareTestsWithPrefix(prefix string) (*PQDatabase, error)

func (*PQDatabase) AddAttribute 

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

func (*PQDatabase) AddAttributes 

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

func (*PQDatabase) AddColony 

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

func (*PQDatabase) AddCron 

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

func (*PQDatabase) AddExecutor added in v1.0.1 

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

func (*PQDatabase) AddFile added in v1.5.0 

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

func (*PQDatabase) AddFunction added in v1.0.1 

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

func (*PQDatabase) AddGenerator 

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

func (*PQDatabase) AddGeneratorArg 

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

func (*PQDatabase) AddLog added in v1.4.0 

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

func (*PQDatabase) AddProcess 

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

func (*PQDatabase) AddProcessGraph 

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

func (*PQDatabase) AddUser added in v1.7.0 

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

func (*PQDatabase) ApplyRetentionPolicy added in v1.1.0 

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

retentionPeriod in seconds

func (*PQDatabase) ApproveExecutor added in v1.0.1 

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

func (*PQDatabase) Assign added in v1.0.1 

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

func (*PQDatabase) ChangeColonyID added in v1.7.7 

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

func (*PQDatabase) ChangeExecutorID added in v1.7.7 

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

func (*PQDatabase) ChangeUserID added in v1.7.7 

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

func (*PQDatabase) Close 

func (db *PQDatabase) Close()

func (*PQDatabase) Connect 

func (db *PQDatabase) Connect() error

func (*PQDatabase) CountColonies 

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

func (*PQDatabase) CountExecutors added in v1.0.1 

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

func (*PQDatabase) CountExecutorsByColonyName added in v1.7.0 

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

func (*PQDatabase) CountFailedProcessGraphs 

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

func (*PQDatabase) CountFailedProcessGraphsByColonyName added in v1.7.0 

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

func (*PQDatabase) CountFailedProcesses 

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

func (*PQDatabase) CountFailedProcessesByColonyName added in v1.7.0 

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

func (*PQDatabase) CountFiles added in v1.5.0 

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

func (*PQDatabase) CountFilesWithLabel added in v1.5.0 

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

func (*PQDatabase) CountGeneratorArgs 

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

func (*PQDatabase) CountLogs added in v1.5.0 

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

func (*PQDatabase) CountProcesses 

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

func (*PQDatabase) CountRunningProcessGraphs 

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

func (*PQDatabase) CountRunningProcessGraphsByColonyName added in v1.7.0 

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

func (*PQDatabase) CountRunningProcesses 

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

func (*PQDatabase) CountRunningProcessesByColonyName added in v1.7.0 

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

func (*PQDatabase) CountSuccessfulProcessGraphs 

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

func (*PQDatabase) CountSuccessfulProcessGraphsByColonyName added in v1.7.0 

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

func (*PQDatabase) CountSuccessfulProcesses 

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

func (*PQDatabase) CountSuccessfulProcessesByColonyName added in v1.7.0 

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

func (*PQDatabase) CountWaitingProcessGraphs 

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

func (*PQDatabase) CountWaitingProcessGraphsByColonyName added in v1.7.0 

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

func (*PQDatabase) CountWaitingProcesses 

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

func (*PQDatabase) CountWaitingProcessesByColonyName added in v1.7.0 

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

func (*PQDatabase) CreateSnapshot added in v1.5.0 

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

func (*PQDatabase) Drop 

func (db *PQDatabase) Drop() error

func (*PQDatabase) FindAllCrons 

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

func (*PQDatabase) FindAllGenerators 

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

func (*PQDatabase) FindAllRunningProcesses 

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

func (*PQDatabase) FindAllWaitingProcesses 

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

func (*PQDatabase) FindCandidates added in v1.7.7 

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

func (*PQDatabase) FindCandidatesByName added in v1.7.7 

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

func (*PQDatabase) FindCronsByColonyName added in v1.7.0 

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

func (*PQDatabase) FindFailedProcessGraphs 

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

func (*PQDatabase) FindFailedProcesses 

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

func (*PQDatabase) FindGeneratorsByColonyName added in v1.7.0 

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

func (*PQDatabase) FindProcessesByColonyName added in v1.7.0 

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

func (*PQDatabase) FindProcessesByExecutorID added in v1.0.1 

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

func (*PQDatabase) FindRunningProcessGraphs 

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

func (*PQDatabase) FindRunningProcesses 

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

func (*PQDatabase) FindSuccessfulProcessGraphs 

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

func (*PQDatabase) FindSuccessfulProcesses 

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

func (*PQDatabase) FindWaitingProcessGraphs 

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

func (*PQDatabase) FindWaitingProcesses 

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

func (*PQDatabase) GetAttribute 

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

func (*PQDatabase) GetAttributeByID 

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

func (*PQDatabase) GetAttributes 

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

func (*PQDatabase) GetAttributesByColonyName added in v1.7.0 

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

func (*PQDatabase) GetAttributesByType 

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

func (*PQDatabase) GetColonies 

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

func (*PQDatabase) GetColonyByID 

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

func (*PQDatabase) GetColonyByName added in v1.7.0 

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

func (*PQDatabase) GetCronByID 

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

func (*PQDatabase) GetCronByName added in v1.7.1 

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

func (*PQDatabase) GetExecutorByID added in v1.0.1 

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

func (*PQDatabase) GetExecutorByName added in v1.1.0 

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

func (*PQDatabase) GetExecutors added in v1.0.1 

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

func (*PQDatabase) GetExecutorsByColonyName added in v1.7.0 

func (db *PQDatabase) GetExecutorsByColonyName(colonyName string) ([]*core.Executor, error)

func (*PQDatabase) GetFileByID added in v1.5.0 

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

func (*PQDatabase) GetFileByName added in v1.5.0 

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

func (*PQDatabase) GetFileDataByLabel added in v1.7.4 

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

func (*PQDatabase) GetFileLabelByName added in v1.8.2 

func (db *PQDatabase) GetFileLabelByName(colonyName string, name string) (*core.Label, error)

func (*PQDatabase) GetFileLabels added in v1.5.0 

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

func (*PQDatabase) GetFileLabelsByName added in v1.6.0 

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

func (*PQDatabase) GetFilenamesByLabel added in v1.5.0 

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

func (*PQDatabase) GetFunctionByID added in v1.0.1 

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

func (*PQDatabase) GetFunctionsByColonyName added in v1.7.0 

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

func (*PQDatabase) GetFunctionsByExecutorAndName added in v1.7.0 

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

func (*PQDatabase) GetFunctionsByExecutorName added in v1.7.0 

func (db *PQDatabase) GetFunctionsByExecutorName(colonyName string, executorID string) ([]*core.Function, error)

func (*PQDatabase) GetGeneratorArgs 

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

func (*PQDatabase) GetGeneratorByID 

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

func (*PQDatabase) GetGeneratorByName 

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

func (*PQDatabase) GetLatestFileByName added in v1.5.0 

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

func (*PQDatabase) GetLogsByExecutor added in v1.7.7 

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

func (*PQDatabase) GetLogsByExecutorSince added in v1.7.7 

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

func (*PQDatabase) GetLogsByProcessID added in v1.4.0 

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

func (*PQDatabase) GetLogsByProcessIDSince added in v1.4.0 

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

func (*PQDatabase) GetProcessByID 

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

func (*PQDatabase) GetProcessGraphByID 

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

func (*PQDatabase) GetProcesses 

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

func (*PQDatabase) GetServerID added in v1.7.7 

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

func (*PQDatabase) GetSnapshotByID added in v1.5.0 

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

func (*PQDatabase) GetSnapshotByName added in v1.5.0 

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

func (*PQDatabase) GetSnapshotsByColonyName added in v1.7.0 

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

func (*PQDatabase) GetUserByID added in v1.7.0 

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

func (*PQDatabase) GetUserByName added in v1.7.0 

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

func (*PQDatabase) GetUsersByColonyName added in v1.7.0 

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

func (*PQDatabase) Initialize 

func (db *PQDatabase) Initialize() error

func (*PQDatabase) Lock 

func (db *PQDatabase) Lock(timeout int) error

func (*PQDatabase) MarkAlive 

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

func (*PQDatabase) MarkFailed 

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

func (*PQDatabase) MarkSuccessful 

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

func (*PQDatabase) RejectExecutor added in v1.0.1 

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

func (*PQDatabase) RemoveAllAttributes added in v1.7.0 

func (db *PQDatabase) RemoveAllAttributes() error

func (*PQDatabase) RemoveAllAttributesByColonyName added in v1.7.0 

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

func (*PQDatabase) RemoveAllAttributesByColonyNameWithState added in v1.7.0 

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

func (*PQDatabase) RemoveAllAttributesByProcessGraphID added in v1.7.0 

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

func (*PQDatabase) RemoveAllAttributesByTargetID added in v1.7.0 

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

func (*PQDatabase) RemoveAllAttributesInProcessGraphsByColonyName added in v1.7.0 

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

func (*PQDatabase) RemoveAllAttributesInProcessGraphsByColonyNameWithState added in v1.7.0 

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

func (*PQDatabase) RemoveAllCronsByColonyName added in v1.7.0 

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

func (*PQDatabase) RemoveAllFailedProcessGraphsByColonyName added in v1.7.0 

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

func (*PQDatabase) RemoveAllFailedProcessesByColonyName added in v1.7.0 

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

func (*PQDatabase) RemoveAllGeneratorArgsByColonyName added in v1.7.0 

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

func (*PQDatabase) RemoveAllGeneratorArgsByGeneratorID added in v1.7.0 

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

func (*PQDatabase) RemoveAllGeneratorsByColonyName added in v1.7.0 

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

func (*PQDatabase) RemoveAllProcessGraphsByColonyName added in v1.7.0 

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

func (*PQDatabase) RemoveAllProcesses added in v1.7.0 

func (db *PQDatabase) RemoveAllProcesses() error

func (*PQDatabase) RemoveAllProcessesByColonyName added in v1.7.0 

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

func (*PQDatabase) RemoveAllProcessesByProcessGraphID added in v1.7.0 

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

func (*PQDatabase) RemoveAllProcessesInProcessGraphsByColonyName added in v1.7.0 

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

func (*PQDatabase) RemoveAllProcessesInProcessGraphsByColonyNameWithState added in v1.7.0 

func (db *PQDatabase) RemoveAllProcessesInProcessGraphsByColonyNameWithState(colonyName string, state int) error

func (*PQDatabase) RemoveAllRunningProcessGraphsByColonyName added in v1.7.0 

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

XXX: This function can cause inconsisteny, for example if the processgraph is running, and all running processes is removed it will no longer be possible to resolve the processgraph

func (*PQDatabase) RemoveAllRunningProcessesByColonyName added in v1.7.0 

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

func (*PQDatabase) RemoveAllSuccessfulProcessGraphsByColonyName added in v1.7.0 

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

func (*PQDatabase) RemoveAllSuccessfulProcessesByColonyName added in v1.7.0 

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

func (*PQDatabase) RemoveAllWaitingProcessGraphsByColonyName added in v1.7.0 

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

XXX: This function may remove all belonging processes if the graph is running.

func (*PQDatabase) RemoveAllWaitingProcessesByColonyName added in v1.7.0 

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

func (*PQDatabase) RemoveAttributeByID added in v1.7.0 

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

func (*PQDatabase) RemoveAttributesByTargetID added in v1.7.0 

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

func (*PQDatabase) RemoveColonyByName added in v1.7.0 

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

func (*PQDatabase) RemoveCronByID added in v1.7.0 

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

func (*PQDatabase) RemoveExecutorByName added in v1.7.0 

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

func (*PQDatabase) RemoveExecutorsByColonyName added in v1.7.0 

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

func (*PQDatabase) RemoveFileByID added in v1.7.0 

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

func (*PQDatabase) RemoveFileByName added in v1.7.0 

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

func (*PQDatabase) RemoveFilesByColonyName added in v1.7.0 

func (db *PQDatabase) RemoveFilesByColonyName(colonyName string) error

func (*PQDatabase) RemoveFunctionByID added in v1.7.0 

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

func (*PQDatabase) RemoveFunctionByName added in v1.7.0 

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

func (*PQDatabase) RemoveFunctions added in v1.7.0 

func (db *PQDatabase) RemoveFunctions() error

func (*PQDatabase) RemoveFunctionsByColonyName added in v1.7.0 

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

func (*PQDatabase) RemoveFunctionsByExecutorName added in v1.7.0 

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

func (*PQDatabase) RemoveGeneratorArgByID added in v1.7.0 

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

func (*PQDatabase) RemoveGeneratorByID added in v1.7.0 

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

func (*PQDatabase) RemoveLogsByColonyName added in v1.7.0 

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

func (*PQDatabase) RemoveProcessByID added in v1.7.0 

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

func (*PQDatabase) RemoveProcessGraphByID added in v1.7.0 

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

func (*PQDatabase) RemoveSnapshotByID added in v1.7.0 

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

func (*PQDatabase) RemoveSnapshotByName added in v1.7.0 

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

func (*PQDatabase) RemoveSnapshotsByColonyName added in v1.7.0 

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

func (*PQDatabase) RemoveUserByID added in v1.7.0 

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

func (*PQDatabase) RemoveUserByName added in v1.7.0 

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

func (*PQDatabase) RemoveUsersByColonyName added in v1.7.0 

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

func (*PQDatabase) RenameColony added in v1.1.0 

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

func (*PQDatabase) ResetProcess 

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

func (*PQDatabase) SearchLogs added in v1.7.7 

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

func (*PQDatabase) SetAllocations added in v1.7.8 

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

func (*PQDatabase) SetAttributeState added in v1.1.0 

func (db *PQDatabase) SetAttributeState(processID string, state int) error

func (*PQDatabase) SetChildren 

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

func (*PQDatabase) SetErrors 

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

func (*PQDatabase) SetExecDeadline 

func (db *PQDatabase) SetExecDeadline(process *core.Process, execDeadline time.Time) error

func (*PQDatabase) SetGeneratorFirstPack added in v1.1.0 

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

func (*PQDatabase) SetGeneratorLastRun 

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

func (*PQDatabase) SetInput 

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

func (*PQDatabase) SetOutput 

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

func (*PQDatabase) SetParents 

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

func (*PQDatabase) SetProcessGraphState 

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

func (*PQDatabase) SetProcessState 

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

func (*PQDatabase) SetServerID added in v1.7.7 

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

func (*PQDatabase) SetWaitDeadline 

func (db *PQDatabase) SetWaitDeadline(process *core.Process, waitDeadline time.Time) error

func (*PQDatabase) SetWaitForParents 

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

func (*PQDatabase) Unassign added in v1.0.1 

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

func (*PQDatabase) Unlock 

func (db *PQDatabase) Unlock() error

func (*PQDatabase) UpdateAttribute 

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

func (*PQDatabase) UpdateCron 

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

func (*PQDatabase) UpdateFunctionStats added in v1.0.1 

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

type Postgresql added in v1.1.1 

type Postgresql interface {
	Begin() (*sql.Tx, error)
	BeginTx(ctx context.Context, opts *sql.TxOptions) (*sql.Tx, error)
	Close() error
	Conn(ctx context.Context) (*sql.Conn, error)
	Driver() driver.Driver
	Exec(query string, args ...any) (sql.Result, error)
	ExecContext(ctx context.Context, query string, args ...any) (sql.Result, error)
	Ping() error
	PingContext(ctx context.Context) error
	Prepare(query string) (*sql.Stmt, error)
	PrepareContext(ctx context.Context, query string) (*sql.Stmt, error)
	Query(query string, args ...any) (*sql.Rows, error)
	QueryContext(ctx context.Context, query string, args ...any) (*sql.Rows, error)
	QueryRow(query string, args ...any) *sql.Row
	QueryRowContext(ctx context.Context, query string, args ...any) *sql.Row
	SetConnMaxIdleTime(d time.Duration)
	SetConnMaxLifetime(d time.Duration)
	SetMaxIdleConns(n int)
	SetMaxOpenConns(n int)
	Stats() sql.DBStats
}

Source Files

View all Source files

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.