Documentation ¶
Index ¶
- type DestinationServer
- 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
- 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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type DestinationServer ¶
type DestinationServer struct { pb.UnimplementedDestinationServer Plugin plugins.DestinationPlugin }
func (*DestinationServer) Configure ¶
func (s *DestinationServer) Configure(ctx context.Context, req *pb.Configure_Request) (*pb.Configure_Response, error)
func (*DestinationServer) GetExampleConfig ¶
func (s *DestinationServer) GetExampleConfig(context.Context, *pb.GetExampleConfig_Request) (*pb.GetExampleConfig_Response, error)
func (*DestinationServer) GetName ¶ added in v0.0.10
func (s *DestinationServer) GetName(context.Context, *pb.GetName_Request) (*pb.GetName_Response, error)
func (*DestinationServer) GetVersion ¶ added in v0.0.10
func (s *DestinationServer) GetVersion(context.Context, *pb.GetVersion_Request) (*pb.GetVersion_Response, error)
func (*DestinationServer) Write ¶ added in v0.0.4
func (s *DestinationServer) Write(msg pb.Destination_WriteServer) error
type SourceServer ¶
type SourceServer struct { pb.UnimplementedSourceServer Plugin *plugins.SourcePlugin }
func (*SourceServer) GetExampleConfig ¶
func (s *SourceServer) GetExampleConfig(context.Context, *pb.GetExampleConfig_Request) (*pb.GetExampleConfig_Response, error)
func (*SourceServer) GetName ¶ added in v0.0.10
func (s *SourceServer) GetName(context.Context, *pb.GetName_Request) (*pb.GetName_Response, error)
func (*SourceServer) GetTables ¶
func (s *SourceServer) GetTables(context.Context, *pb.GetTables_Request) (*pb.GetTables_Response, error)
func (*SourceServer) GetVersion ¶ added in v0.0.10
func (s *SourceServer) GetVersion(context.Context, *pb.GetVersion_Request) (*pb.GetVersion_Response, error)
func (*SourceServer) Sync ¶ added in v0.0.4
func (s *SourceServer) Sync(req *pb.Sync_Request, stream pb.Source_SyncServer) error
Click to show internal directories.
Click to hide internal directories.