bigquery

type Config struct {
	ProjectID                    string
	CredentialsJSON              string
	CredentialsEnvVars           []string
	Sources                      []SourceConfig
	BilledBytesWarningThreshold  int64
	BilledBytesCriticalThreshold int64
	Logger                       *slog.Logger
}

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

type Option func(*handler)

type RowEmitter func(datasourcearrow.Row) error

type RowReader interface {
	ReadRows(ctx context.Context, query string, emit RowEmitter) error
}

type RowReaderFunc func(ctx context.Context, query string, emit RowEmitter) error

type SourceConfig struct {
	SourceID  string
	ProjectID string
	DatasetID string
	Tables    []datasource.TableConfig
}