postgresql

package
v1.0.1 Latest Latest
Warning

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

 Go to latest Published: Mar 16, 2023 License: MIT Imports: 13 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) *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) 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) AddProcess 

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

func (*PQDatabase) AddProcessGraph 

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

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) 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) CountExecutorsByColonyID added in v1.0.1 

func (db *PQDatabase) CountExecutorsByColonyID(colonyID string) (int, error)

func (*PQDatabase) CountFailedProcessGraphs 

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

func (*PQDatabase) CountFailedProcessGraphsByColonyID 

func (db *PQDatabase) CountFailedProcessGraphsByColonyID(colonyID string) (int, error)

func (*PQDatabase) CountFailedProcesses 

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

func (*PQDatabase) CountFailedProcessesByColonyID 

func (db *PQDatabase) CountFailedProcessesByColonyID(colonyID string) (int, error)

func (*PQDatabase) CountGeneratorArgs 

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

func (*PQDatabase) CountProcesses 

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

func (*PQDatabase) CountRunningProcessGraphs 

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

func (*PQDatabase) CountRunningProcessGraphsByColonyID 

func (db *PQDatabase) CountRunningProcessGraphsByColonyID(colonyID string) (int, error)

func (*PQDatabase) CountRunningProcesses 

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

func (*PQDatabase) CountRunningProcessesByColonyID 

func (db *PQDatabase) CountRunningProcessesByColonyID(colonyID string) (int, error)

func (*PQDatabase) CountSuccessfulProcessGraphs 

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

func (*PQDatabase) CountSuccessfulProcessGraphsByColonyID 

func (db *PQDatabase) CountSuccessfulProcessGraphsByColonyID(colonyID string) (int, error)

func (*PQDatabase) CountSuccessfulProcesses 

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

func (*PQDatabase) CountSuccessfulProcessesByColonyID 

func (db *PQDatabase) CountSuccessfulProcessesByColonyID(colonyID string) (int, error)

func (*PQDatabase) CountWaitingProcessGraphs 

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

func (*PQDatabase) CountWaitingProcessGraphsByColonyID 

func (db *PQDatabase) CountWaitingProcessGraphsByColonyID(colonyID string) (int, error)

func (*PQDatabase) CountWaitingProcesses 

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

func (*PQDatabase) CountWaitingProcessesByColonyID 

func (db *PQDatabase) CountWaitingProcessesByColonyID(colonyID string) (int, error)

func (*PQDatabase) DeleteAllAttributes 

func (db *PQDatabase) DeleteAllAttributes() error

func (*PQDatabase) DeleteAllAttributesByColonyID 

func (db *PQDatabase) DeleteAllAttributesByColonyID(colonyID string) error

func (*PQDatabase) DeleteAllAttributesByProcessGraphID 

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

func (*PQDatabase) DeleteAllAttributesByTargetID 

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

func (*PQDatabase) DeleteAllAttributesInProcessGraphsByColonyID 

func (db *PQDatabase) DeleteAllAttributesInProcessGraphsByColonyID(colonyID string) error

func (*PQDatabase) DeleteAllCronsByColonyID 

func (db *PQDatabase) DeleteAllCronsByColonyID(colonyID string) error

func (*PQDatabase) DeleteAllGeneratorArgsByColonyID 

func (db *PQDatabase) DeleteAllGeneratorArgsByColonyID(colonyID string) error

func (*PQDatabase) DeleteAllGeneratorArgsByGeneratorID 

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

func (*PQDatabase) DeleteAllGeneratorsByColonyID 

func (db *PQDatabase) DeleteAllGeneratorsByColonyID(colonyID string) error

func (*PQDatabase) DeleteAllProcessGraphsByColonyID 

func (db *PQDatabase) DeleteAllProcessGraphsByColonyID(colonyID string) error

func (*PQDatabase) DeleteAllProcesses 

func (db *PQDatabase) DeleteAllProcesses() error

func (*PQDatabase) DeleteAllProcessesByColonyID 

func (db *PQDatabase) DeleteAllProcessesByColonyID(colonyID string) error

func (*PQDatabase) DeleteAllProcessesByProcessGraphID 

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

func (*PQDatabase) DeleteAllProcessesInProcessGraphsByColonyID 

func (db *PQDatabase) DeleteAllProcessesInProcessGraphsByColonyID(colonyID string) error

