queryapi

package
v0.4.27 Latest Latest
Warning

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

Go to latest
Published: Mar 1, 2024 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

JobRunStateMap is a mapping between database state and api Job Run states

JobStateMap is a mapping between database state and api Job states

Functions

func DbTimeToGoTime added in v0.4.24

func DbTimeToGoTime(t pgtype.Timestamp) *time.Time

func NilStringToString added in v0.4.24

func NilStringToString(s *string) string

Types

type QueryApi

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

func New

func New(db *pgxpool.Pool, maxQueryItems int, decompressorFactory func() compress.Decompressor) *QueryApi

func (*QueryApi) GetJobDetails added in v0.4.24

func (q *QueryApi) GetJobDetails(ctx context.Context, req *api.JobDetailsRequest) (*api.JobDetailsResponse, error)

func (*QueryApi) GetJobRunDetails added in v0.4.24

func (q *QueryApi) GetJobRunDetails(ctx context.Context, req *api.JobRunDetailsRequest) (*api.JobRunDetailsResponse, error)

func (*QueryApi) GetJobStatus

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

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL