software.chronicle.datagrid.internal.tree

Class VanillaAssetTree

java.lang.Object

net.openhft.chronicle.core.io.AbstractCloseable

software.chronicle.datagrid.internal.tree.VanillaAssetTree

All Implemented Interfaces:

Closeable, AutoCloseable, net.openhft.chronicle.core.io.CloseableTracer, net.openhft.chronicle.core.io.QueryCloseable, net.openhft.chronicle.core.io.ReferenceOwner, AssetTree

public final class VanillaAssetTree
extends net.openhft.chronicle.core.io.AbstractCloseable
implements AssetTree

Nested Class Summary

Nested classes/interfaces inherited from interface software.chronicle.datagrid.tree.AssetTree

AssetTree.ClientBuilder

Field Summary

Fields inherited from class net.openhft.chronicle.core.io.AbstractCloseable

CHECK_THREAD_SAFETY, DISABLE_DISCARD_WARNING, DISABLE_THREAD_SAFETY, STRICT_DISCARD_WARNING, WARN_NS

Fields inherited from interface net.openhft.chronicle.core.io.ReferenceOwner

INIT

Constructor Summary

Constructors

Constructor and Description
VanillaAssetTree()
VanillaAssetTree(AssetRuleProvider ruleProvider)
VanillaAssetTree(int hostId)
VanillaAssetTree(int hostId, AssetRuleProvider ruleProvider)
VanillaAssetTree(@Nullable String name)
VanillaAssetTree(@Nullable String name, AssetRuleProvider ruleProvider)

Method Summary

Modifier and Type	Method and Description
String	clusterName()
void	clusterName(String clusterName)
@NotNull VanillaAssetTree	forRemoteAccess(String hostPortDescription)
@NotNull VanillaAssetTree	forRemoteAccess(@NotNull String[] hostPortDescription, @NotNull net.openhft.chronicle.wire.WireType wire)
@NotNull VanillaAssetTree	forRemoteAccess(@NotNull String[] hostPortDescription, @NotNull net.openhft.chronicle.wire.WireType wire, @Nullable net.openhft.chronicle.network.connection.ClientConnectionMonitor clientConnectionMonitor, @NotNull net.openhft.chronicle.network.ConnectionStrategy connectionStrategy) creates an asset tree that connects to a remote server via tcp/ip
@NotNull VanillaAssetTree	forRemoteAccess(@NotNull String[] hostPortDescription, @NotNull net.openhft.chronicle.wire.WireType wire, @Nullable net.openhft.chronicle.network.connection.ClientConnectionMonitor clientConnectionMonitor, @NotNull net.openhft.chronicle.network.ConnectionStrategy connectionStrategy, @NotNull net.openhft.chronicle.network.api.session.SessionDetails sessionDetails, @Nullable Supplier<net.openhft.chronicle.threads.Pauser> pauserSupplier) Creates an asset tree that connects to a remote server via tcp/ip
@NotNull VanillaAssetTree	forRemoteAccess(String hostPortDescription, @NotNull net.openhft.chronicle.wire.WireType wire)
@NotNull VanillaAssetTree	forRemoteAccess(String serverAddress, @NotNull net.openhft.chronicle.wire.WireType wireType, Consumer<Throwable> t)
@NotNull VanillaAssetTree	forServer()
@NotNull VanillaAssetTree	forServer(boolean daemon)
@NotNull VanillaAssetTree	forTesting()
@NotNull VanillaAssetTree	forTesting(boolean daemon)
protected void	performClose()
String	region()
VanillaAssetTree	region(String region)
@NotNull VanillaAsset	root() Returns the root asset.
@NotNull String	toString()
@NotNull AssetTreeStats	usageStats()
@NotNull AssetTree	withConfig(String etcDir, String baseDir) Deprecated.

Methods inherited from class net.openhft.chronicle.core.io.AbstractCloseable

assertCloseablesClosed, clearUsedByThread, close, createdHere, disableCloseableTracing, enableCloseableTracing, isClosed, isClosing, isInUserThread, performCloseInBackground, referenceId, resetUsedByThread, shouldPerformCloseInBackground, shouldWaitForClosed, threadSafetyCheck, throwExceptionIfClosed, throwExceptionIfClosedInSetter, unmonitor, waitForCloseablesToClose, waitForClosed, warnAndCloseIfNotClosed

Methods inherited from class java.lang.Object

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

Methods inherited from interface software.chronicle.datagrid.tree.AssetTree

acquireMap, acquirePublisher, acquireQueue, acquireQueue, acquireQueue, acquireQueue, acquireReference, acquireService, acquireSet, acquireSubscription, acquireTopicPublisher, acquireTopicPublisher, acquireView, clientBuilder, disableManagement, enableManagement, enableManagement, getSubscription, registerSubscriber, registerSubscriber, registerTopicSubscriber, registerTopicSubscriber, registerTopicSubscriber, unregisterSubscriber, unregisterTopicSubscriber

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

