Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

Pubsub final #11

Open
wants to merge 43 commits into
base: 3.0
Choose a base branch
from
Open

Pubsub final #11

wants to merge 43 commits into from

Commits on Nov 18, 2020

  1. Initial: added pubsub

    @sauravcld
    sauravcld committed Nov 18, 2020
    Configuration menu
    Copy the full SHA
    d8cba1a View commit details
    Browse the repository at this point in the history

  2. created file to establish connection between Kombu and pubsub

    @26christy
    26christy committed Nov 18, 2020
    Configuration menu
    Copy the full SHA
    8ddb227 View commit details
    Browse the repository at this point in the history

Commits on Nov 19, 2020

  1. chnages to establish connection

    @26christy
    26christy committed Nov 19, 2020
    Configuration menu
    Copy the full SHA
    9cf6bd7 View commit details
    Browse the repository at this point in the history

Commits on Nov 20, 2020

  1. new changes

    @26christy
    26christy committed Nov 20, 2020
    Configuration menu
    Copy the full SHA
    4c3e3c2 View commit details
    Browse the repository at this point in the history

  2. feat: gcp pubsub integration 

    - add gcp pubsub support
    - add custom Transport
    - add custom Message
    - add custom Channel
    Shivanjan Chakravorty committed Nov 20, 2020
    Configuration menu
    Copy the full SHA
    4a92f81 View commit details
    Browse the repository at this point in the history

Commits on Nov 23, 2020

  1. fix: gcp pubsub integration 

    - fix gcp pubsub connection
- add basic publish
- add basic exchange
    Shivanjan Chakravorty committed Nov 23, 2020
    Configuration menu
    Copy the full SHA
    ef153bb View commit details
    Browse the repository at this point in the history

Commits on Nov 24, 2020

  1. wip: subscribe and consume 

    - create subscription
- basic consume
- basic ack
    Shivanjan Chakravorty committed Nov 24, 2020
    Configuration menu
    Copy the full SHA
    5d7cb5b View commit details
    Browse the repository at this point in the history

Commits on Nov 25, 2020

  1. fix: subscribe and consume 

    - basic consume
- basic ack

todo:

- fix multiconsume
    Shivanjan Chakravorty committed Nov 25, 2020
    Configuration menu
    Copy the full SHA
    7301883 View commit details
    Browse the repository at this point in the history

Commits on Nov 26, 2020

  1. refactor: add docstring and minor fix 

    - add docstring
- remove unused code
- fix multiple consume
    Shivanjan Chakravorty committed Nov 26, 2020
    Configuration menu
    Copy the full SHA
    23433a5 View commit details
    Browse the repository at this point in the history

Commits on Nov 30, 2020

  1. fix: fix qos basic_ack 

    - fix qos basic_ack inheritence
    Shivanjan Chakravorty committed Nov 30, 2020
    Configuration menu
    Copy the full SHA
    0da7bac View commit details
    Browse the repository at this point in the history

Commits on Dec 1, 2020

  1. Additions 

        1. Updated requirement files
    2. Test case for channel class
    @sauravcld
    sauravcld committed Dec 1, 2020
    Configuration menu
    Copy the full SHA
    0540e43 View commit details
    Browse the repository at this point in the history

  2. Resolved merge conflicts

    @sauravcld
    sauravcld committed Dec 1, 2020
    Configuration menu
    Copy the full SHA
    16e3da6 View commit details
    Browse the repository at this point in the history

  3. Removed redundant debugger

    @sauravcld
    sauravcld committed Dec 1, 2020
    Configuration menu
    Copy the full SHA
    9f77495 View commit details
    Browse the repository at this point in the history

  4. updated PubSub UT

    @26christy
    26christy committed Dec 1, 2020
    Configuration menu
    Copy the full SHA
    6f87cb0 View commit details
    Browse the repository at this point in the history

  5. Fix: 

    1. raise exception when no get
2. refactored unit tests
    @sauravcld
    sauravcld committed Dec 1, 2020
    Configuration menu
    Copy the full SHA
    c6ed65e View commit details
    Browse the repository at this point in the history

  6. refactor: queue imported from kombu.five

    @sauravcld
    sauravcld committed Dec 1, 2020
    Configuration menu
    Copy the full SHA
    8dfa887 View commit details
    Browse the repository at this point in the history

Commits on Dec 3, 2020

  1. Fix: 

    - ignore pull from pidbox related queues
- increases consumer throughput
    @sauravcld
    sauravcld committed Dec 3, 2020
    Configuration menu
    Copy the full SHA
    e6b20ee View commit details
    Browse the repository at this point in the history

  2. Merge pull request #1 from cldcvr/development 

    Pubsub support for Kombu
    @sauravcld
    sauravcld authored Dec 3, 2020
    Configuration menu
    Copy the full SHA
    f0eae95 View commit details
    Browse the repository at this point in the history

Commits on Dec 7, 2020

  1. fix: message attributes to be set in pubsub Message declaration

    @sauravcld
    sauravcld committed Dec 7, 2020
    Configuration menu
    Copy the full SHA
    c03a6fe View commit details
    Browse the repository at this point in the history

  2. Merge pull request #2 from cldcvr/development 

    Fix: message attributes to be set in pubsub Message declaration
    @sauravcld
    sauravcld authored Dec 7, 2020
    Configuration menu
    Copy the full SHA
    ed00247 View commit details
    Browse the repository at this point in the history

  3. fix: pubsub to return immediately is not messages to pull

    @sauravcld
    sauravcld committed Dec 7, 2020
    Configuration menu
    Copy the full SHA
    fa875ef View commit details
    Browse the repository at this point in the history

