org.twitter.zipkin.storage.cassandra

Class ZipkinRetryPolicy

java.lang.Object

org.twitter.zipkin.storage.cassandra.ZipkinRetryPolicy

All Implemented Interfaces:

com.datastax.driver.core.policies.RetryPolicy

public final class ZipkinRetryPolicy
extends java.lang.Object
implements com.datastax.driver.core.policies.RetryPolicy

Nested Class Summary

Nested classes/interfaces inherited from interface com.datastax.driver.core.policies.RetryPolicy

com.datastax.driver.core.policies.RetryPolicy.RetryDecision

Field Summary

Fields

Modifier and Type	Field and Description
static ZipkinRetryPolicy	INSTANCE

Method Summary

Methods

Modifier and Type	Method and Description
com.datastax.driver.core.policies.RetryPolicy.RetryDecision	onReadTimeout(com.datastax.driver.core.Statement statement, com.datastax.driver.core.ConsistencyLevel cl, int requiredResponses, int receivedResponses, boolean dataRetrieved, int nbRetry)
com.datastax.driver.core.policies.RetryPolicy.RetryDecision	onUnavailable(com.datastax.driver.core.Statement statement, com.datastax.driver.core.ConsistencyLevel cl, int requiredReplica, int aliveReplica, int nbRetry)
com.datastax.driver.core.policies.RetryPolicy.RetryDecision	onWriteTimeout(com.datastax.driver.core.Statement statement, com.datastax.driver.core.ConsistencyLevel cl, com.datastax.driver.core.WriteType writeType, int requiredAcks, int receivedAcks, int nbRetry)

Methods inherited from class java.lang.Object

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

Field Detail

INSTANCE

public static final ZipkinRetryPolicy INSTANCE

Method Detail

onReadTimeout

public com.datastax.driver.core.policies.RetryPolicy.RetryDecision onReadTimeout(com.datastax.driver.core.Statement statement,
                                                                        com.datastax.driver.core.ConsistencyLevel cl,
                                                                        int requiredResponses,
                                                                        int receivedResponses,
                                                                        boolean dataRetrieved,
                                                                        int nbRetry)

Specified by:

onReadTimeout in interface com.datastax.driver.core.policies.RetryPolicy

onWriteTimeout

public com.datastax.driver.core.policies.RetryPolicy.RetryDecision onWriteTimeout(com.datastax.driver.core.Statement statement,
                                                                         com.datastax.driver.core.ConsistencyLevel cl,
                                                                         com.datastax.driver.core.WriteType writeType,
                                                                         int requiredAcks,
                                                                         int receivedAcks,
                                                                         int nbRetry)

Specified by:

onWriteTimeout in interface com.datastax.driver.core.policies.RetryPolicy

onUnavailable

public com.datastax.driver.core.policies.RetryPolicy.RetryDecision onUnavailable(com.datastax.driver.core.Statement statement,
                                                                        com.datastax.driver.core.ConsistencyLevel cl,
                                                                        int requiredReplica,
                                                                        int aliveReplica,
                                                                        int nbRetry)

Specified by:

onUnavailable in interface com.datastax.driver.core.policies.RetryPolicy