servers

Documentation

Index

• type DestinationServer
  • func (s *DestinationServer) Close(ctx context.Context, _ *pb.Close_Request) (*pb.Close_Response, error)
  • func (s *DestinationServer) Configure(ctx context.Context, req *pb.Configure_Request) (*pb.Configure_Response, error)
  • func (s *DestinationServer) DeleteStale(ctx context.Context, req *pb.DeleteStale_Request) (*pb.DeleteStale_Response, error)
  • func (s *DestinationServer) GetMetrics(context.Context, *pb.GetDestinationMetrics_Request) (*pb.GetDestinationMetrics_Response, error)
  • func (s *DestinationServer) GetName(context.Context, *pb.GetName_Request) (*pb.GetName_Response, error)
  • func (*DestinationServer) GetProtocolVersion(context.Context, *pb.GetProtocolVersion_Request) (*pb.GetProtocolVersion_Response, error)
  • func (s *DestinationServer) GetVersion(context.Context, *pb.GetVersion_Request) (*pb.GetVersion_Response, error)
  • func (s *DestinationServer) Migrate(ctx context.Context, req *pb.Migrate_Request) (*pb.Migrate_Response, error)
  • func (*DestinationServer) Write(pb.Destination_WriteServer) error
  • func (s *DestinationServer) Write2(msg pb.Destination_Write2Server) error
• type SourceServer
  • func (s *SourceServer) GetMetrics(context.Context, *pb.GetSourceMetrics_Request) (*pb.GetSourceMetrics_Response, error)
  • func (s *SourceServer) GetName(context.Context, *pb.GetName_Request) (*pb.GetName_Response, error)
  • func (*SourceServer) GetProtocolVersion(context.Context, *pb.GetProtocolVersion_Request) (*pb.GetProtocolVersion_Response, error)
  • func (*SourceServer) GetSyncSummary(context.Context, *pb.GetSyncSummary_Request) (*pb.GetSyncSummary_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 (*SourceServer) Sync(*pb.Sync_Request, pb.Source_SyncServer) error
  • func (s *SourceServer) Sync2(req *pb.Sync2_Request, stream pb.Source_Sync2Server) error

Types

type DestinationServer

type DestinationServer struct {
	pb.UnimplementedDestinationServer
	Plugin *plugins.DestinationPlugin
	Logger zerolog.Logger
}

func (*DestinationServer) Close

func (s *DestinationServer) Close(ctx context.Context, _ *pb.Close_Request) (*pb.Close_Response, error)

func (*DestinationServer) Configure

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

func (*DestinationServer) DeleteStale

func (s *DestinationServer) DeleteStale(ctx context.Context, req *pb.DeleteStale_Request) (*pb.DeleteStale_Response, error)

func (*DestinationServer) GetMetrics

func (s *DestinationServer) GetMetrics(context.Context, *pb.GetDestinationMetrics_Request) (*pb.GetDestinationMetrics_Response, error)

func (*DestinationServer) GetName

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

func (*DestinationServer) GetProtocolVersion

func (*DestinationServer) GetProtocolVersion(context.Context, *pb.GetProtocolVersion_Request) (*pb.GetProtocolVersion_Response, error)

func (*DestinationServer) GetVersion

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

func (*DestinationServer) Migrate

func (s *DestinationServer) Migrate(ctx context.Context, req *pb.Migrate_Request) (*pb.Migrate_Response, error)

func (*DestinationServer) Write

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

func (*DestinationServer) Write2

func (s *DestinationServer) Write2(msg pb.Destination_Write2Server) error

Note the order of operations in this method is important! Trying to insert into the `resources` channel before starting the reader goroutine will cause a deadlock.

type SourceServer

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

func (*SourceServer) GetMetrics

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

func (*SourceServer) GetName

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

func (*SourceServer) GetProtocolVersion

func (*SourceServer) GetProtocolVersion(context.Context, *pb.GetProtocolVersion_Request) (*pb.GetProtocolVersion_Response, error)

func (*SourceServer) GetSyncSummary

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

func (*SourceServer) GetTables

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

func (*SourceServer) GetVersion

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

func (*SourceServer) Sync

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

func (*SourceServer) Sync2

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