Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type BigQueryPuller ¶
type BigQueryPuller struct {
Ctx context.Context
Client *bigquery.Client
GcpProject string
DatasetName string
}
BigQueryPuller BigQueryPuller
func (*BigQueryPuller) Pull ¶
func (p *BigQueryPuller) Pull(query string, params *[]bigquery.QueryParameter) *[][]bigquery.Value
Pull Pull
func (*BigQueryPuller) SetClient ¶
func (p *BigQueryPuller) SetClient(clt *bigquery.Client)
SetClient SetClient
func (*BigQueryPuller) SetContext ¶
func (p *BigQueryPuller) SetContext(ctx context.Context)
SetContext SetContext
type MockPuller ¶
type MockPuller struct {
Ctx context.Context
Client *bigquery.Client
GcpProject string
DatasetName string
MockResp [][]bigquery.Value
}
MockPuller MockPuller
func (*MockPuller) Pull ¶
func (p *MockPuller) Pull(query string, params *[]bigquery.QueryParameter) *[][]bigquery.Value
Pull Pull
func (*MockPuller) SetClient ¶
func (p *MockPuller) SetClient(clt *bigquery.Client)
SetClient SetClient
func (*MockPuller) SetContext ¶
func (p *MockPuller) SetContext(ctx context.Context)
SetContext SetContext
Click to show internal directories.
Click to hide internal directories.