org.elasticsearch.index.seqno

Class GlobalCheckpointTracker.PrimaryContext

java.lang.Object

org.elasticsearch.index.seqno.GlobalCheckpointTracker.PrimaryContext

All Implemented Interfaces:

Writeable

Enclosing class:

GlobalCheckpointTracker

public static class GlobalCheckpointTracker.PrimaryContext
extends java.lang.Object
implements Writeable

Represents the sequence number component of the primary context. This is the knowledge on the primary of the in-sync and initializing shards and their local checkpoints.

Nested Class Summary

Nested classes/interfaces inherited from interface org.elasticsearch.common.io.stream.Writeable

Writeable.Reader<V>, Writeable.Writer<V>

Constructor Summary

Constructors

Constructor and Description
PrimaryContext(long clusterStateVersion, java.util.Map<java.lang.String,GlobalCheckpointTracker.CheckpointState> checkpoints, IndexShardRoutingTable routingTable)
PrimaryContext(StreamInput in)

Method Summary

Modifier and Type	Method and Description
long	clusterStateVersion()
boolean	equals(java.lang.Object o)
java.util.Map<java.lang.String,GlobalCheckpointTracker.CheckpointState>	getCheckpointStates()
IndexShardRoutingTable	getRoutingTable()
int	hashCode()
java.lang.String	toString()
void	writeTo(StreamOutput out) Write this into the StreamOutput.

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

PrimaryContext

public PrimaryContext(long clusterStateVersion,
                      java.util.Map<java.lang.String,GlobalCheckpointTracker.CheckpointState> checkpoints,
                      IndexShardRoutingTable routingTable)

PrimaryContext

public PrimaryContext(StreamInput in)
               throws java.io.IOException

Throws:

java.io.IOException

Method Detail

clusterStateVersion

public long clusterStateVersion()

getCheckpointStates

public java.util.Map<java.lang.String,GlobalCheckpointTracker.CheckpointState> getCheckpointStates()

getRoutingTable

public IndexShardRoutingTable getRoutingTable()

writeTo

public void writeTo(StreamOutput out)
             throws java.io.IOException

Description copied from interface: Writeable

Write this into the StreamOutput.

Specified by:

writeTo in interface Writeable

Throws:

java.io.IOException

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

equals

public boolean equals(java.lang.Object o)

Overrides:

equals in class java.lang.Object

hashCode

public int hashCode()

Overrides:

hashCode in class java.lang.Object