bqclient

type BQClient interface {
	Put(ctx context.Context, table string, data any) error
	StreamRead(ctx context.Context, table string, projectIDs []string) (<-chan []byte, <-chan error)
	StreamPut(ctx context.Context, table string, data any) error
	StreamPutAll(ctx context.Context, inputs map[string][]any) error
	Query(ctx context.Context, query string, params []bigquery.QueryParameter) (*bigquery.RowIterator, error)
	QueryRow(ctx context.Context, query string, params []bigquery.QueryParameter, dst any) error
	Update(ctx context.Context, table string, id string, updates map[string]interface{}) error
	Delete(ctx context.Context, table string, id string) error
	Get(ctx context.Context, table string, id string, dst any) error
	Close() error
}

type Config struct {
	ProjectID string `koanf:"project_id" json:"project_id" envconfig:"project_id"`
	DatasetID string `koanf:"dataset_id" json:"dataset_id" envconfig:"dataset_id"`
	CredsPath string `koanf:"creds_path" json:"creds_path" envconfig:"creds_path"`
}