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

Added generic cluster state update ack mechanism #3800

Closed
wants to merge 5 commits into from
Closed

Added generic cluster state update ack mechanism #3800

wants to merge 5 commits into from

Commits on Oct 15, 2013

  1. Added generic cluster state update ack mechanism 

    Added new AckedClusterStateUpdateTask interface that can be used to submit cluster state update tasks and allows actions to be notified back when a set of (configurable) nodes have acknowledged the cluster state update. Supports a configurable timeout, so that we wait for acknowledgement for a limited amount of time (will be provided in the request as it curently happens, default 10s).

Internally, a low level AckListener is created (InternalClusterService) and passed to the publish method, so that it can be notified whenever each node responds to the publish request. Once all the expected nodes have responded or the timeoeout has expired, the AckListener notifies the action which will return adding the proper acknowledged flag to the response.

Ideally, this new mechanism will gradually replace the existing ones based on custom endpoints and notifications (per api).

Closes elastic#3786
    @javanna
    javanna committed Oct 15, 2013
    Configuration menu
    Copy the full SHA
    8d15545 View commit details
    Browse the repository at this point in the history

  2. Put warmer api to support acknowledgements 

    Added support for acknowledgements in put warmer api using the generic mechanism introduced in elastic#3786

Closes elastic#3831
    @javanna
    javanna committed Oct 15, 2013
    Configuration menu
    Copy the full SHA
    8344d6e View commit details
    Browse the repository at this point in the history

  3. Delete warmer api to support acknowledgements 

    Added support for acknowledgements in delete warmer api using the generic mechanism introduced in#3786

Closes elastic#3833
    @javanna
    javanna committed Oct 15, 2013
    Configuration menu
    Copy the full SHA
    37b574d View commit details
    Browse the repository at this point in the history

  4. Added simple count down class that allows to be fast forwarded

    @s1monw @javanna
    s1monw authored and javanna committed Oct 15, 2013
    Configuration menu
    Copy the full SHA
    517f09b View commit details
    Browse the repository at this point in the history

  5. fixed CountDownTest

    @javanna
    javanna committed Oct 15, 2013
    Configuration menu
    Copy the full SHA
    088709f View commit details
    Browse the repository at this point in the history