Documentation
¶
Overview ¶
Package streaming contains the logic of converting the data stream coming from the data source into the data stream sent over the network to the client.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Streamer ¶
type Streamer struct {
// contains filtered or unexported fields
}
func NewStreamer ¶
func NewStreamer( logger log.Logger, stream api_service.Connector_ReadSplitsServer, request *api_service_protos.TReadSplitsRequest, split *api_service_protos.TSplit, sink paging.Sink, dataSource data_source.DataSource, ) *Streamer
Click to show internal directories.
Click to hide internal directories.