The highest tagged major version is v4.

servers

package

v0.0.2 Latest Latest Go to latest Published: Aug 9, 2022 License: MPL-2.0 Imports: 12 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type DestinationServer struct {
	pb.UnimplementedDestinationServer
	Plugin plugins.DestinationPlugin
}

func (s *DestinationServer) Configure(ctx context.Context, req *pb.Configure_Request) (*pb.Configure_Response, error)

func (s *DestinationServer) GetExampleConfig(ctx context.Context, req *pb.GetExampleConfig_Request) (*pb.GetExampleConfig_Response, error)

func (s *DestinationServer) Save(msg pb.Destination_SaveServer) error

type SourceServer struct {
	pb.UnimplementedSourceServer
	Plugin *plugins.SourcePlugin
}

func (s *SourceServer) Configure(ctx context.Context, req *pb.Configure_Request) (*pb.Configure_Response, error)

func (s *SourceServer) Fetch(req *pb.Fetch_Request, stream pb.Source_FetchServer) error

func (s *SourceServer) GetExampleConfig(context.Context, *pb.GetExampleConfig_Request) (*pb.GetExampleConfig_Response, error)

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