Versions in this module Expand all Collapse all v0 v0.1.0 Jul 14, 2023 Changes in this version + type Server struct + RecordCh chan sdk.Record + func NewServer(ctx context.Context) *Server + func (s *Server) Close() + func (s *Server) SendAck(position sdk.Position) error + func (s *Server) Stream(stream pb.SourceService_StreamServer) error
Go to main page