Versions in this module Expand all Collapse all v0 v0.0.2 Dec 13, 2023 v0.0.1 Dec 11, 2023 Changes in this version + type ColumnarBuffer interface + Release func() + ToResponse func() (*api_service_protos.TReadSplitsResponse, error) + TotalRows func() int + type ColumnarBufferFactory interface + MakeBuffer func() (ColumnarBuffer, error) + func NewColumnarBufferFactory(logger log.Logger, arrowAllocator memory.Allocator, ...) (ColumnarBufferFactory, error) + type ColumnarBufferMock struct + func (m *ColumnarBufferMock) Release() + func (m *ColumnarBufferMock) ToResponse() (*api_service_protos.TReadSplitsResponse, error) + func (m *ColumnarBufferMock) TotalRows() int + type ReadLimiter interface + type ReadLimiterFactory struct + func NewReadLimiterFactory(cfg *config.TServerReadLimit) *ReadLimiterFactory + func (rlf *ReadLimiterFactory) MakeReadLimiter(logger log.Logger) ReadLimiter + type ReadResult struct + ColumnarBuffer ColumnarBuffer + Error error + Stats *api_service_protos.TReadSplitsResponse_TStats + type Sink interface + AddError func(err error) + AddRow func(transformer utils.Transformer) error + Finish func() + ResultQueue func() <-chan *ReadResult + func NewSink(ctx context.Context, logger log.Logger, trafficTracker *TrafficTracker, ...) (Sink, error) + type SinkMock struct + func (m *SinkMock) AddError(err error) + func (m *SinkMock) AddRow(transformer utils.Transformer) error + func (m *SinkMock) Finish() + func (m *SinkMock) ResultQueue() <-chan *ReadResult + type TrafficTracker struct + func NewTrafficTracker(pagination *config.TPagingConfig) *TrafficTracker + func (tt *TrafficTracker) DumpStats(total bool) *api_service_protos.TReadSplitsResponse_TStats