lookoutdb

Documentation

Index

• func NewLookoutDb(db *pgxpool.Pool, metrics *metrics.Metrics, ...) ingest.Sink[*model.InstructionSet]
• type LookoutDb
  • func (l *LookoutDb) CreateJobRunContainers(ctx context.Context, instructions []*model.CreateJobRunContainerInstruction)
  • func (l *LookoutDb) CreateJobRunContainersBatch(ctx context.Context, instructions []*model.CreateJobRunContainerInstruction) error
  • func (l *LookoutDb) CreateJobRunContainersScalar(ctx context.Context, instructions []*model.CreateJobRunContainerInstruction)
  • func (l *LookoutDb) CreateJobRuns(ctx context.Context, instructions []*model.CreateJobRunInstruction)
  • func (l *LookoutDb) CreateJobRunsBatch(ctx context.Context, instructions []*model.CreateJobRunInstruction) error
  • func (l *LookoutDb) CreateJobRunsScalar(ctx context.Context, instructions []*model.CreateJobRunInstruction)
  • func (l *LookoutDb) CreateJobs(ctx context.Context, instructions []*model.CreateJobInstruction)
  • func (l *LookoutDb) CreateJobsBatch(ctx context.Context, instructions []*model.CreateJobInstruction) error
  • func (l *LookoutDb) CreateJobsScalar(ctx context.Context, instructions []*model.CreateJobInstruction)
  • func (l *LookoutDb) CreateUserAnnotations(ctx context.Context, instructions []*model.CreateUserAnnotationInstruction)
  • func (l *LookoutDb) CreateUserAnnotationsBatch(ctx context.Context, instructions []*model.CreateUserAnnotationInstruction) error
  • func (l *LookoutDb) CreateUserAnnotationsScalar(ctx context.Context, instructions []*model.CreateUserAnnotationInstruction)
  • func (l *LookoutDb) Store(ctx context.Context, instructions *model.InstructionSet) error
  • func (l *LookoutDb) UpdateJobRuns(ctx context.Context, instructions []*model.UpdateJobRunInstruction)
  • func (l *LookoutDb) UpdateJobRunsBatch(ctx context.Context, instructions []*model.UpdateJobRunInstruction) error
  • func (l *LookoutDb) UpdateJobRunsScalar(ctx context.Context, instructions []*model.UpdateJobRunInstruction)
  • func (l *LookoutDb) UpdateJobs(ctx context.Context, instructions []*model.UpdateJobInstruction)
  • func (l *LookoutDb) UpdateJobsBatch(ctx context.Context, instructions []*model.UpdateJobInstruction) error
  • func (l *LookoutDb) UpdateJobsScalar(ctx context.Context, instructions []*model.UpdateJobInstruction)

Functions

func NewLookoutDb

func NewLookoutDb(
	db *pgxpool.Pool,
	metrics *metrics.Metrics,
	config *configuration.LookoutIngesterConfiguration,
) ingest.Sink[*model.InstructionSet]

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)