bq

Documentation

Index

• type BQ
  • func NewBQ(ctx context.Context, projectID string, dataset string, tablePrefix string, ...) (*BQ, error)
  • func (bq *BQ) Close() error
  • func (bq *BQ) CreateTableIfNotExists(ctx context.Context) error
  • func (bq *BQ) InsertRecord(ctx context.Context, record *Record) error
• type Cursor
• type Record

Types

type BQ

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

func NewBQ

func NewBQ(
	ctx context.Context,
	projectID string,
	dataset string,
	tablePrefix string,
	logger *slog.Logger,
) (*BQ, error)

func (*BQ) Close

func (bq *BQ) Close() error

func (*BQ) CreateTableIfNotExists

func (bq *BQ) CreateTableIfNotExists(ctx context.Context) error

func (*BQ) InsertRecord

func (bq *BQ) InsertRecord(ctx context.Context, record *Record) error

type Cursor

type Cursor struct {
	gorm.Model
	LastSeq int64
}

type Record

type Record struct {
	CreatedAt time.Time `bigquery:"created_at"`

	FirehoseSeq int64             `bigquery:"firehose_seq"`
	Repo        string            `bigquery:"repo"`
	Collection  string            `bigquery:"collection"`
	RKey        string            `bigquery:"r_key"`
	Action      string            `bigquery:"action"`
	Raw         bigquery.NullJSON `bigquery:"raw"`

	Error string `bigquery:"error"`
}