Documentation
¶
Index ¶
- Constants
- type GoogleBigQuery
- func (d *GoogleBigQuery) Asset(ctx context.Context, asset *v2.AssetRef) (string, io.ReadCloser, error)
- func (d *GoogleBigQuery) Metadata(ctx context.Context) (*v2.ConnectorMetadata, error)
- func (d *GoogleBigQuery) ResourceSyncers(ctx context.Context) []connectorbuilder.ResourceSyncer
- func (d *GoogleBigQuery) Validate(ctx context.Context) (annotations.Annotations, error)
Constants ¶
View Source
const (
NF = -1
)
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type GoogleBigQuery ¶
type GoogleBigQuery struct {
ProjectsClient *resourcemanager.ProjectsClient
BigQueryClient *bigquery.Client
}
func New ¶
func New(ctx context.Context, credentialsJSONFilePath string) (*GoogleBigQuery, error)
New returns a new instance of the connector.
func NewFromJSONBytes ¶ added in v0.0.2
func NewFromJSONBytes(ctx context.Context, credentialsJSON []byte) (*GoogleBigQuery, error)
func (*GoogleBigQuery) Asset ¶
func (d *GoogleBigQuery) Asset(ctx context.Context, asset *v2.AssetRef) (string, io.ReadCloser, error)
Asset takes an input AssetRef and attempts to fetch it using the connector's authenticated http client It streams a response, always starting with a metadata object, following by chunked payloads for the asset.
func (*GoogleBigQuery) Metadata ¶
func (d *GoogleBigQuery) Metadata(ctx context.Context) (*v2.ConnectorMetadata, error)
Metadata returns metadata about the connector.
func (*GoogleBigQuery) ResourceSyncers ¶
func (d *GoogleBigQuery) ResourceSyncers(ctx context.Context) []connectorbuilder.ResourceSyncer
ResourceSyncers returns a ResourceSyncer for each resource type that should be synced from the upstream service.
func (*GoogleBigQuery) Validate ¶
func (d *GoogleBigQuery) Validate(ctx context.Context) (annotations.Annotations, error)
Validate is called to ensure that the connector is properly configured. It should exercise any API credentials to be sure that they are valid.
Source Files
Click to show internal directories.
Click to hide internal directories.