source

Documentation

Index

• type Server
  • func (s *Server) GenDocs(_ context.Context, req *pb.GenDocs_Request) (*pb.GenDocs_Response, error)
  • func (s *Server) GetDynamicTables(context.Context, *pb.GetDynamicTables_Request) (*pb.GetDynamicTables_Response, error)
  • func (s *Server) GetMetrics(context.Context, *pb.GetMetrics_Request) (*pb.GetMetrics_Response, error)
  • func (s *Server) GetName(context.Context, *pb.GetName_Request) (*pb.GetName_Response, error)
  • func (s *Server) GetTables(context.Context, *pb.GetTables_Request) (*pb.GetTables_Response, error)
  • func (s *Server) GetVersion(context.Context, *pb.GetVersion_Request) (*pb.GetVersion_Response, error)
  • func (s *Server) Init(ctx context.Context, req *pb.Init_Request) (*pb.Init_Response, error)
  • func (s *Server) Sync(_ *pb.Sync_Request, stream pb.Source_SyncServer) error

Types

type Server

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

func (*Server) GenDocs

func (s *Server) GenDocs(_ context.Context, req *pb.GenDocs_Request) (*pb.GenDocs_Response, error)

func (*Server) GetDynamicTables

func (s *Server) GetDynamicTables(context.Context, *pb.GetDynamicTables_Request) (*pb.GetDynamicTables_Response, error)

func (*Server) GetMetrics

func (s *Server) GetMetrics(context.Context, *pb.GetMetrics_Request) (*pb.GetMetrics_Response, error)

func (*Server) GetName

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

func (*Server) GetTables

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

func (*Server) GetVersion

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

func (*Server) Init

func (s *Server) Init(ctx context.Context, req *pb.Init_Request) (*pb.Init_Response, error)

func (*Server) Sync

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