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

Types

type ListSplitsStreamer

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

func NewListSplitsStreamer

func NewListSplitsStreamer[T paging.Acceptor](
	logger *zap.Logger,
	stream api_service.Connector_ListSplitsServer,
	dataSource datasource.DataSource[T],
	request *api_service_protos.TListSplitsRequest,
	slct *api_service_protos.TSelect,
) *ListSplitsStreamer[T]

func (*ListSplitsStreamer[T]) Run

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

type ReadSplitsStreamer

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

func NewReadSplitsStreamer

func NewReadSplitsStreamer[T paging.Acceptor](
	logger *zap.Logger,
	stream api_service.Connector_ReadSplitsServer,
	request *api_service_protos.TReadSplitsRequest,
	split *api_service_protos.TSplit,
	sinkFactory paging.SinkFactory[T],
	dataSource datasource.DataSource[T],
) *ReadSplitsStreamer[T]

func (*ReadSplitsStreamer[T]) Run

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