bq

package
v0.1.2 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 31, 2024 License: Apache-2.0 Imports: 19 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Client 

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

func New 

func New(ctx context.Context, projectID types.GoogleProjectID) (*Client, error)

func (*Client) CreateTable 

func (x *Client) CreateTable(ctx context.Context, dataset types.BQDatasetID, table types.BQTableID, md *bigquery.TableMetadata) error

CreateTable implements interfaces.BigQuery.

func (*Client) GetMetadata 

func (x *Client) GetMetadata(ctx context.Context, dataset types.BQDatasetID, table types.BQTableID) (*bigquery.TableMetadata, error)

GetMetadata implements interfaces.BigQuery. If the table does not exist, it returns nil.

func (*Client) Insert 

func (x *Client) Insert(ctx context.Context, datasetID types.BQDatasetID, tableID types.BQTableID, schema bigquery.Schema, data []any) error

func (*Client) NewStream added in v0.1.2 

func (x *Client) NewStream(ctx context.Context, datasetID types.BQDatasetID, tableID types.BQTableID, schema bigquery.Schema) (interfaces.BigQueryStream, error)

func (*Client) Query 

func (x *Client) Query(ctx context.Context, query string) (interfaces.BigQueryIterator, error)

Query implements interfaces.BigQuery.

func (*Client) UpdateTable 

func (x *Client) UpdateTable(ctx context.Context, dataset types.BQDatasetID, table types.BQTableID, md bigquery.TableMetadataToUpdate, eTag string) error

UpdateSchema implements interfaces.BigQuery.

type GeneralMock added in v0.1.2 

type GeneralMock struct {
	Metadata []*bigquery.TableMetadata

	OpenedStream []struct {
		Dataset types.BQDatasetID
		Table   types.BQTableID
		Schema  bigquery.Schema
	}
	Streams []*MockStream

	CreatedTable []struct {
		Dataset types.BQDatasetID
		Table   types.BQTableID
		MD      *bigquery.TableMetadata
	}
	UpdatedTable []struct {
		Dataset types.BQDatasetID
		Table   types.BQTableID
		MD      bigquery.TableMetadataToUpdate
		ETag    string
	}

	Queries []string
	// contains filtered or unexported fields
}

func NewGeneralMock 

func NewGeneralMock() *GeneralMock

func (*GeneralMock) CreateTable added in v0.1.2 

func (x *GeneralMock) CreateTable(ctx context.Context, dataset types.BQDatasetID, table types.BQTableID, md *bigquery.TableMetadata) error

CreateTable implements interfaces.BigQuery.

func (*GeneralMock) GetMetadata added in v0.1.2 

func (x *GeneralMock) GetMetadata(ctx context.Context, dataset types.BQDatasetID, table types.BQTableID) (*bigquery.TableMetadata, error)

GetMetadata implements interfaces.BigQuery.

func (*GeneralMock) NewStream added in v0.1.2 

func (x *GeneralMock) NewStream(ctx context.Context, datasetID types.BQDatasetID, tableID types.BQTableID, schema bigquery.Schema) (interfaces.BigQueryStream, error)

func (*GeneralMock) Query added in v0.1.2 

func (x *GeneralMock) Query(ctx context.Context, query string) (interfaces.BigQueryIterator, error)

Query implements interfaces.BigQuery.

func (*GeneralMock) UpdateTable added in v0.1.2 

func (x *GeneralMock) UpdateTable(ctx context.Context, dataset types.BQDatasetID, table types.BQTableID, md bigquery.TableMetadataToUpdate, eTag string) error

UpdateTable implements interfaces.BigQuery.

type Mock 

type Mock struct {
	MockQuery       func(ctx context.Context, query string) (interfaces.BigQueryIterator, error)
	MockInsert      (func(ctx context.Context, datasetID types.BQDatasetID, tableID types.BQTableID, data []any) error)
	MockGetMetadata (func(ctx context.Context, datasetID types.BQDatasetID, tableID types.BQTableID) (*bigquery.TableMetadata, error))
	MockUpdateTable (func(ctx context.Context, datasetID types.BQDatasetID, tableID types.BQTableID, md bigquery.TableMetadataToUpdate, eTag string) error)
	MockCreateTable (func(ctx context.Context, dataset types.BQDatasetID, table types.BQTableID, md *bigquery.TableMetadata) error)
}

func NewMock 

func NewMock() *Mock

func (*Mock) CreateTable 

func (x *Mock) CreateTable(ctx context.Context, dataset types.BQDatasetID, table types.BQTableID, md *bigquery.TableMetadata) error

CreateTable implements interfaces.BigQuery.

func (*Mock) GetMetadata 

func (x *Mock) GetMetadata(ctx context.Context, datasetID types.BQDatasetID, tableID types.BQTableID) (*bigquery.TableMetadata, error)

func (*Mock) Insert 

func (x *Mock) Insert(ctx context.Context, datasetID types.BQDatasetID, tableID types.BQTableID, schema bigquery.Schema, data []any) error

func (*Mock) NewStream added in v0.1.2 

func (x *Mock) NewStream(ctx context.Context, datasetID types.BQDatasetID, tableID types.BQTableID, schema bigquery.Schema) (interfaces.BigQueryStream, error)

func (*Mock) Query 

func (x *Mock) Query(ctx context.Context, query string) (interfaces.BigQueryIterator, error)

func (*Mock) UpdateTable 

func (x *Mock) UpdateTable(ctx context.Context, datasetID types.BQDatasetID, tableID types.BQTableID, md bigquery.TableMetadataToUpdate, eTag string) error

type MockInsertedData added in v0.1.0 

type MockInsertedData struct {
	DatasetID types.BQDatasetID
	TableID   types.BQTableID
	Schema    bigquery.Schema
	Data      []any
}

type MockStream added in v0.1.2 

type MockStream struct {
	Inserted [][]any
	// contains filtered or unexported fields
}

func (*MockStream) Close added in v0.1.2 

func (x *MockStream) Close() error

func (*MockStream) Insert added in v0.1.2 

func (x *MockStream) Insert(ctx context.Context, data []any) error

type Stream added in v0.1.2 

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

func (*Stream) Close added in v0.1.2 

func (x *Stream) Close() error

func (*Stream) Insert added in v0.1.2 

func (x *Stream) Insert(ctx context.Context, data []any) error

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.