software.chronicle.datagrid.cluster

Class Clusters

java.lang.Object

net.openhft.chronicle.wire.AbstractCommonMarshallable

net.openhft.chronicle.wire.SelfDescribingMarshallable

software.chronicle.datagrid.cluster.Clusters

All Implemented Interfaces:

Closeable, AutoCloseable, net.openhft.chronicle.bytes.BytesMarshallable, net.openhft.chronicle.bytes.CommonMarshallable, net.openhft.chronicle.bytes.ReadBytesMarshallable, net.openhft.chronicle.bytes.WriteBytesMarshallable, net.openhft.chronicle.core.io.QueryCloseable, net.openhft.chronicle.core.io.Resettable, net.openhft.chronicle.wire.Marshallable, net.openhft.chronicle.wire.ReadMarshallable, net.openhft.chronicle.wire.WriteMarshallable, net.openhft.chronicle.wire.WriteValue

public final class Clusters
extends net.openhft.chronicle.wire.SelfDescribingMarshallable
implements net.openhft.chronicle.wire.Marshallable, net.openhft.chronicle.core.io.Closeable

Field Summary

Fields

Modifier and Type	Field and Description
Map<String,DatagridCluster>	clusterMap

Fields inherited from interface net.openhft.chronicle.wire.WriteMarshallable

EMPTY

Fields inherited from interface net.openhft.chronicle.wire.ReadMarshallable

DISCARD

Constructor Summary

Constructors

Constructor and Description
Clusters()
Clusters(@NotNull Map<String,DatagridCluster> clusterMap)

Method Summary

Modifier and Type	Method and Description
void	close()
Set<Map.Entry<String,DatagridCluster>>	clusters()
@NotNull DatagridCluster	firstCluster()
DatagridCluster	get(String cluster)
void	homeDirectory(String homeDirectory)
void	install(@NotNull AssetTree assetTree, String baseDir)
boolean	isClosed()
void	notifyClosing()
void	put(String clusterName, DatagridCluster datagridCluster)
void	readMarshallable(@NotNull net.openhft.chronicle.wire.WireIn wire)
int	size()
void	writeMarshallable(@NotNull net.openhft.chronicle.wire.WireOut wire)

Methods inherited from class net.openhft.chronicle.wire.SelfDescribingMarshallable

usesSelfDescribingMessage

Methods inherited from class net.openhft.chronicle.wire.AbstractCommonMarshallable

equals, hashCode, toString

Methods inherited from class java.lang.Object

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

Methods inherited from interface net.openhft.chronicle.wire.Marshallable

$equals, $fieldInfoMap, $fieldInfos, $hashCode, $toString, className, copyFrom, copyTo, deepCopy, fromFile, fromFile, fromFileAsMap, fromFileAsMap, fromHexString, fromString, fromString, fromString, getField, getLongField, mergeToMap, reset, setField, setLongField, streamFromFile, streamFromFile, usesSelfDescribingMessage

Methods inherited from interface net.openhft.chronicle.wire.WriteMarshallable

writeValue

Methods inherited from interface net.openhft.chronicle.wire.ReadMarshallable

unexpectedField

Methods inherited from interface net.openhft.chronicle.core.io.Closeable

closeQuietly, closeQuietly

Methods inherited from interface net.openhft.chronicle.core.io.QueryCloseable

isClosing, throwExceptionIfClosed

Methods inherited from interface net.openhft.chronicle.bytes.BytesMarshallable

$toString, readMarshallable, writeMarshallable

Field Detail

clusterMap

public final Map<String,DatagridCluster> clusterMap

Constructor Detail

Clusters

public Clusters()

Clusters

public Clusters(@NotNull
                @NotNull Map<String,DatagridCluster> clusterMap)

Method Detail

readMarshallable

public void readMarshallable(@NotNull
                             @NotNull net.openhft.chronicle.wire.WireIn wire)

Specified by:

readMarshallable in interface net.openhft.chronicle.wire.Marshallable

Specified by:

readMarshallable in interface net.openhft.chronicle.wire.ReadMarshallable

writeMarshallable

public void writeMarshallable(@NotNull
                              @NotNull net.openhft.chronicle.wire.WireOut wire)

Specified by:

writeMarshallable in interface net.openhft.chronicle.wire.Marshallable

Specified by:

writeMarshallable in interface net.openhft.chronicle.wire.WriteMarshallable

install

public void install(@NotNull
                    @NotNull AssetTree assetTree,
                    String baseDir)

get

public DatagridCluster get(String cluster)

clusters

public Set<Map.Entry<String,DatagridCluster>> clusters()

firstCluster

@NotNull
public @NotNull DatagridCluster firstCluster()

put

public void put(String clusterName,
                DatagridCluster datagridCluster)

close

public void close()

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

notifyClosing

public void notifyClosing()

isClosed

public boolean isClosed()

Specified by:

isClosed in interface net.openhft.chronicle.core.io.QueryCloseable

size

public int size()

Returns:

the number of clusters

homeDirectory

public void homeDirectory(String homeDirectory)