source

Documentation

Index

• type Server
  • func (s *Server) GetMetrics(context.Context, *pb.GetSourceMetrics_Request) (*pb.GetSourceMetrics_Response, error)
  • func (s *Server) GetName(context.Context, *pbBase.GetName_Request) (*pbBase.GetName_Response, error)
  • func (*Server) GetProtocolVersion(context.Context, *pbBase.GetProtocolVersion_Request) (*pbBase.GetProtocolVersion_Response, error)
  • func (*Server) GetSyncSummary(context.Context, *pb.GetSyncSummary_Request) (*pb.GetSyncSummary_Response, error)
  • func (s *Server) GetTables(context.Context, *pb.GetTables_Request) (*pb.GetTables_Response, error)
  • func (s *Server) GetTablesForSpec(_ context.Context, req *pb.GetTablesForSpec_Request) (*pb.GetTablesForSpec_Response, error)
  • func (s *Server) GetVersion(context.Context, *pbBase.GetVersion_Request) (*pbBase.GetVersion_Response, error)
  • func (*Server) Sync(*pb.Sync_Request, pb.Source_SyncServer) error
  • func (s *Server) Sync2(req *pb.Sync2_Request, stream pb.Source_Sync2Server) error

Types

type Server

type Server struct {
	pb.UnimplementedSourceServer
	Plugin *source.Plugin
	Logger zerolog.Logger
}

func (*Server) GetMetrics

func (s *Server) GetMetrics(context.Context, *pb.GetSourceMetrics_Request) (*pb.GetSourceMetrics_Response, error)

func (*Server) GetName

func (s *Server) GetName(context.Context, *pbBase.GetName_Request) (*pbBase.GetName_Response, error)

func (*Server) GetProtocolVersion

func (*Server) GetProtocolVersion(context.Context, *pbBase.GetProtocolVersion_Request) (*pbBase.GetProtocolVersion_Response, error)

Deprecated: use GetSupportedProtocolVersions instead

func (*Server) GetSyncSummary

func (*Server) GetSyncSummary(context.Context, *pb.GetSyncSummary_Request) (*pb.GetSyncSummary_Response, error)

func (*Server) GetTables

func (s *Server) GetTables(context.Context, *pb.GetTables_Request) (*pb.GetTables_Response, error)

func (*Server) GetTablesForSpec

func (s *Server) GetTablesForSpec(_ context.Context, req *pb.GetTablesForSpec_Request) (*pb.GetTablesForSpec_Response, error)

func (*Server) GetVersion

func (s *Server) GetVersion(context.Context, *pbBase.GetVersion_Request) (*pbBase.GetVersion_Response, error)

func (*Server) Sync

func (*Server) Sync(*pb.Sync_Request, pb.Source_SyncServer) error

func (*Server) Sync2

func (s *Server) Sync2(req *pb.Sync2_Request, stream pb.Source_Sync2Server) error