dblog

type AfterSchedule func()

type AgentSource struct {
	// contains filtered or unexported fields
}

type CancelFunc func()

type Controller struct {
	pb.UnimplementedDBLogControllerServer
	Scheduler Scheduler
	// contains filtered or unexported fields
}

type DumpInfo struct {
	Resp *pb.DumpInfoResponse
	// contains filtered or unexported fields
}

type DumpInfoPuller interface {
	Pull(ctx context.Context, uri string) chan DumpInfo
}

type GRPCDumpInfoPuller struct {
	Client pb.DBLogControllerClient
}

type Gateway struct {
	pb.UnimplementedDBLogGatewayServer
	SourceResolver SourceResolver
	DumpInfoPuller DumpInfoPuller
}

type MemoryScheduler struct {
	// contains filtered or unexported fields
}

type OnSchedule func(response *pb.DumpInfoResponse) error

type PGXSourceDumper struct {
	SkipLSNCheck bool
	// contains filtered or unexported fields
}

type Scheduler interface {
	Schedule(uri string, dumps []*pb.DumpInfoResponse, fn AfterSchedule) error
	Register(uri string, client string, fn OnSchedule) (CancelFunc, error)
	Ack(uri string, client string, requeue string)
	SetCoolDown(uri string, dur time.Duration)
	StopSchedule(uri string)
}

type SourceDumper interface {
	LoadDump(minLSN uint64, info *pb.DumpInfoResponse) ([]*pb.Change, error)
	Stop()
}

type SourceResolver interface {
	Source(ctx context.Context, uri string) (source.RequeueSource, error)
	Dumper(ctx context.Context, uri string) (SourceDumper, error)
}

type StaticAgentPulsarResolver struct {
	// contains filtered or unexported fields
}

type StaticAgentPulsarURIConfig struct {
	PulsarURL            string
	PulsarTopic          string
	PulsarSubscription   string
	PulsarReplicateState bool
	AgentURL             string
}