source

Documentation

Index

• type Server
  • 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

Types

type Server

type Server struct {
	pb.UnimplementedSourceServiceServer

	RecordCh chan sdk.Record
	// contains filtered or unexported fields
}

func NewServer

func NewServer(ctx context.Context) *Server

func (*Server) Close

func (s *Server) Close()

func (*Server) SendAck

func (s *Server) SendAck(position sdk.Position) error

func (*Server) Stream

func (s *Server) Stream(stream pb.SourceService_StreamServer) error