Documentation
¶
Index ¶
- func NewGeneralMock() *generalMock
- type Client
- func (x *Client) CreateTable(ctx context.Context, dataset types.BQDatasetID, table types.BQTableID, ...) error
- func (x *Client) GetMetadata(ctx context.Context, dataset types.BQDatasetID, table types.BQTableID) (*bigquery.TableMetadata, error)
- func (x *Client) Insert(ctx context.Context, datasetID types.BQDatasetID, tableID types.BQTableID, ...) error
- func (x *Client) Query(ctx context.Context, query string) (interfaces.BigQueryIterator, error)
- func (x *Client) UpdateTable(ctx context.Context, dataset types.BQDatasetID, table types.BQTableID, ...) error
- type Mock
- func (x *Mock) CreateTable(ctx context.Context, dataset types.BQDatasetID, table types.BQTableID, ...) error
- func (x *Mock) GetMetadata(ctx context.Context, datasetID types.BQDatasetID, tableID types.BQTableID) (*bigquery.TableMetadata, error)
- func (x *Mock) Insert(ctx context.Context, datasetID types.BQDatasetID, tableID types.BQTableID, ...) error
- func (x *Mock) Query(ctx context.Context, query string) (interfaces.BigQueryIterator, error)
- func (x *Mock) UpdateTable(ctx context.Context, datasetID types.BQDatasetID, tableID types.BQTableID, ...) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewGeneralMock ¶
func NewGeneralMock() *generalMock
Types ¶
type Client ¶
type Client struct {
// contains filtered or unexported fields
}
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) 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 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 (*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) Query ¶
func (x *Mock) Query(ctx context.Context, query string) (interfaces.BigQueryIterator, error)
func (*Mock) UpdateTable ¶
Click to show internal directories.
Click to hide internal directories.