lookoutdb

package
v0.3.70-rc-db828c9 Latest Latest
Warning

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

Go to latest
Published: Jun 1, 2023 License: Apache-2.0 Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

Types

type LookoutDb

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

func (*LookoutDb) CreateJobRunContainers

func (l *LookoutDb) CreateJobRunContainers(ctx context.Context, instructions []*model.CreateJobRunContainerInstruction)

func (*LookoutDb) CreateJobRunContainersBatch

func (l *LookoutDb) CreateJobRunContainersBatch(ctx context.Context, instructions []*model.CreateJobRunContainerInstruction) error

func (*LookoutDb) CreateJobRunContainersScalar

func (l *LookoutDb) CreateJobRunContainersScalar(ctx context.Context, instructions []*model.CreateJobRunContainerInstruction)

func (*LookoutDb) CreateJobRuns

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

func (*LookoutDb) CreateJobRunsBatch

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

func (*LookoutDb) CreateJobRunsScalar

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

func (*LookoutDb) CreateJobs

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

func (*LookoutDb) CreateJobsBatch

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

func (*LookoutDb) CreateJobsScalar

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

CreateJobsScalar will insert jobs one by one into the database

func (*LookoutDb) CreateUserAnnotations

func (l *LookoutDb) CreateUserAnnotations(ctx context.Context, instructions []*model.CreateUserAnnotationInstruction)

func (*LookoutDb) CreateUserAnnotationsBatch

func (l *LookoutDb) CreateUserAnnotationsBatch(ctx context.Context, instructions []*model.CreateUserAnnotationInstruction) error

func (*LookoutDb) CreateUserAnnotationsScalar

func (l *LookoutDb) CreateUserAnnotationsScalar(ctx context.Context, instructions []*model.CreateUserAnnotationInstruction)

func (*LookoutDb) Store

func (l *LookoutDb) Store(ctx context.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, New Job Containers 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 context.Context, instructions []*model.UpdateJobRunInstruction)

func (*LookoutDb) UpdateJobRunsBatch

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

func (*LookoutDb) UpdateJobRunsScalar

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

func (*LookoutDb) UpdateJobs

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

func (*LookoutDb) UpdateJobsBatch

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

func (*LookoutDb) UpdateJobsScalar

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

Jump to

Keyboard shortcuts

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