Package org.elasticsearch.indices.store

Class TransportNodesListShardStoreMetadata.StoreFilesMetadata

java.lang.Object

org.elasticsearch.indices.store.TransportNodesListShardStoreMetadata.StoreFilesMetadata

All Implemented Interfaces:

Iterable<StoreFileMetadata>, Writeable

Enclosing class:

TransportNodesListShardStoreMetadata

public static class TransportNodesListShardStoreMetadata.StoreFilesMetadata
extends Object
implements Iterable<StoreFileMetadata>, Writeable

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	Description
StoreFilesMetadata(StreamInput in)
StoreFilesMetadata(ShardId shardId, Store.MetadataSnapshot metadataSnapshot, List<RetentionLease> peerRecoveryRetentionLeases)

Method Summary

Modifier and Type	Method	Description
StoreFileMetadata	file(String name)
boolean	fileExists(String name)
long	getPeerRecoveryRetentionLeaseRetainingSeqNo(DiscoveryNode node)	Returns the retaining sequence number of the peer recovery retention lease for a given node if exists; otherwise, returns -1.
boolean	isEmpty()
Iterator<StoreFileMetadata>	iterator()
List<RetentionLease>	peerRecoveryRetentionLeases()
ShardId	shardId()
String	syncId()
String	toString()
void	writeTo(StreamOutput out)	Write this into the StreamOutput.

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Constructor Details

StoreFilesMetadata

public StoreFilesMetadata(ShardId shardId,
 Store.MetadataSnapshot metadataSnapshot,
 List<RetentionLease> peerRecoveryRetentionLeases)

StoreFilesMetadata

public StoreFilesMetadata(StreamInput in)
                   throws IOException

Throws:

IOException

Method Details

writeTo

public void writeTo(StreamOutput out)
             throws IOException

Description copied from interface: Writeable

Write this into the StreamOutput.

Specified by:

writeTo in interface Writeable

Throws:

IOException

shardId

public ShardId shardId()

isEmpty

public boolean isEmpty()

iterator

public Iterator<StoreFileMetadata> iterator()

Specified by:

iterator in interface Iterable<StoreFileMetadata>

fileExists

public boolean fileExists(String name)

file

public StoreFileMetadata file(String name)

getPeerRecoveryRetentionLeaseRetainingSeqNo

public long getPeerRecoveryRetentionLeaseRetainingSeqNo(DiscoveryNode node)

Returns the retaining sequence number of the peer recovery retention lease for a given node if exists; otherwise, returns -1.

peerRecoveryRetentionLeases

public List<RetentionLease> peerRecoveryRetentionLeases()

syncId

public String syncId()

Returns:

commit sync id if exists, else null

toString

public String toString()

Overrides:

toString in class Object