software.chronicle.datagrid.internal.map.remote

Class RemoteKeyValueStore<K,V>

java.lang.Object

net.openhft.chronicle.core.io.SimpleCloseable

net.openhft.chronicle.network.connection.AbstractStatelessClient<MapWireHandler.EventId>

software.chronicle.datagrid.internal.map.remote.RemoteKeyValueStore<K,V>

All Implemented Interfaces:

Closeable, AutoCloseable, Cloneable, net.openhft.chronicle.core.io.QueryCloseable, net.openhft.chronicle.core.io.ReferenceOwner, AuthenticatedKeyValueStore<K,V>, ObjectKeyValueStore<K,V>, KeyValueStore<K,V>, SubscriptionKeyValueStore<K,V>, Assetted<KeyValueStore<K,V>>, KeyedView

public final class RemoteKeyValueStore<K,V>
extends net.openhft.chronicle.network.connection.AbstractStatelessClient<MapWireHandler.EventId>
implements Cloneable, ObjectKeyValueStore<K,V>

Nested Class Summary

Nested classes/interfaces inherited from interface software.chronicle.datagrid.map.KeyValueStore

KeyValueStore.Entry<K,V>

Field Summary

Fields inherited from class net.openhft.chronicle.network.connection.AbstractStatelessClient

csp, hub

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

INIT

Constructor Summary

Constructors

Constructor and Description
RemoteKeyValueStore(@NotNull RequestContext requestContext, @NotNull Asset asset)
RemoteKeyValueStore(@NotNull RequestContext context, @NotNull Asset asset, @NotNull net.openhft.chronicle.network.connection.TcpChannelHub hub)

Method Summary

Modifier and Type	Method and Description
<A,R> R	applyTo(@NotNull net.openhft.chronicle.core.util.SerializableBiFunction<MapView<K,V>,A,R> function, A arg)
@NotNull Asset	asset()
<A> void	asyncUpdate(net.openhft.chronicle.core.util.SerializableUpdaterWithArg updateFunction, A arg)
void	clear()
boolean	containsKey(Object key)
boolean	containsValue(V value)
void	entriesFor(int segment, @NotNull SubscriptionConsumer<MapEvent<K,V>> kvConsumer)
@NotNull Set<Map.Entry<K,V>>	entrySet()
@NotNull Iterator<Map.Entry<K,V>>	entrySetIterator()
boolean	equals(@Nullable Object object) calling this method should be avoided at all cost, as the entire object is serialized.
@NotNull File	file()
V	get(Object key)
V	getAndPut(Object key, Object value)
V	getAndRemove(Object key)
V	getUsing(K key, Object usingValue)
int	hashCode()
boolean	isEmpty()
boolean	isKeyType(Object key)
@NotNull Set<K>	keySet()
void	keysFor(int segment, @NotNull SubscriptionConsumer<K> kConsumer)
Class<K>	keyType()
long	longSize()
boolean	put(K key, V value) put an entry
V	putIfAbsent(K key, V value)
boolean	remove(Object key) remove a key
boolean	remove(@Nullable Object key, Object value)
V	replace(K key, V value)
boolean	replace(K key, V oldValue, V newValue)
@NotNull ObjectSubscription<K,V>	subscription(boolean createIfAbsent)
<R,UA,RA> R	syncUpdate(net.openhft.chronicle.core.util.SerializableUpdaterWithArg updateFunction, UA ua, net.openhft.chronicle.core.util.SerializableBiFunction returnFunction, RA ra)
@NotNull String	toString()
@NotNull KeyValueStore<K,V>	underlying()
@NotNull Collection<V>	values()
Class<V>	valueType()

Methods inherited from class net.openhft.chronicle.network.connection.AbstractStatelessClient

attempt, performClose, proxyReturnBoolean, proxyReturnBooleanWithArgs, proxyReturnBooleanWithSequence, proxyReturnByte, proxyReturnByte, proxyReturnInt, proxyReturnInt, proxyReturnLong, proxyReturnLongWithArgs, proxyReturnTypedObject, proxyReturnTypedObject, proxyReturnTypedObject, proxyReturnUint16, proxyReturnVoid, proxyReturnVoid, proxyReturnWireConsumer, proxyReturnWireConsumerInOut, proxyReturnWireTypedObject, readBoolean, readInt, sendBytes, sendEvent, sendEventAsync, toParameters, toParameters, writeMetaDataForKnownTID

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

close, isClosed

Methods inherited from class java.lang.Object

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

Methods inherited from interface software.chronicle.datagrid.map.KeyValueStore

isReadOnly, keySetIterator, removeIfEqual, replaceIfEqual, segmentFor, segments, valuesIterator

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

close, closeQuietly, closeQuietly, notifyClosing

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

isClosed, isClosing, throwExceptionIfClosed

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

keyedView

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

referenceId, referenceName, temporary

Constructor Detail

RemoteKeyValueStore

public RemoteKeyValueStore(@NotNull
                           @NotNull RequestContext context,
                           @NotNull
                           @NotNull Asset asset,
                           @NotNull
                           @NotNull net.openhft.chronicle.network.connection.TcpChannelHub hub)

