streaming

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

• type Streamer
  • func NewStreamer[T utils.Acceptor](logger log.Logger, stream api_service.Connector_ReadSplitsServer, ...) *Streamer[T]
  • func (s *Streamer[T]) Run() error

Types

type Streamer

type Streamer[T utils.Acceptor] struct {
	// contains filtered or unexported fields
}

func NewStreamer

func NewStreamer[T utils.Acceptor](
	logger log.Logger,
	stream api_service.Connector_ReadSplitsServer,
	request *api_service_protos.TReadSplitsRequest,
	split *api_service_protos.TSplit,
	sink paging.Sink[T],
	dataSource datasource.DataSource[T],
) *Streamer[T]

func (*Streamer[T]) Run

func (s *Streamer[T]) Run() error