software.chronicle.datagrid.internal.map

Class ObjectObjectKeyValueStore<K,V>

java.lang.Object

net.openhft.chronicle.core.io.SimpleCloseable

software.chronicle.datagrid.internal.map.ObjectObjectKeyValueStore<K,V>

All Implemented Interfaces:

Closeable, AutoCloseable, net.openhft.chronicle.core.io.ManagedCloseable, net.openhft.chronicle.core.io.QueryCloseable, net.openhft.chronicle.core.io.ReferenceOwner, KeyValueStore<K,V>, Assetted<KeyValueStore<K,V>>, KeyedView

public final class ObjectObjectKeyValueStore<K,V>
extends net.openhft.chronicle.core.io.SimpleCloseable
implements KeyValueStore<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 interface net.openhft.chronicle.core.io.ReferenceOwner

INIT

Constructor Summary

Constructors

Constructor and Description
ObjectObjectKeyValueStore(@NotNull RequestContext context, Asset asset, Assetted assetted)

Method Summary

Modifier and Type	Method and Description
Asset	asset()
void	clear()
boolean	containsValue(V value)
void	entriesFor(int segment, @NotNull SubscriptionConsumer<MapEvent<K,V>> kvConsumer)
@NotNull Iterator<Map.Entry<K,V>>	entrySetIterator()
V	getAndPut(K key, V value)
V	getAndRemove(K key)
V	getUsing(K key, Object value)
void	keysFor(int segment, @NotNull SubscriptionConsumer<K> kConsumer)
long	longSize()
protected void	performClose()
boolean	put(K key, V value) put an entry
boolean	remove(K key) remove a key
V	replace(K key, V value)
KeyValueStore	underlying()

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

close, isClosed

Methods inherited from class java.lang.Object

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

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

containsKey, get, isKeyType, isReadOnly, keySetIterator, putIfAbsent, removeIfEqual, replaceIfEqual, segmentFor, segments, valuesIterator

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

close, closeQuietly, closeQuietly

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

isClosed, isClosing

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

keyedView

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

referenceId, referenceName, temporary

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

createdHere, throwExceptionIfClosed, warnAndCloseIfNotClosed

Constructor Detail

ObjectObjectKeyValueStore

public ObjectObjectKeyValueStore(@NotNull
                                 @NotNull RequestContext context,
                                 Asset asset,
                                 Assetted assetted)

Method Detail

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(K key,
                             V value)

Specified by:

getAndPut in interface KeyValueStore<K,V>

remove

public boolean remove(K 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(K key)

Specified by:

getAndRemove in interface KeyValueStore<K,V>

getUsing

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

Specified by:

getUsing in interface KeyValueStore<K,V>

longSize

public long longSize()

Specified by:

longSize in interface KeyValueStore<K,V>

keysFor

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

Specified by:

keysFor in interface KeyValueStore<K,V>

Throws:

InvalidSubscriberException

entriesFor

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

Specified by:

entriesFor in interface KeyValueStore<K,V>

Throws:

InvalidSubscriberException

entrySetIterator

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

Specified by:

entrySetIterator in interface KeyValueStore<K,V>

clear

public void clear()

Specified by:

clear in interface KeyValueStore<K,V>

replace

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

Specified by:

replace in interface KeyValueStore<K,V>

containsValue

public boolean containsValue(V value)

Specified by:

containsValue in interface KeyValueStore<K,V>

asset

public Asset asset()

Specified by:

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

Returns:

The Asset this resource is associated with.

underlying

public KeyValueStore underlying()

Specified by:

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

Returns:

The Underlying view this view is built on.

performClose

protected void performClose()

Overrides:

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