repository

Documentation

Index

• Variables
• func ParseNullBool(nullBool sql.NullBool) bool
• func ParseNullFloat(nullFloat sql.NullFloat64) float64
• func ParseNullInt(nullInt sql.NullInt64) int64
• func ParseNullString(nullString sql.NullString) string
• func ParseNullTime(nullTime pq.NullTime) *time.Time
• func ParseNullTimeDefault(nullTime pq.NullTime) time.Time
• func StartsWith(field exp.IdentifierExpression, pattern string) goqu.Expression
• func ToUTC(t time.Time) time.Time
• type Clock
• type DefaultClock
  • func (c *DefaultClock) Now() time.Time
• type JobRecorder
• type JobRepository
• type JobRow
• type JobState
• type SQLJobRepository
  • func NewSQLJobRepository(db *goqu.Database, clock Clock) *SQLJobRepository
  • func (r *SQLJobRepository) GetJobSetInfos(ctx context.Context, opts *lookout.GetJobSetsRequest) ([]*lookout.JobSetInfo, error)
  • func (r *SQLJobRepository) GetJobs(ctx context.Context, opts *lookout.GetJobsRequest) ([]*lookout.JobInfo, error)
  • func (r *SQLJobRepository) GetQueueInfos(ctx context.Context) ([]*lookout.QueueInfo, error)
• type SQLJobStore
  • func NewSQLJobStore(db *goqu.Database) *SQLJobStore
  • func (r *SQLJobStore) MarkCancelled(event *api.JobCancelledEvent) error
  • func (r *SQLJobStore) RecordJob(job *api.Job) error
  • func (r *SQLJobStore) RecordJobFailed(event *api.JobFailedEvent) error
  • func (r *SQLJobStore) RecordJobPending(event *api.JobPendingEvent) error
  • func (r *SQLJobStore) RecordJobPriorityChange(event *api.JobReprioritizedEvent) error
  • func (r *SQLJobStore) RecordJobRunning(event *api.JobRunningEvent) error
  • func (r *SQLJobStore) RecordJobSucceeded(event *api.JobSucceededEvent) error
  • func (r *SQLJobStore) RecordJobUnableToSchedule(event *api.JobUnableToScheduleEvent) error

Variables

var AllJobStates = []JobState{
	JobQueued,
	JobPending,
	JobRunning,
	JobSucceeded,
	JobFailed,
	JobCancelled,
}

var IntToJobStateMap = map[int]JobState{
	1: JobQueued,
	2: JobPending,
	3: JobRunning,
	4: JobSucceeded,
	5: JobFailed,
	6: JobCancelled,
}

var JobStateToIntMap = map[JobState]int{
	JobQueued:    1,
	JobPending:   2,
	JobRunning:   3,
	JobSucceeded: 4,
	JobFailed:    5,
	JobCancelled: 6,
}

Functions

func ParseNullBool

func ParseNullBool(nullBool sql.NullBool) bool

func ParseNullFloat

func ParseNullFloat(nullFloat sql.NullFloat64) float64

func ParseNullInt

func ParseNullInt(nullInt sql.NullInt64) int64

func ParseNullString

func ParseNullString(nullString sql.NullString) string

func ParseNullTime

func ParseNullTime(nullTime pq.NullTime) *time.Time

func ParseNullTimeDefault

func ParseNullTimeDefault(nullTime pq.NullTime) time.Time

func StartsWith

func StartsWith(field exp.IdentifierExpression, pattern string) goqu.Expression

func ToUTC

func ToUTC(t time.Time) time.Time

Types

type Clock

type Clock interface {
	Now() time.Time
}

type DefaultClock

type DefaultClock struct{}

func (*DefaultClock) Now

func (c *DefaultClock) Now() time.Time

type JobRecorder

type JobRecorder interface {
	RecordJob(job *api.Job) error
	MarkCancelled(*api.JobCancelledEvent) error
	RecordJobPriorityChange(event *api.JobReprioritizedEvent) error

	RecordJobPending(event *api.JobPendingEvent) error
	RecordJobRunning(event *api.JobRunningEvent) error
	RecordJobSucceeded(event *api.JobSucceededEvent) error
	RecordJobFailed(event *api.JobFailedEvent) error
	RecordJobUnableToSchedule(event *api.JobUnableToScheduleEvent) error
}

