The highest tagged major version is v4.

servers

package

v0.7.0 Latest Latest Go to latest Published: Sep 19, 2022 License: MPL-2.0 Imports: 11 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(context.Context, *pb.GetExampleConfig_Request) (*pb.GetExampleConfig_Response, error)

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

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

func (s *DestinationServer) Write(msg pb.Destination_WriteServer) error

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

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

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

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

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

func (s *SourceServer) Sync(req *pb.Sync_Request, stream pb.Source_SyncServer) error