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

Implement admin client. #17

Merged
merged 8 commits into from Sep 15, 2020
Merged

Implement admin client. #17

merged 8 commits into from Sep 15, 2020

Commits on Sep 14, 2020

  1. feat: Implement committer 

    Also small fix to retrying connection so it doesn't leak reads/writes from previous connections.
    @dpcollins-google
    dpcollins-google committed Sep 14, 2020
    Configuration menu
    Copy the full SHA
    ba3140b View commit details
    Browse the repository at this point in the history

  2. fix: Patch retrying connection and add comments.

    @dpcollins-google
    dpcollins-google committed Sep 14, 2020
    Configuration menu
    Copy the full SHA
    8d34653 View commit details
    Browse the repository at this point in the history

  3. feat: Implement assigner which generates subscription-partition assig… 

    …nments.

Also slightly change the semantics of PermanentFailable to not fail a RetryingConnection on retryable errors from a watched awaitable.
    @dpcollins-google
    dpcollins-google committed Sep 14, 2020
    Configuration menu
    Copy the full SHA
    e370118 View commit details
    Browse the repository at this point in the history

  4. feat: Implement FlowControlBatcher 

    This handles aggregating flow control requests without allowing them to get above the max int64 value.
    @dpcollins-google
    dpcollins-google committed Sep 14, 2020
    Configuration menu
    Copy the full SHA
    0500806 View commit details
    Browse the repository at this point in the history

  5. Use correct request for comparisson.

    @dpcollins-google
    dpcollins-google committed Sep 14, 2020
    Configuration menu
    Copy the full SHA
    5eab873 View commit details
    Browse the repository at this point in the history

  6. feat: Implement Subscriber, which handles flow control and batch mess… 

    …age processing.

Also ensure all asynchronous loopers are torn down when their underlying objects are.
    @dpcollins-google
    dpcollins-google committed Sep 14, 2020
    Configuration menu
    Copy the full SHA
    6c44e92 View commit details
    Browse the repository at this point in the history

  7. feat: Implement AdminClient, which helps users perform admin operatio… 

    …ns in a given region.
    @dpcollins-google
    dpcollins-google committed Sep 14, 2020
    Configuration menu
    Copy the full SHA
    159d3ef View commit details
    Browse the repository at this point in the history

Commits on Sep 15, 2020

  1. Merge branch 'master' into admin_client_impl

    @dpcollins-google
    dpcollins-google committed Sep 15, 2020
    Configuration menu
    Copy the full SHA
    b5a33d0 View commit details
    Browse the repository at this point in the history