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 paging.Acceptor](logger *zap.Logger, stream api_service.Connector_ReadSplitsServer, ...) *Streamer[T]
  • func (s *Streamer[T]) Run() error

Types

type Streamer

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

func NewStreamer

func NewStreamer[T paging.Acceptor](
	logger *zap.Logger,
	stream api_service.Connector_ReadSplitsServer,
	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