func (*PQDatabase) DeleteAttributeByID 

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

func (*PQDatabase) DeleteAttributesByTargetID 

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

func (*PQDatabase) DeleteColonyByID 

func (db *PQDatabase) DeleteColonyByID(colonyID string) error

func (*PQDatabase) DeleteCronByID 

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

func (*PQDatabase) DeleteExecutorByID added in v1.0.1 

func (db *PQDatabase) DeleteExecutorByID(executorID string) error

func (*PQDatabase) DeleteExecutorsByColonyID added in v1.0.1 

func (db *PQDatabase) DeleteExecutorsByColonyID(colonyID string) error

func (*PQDatabase) DeleteFunctionByID added in v1.0.1 

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

func (*PQDatabase) DeleteFunctionByName added in v1.0.1 

func (db *PQDatabase) DeleteFunctionByName(executorID string, name string) error

func (*PQDatabase) DeleteFunctions added in v1.0.1 

func (db *PQDatabase) DeleteFunctions() error

func (*PQDatabase) DeleteFunctionsByColonyID added in v1.0.1 

func (db *PQDatabase) DeleteFunctionsByColonyID(colonyID string) error

func (*PQDatabase) DeleteFunctionsByExecutorID added in v1.0.1 

func (db *PQDatabase) DeleteFunctionsByExecutorID(executorID string) error

func (*PQDatabase) DeleteGeneratorArgByID 

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

func (*PQDatabase) DeleteGeneratorByID 

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

func (*PQDatabase) DeleteProcessByID 

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

func (*PQDatabase) DeleteProcessGraphByID 

func (db *PQDatabase) DeleteProcessGraphByID(processGraphID string) 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) FindCronsByColonyID 

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

func (*PQDatabase) FindFailedProcessGraphs 

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

func (*PQDatabase) FindFailedProcesses 

func (db *PQDatabase) FindFailedProcesses(colonyID string, count int) ([]*core.Process, error)

func (*PQDatabase) FindGeneratorsByColonyID 

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

func (*PQDatabase) FindProcessesByColonyID 

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

func (*PQDatabase) FindProcessesByExecutorID added in v1.0.1 

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

func (*PQDatabase) FindRunningProcessGraphs 

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

func (*PQDatabase) FindRunningProcesses 

func (db *PQDatabase) FindRunningProcesses(colonyID string, count int) ([]*core.Process, error)

func (*PQDatabase) FindSuccessfulProcessGraphs 

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

func (*PQDatabase) FindSuccessfulProcesses 

func (db *PQDatabase) FindSuccessfulProcesses(colonyID string, count int) ([]*core.Process, error)

func (*PQDatabase) FindUnassignedProcesses 

func (db *PQDatabase) FindUnassignedProcesses(colonyID string, executorID string, executorType string, count int, latest bool) ([]*core.Process, error)

func (*PQDatabase) FindWaitingProcessGraphs 

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

func (*PQDatabase) FindWaitingProcesses 

func (db *PQDatabase) FindWaitingProcesses(colonyID 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) 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) GetCronByID 

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

func (*PQDatabase) GetExecutorByID added in v1.0.1 

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

func (*PQDatabase) GetExecutors added in v1.0.1 

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

func (*PQDatabase) GetExecutorsByColonyID added in v1.0.1 

func (db *PQDatabase) GetExecutorsByColonyID(colonyID string) ([]*core.Executor, error)

func (*PQDatabase) GetFunctionByID added in v1.0.1 

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

func (*PQDatabase) GetFunctionsByColonyID added in v1.0.1 

func (db *PQDatabase) GetFunctionsByColonyID(colonyID string) ([]*core.Function, error)

func (*PQDatabase) GetFunctionsByExecutorID added in v1.0.1 

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

func (*PQDatabase) GetFunctionsByExecutorIDAndName added in v1.0.1 

func (db *PQDatabase) GetFunctionsByExecutorIDAndName(executorID string, name 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(name string) (*core.Generator, 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) 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) ResetAllProcesses 

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

func (*PQDatabase) ResetProcess 

func (db *PQDatabase) ResetProcess(process *core.Process) 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) 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) 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(executorID string,
	name string,
	counter int,
	minWaitTime float64,
	maxWaitTime float64,
	minExecTime float64,
	maxExecTime float64,
	avgWaitTime float64,
	avgExecTime float64) error

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.