summaryrefslogtreecommitdiff
path: root/python/pgq
AgeCommit message (Collapse)Author
2014-10-08pgq.cascade.admin: fixed takeover ("cannot subscribe to itself")martinko
2014-08-07cascadeadmin: allow drop-node of rootMarko Kreen
2014-01-23pgq.cascade.admin: do not allow subscribing to itself (same node)martinko
2014-01-13pgq.localconsumer: added file path check on config loadmartinko
2013-11-11python/pgq: fixes (event & walker)martinko
2013-09-19python: amendmentsmartinko
2013-09-18Get rid of dictfetch*() usage, it's obsolete.Marko Kreen
2013-07-07pgq: move RetriableEvent to consumer.pyMarko Kreen
It's hard to get overview if the retry-related code is laying around in different places. As only Consumer class deals with retry, move all crap into same file.
2013-07-07pgq.Consumer: non-lazy loading should use RetriableEventMarko Kreen
2013-06-20pgq: Consumer class also need _make_event, for _load_batch_events_old()Marko Kreen
2013-04-18londiste status: make node name easier to selectMarko Kreen
2013-04-02cascadeadmin: downgrade missing host= error.Marko Kreen
It's not 100% certain that user does not want such connect strings, so erroring out is not right.
2013-03-22DBScript.add_connect_string_profile: single place for profile logicMarko Kreen
2013-03-22status: forgot to drop cstr_extra argumentMarko Kreen
2013-03-22cascadeadmin: cleanup of profile hack in status commandMarko Kreen
2013-03-22londiste: connection profilesMarko Kreen
Way to add extra connect string parameters for non-config connection strings (public node locations).
2013-03-22cascadeadmin: forgot to make node_name optional everywhereMarko Kreen
2013-03-20cascadeadmin: avoid hardwired db nameMarko Kreen
2013-03-20londiste create: load node name and initial provider also from configMarko Kreen
2013-03-20adminscripts: make info commands not use pidfileMarko Kreen
otherwise they conflict with change operations.
2013-03-06python: text fixesmartinko
2013-03-03cascadeadmin status: wait for threadsMarko Kreen
Instead Queue.join(), call Thread.join() for each thread. Otherwise the thread can be active during process shutdown and throw weird errors. After that, calling Queue.join() seems useless; it can even allow additional failure situations. Also clarify thread count logic.
2013-03-01create-node: validate, accept public location from configMarko Kreen
2013-02-27pgq.cascade.admin: amended threadingmartinko
2013-02-27thread safety catchupmartinko
2013-02-27pgq/cascade: significant speed up of getting status on big cascadesmartinko
e.g.: 1000 node cascade status went from minutes to seconds
2013-02-22noisemartinko
2013-02-22pgq: sweeping change to postpone log string formattingmartinko
2013-02-13noisemartinko
2013-01-28PGQ: same bug different place...Petr Jelinek
2013-01-28Pgq: fix RetriableBatchWalker initializationPetr Jelinek
2013-01-25Remove typo in EventPetr Jelinek
2013-01-24Initialize Event properly in BaseConsumerPetr Jelinek
2013-01-14Remove: pgqadm and related code, its unmaintainedMarko Kreen
Although it was nice to have Python code that shows how PgQ ticker and maintenance operations should work, if it's unmaintaned, it's pointless.
2013-01-14pgq.event: __slots__ cleanupMarko Kreen
2013-01-11Move more of retry logic away from BaseConsumer/Event classesPetr Jelinek
2013-01-09CascadedConsumer is now also subclass of BaseConsumer (does not allow retry)Petr Jelinek
2013-01-08Refactor Consumer code.Petr Jelinek
Common code from pgq.Consumer goes into new pgq.BaseConsumer, pgq.Consumer and pgq.LocalConsumer are now subclasses of pgq.BaseConsumer and pgq.Consumer adds retry api/logic. pgq.Event code is now split between pgq.Event and pgq.RetriableEvent. These changes reflect the fact that pgq.LocalConsumer should not be allowed to use retry logic.
2012-12-04white noisemartinko
2012-11-28Merge remote-tracking branch 'sasha/master'Marko Kreen
- node-status
2012-11-28node-status cleanupSasha Aliashkevich
2012-11-27londiste takeover: fix bug in loading events from other nodeMarko Kreen
code forgot to remember the new most recent tick id
2012-11-26Londiste: node-status command for local nodeSasha Aliashkevich
2012-11-26takeover --dead-root: search for latest events on nodesMarko Kreen
In case of several subscribers to root node, one of them may be ahead of others. Search over cascade for most-ahead subscriber and load events to new root.
2012-11-26londiste resurrect: Get dead root back into cascadeMarko Kreen
In some cases the 'takeover --dead-root' will be used although actual data on node is fine. Eg. network downtime, lost power. It would be good to have a way to bring it back to cascade without need for full rebuild. This command sync queue contents and re-subscribes node. Any events found on old root that are not spread to rest of cascade are dumped and deleted. No actual table changes are made, thus there must be external mechanism to avoid data conflicts.
2012-11-22cascadeadmin: clean help textMarko Kreen
2012-11-02Merge remote-tracking branch 'intgit/master'Marko Kreen
2012-11-02pgq.LocalConsumer: improve docstrings.Marko Kreen
2012-10-19white noisemartinko
2012-10-18CascadeAdmin: document wait-provider/wait-root commandsMarko Kreen