Commit message (Collapse) | Author | Age | Files | Lines | ||
---|---|---|---|---|---|---|
... | ||||||
| * | | | | | Merge branch 'feature/connect2' into feature/replication-protocol | Oleksandr Shulgin | 2015-10-27 | 7 | -63/+303 | |
| |\ \ \ \ \ | | |_|/ / / | |/| | | | | ||||||
| | * | | | | Rework psycopg2.connect() interface. | Oleksandr Shulgin | 2015-10-27 | 7 | -63/+303 | |
| | | |_|/ | | |/| | | ||||||
| * | | | | Merge branch 'master' into feature/replication-protocol | Oleksandr Shulgin | 2015-10-27 | 1 | -2/+2 | |
| |\ \ \ \ | | |/ / / | ||||||
| * | | | | Drop ReplicationCursor.flush_feedback(), rectify pq_*_replication_*() interface. | Oleksandr Shulgin | 2015-10-23 | 7 | -109/+49 | |
| | | | | | ||||||
| * | | | | Improve async replication example. | Oleksandr Shulgin | 2015-10-23 | 1 | -8/+9 | |
| | | | | | ||||||
| * | | | | Move the `decode` parameter to `start_replication()`. | Oleksandr Shulgin | 2015-10-23 | 6 | -71/+72 | |
| | | | | | | | | | | | | | | | | | | | | | | | | | It makes more sense this way, because otherwise it must be passed to every call of `read_message()`. | |||||
| * | | | | Use direct call to consume() callable in pq_copy_both() | Oleksandr Shulgin | 2015-10-22 | 1 | -5/+3 | |
| | | | | | ||||||
| * | | | | Actually add replication tests to the test suite. | Oleksandr Shulgin | 2015-10-20 | 2 | -0/+3 | |
| | | | | | ||||||
| * | | | | Fix cursor_init() declaration for use in replication_cursor_type.c | Oleksandr Shulgin | 2015-10-20 | 1 | -1/+2 | |
| | | | | | ||||||
| * | | | | Fix send_time printf format in replmsg_repr(). | Oleksandr Shulgin | 2015-10-20 | 1 | -1/+1 | |
| | | | | | ||||||
| * | | | | Add quick start to the replication doc, minor doc fixes. | Oleksandr Shulgin | 2015-10-20 | 3 | -91/+161 | |
| | | | | | ||||||
| * | | | | Properly subclass ReplicationCursor on C level. | Oleksandr Shulgin | 2015-10-19 | 14 | -349/+554 | |
| | | | | | ||||||
| * | | | | Improve async replication test. | Oleksandr Shulgin | 2015-10-19 | 2 | -35/+50 | |
| | | | | | ||||||
| * | | | | Replace stop_replication with requirement for an exception. | Oleksandr Shulgin | 2015-10-19 | 6 | -51/+51 | |
| | | | | | ||||||
| * | | | | Fix PSYCOPG2_TEST_REPL_DSN handling. | Oleksandr Shulgin | 2015-10-16 | 2 | -1/+21 | |
| | | | | | ||||||
| * | | | | Fix async replication and test. | Oleksandr Shulgin | 2015-10-15 | 5 | -69/+147 | |
| | | | | | ||||||
| * | | | | Use quote_ident from psycopg2.extensions | Oleksandr Shulgin | 2015-10-15 | 2 | -11/+21 | |
| | | | | | ||||||
| * | | | | Merge branch 'master' into feature/replication-protocol | Oleksandr Shulgin | 2015-10-15 | 10 | -19/+156 | |
| |\ \ \ \ | ||||||
| * | | | | | Add psyco_curs_datetime_init | Oleksandr Shulgin | 2015-10-14 | 3 | -3/+18 | |
| | | | | | | ||||||
| * | | | | | Remove commented copy_both code in pqfetch. | Oleksandr Shulgin | 2015-10-14 | 1 | -7/+2 | |
| | | | | | | ||||||
| * | | | | | Fix select/timeout indication in async replication example | Oleksandr Shulgin | 2015-10-14 | 1 | -2/+2 | |
| | | | | | | ||||||
| * | | | | | Clear repl_stop flag after the consume loop. | Oleksandr Shulgin | 2015-10-14 | 1 | -0/+1 | |
| | | | | | | ||||||
| * | | | | | Add checks on replication state, have to have a separate check for consume loop. | Oleksandr Shulgin | 2015-10-14 | 2 | -11/+35 | |
| | | | | | | ||||||
| * | | | | | Update stop_repl, require replication consumer to be a callable. | Oleksandr Shulgin | 2015-10-14 | 4 | -29/+34 | |
| | | | | | | ||||||
| * | | | | | Fix stop_replication: always raise outside the loop. | Oleksandr Shulgin | 2015-10-14 | 2 | -2/+14 | |
| | | | | | | ||||||
| * | | | | | Fix ReplicationTest: no NotSupportedError now. | Oleksandr Shulgin | 2015-10-14 | 2 | -8/+14 | |
| | | | | | | ||||||
| * | | | | | Remove IDENTIFY_SYSTEM wrapper method (it can't work with async anyway). | Oleksandr Shulgin | 2015-10-13 | 2 | -18/+1 | |
| | | | | | | ||||||
| * | | | | | Fix create_replication_slot doc signature | Oleksandr Shulgin | 2015-10-13 | 1 | -1/+1 | |
| | | | | | | ||||||
| * | | | | | Rework replication connection/cursor classes | Oleksandr Shulgin | 2015-10-01 | 8 | -243/+369 | |
| | | | | | | ||||||
| * | | | | | Use parse_dsn in ReplicationConnectionBase | Oleksandr Shulgin | 2015-10-01 | 1 | -15/+10 | |
| | | | | | | ||||||
| * | | | | | Update replication connection/cursor interface and docs. | Oleksandr Shulgin | 2015-10-01 | 2 | -71/+151 | |
| | | | | | | ||||||
| * | | | | | Cleanup start replication wrt. slot type a bit. | Oleksandr Shulgin | 2015-10-01 | 3 | -34/+32 | |
| | | | | | | ||||||
| * | | | | | Remove typedef for uint32, include internal/c.h | Oleksandr Shulgin | 2015-10-01 | 1 | -2/+2 | |
| | | | | | | ||||||
| * | | | | | Merge remote-tracking branch 'origin/master' into repl | Oleksandr Shulgin | 2015-10-01 | 10 | -14/+223 | |
| |\ \ \ \ \ | ||||||
| * | | | | | | Fix use of PQconsumeInput() in pq_read_replication_message() | Oleksandr Shulgin | 2015-07-07 | 1 | -11/+25 | |
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | The libpq's PQconsumeInput() returns 0 in case of an error only, but we need to know if it was able to actually read something. Work around this by setting an internal flag before retry. | |||||
| * | | | | | | Fix missing GC flag in ReplicationMessage type | Oleksandr Shulgin | 2015-07-03 | 1 | -3/+11 | |
| | | | | | | | ||||||
| * | | | | | | Fix missing free in replmsg_dealloc | Oleksandr Shulgin | 2015-07-03 | 1 | -0/+4 | |
| | | | | | | | ||||||
| * | | | | | | Check return value of PQsocket | Oleksandr Shulgin | 2015-07-02 | 1 | -6/+9 | |
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | When connection is closed by the server, we might get -1 there. | |||||
| * | | | | | | Fix PQconsumeInput usage. | Oleksandr Shulgin | 2015-07-02 | 1 | -4/+9 | |
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | Only call when no data is available in the internal buffer. | |||||
| * | | | | | | Update docs on ReplicationCursor | Oleksandr Shulgin | 2015-07-01 | 1 | -57/+60 | |
| | | | | | | | ||||||
| * | | | | | | Comment on special handling of PGRES_COPY_BOTH | Oleksandr Shulgin | 2015-06-30 | 1 | -0/+4 | |
| | | | | | | | ||||||
| * | | | | | | Update docs for Replication protocol | Oleksandr Shulgin | 2015-06-30 | 1 | -34/+165 | |
| | | | | | | | ||||||
| * | | | | | | Merge remote-tracking branch 'zalando/feature/replication-protocol' into ↵ | Oleksandr Shulgin | 2015-06-30 | 23 | -49/+304 | |
| |\ \ \ \ \ \ | | | | | | | | | | | | | | | | | | | | | | | | | feature/replication-protocol | |||||
| | * \ \ \ \ \ | Merge branch 'master' into feature/replication-message-object | Oleksandr Shulgin | 2015-06-30 | 23 | -49/+304 | |
| | |\ \ \ \ \ \ | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | Conflicts: lib/extensions.py | |||||
| * | | | | | | | | Rework replication protocol | Oleksandr Shulgin | 2015-06-30 | 6 | -236/+355 | |
| |/ / / / / / / | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | This change exposes lower level functions for operating the (logical) replication protocol, while keeping the high-level start_replication function that does all the job for you in case of a synchronous connection. A number of other changes and fixes are put into this commit. | |||||
| * | | | | | | | Refer cursor from ReplicationMessage object. At the same time, for the sync ↵ | Oleksandr Shulgin | 2015-06-11 | 5 | -30/+21 | |
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | use LSN instead of msg reference in cursor. | |||||
| * | | | | | | | Expose ReplicationMessage type in extras | Oleksandr Shulgin | 2015-06-11 | 3 | -3/+5 | |
| | | | | | | | | ||||||
| * | | | | | | | Add handling of send_time field in replmsg | Oleksandr Shulgin | 2015-06-10 | 6 | -14/+62 | |
| | | | | | | | | ||||||
| * | | | | | | | Fix logical decoding plugin options adaptation on python3 | Oleksandr Shulgin | 2015-06-10 | 1 | -1/+1 | |
| | | | | | | | | ||||||
| * | | | | | | | Add ReplicationMessage object | Oleksandr Shulgin | 2015-06-05 | 10 | -12/+295 | |
| | | | | | | | |