close, closeQuietly, closeQuietly, notifyClosing, warnAndCloseIfNotClosed

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

isClosed, isClosing, throwExceptionIfClosed

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

referenceName, temporary

Constructor Detail

VanillaAssetTree

public VanillaAssetTree()

VanillaAssetTree

public VanillaAssetTree(int hostId)

VanillaAssetTree

public VanillaAssetTree(@Nullable
                        @Nullable String name)

VanillaAssetTree

public VanillaAssetTree(AssetRuleProvider ruleProvider)

VanillaAssetTree

public VanillaAssetTree(@Nullable
                        @Nullable String name,
                        AssetRuleProvider ruleProvider)

VanillaAssetTree

public VanillaAssetTree(int hostId,
                        AssetRuleProvider ruleProvider)

Method Detail

root

@NotNull
public @NotNull VanillaAsset root()

Description copied from interface: AssetTree

Returns the root asset.

This gives an entry point to the entire asset Tress. This is useful for adding global rules for constructing views.

Specified by:

root in interface AssetTree

Returns:

the root Asset.

usageStats

@NotNull
public @NotNull AssetTreeStats usageStats()

Specified by:

usageStats in interface AssetTree

forTesting

@NotNull
public @NotNull VanillaAssetTree forTesting()

forTesting

@NotNull
public @NotNull VanillaAssetTree forTesting(boolean daemon)

forServer

@NotNull
public @NotNull VanillaAssetTree forServer()

forServer

@NotNull
public @NotNull VanillaAssetTree forServer(boolean daemon)

forRemoteAccess

@NotNull
public @NotNull VanillaAssetTree forRemoteAccess(String hostPortDescription,
                                                          @NotNull
                                                          @NotNull net.openhft.chronicle.wire.WireType wire)

forRemoteAccess

@NotNull
public @NotNull VanillaAssetTree forRemoteAccess(@NotNull
                                                          @NotNull String[] hostPortDescription,
                                                          @NotNull
                                                          @NotNull net.openhft.chronicle.wire.WireType wire)

forRemoteAccess

@NotNull
public @NotNull VanillaAssetTree forRemoteAccess(@NotNull
                                                          @NotNull String[] hostPortDescription,
                                                          @NotNull
                                                          @NotNull net.openhft.chronicle.wire.WireType wire,
                                                          @Nullable
                                                          @Nullable net.openhft.chronicle.network.connection.ClientConnectionMonitor clientConnectionMonitor,
                                                          @NotNull
                                                          @NotNull net.openhft.chronicle.network.ConnectionStrategy connectionStrategy)

creates an asset tree that connects to a remote server via tcp/ip

Parameters:

hostPortDescription - the primary host and other failover hosts

wire - the type of wire

clientConnectionMonitor - used to monitor client failover

connectionStrategy - connection strategy

Returns:

an instance of VanillaAssetTree

forRemoteAccess

@NotNull
public @NotNull VanillaAssetTree forRemoteAccess(@NotNull
                                                          @NotNull String[] hostPortDescription,
                                                          @NotNull
                                                          @NotNull net.openhft.chronicle.wire.WireType wire,
                                                          @Nullable
                                                          @Nullable net.openhft.chronicle.network.connection.ClientConnectionMonitor clientConnectionMonitor,
                                                          @NotNull
                                                          @NotNull net.openhft.chronicle.network.ConnectionStrategy connectionStrategy,
                                                          @NotNull
                                                          @NotNull net.openhft.chronicle.network.api.session.SessionDetails sessionDetails,
                                                          @Nullable
                                                          @Nullable Supplier<net.openhft.chronicle.threads.Pauser> pauserSupplier)

Creates an asset tree that connects to a remote server via tcp/ip

Parameters:

hostPortDescription - the primary host and other fail-over hosts

wire - the type of wire

clientConnectionMonitor - used to monitor client fail-over

connectionStrategy - connection strategy

sessionDetails - session details

pauserSupplier - that determines the paused being used for message handling

Returns:

an instance of VanillaAssetTree

forRemoteAccess

@NotNull
public @NotNull VanillaAssetTree forRemoteAccess(String hostPortDescription)

performClose

protected void performClose()

Specified by:

performClose in class net.openhft.chronicle.core.io.AbstractCloseable

withConfig

@NotNull
 @Deprecated
public @NotNull AssetTree withConfig(String etcDir,
                                                           String baseDir)

Deprecated.

toString

@NotNull
public @NotNull String toString()

Overrides:

toString in class net.openhft.chronicle.core.io.AbstractCloseable

forRemoteAccess

@NotNull
public @NotNull VanillaAssetTree forRemoteAccess(String serverAddress,
                                                          @NotNull
                                                          @NotNull net.openhft.chronicle.wire.WireType wireType,
                                                          Consumer<Throwable> t)

region

public VanillaAssetTree region(String region)

region

public String region()

clusterName

public String clusterName()

clusterName

public void clusterName(String clusterName)