grpc

type DBProvider func(id string) (HADB, bool)

type DataSourceNamesFn func() []string

type HADB interface {
	PubSeq() uint64
	DB() *sql.DB
	LatestSnapshot(context.Context) (uint64, io.ReadCloser, error)
}

type ReplicationIDsFn func() []string

type SQLExpectResultSetFn func(context.Context, string) (bool, error)

type Server struct {
	*grpc.Server
	ReferenceCount int
}

type Service struct {
	sqlv1.UnimplementedDatabaseServiceServer
	DBProvider         DBProvider
	DSNList            DataSourceNamesFn
	ReplicationIDList  ReplicationIDsFn
	SQLExpectResultSet SQLExpectResultSetFn
}