lookoutdb

package
v0.12.1 Latest Latest
Warning

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

Go to latest
Published: Sep 23, 2024 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type LookoutDb

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

func NewLookoutDb

func NewLookoutDb(db *pgxpool.Pool, fatalErrors []*regexp.Regexp, metrics *metrics.Metrics, maxBackoff int) *LookoutDb

func (*LookoutDb) CreateJobErrors added in v0.8.3

func (l *LookoutDb) CreateJobErrors(ctx *armadacontext.Context, instructions []*model.CreateJobErrorInstruction)

func (*LookoutDb) CreateJobErrorsBatch added in v0.8.3

func (l *LookoutDb) CreateJobErrorsBatch(ctx *armadacontext.Context, instructions []*model.CreateJobErrorInstruction) error

func (*LookoutDb) CreateJobErrorsScalar added in v0.8.3

func (l *LookoutDb) CreateJobErrorsScalar(ctx *armadacontext.Context, instructions []*model.CreateJobErrorInstruction)

func (*LookoutDb) CreateJobRuns

func (l *LookoutDb) CreateJobRuns(ctx *armadacontext.Context, instructions []*model.CreateJobRunInstruction)

func (*LookoutDb) CreateJobRunsBatch

func (l *LookoutDb) CreateJobRunsBatch(ctx *armadacontext.Context, instructions []*model.CreateJobRunInstruction) error

func (*LookoutDb) CreateJobRunsScalar

func (l *LookoutDb) CreateJobRunsScalar(ctx *armadacontext.Context, instructions []*model.CreateJobRunInstruction)

func (*LookoutDb) CreateJobSpecs added in v0.12.1

func (l *LookoutDb) CreateJobSpecs(ctx *armadacontext.Context, instructions []*model.CreateJobInstruction)

func (*LookoutDb) CreateJobSpecsBatch added in v0.12.1

func (l *LookoutDb) CreateJobSpecsBatch(ctx *armadacontext.Context, instructions []*model.CreateJobInstruction) error

func (*LookoutDb) CreateJobSpecsScalar added in v0.12.1

func (l *LookoutDb) CreateJobSpecsScalar(ctx *armadacontext.Context, instructions []*model.CreateJobInstruction)

func (*LookoutDb) CreateJobs

func (l *LookoutDb) CreateJobs(ctx *armadacontext.Context, instructions []*model.CreateJobInstruction)

func (*LookoutDb) CreateJobsBatch

func (l *LookoutDb) CreateJobsBatch(ctx *armadacontext.Context, instructions []*model.CreateJobInstruction) error

func (*LookoutDb) CreateJobsScalar

func (l *LookoutDb) CreateJobsScalar(ctx *armadacontext.Context, instructions []*model.CreateJobInstruction)

CreateJobsScalar will insert jobs one by one into the database

func (*LookoutDb) Store

func (l *LookoutDb) Store(ctx *armadacontext.Context, instructions *model.InstructionSet) error

Store updates the lookout database according to the supplied InstructionSet. The updates are applied in the following order: * New Job Creations * Job Updates, New Job Creations, New User Annotations * Job Run Updates In each case we first try to bach insert the rows using the postgres copy protocol. If this fails then we try a slower, serial insert and discard any rows that cannot be inserted.

func (*LookoutDb) UpdateJobRuns

func (l *LookoutDb) UpdateJobRuns(ctx *armadacontext.Context, instructions []*model.UpdateJobRunInstruction)

func (*LookoutDb) UpdateJobRunsBatch

func (l *LookoutDb) UpdateJobRunsBatch(ctx *armadacontext.Context, instructions []*model.UpdateJobRunInstruction) error

func (*LookoutDb) UpdateJobRunsScalar

func (l *LookoutDb) UpdateJobRunsScalar(ctx *armadacontext.Context, instructions []*model.UpdateJobRunInstruction)

func (*LookoutDb) UpdateJobs

func (l *LookoutDb) UpdateJobs(ctx *armadacontext.Context, instructions []*model.UpdateJobInstruction)

func (*LookoutDb) UpdateJobsBatch

func (l *LookoutDb) UpdateJobsBatch(ctx *armadacontext.Context, instructions []*model.UpdateJobInstruction) error

func (*LookoutDb) UpdateJobsScalar

func (l *LookoutDb) UpdateJobsScalar(ctx *armadacontext.Context, instructions []*model.UpdateJobInstruction)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL