| 53 | } |
| 54 | |
| 55 | type BigQueryConnector struct { |
| 56 | *metadataStore.PostgresMetadata |
| 57 | logger log.Logger |
| 58 | bqConfig *protos.BigqueryConfig |
| 59 | credentials *auth.Credentials |
| 60 | client *bigquery.Client |
| 61 | storageClient *storage.Client |
| 62 | catalogPool shared.CatalogPool |
| 63 | datasetID string |
| 64 | projectID string |
| 65 | } |
| 66 | |
| 67 | func NewBigQueryConnector(ctx context.Context, config *protos.BigqueryConfig) (*BigQueryConnector, error) { |
| 68 | logger := internal.LoggerFromCtx(ctx) |
nothing calls this directly
no outgoing calls
no test coverage detected