server

Documentation

Index

• Variables
• type QueryApi
  • func New(db *pgxpool.Pool) *QueryApi
  • func (q *QueryApi) GetJobStatus(ctx context.Context, req *queryapi.JobStatusRequest) (*queryapi.JobStatusResponse, error)

Variables

var JobStateMap = map[int16]queryapi.JobStatus{
	lookout.JobLeasedOrdinal:    queryapi.JobStatus_LEASED,
	lookout.JobQueuedOrdinal:    queryapi.JobStatus_QUEUED,
	lookout.JobPendingOrdinal:   queryapi.JobStatus_PENDING,
	lookout.JobRunningOrdinal:   queryapi.JobStatus_RUNNING,
	lookout.JobSucceededOrdinal: queryapi.JobStatus_SUCCEEDED,
	lookout.JobFailedOrdinal:    queryapi.JobStatus_FAILED,
	lookout.JobCancelledOrdinal: queryapi.JobStatus_CANCELLED,
	lookout.JobPreemptedOrdinal: queryapi.JobStatus_PREEMPTED,
}

JobStateMap is a mapping between database state and api states

Types

type QueryApi

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

func New

func New(db *pgxpool.Pool) *QueryApi

func (*QueryApi) GetJobStatus

func (q *QueryApi) GetJobStatus(ctx context.Context, req *queryapi.JobStatusRequest) (*queryapi.JobStatusResponse, error)