Interface MetadataServiceRebalanceListener

All Known Implementing Classes:
MetadataNodeManager
public interface MetadataServiceRebalanceListener
Rebalance listener implemented by the writer manager. Partition writer lock must not be held be the caller when the notification methods are invoked since these methods may acquire one or more partition writer locks.

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    onAssigned(MetadataServiceAssignment assignment, int generationId)
    Assignment completion notification generated when rebalance completes.
    void
    onRevoked(int generationId)
    Assignment revocation notification generated when rebalance commences.
    void
    onWriterResigned(int generationId)
    Writer resignation notification generated by the writer when an error is encountered, cache refresh times out or a generation marker with newer generation is is received.

  • Method Details

    • onAssigned

      void onAssigned(MetadataServiceAssignment assignment, int generationId)
      Assignment completion notification generated when rebalance completes.

    • onRevoked

      void onRevoked(int generationId)
      Assignment revocation notification generated when rebalance commences.

    • onWriterResigned

      void onWriterResigned(int generationId)
      Writer resignation notification generated by the writer when an error is encountered, cache refresh times out or a generation marker with newer generation is is received. This is used to trigger re-election.