postgresql

package
v1.6.0 Latest Latest
Warning

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

 Go to latest Published: Oct 10, 2023 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 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, colonyID string, executorID string, timestamp int64, msg string) error

func (*PQDatabase) AddOrReplaceExecutor added in v1.1.0 

func (db *PQDatabase) AddOrReplaceExecutor(executor *core.Executor) 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) 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) 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) CountFiles added in v1.5.0 

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

func (*PQDatabase) CountFilesWithLabel added in v1.5.0 

func (db *PQDatabase) CountFilesWithLabel(colonyID 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(colonyID 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) CreateSnapshot added in v1.5.0 

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

func (*PQDatabase) DeleteAllAttributes 

func (db *PQDatabase) DeleteAllAttributes() error

func (*PQDatabase) DeleteAllAttributesByColonyID 

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

func (*PQDatabase) DeleteAllAttributesByColonyIDWithState added in v1.1.0 

func (db *PQDatabase) DeleteAllAttributesByColonyIDWithState(colonyID string, state int) 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) DeleteAllAttributesInProcessGraphsByColonyIDWithState added in v1.1.0 

func (db *PQDatabase) DeleteAllAttributesInProcessGraphsByColonyIDWithState(colonyID string, state int) error

func (*PQDatabase) DeleteAllCronsByColonyID 

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

func (*PQDatabase) DeleteAllFailedProcessGraphsByColonyID added in v1.1.0 

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

func (*PQDatabase) DeleteAllFailedProcessesByColonyID added in v1.1.0 

func (db *PQDatabase) DeleteAllFailedProcessesByColonyID(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) DeleteAllProcessesInProcessGraphsByColonyIDWithState added in v1.1.0 

func (db *PQDatabase) DeleteAllProcessesInProcessGraphsByColonyIDWithState(colonyID string, state int) error

func (*PQDatabase) DeleteAllRunningProcessGraphsByColonyID added in v1.1.0 

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

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

func (*PQDatabase) DeleteAllRunningProcessesByColonyID added in v1.1.0 

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

func (*PQDatabase) DeleteAllSuccessfulProcessGraphsByColonyID added in v1.1.0 

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

func (*PQDatabase) DeleteAllSuccessfulProcessesByColonyID added in v1.1.0 

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

func (*PQDatabase) DeleteAllWaitingProcessGraphsByColonyID added in v1.1.0 

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

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

func (*PQDatabase) DeleteAllWaitingProcessesByColonyID added in v1.1.0 

func (db *PQDatabase) DeleteAllWaitingProcessesByColonyID(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) DeleteFileByID added in v1.5.0 

func (db *PQDatabase) DeleteFileByID(colonyID string, fileID string) error

func (*PQDatabase) DeleteFileByName added in v1.5.0 

func (db *PQDatabase) DeleteFileByName(colonyID string, label string, name string) error

func (*PQDatabase) DeleteFilesByColonyID added in v1.5.0 

func (db *PQDatabase) DeleteFilesByColonyID(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) DeleteLogsByColonyID added in v1.5.0 

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

func (*PQDatabase) DeleteProcessByID 

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

func (*PQDatabase) DeleteProcessGraphByID 

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

func (*PQDatabase) DeleteSnapshotByID added in v1.5.0 

func (db *PQDatabase) DeleteSnapshotByID(colonyID string, snapshotID string) error

func (*PQDatabase) DeleteSnapshotByName added in v1.5.0 

func (db *PQDatabase) DeleteSnapshotByName(colonyID string, name string) error

func (*PQDatabase) DeleteSnapshotsByColonyID added in v1.5.0 

func (db *PQDatabase) DeleteSnapshotsByColonyID(colonyID 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, executorType 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, executorType 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, executorType string, count int) ([]*core.Process, error)

func (*PQDatabase) FindUnassignedProcesses 

func (db *PQDatabase) FindUnassignedProcesses(colonyID string, executorID string, executorType string, count int) ([]*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, executorType 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) GetAttributesByColonyID added in v1.1.0 

func (db *PQDatabase) GetAttributesByColonyID(colonyID 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) GetExecutorByName added in v1.1.0 

func (db *PQDatabase) GetExecutorByName(colonyID string, executorName 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) GetFileByID added in v1.5.0 

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

func (*PQDatabase) GetFileByName added in v1.5.0 

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

func (*PQDatabase) GetFileLabels added in v1.5.0 

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

func (*PQDatabase) GetFileLabelsByName added in v1.6.0 

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

func (*PQDatabase) GetFilenamesByLabel added in v1.5.0 

func (db *PQDatabase) GetFilenamesByLabel(colonyID string, label string) ([]string, 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) GetLatestFileByName added in v1.5.0 

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

func (*PQDatabase) GetLogsByExecutorID added in v1.4.0 

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

func (*PQDatabase) GetLogsByExecutorIDSince added in v1.4.0 

func (db *PQDatabase) GetLogsByExecutorIDSince(executorID 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) GetSnapshotByID added in v1.5.0 

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

func (*PQDatabase) GetSnapshotByName added in v1.5.0 

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

func (*PQDatabase) GetSnapshotsByColonyID added in v1.5.0 

func (db *PQDatabase) GetSnapshotsByColonyID(colonyID string) ([]*core.Snapshot, 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) RenameColony added in v1.1.0 

func (db *PQDatabase) RenameColony(id string, name string) error

func (*PQDatabase) ResetProcess 

func (db *PQDatabase) ResetProcess(process *core.Process) 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) 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

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.