Commits on Dec 14, 2020

  1. feat: support for delayed tasks in Celery

    @sauravcld
    sauravcld committed Dec 14, 2020
    Configuration menu
    Copy the full SHA
    03d5059 View commit details
    Browse the repository at this point in the history

  2. Merge pull request #3 from cldcvr/development 

    feat: Support for `delay` task in Celery
    @sauravcld
    sauravcld authored Dec 14, 2020
    Configuration menu
    Copy the full SHA
    d1d0f09 View commit details
    Browse the repository at this point in the history

  3. feat: consumer optimization by using worker threads for pulling messages

    @sauravcld
    sauravcld committed Dec 14, 2020
    Configuration menu
    Copy the full SHA
    194f4c3 View commit details
    Browse the repository at this point in the history

  4. fix: catch pull error from subscription before creation

    @sauravcld
    sauravcld committed Dec 14, 2020
    Configuration menu
    Copy the full SHA
    e3556db View commit details
    Browse the repository at this point in the history

Commits on Dec 15, 2020

  1. feat: direct call to create cloud task for delayed messages

    @sauravcld
    sauravcld committed Dec 15, 2020
    Configuration menu
    Copy the full SHA
    a102022 View commit details
    Browse the repository at this point in the history

Commits on Dec 16, 2020

  1. fix: updated requirements.py file

    @sauravcld
    sauravcld committed Dec 16, 2020
    Configuration menu
    Copy the full SHA
    7094160 View commit details
    Browse the repository at this point in the history

  2. Merge pull request #4 from cldcvr/development 

    feat: direct call to create cloud task for delayed messages
    @sauravcld
    sauravcld authored Dec 16, 2020
    Configuration menu
    Copy the full SHA
    9f30f3f View commit details
    Browse the repository at this point in the history

  3. bug fix: corrected parameter name

    @sauravcld
    sauravcld committed Dec 16, 2020
    Configuration menu
    Copy the full SHA
    661c181 View commit details
    Browse the repository at this point in the history

  4. Merge pull request #5 from cldcvr/development 

    Support for delayed functions
    @sauravcld
    sauravcld authored Dec 16, 2020
    Configuration menu
    Copy the full SHA
    5011f0c View commit details
    Browse the repository at this point in the history

  5. Merge pull request #10 from cldcvr/3.0 

    Pubsub support for kombu
    @jeechu
    jeechu authored Dec 16, 2020
    Configuration menu
    Copy the full SHA
    a56703a View commit details
    Browse the repository at this point in the history

  6. Added dependencies

    @sauravcld
    sauravcld committed Dec 16, 2020
    Configuration menu
    Copy the full SHA
    e22d38d View commit details
    Browse the repository at this point in the history

  7. Merge pull request #6 from cldcvr/development 

    Added dependencies
    @sauravcld
    sauravcld authored Dec 16, 2020
    Configuration menu
    Copy the full SHA
    c4732bc View commit details
    Browse the repository at this point in the history

  8. Merge pull request #13 from cldcvr/3.0 

    Dependencies added
    @jeechu
    jeechu authored Dec 16, 2020
    Configuration menu
    Copy the full SHA
    7eea1ad View commit details
    Browse the repository at this point in the history

  9. added logic to send oidc token for creating task

    @sauravcld
    sauravcld committed Dec 16, 2020
    Configuration menu
    Copy the full SHA
    3a11afd View commit details
    Browse the repository at this point in the history

  10. removed import checks

    @sauravcld
    sauravcld committed Dec 16, 2020
    Configuration menu
    Copy the full SHA
    fbe9e1e View commit details
    Browse the repository at this point in the history

  11. Merge pull request #15 from cldcvr/development 

    Development
    @jeechu
    jeechu authored Dec 16, 2020
    Configuration menu
    Copy the full SHA
    6fe84aa View commit details
    Browse the repository at this point in the history

Commits on Dec 17, 2020

  1. feat: flag to switch between sync and concurrent pulls

    @sauravcld
    sauravcld committed Dec 17, 2020
    Configuration menu
    Copy the full SHA
    a51802b View commit details
    Browse the repository at this point in the history

  2. Merge pull request #7 from cldcvr/development 

    feat: flag to support switch between sync and concurrent pulls
    @sauravcld
    sauravcld authored Dec 17, 2020
    Configuration menu
    Copy the full SHA
    94a990c View commit details
    Browse the repository at this point in the history

Commits on Dec 18, 2020

  1. Merge pull request #16 from cldcvr/3.0 

    feat: flag to support switch between sync and concurrent pulls
    @jeechu
    jeechu authored Dec 18, 2020
    Configuration menu
    Copy the full SHA
    6a3569a View commit details
    Browse the repository at this point in the history

  2. fix: service account to be fetched from celery app config

    @sauravcld
    sauravcld committed Dec 18, 2020
    Configuration menu
    Copy the full SHA
    6ad4922 View commit details
    Browse the repository at this point in the history

  3. Merge pull request #8 from cldcvr/development 

    fix: service account email to be fetched from celery app config
    @sauravcld
    sauravcld authored Dec 18, 2020
    Configuration menu
    Copy the full SHA
    9d3ea3c View commit details
    Browse the repository at this point in the history

  4. Merge pull request #18 from cldcvr/3.0 

    fix: service account email to be fetched from celery app config
    @mpsmks
    mpsmks authored Dec 18, 2020
    Configuration menu
    Copy the full SHA
    3fa9a48 View commit details
    Browse the repository at this point in the history