bigquery

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

type Uploader interface {
	// bufferFor returns a buffer of exactly size bytes.
	BufferFor(size int) []byte

	// add is called to note that the buffer returned by bufferFor was used and
	// is full of useful data,
	Add(buf []byte)

	Flush()

	// TryFlush attempts to flush the buffer to the table writer. It will not spill to disk.
	TryFlush()
}

type UploaderFactory func(ctx context.Context, desc *protocol.ConnectionDescriptor) (Uploader, error)