queryapi

Documentation

Index

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

Variables

var JobStateMap = map[int16]api.JobStatus{
	lookout.JobLeasedOrdinal:    api.JobStatus_LEASED,
	lookout.JobQueuedOrdinal:    api.JobStatus_QUEUED,
	lookout.JobPendingOrdinal:   api.JobStatus_PENDING,
	lookout.JobRunningOrdinal:   api.JobStatus_RUNNING,
	lookout.JobSucceededOrdinal: api.JobStatus_SUCCEEDED,
	lookout.JobFailedOrdinal:    api.JobStatus_FAILED,
	lookout.JobCancelledOrdinal: api.JobStatus_CANCELLED,
	lookout.JobPreemptedOrdinal: api.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 *api.JobStatusRequest) (*api.JobStatusResponse, error)