RemoteKeyValueStore

public RemoteKeyValueStore(@NotNull
                           @NotNull RequestContext requestContext,
                           @NotNull
                           @NotNull Asset asset)

Method Detail

isKeyType

public boolean isKeyType(Object key)

Specified by:

isKeyType in interface KeyValueStore<K,V>

file

@NotNull
public @NotNull File file()

putIfAbsent

@Nullable
public V putIfAbsent(K key,
                               V value)

Specified by:

putIfAbsent in interface KeyValueStore<K,V>

containsValue

public boolean containsValue(V value)

Specified by:

containsValue in interface KeyValueStore<K,V>

remove

public boolean remove(@Nullable
                      @Nullable Object key,
                      Object value)

replace

public boolean replace(K key,
                       V oldValue,
                       V newValue)

replace

@Nullable
public V replace(K key,
                           V value)

Specified by:

replace in interface KeyValueStore<K,V>

applyTo

@Nullable
public <A,R> R applyTo(@NotNull
                                 @NotNull net.openhft.chronicle.core.util.SerializableBiFunction<MapView<K,V>,A,R> function,
                                 A arg)

syncUpdate

@Nullable
public <R,UA,RA> R syncUpdate(net.openhft.chronicle.core.util.SerializableUpdaterWithArg updateFunction,
                                        UA ua,
                                        net.openhft.chronicle.core.util.SerializableBiFunction returnFunction,
                                        RA ra)

asyncUpdate

public <A> void asyncUpdate(net.openhft.chronicle.core.util.SerializableUpdaterWithArg updateFunction,
                            A arg)

keysFor

public void keysFor(int segment,
                    @NotNull
                    @NotNull SubscriptionConsumer<K> kConsumer)

Specified by:

keysFor in interface KeyValueStore<K,V>

entriesFor

public void entriesFor(int segment,
                       @NotNull
                       @NotNull SubscriptionConsumer<MapEvent<K,V>> kvConsumer)

Specified by:

entriesFor in interface KeyValueStore<K,V>

equals

public boolean equals(@Nullable
                      @Nullable Object object)

calling this method should be avoided at all cost, as the entire object is serialized. This equals can be used to compare map that extends ChronicleMap. So two Chronicle Maps that contain the same data are considered equal, even if the instances of the chronicle maps were of different types

Overrides:

equals in class Object

Parameters:

object - the object that you are comparing against

Returns:

true if the contain the same data

hashCode

public int hashCode()

Overrides:

hashCode in class Object

toString

@NotNull
public @NotNull String toString()

Overrides:

toString in class Object

isEmpty

public boolean isEmpty()

containsKey

public boolean containsKey(Object key)

Specified by:

containsKey in interface KeyValueStore<K,V>

get

@Nullable
public V get(Object key)

Specified by:

get in interface KeyValueStore<K,V>

getUsing

@Nullable
public V getUsing(K key,
                            Object usingValue)

Specified by:

getUsing in interface KeyValueStore<K,V>

longSize

public long longSize()

Specified by:

longSize in interface KeyValueStore<K,V>

remove

public boolean remove(Object key)

Description copied from interface: KeyValueStore

remove a key

Specified by:

remove in interface KeyValueStore<K,V>

Parameters:

key - to remove

Returns:

true if it was removed, false if not.

getAndRemove

@Nullable
public V getAndRemove(Object key)

Specified by:

getAndRemove in interface KeyValueStore<K,V>

put

public boolean put(K key,
                   V value)

Description copied from interface: KeyValueStore

put an entry

Specified by:

put in interface KeyValueStore<K,V>

Parameters:

key - to set

value - to set

Returns:

true if it was replaced or the value is identical, false if it was added.

getAndPut

@Nullable
public V getAndPut(Object key,
                             Object value)

Specified by:

getAndPut in interface KeyValueStore<K,V>

clear

public void clear()

Specified by:

clear in interface KeyValueStore<K,V>

values

@NotNull
public @NotNull Collection<V> values()

entrySet

@NotNull
public @NotNull Set<Map.Entry<K,V>> entrySet()

entrySetIterator

@NotNull
public @NotNull Iterator<Map.Entry<K,V>> entrySetIterator()

Specified by:

entrySetIterator in interface KeyValueStore<K,V>

keySet

@NotNull
public @NotNull Set<K> keySet()

asset

@NotNull
public @NotNull Asset asset()

Specified by:

asset in interface Assetted<KeyValueStore<K,V>>

Returns:

The Asset this resource is associated with.

underlying

@NotNull
public @NotNull KeyValueStore<K,V> underlying()

Specified by:

underlying in interface Assetted<KeyValueStore<K,V>>

Returns:

The Underlying view this view is built on.

subscription

@NotNull
public @NotNull ObjectSubscription<K,V> subscription(boolean createIfAbsent)

Specified by:

subscription in interface SubscriptionKeyValueStore<K,V>

keyType

public Class<K> keyType()

Specified by:

keyType in interface ObjectKeyValueStore<K,V>

valueType

public Class<V> valueType()

Specified by:

valueType in interface ObjectKeyValueStore<K,V>