repository

Documentation

Index

• Variables
• func NewNullString(s string) sql.NullString
• 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, annotationPrefix string) *SQLJobStore
  • func (r *SQLJobStore) MarkCancelled(event *api.JobCancelledEvent) error
  • func (r *SQLJobStore) RecordJob(job *api.Job) error
  • func (r *SQLJobStore) RecordJobDuplicate(event *api.JobDuplicateFoundEvent) error
  • func (r *SQLJobStore) RecordJobFailed(event *api.JobFailedEvent) error
  • func (r *SQLJobStore) RecordJobPending(event *api.JobPendingEvent) error
  • func (r *SQLJobStore) RecordJobReprioritized(event *api.JobReprioritizedEvent) error
  • func (r *SQLJobStore) RecordJobRunning(event *api.JobRunningEvent) error
  • func (r *SQLJobStore) RecordJobSucceeded(event *api.JobSucceededEvent) error
  • func (r *SQLJobStore) RecordJobTerminated(event *api.JobTerminatedEvent) error
  • func (r *SQLJobStore) RecordJobUnableToSchedule(event *api.JobUnableToScheduleEvent) error

Variables

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

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

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

Functions

func NewNullString

func NewNullString(s string) sql.NullString

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

	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
	RecordJobDuplicate(event *api.JobDuplicateFoundEvent) error
	RecordJobTerminated(event *api.JobTerminatedEvent) error
	RecordJobReprioritized(event *api.JobReprioritizedEvent) 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"
	JobDuplicate JobState = "DUPLICATE"
)

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, annotationPrefix string) *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) RecordJobDuplicate

func (r *SQLJobStore) RecordJobDuplicate(event *api.JobDuplicateFoundEvent) 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) RecordJobReprioritized

func (r *SQLJobStore) RecordJobReprioritized(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) RecordJobTerminated

func (r *SQLJobStore) RecordJobTerminated(event *api.JobTerminatedEvent) error

func (*SQLJobStore) RecordJobUnableToSchedule

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