repository

package
v0.1.23 Latest Latest
Warning

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

 Go to latest Published: Feb 11, 2021 License: Apache-2.0 Imports: 16 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var AllJobStates = []JobState{
	JobQueued,
	JobPending,
	JobRunning,
	JobSucceeded,
	JobFailed,
	JobCancelled,
}
View Source 
var FiltersForState = map[JobState][]goqu.Expression{
	JobQueued: {
		job_submitted.IsNotNull(),
		job_cancelled.IsNull(),
		jobRun_created.IsNull(),
		jobRun_started.IsNull(),
		jobRun_finished.IsNull(),
		jobRun_unableToSchedule.IsNull(),
	},
	JobPending: {
		job_cancelled.IsNull(),
		jobRun_created.IsNotNull(),
		jobRun_started.IsNull(),
		jobRun_finished.IsNull(),
		jobRun_unableToSchedule.IsNull(),
	},
	JobRunning: {
		job_cancelled.IsNull(),
		jobRun_started.IsNotNull(),
		jobRun_finished.IsNull(),
		jobRun_unableToSchedule.IsNull(),
	},
	JobSucceeded: {
		job_cancelled.IsNull(),
		jobRun_finished.IsNotNull(),
		jobRun_succeeded.IsTrue(),
		jobRun_unableToSchedule.IsNull(),
	},
	JobFailed: {
		jobRun_succeeded.IsFalse(),
	},
	JobCancelled: {
		job_cancelled.IsNotNull(),
	},
}

Functions

func ParseNullBool added in v0.1.17 

func ParseNullBool(nullBool sql.NullBool) bool

func ParseNullFloat added in v0.1.17 

func ParseNullFloat(nullFloat sql.NullFloat64) float64

func ParseNullInt added in v0.1.21 

func ParseNullInt(nullInt sql.NullInt64) int64

func ParseNullString added in v0.1.17 

func ParseNullString(nullString sql.NullString) string

func ParseNullTime added in v0.1.17 

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

func ParseNullTimeDefault added in v0.1.17 

func ParseNullTimeDefault(nullTime pq.NullTime) time.Time

Types

type Clock added in v0.1.21 

type Clock interface {
	Now() time.Time
}

type DefaultClock added in v0.1.21 

type DefaultClock struct{}

func (*DefaultClock) Now added in v0.1.21 

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 added in v0.1.21 

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"`
	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 added in v0.1.23 

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 added in v0.1.21 

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

func (*SQLJobRepository) GetJobs added in v0.1.23 

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

func (*SQLJobRepository) GetQueueInfos added in v0.1.21 

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 added in v0.1.23 

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

Source Files

View all Source files

Directories

Path Synopsis
statik

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.