postgres

Documentation

Index

• func Migrate(db *sql.DB) error
• type JobStore
  • func NewJobStore(db *sql.DB) (*JobStore, error)
  • func (s *JobStore) Find(ctx context.Context, filter []*v1.FilterExpression, ...) (slice []v1.JobStatus, total int, err error)
  • func (s *JobStore) GarbageCollect(olderThan time.Duration) error
  • func (s *JobStore) Get(ctx context.Context, name string) (*v1.JobStatus, error)
  • func (s *JobStore) GetJobSpec(name string) (*v1.JobSpec, []byte, error)
  • func (s *JobStore) RegisterPrometheusMetrics(reg prometheus.Registerer)
  • func (s *JobStore) Store(ctx context.Context, job v1.JobStatus) error
  • func (s *JobStore) StoreJobSpec(name string, spec v1.JobSpec, data []byte) error
• type NumberGroup
  • func NewNumberGroup(db *sql.DB) (*NumberGroup, error)
  • func (ngrp *NumberGroup) Latest(group string) (nr int, err error)
  • func (ngrp *NumberGroup) Next(group string) (nr int, err error)

Functions

func Migrate

func Migrate(db *sql.DB) error

Migrate ensures that the database has the current schema required for using any of the postgres storage

Types

type JobStore

type JobStore struct {
	DB *sql.DB
	// contains filtered or unexported fields
}

JobStore stores jobs in a Postgres database

func NewJobStore

func NewJobStore(db *sql.DB) (*JobStore, error)

NewJobStore creates a new SQL job store

func (*JobStore) Find

func (s *JobStore) Find(ctx context.Context, filter []*v1.FilterExpression, order []*v1.OrderExpression, start, limit int) (slice []v1.JobStatus, total int, err error)

Find searches for jobs based on their annotations. If filter is empty no filter is applied.

func (*JobStore) GarbageCollect

func (s *JobStore) GarbageCollect(olderThan time.Duration) error

GarbageCollect removes all job entries older than the specified duration

func (*JobStore) Get

func (s *JobStore) Get(ctx context.Context, name string) (*v1.JobStatus, error)

Get retrieves a particular job bassd on its name.

func (*JobStore) GetJobSpec

func (s *JobStore) GetJobSpec(name string) (*v1.JobSpec, []byte, error)

GetJobSpec retrieves a particular job bassd on its name.

func (*JobStore) RegisterPrometheusMetrics

func (s *JobStore) RegisterPrometheusMetrics(reg prometheus.Registerer)

RegisterPrometheusMetrics registers metrics on the registerer with MustRegister

func (*JobStore) Store

func (s *JobStore) Store(ctx context.Context, job v1.JobStatus) error

Store stores job information in the store.

func (*JobStore) StoreJobSpec

func (s *JobStore) StoreJobSpec(name string, spec v1.JobSpec, data []byte) error

StoreJobSpec stores job information in the store.

type NumberGroup

type NumberGroup struct {
	DB *sql.DB
}

NumberGroup provides postgres backed number groups

func NewNumberGroup

func NewNumberGroup(db *sql.DB) (*NumberGroup, error)

NewNumberGroup creates a new SQL number group store

func (*NumberGroup) Latest

func (ngrp *NumberGroup) Latest(group string) (nr int, err error)

Latest returns the latest number of a particular number group.

func (*NumberGroup) Next

func (ngrp *NumberGroup) Next(group string) (nr int, err error)

Next returns the next number in the group.