type JobRepository

type JobRepository interface {
	GetQueueInfos(ctx context.Context) ([]*lookout.QueueInfo, error)
	GetJobSetInfos(ctx context.Context, opts *lookout.GetJobSetsRequest) ([]*lookout.JobSetInfo, error)
	GetJobs(ctx context.Context, opts *lookout.GetJobsRequest) ([]*lookout.JobInfo, error)
}

type JobRow

type JobRow struct {
	JobId     sql.NullString  `db:"job_id"`
	Queue     sql.NullString  `db:"queue"`
	Owner     sql.NullString  `db:"owner"`
	JobSet    sql.NullString  `db:"jobset"`
	Priority  sql.NullFloat64 `db:"priority"`
	Submitted pq.NullTime     `db:"submitted"`
	Cancelled pq.NullTime     `db:"cancelled"`
	JobJson   sql.NullString  `db:"job"`
	State     sql.NullInt64   `db:"state"`
	RunId     sql.NullString  `db:"run_id"`
	PodNumber sql.NullInt64   `db:"pod_number"`
	Cluster   sql.NullString  `db:"cluster"`
	Node      sql.NullString  `db:"node"`
	Created   pq.NullTime     `db:"created"`
	Started   pq.NullTime     `db:"started"`
	Finished  pq.NullTime     `db:"finished"`
	Succeeded sql.NullBool    `db:"succeeded"`
	Error     sql.NullString  `db:"error"`
}

type JobState

type JobState string

Emulates JobStates enum can't use protobuf enums because gogoproto + grpc-gateway is hard with K8s specific messages

const (
	JobQueued    JobState = "QUEUED"
	JobPending   JobState = "PENDING"
	JobRunning   JobState = "RUNNING"
	JobSucceeded JobState = "SUCCEEDED"
	JobFailed    JobState = "FAILED"
	JobCancelled JobState = "CANCELLED"
)

type SQLJobRepository

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

func NewSQLJobRepository

func NewSQLJobRepository(db *goqu.Database, clock Clock) *SQLJobRepository

func (*SQLJobRepository) GetJobSetInfos

func (r *SQLJobRepository) GetJobSetInfos(ctx context.Context, opts *lookout.GetJobSetsRequest) ([]*lookout.JobSetInfo, error)

func (*SQLJobRepository) GetJobs

func (r *SQLJobRepository) GetJobs(ctx context.Context, opts *lookout.GetJobsRequest) ([]*lookout.JobInfo, error)

func (*SQLJobRepository) GetQueueInfos

func (r *SQLJobRepository) GetQueueInfos(ctx context.Context) ([]*lookout.QueueInfo, error)

type SQLJobStore

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

func NewSQLJobStore

func NewSQLJobStore(db *goqu.Database) *SQLJobStore

func (*SQLJobStore) MarkCancelled

func (r *SQLJobStore) MarkCancelled(event *api.JobCancelledEvent) error

func (*SQLJobStore) RecordJob

func (r *SQLJobStore) RecordJob(job *api.Job) error

func (*SQLJobStore) RecordJobFailed

func (r *SQLJobStore) RecordJobFailed(event *api.JobFailedEvent) error

func (*SQLJobStore) RecordJobPending

func (r *SQLJobStore) RecordJobPending(event *api.JobPendingEvent) error

func (*SQLJobStore) RecordJobPriorityChange

func (r *SQLJobStore) RecordJobPriorityChange(event *api.JobReprioritizedEvent) error

func (*SQLJobStore) RecordJobRunning

func (r *SQLJobStore) RecordJobRunning(event *api.JobRunningEvent) error

func (*SQLJobStore) RecordJobSucceeded

func (r *SQLJobStore) RecordJobSucceeded(event *api.JobSucceededEvent) error

func (*SQLJobStore) RecordJobUnableToSchedule

func (r *SQLJobStore) RecordJobUnableToSchedule(event *api.JobUnableToScheduleEvent) error