Class Cqld4LoadBalancerObserver

java.lang.Object
io.nosqlbench.adapter.cqld4.wrapper.Cqld4LoadBalancerObserver
All Implemented Interfaces:
com.datastax.oss.driver.api.core.loadbalancing.LoadBalancingPolicy, AutoCloseable
public class Cqld4LoadBalancerObserver extends Object implements com.datastax.oss.driver.api.core.loadbalancing.LoadBalancingPolicy

  • Nested Class Summary

    Nested Classes
    Modifier and Type
    Class
    Description
    static class 
    Cqld4LoadBalancerObserver.Bucket
     

    Nested classes/interfaces inherited from interface com.datastax.oss.driver.api.core.loadbalancing.LoadBalancingPolicy

    com.datastax.oss.driver.api.core.loadbalancing.LoadBalancingPolicy.DistanceReporter

  • Constructor Summary

    Constructors
    Constructor
    Description
    Cqld4LoadBalancerObserver(com.datastax.oss.driver.api.core.loadbalancing.LoadBalancingPolicy delegate, NodeSummary summarizer)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    checkpoint()
     
    void
    close()
     
    void
    init(@NotNull Map<UUID,com.datastax.oss.driver.api.core.metadata.Node> nodes, com.datastax.oss.driver.api.core.loadbalancing.LoadBalancingPolicy.DistanceReporter distanceReporter)
     
    @NotNull Queue<com.datastax.oss.driver.api.core.metadata.Node>
    newQueryPlan(@Nullable com.datastax.oss.driver.api.core.session.Request request, @Nullable com.datastax.oss.driver.api.core.session.Session session)
     
    void
    onAdd(@NotNull com.datastax.oss.driver.api.core.metadata.Node node)
     
    void
    onDown(@NotNull com.datastax.oss.driver.api.core.metadata.Node node)
     
    void
    onRemove(@NotNull com.datastax.oss.driver.api.core.metadata.Node node)
     
    void
    onUp(@NotNull com.datastax.oss.driver.api.core.metadata.Node node)
     

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

    Methods inherited from interface com.datastax.oss.driver.api.core.loadbalancing.LoadBalancingPolicy

    getRequestTracker

  • Constructor Details

    • Cqld4LoadBalancerObserver

      public Cqld4LoadBalancerObserver(com.datastax.oss.driver.api.core.loadbalancing.LoadBalancingPolicy delegate, NodeSummary summarizer)

  • Method Details

    • init

      public void init(@NotNull @NotNull Map<UUID,com.datastax.oss.driver.api.core.metadata.Node> nodes, @NotNull com.datastax.oss.driver.api.core.loadbalancing.LoadBalancingPolicy.DistanceReporter distanceReporter)
      Specified by:
      init in interface com.datastax.oss.driver.api.core.loadbalancing.LoadBalancingPolicy

    • newQueryPlan

      @NotNull public @NotNull Queue<com.datastax.oss.driver.api.core.metadata.Node> newQueryPlan(@Nullable @Nullable com.datastax.oss.driver.api.core.session.Request request, @Nullable @Nullable com.datastax.oss.driver.api.core.session.Session session)
      Specified by:
      newQueryPlan in interface com.datastax.oss.driver.api.core.loadbalancing.LoadBalancingPolicy

    • checkpoint

      public void checkpoint()

    • onAdd

      public void onAdd(@NotNull @NotNull com.datastax.oss.driver.api.core.metadata.Node node)
      Specified by:
      onAdd in interface com.datastax.oss.driver.api.core.loadbalancing.LoadBalancingPolicy

    • onUp

      public void onUp(@NotNull @NotNull com.datastax.oss.driver.api.core.metadata.Node node)
      Specified by:
      onUp in interface com.datastax.oss.driver.api.core.loadbalancing.LoadBalancingPolicy

    • onDown

      public void onDown(@NotNull @NotNull com.datastax.oss.driver.api.core.metadata.Node node)
      Specified by:
      onDown in interface com.datastax.oss.driver.api.core.loadbalancing.LoadBalancingPolicy

    • onRemove

      public void onRemove(@NotNull @NotNull com.datastax.oss.driver.api.core.metadata.Node node)
      Specified by:
      onRemove in interface com.datastax.oss.driver.api.core.loadbalancing.LoadBalancingPolicy

    • close

      public void close()
      Specified by:
      close in interface AutoCloseable
      Specified by:
      close in interface com.datastax.oss.driver.api.core.loadbalancing.LoadBalancingPolicy