bigquery

package

v1.36.1 Latest Latest Go to latest Published: Feb 25, 2026 License: MIT Imports: 3 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type BufferedWrite struct {
	sync.RWMutex
	Rows []Row
	// contains filtered or unexported fields
}

func NewBufferedWrite(c int) *BufferedWrite

func (b *BufferedWrite) Append(r Row) error

func (b *BufferedWrite) Capacity() int

func (b *BufferedWrite) Flush() []Row

func (b *BufferedWrite) IsFull() bool

func (b *BufferedWrite) Length() int

func (b *BufferedWrite) Reset()

type Client struct {
	// Service *bigquery.Service
	Context context.Context
}

func NewClient(c context.Context) (*Client, error)

func (c *Client) InsertNewTable(projectID, datasetID, tableName string, fields Fields) error

InsertNewTable creates a new empty table for the given project and dataset with the field name/types defined in the fields map

func (c *Client) InsertRows(projectID string, datasetID string, tableID string, rowsData []Row) error

type Fields map[string]string

type Row map[string]interface{}