Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type BigQueryRecordIterator ¶
type BigQueryRecordIterator struct {
// contains filtered or unexported fields
}
func NewBigQueryRecordIterator ¶
func NewBigQueryRecordIterator(bi *bigquery.RowIterator) *BigQueryRecordIterator
func (*BigQueryRecordIterator) Next ¶
func (ri *BigQueryRecordIterator) Next() (bool, error)
func (*BigQueryRecordIterator) Value ¶
func (ri *BigQueryRecordIterator) Value() Record
type BigQueryStorage ¶
type BigQueryStorage struct {
// contains filtered or unexported fields
}
func NewBigQueryStorage ¶
func NewBigQueryStorage( bqClient *bigquery.Client, datasetName string, tableName string, ) *BigQueryStorage
func (*BigQueryStorage) Close ¶
func (b *BigQueryStorage) Close() error
func (*BigQueryStorage) GetAllRecords ¶
func (b *BigQueryStorage) GetAllRecords(ctx context.Context) (RecordIterator, error)
type InMemIterator ¶
type InMemIterator struct {
// contains filtered or unexported fields
}
func NewInMemIterator ¶
func NewInMemIterator(records []Record) *InMemIterator
func (*InMemIterator) Next ¶
func (imi *InMemIterator) Next() (bool, error)
func (*InMemIterator) Value ¶
func (imi *InMemIterator) Value() Record
type InMemStorage ¶
type InMemStorage struct {
// contains filtered or unexported fields
}
func NewInMemStorage ¶
func NewInMemStorage() *InMemStorage
func (*InMemStorage) Close ¶
func (*InMemStorage) Close() error
func (*InMemStorage) GetAllRecords ¶
func (ims *InMemStorage) GetAllRecords(ctx context.Context) (RecordIterator, error)
type RecordIterator ¶
Click to show internal directories.
Click to hide internal directories.