teeth

Jan 16, 2024

Changes in this version

+ func SaveInvocationCommentStatus(ctx context.Context, bqClient BigQueryClient, ...) error

type BQConfig

+ DatasetID string

+ ProjectID string

+ type BigQuery struct

+ func NewBigQuery(ctx context.Context, config *BQConfig) (*BigQuery, error)

+ func (bq *BigQuery) Close() error

+ func (bq *BigQuery) Insert(ctx context.Context, statuses []*InvocationCommentStatusRecord) error

+ func (bq *BigQuery) QueryLatest(ctx context.Context) ([]*PublisherSourceRecord, error)

type BigQueryClient

+ Insert func(context.Context, []*InvocationCommentStatusRecord) error

+ QueryLatest func(context.Context) ([]*PublisherSourceRecord, error)

type PublisherSourceRecord

+ func GetLatestSourceRecords(ctx context.Context, bqClient BigQueryClient) ([]*PublisherSourceRecord, error)

Dec 5, 2023

Changes in this version

+ var PublisherSourceQuery string

+ func SetUpPublisherSourceQuery(ctx context.Context, bqClient BigQueryClient) (*bigquery.Query, error)

+ type BQConfig struct

+ EventsTable string

+ InvocationCommentStatusTable string

+ LeechStatusTable string

+ PullRequestEventsTable string

+ type BigQueryClient interface

+ Config func() *BQConfig

+ Query func(string) *bigquery.Query

+ type InvocationCommentStatusRecord struct

+ CommentID bigquery.NullInt64

+ JobName string

+ ProcessedAt time.Time

+ PullRequestID int

+ PullRequestURL string

+ Status string

+ type PublisherSourceRecord struct

+ DeliveryID string

+ HeadSHA string

+ LogsURI string

+ PullRequestID int

+ PullRequestURL string

+ Received time.Time