|
14 | 14 | * limitations under the License.
|
15 | 15 | */
|
16 | 16 |
|
17 |
| -package io.r2dbc.postgresql; |
18 |
| - |
19 |
| -import io.r2dbc.postgresql.api.PostgresqlConnectionMetadata; |
20 |
| -import io.r2dbc.postgresql.client.Client; |
21 |
| -import io.r2dbc.postgresql.message.backend.BackendMessage; |
22 |
| -import io.r2dbc.postgresql.message.backend.EmptyQueryResponse; |
23 |
| -import io.r2dbc.postgresql.message.backend.ErrorResponse; |
24 |
| -import io.r2dbc.postgresql.message.backend.ReadyForQuery; |
25 |
| -import io.r2dbc.postgresql.message.frontend.FrontendMessage; |
26 |
| -import io.r2dbc.postgresql.message.frontend.Query; |
27 |
| -import io.r2dbc.postgresql.replication.LogSequenceNumber; |
28 |
| -import io.r2dbc.postgresql.replication.ReplicationRequest; |
29 |
| -import io.r2dbc.postgresql.replication.ReplicationSlot; |
30 |
| -import io.r2dbc.postgresql.replication.ReplicationSlotRequest; |
31 |
| -import io.r2dbc.postgresql.replication.ReplicationStream; |
32 |
| -import io.r2dbc.postgresql.util.Assert; |
| 17 | +package io.r2dbc.gaussdb; |
| 18 | + |
| 19 | +import io.r2dbc.gaussdb.api.PostgresqlConnectionMetadata; |
| 20 | +import io.r2dbc.gaussdb.client.Client; |
| 21 | +import io.r2dbc.gaussdb.message.backend.BackendMessage; |
| 22 | +import io.r2dbc.gaussdb.message.backend.EmptyQueryResponse; |
| 23 | +import io.r2dbc.gaussdb.message.backend.ErrorResponse; |
| 24 | +import io.r2dbc.gaussdb.message.backend.ReadyForQuery; |
| 25 | +import io.r2dbc.gaussdb.message.frontend.FrontendMessage; |
| 26 | +import io.r2dbc.gaussdb.message.frontend.Query; |
| 27 | +import io.r2dbc.gaussdb.replication.LogSequenceNumber; |
| 28 | +import io.r2dbc.gaussdb.replication.ReplicationRequest; |
| 29 | +import io.r2dbc.gaussdb.replication.ReplicationSlot; |
| 30 | +import io.r2dbc.gaussdb.replication.ReplicationSlotRequest; |
| 31 | +import io.r2dbc.gaussdb.replication.ReplicationStream; |
| 32 | +import io.r2dbc.gaussdb.util.Assert; |
33 | 33 | import io.r2dbc.spi.Row;
|
34 | 34 | import reactor.core.publisher.Mono;
|
35 | 35 | import reactor.core.publisher.Sinks;
|
36 | 36 |
|
37 | 37 | import java.util.function.Predicate;
|
38 | 38 |
|
39 |
| -import static io.r2dbc.postgresql.util.PredicateUtils.or; |
| 39 | +import static io.r2dbc.gaussdb.util.PredicateUtils.or; |
40 | 40 |
|
41 | 41 | /**
|
42 | 42 | * Postgres replication connection.
|
43 | 43 | */
|
44 |
| -final class DefaultPostgresqlReplicationConnection implements io.r2dbc.postgresql.api.PostgresqlReplicationConnection { |
| 44 | +final class DefaultPostgresqlReplicationConnection implements io.r2dbc.gaussdb.api.PostgresqlReplicationConnection { |
45 | 45 |
|
46 | 46 | private static final Predicate<BackendMessage> WINDOW_UNTIL = or(ReadyForQuery.class::isInstance, EmptyQueryResponse.class::isInstance, ErrorResponse.class::isInstance);
|
47 | 47 |
|
|
0 commit comments