software.chronicle.datagrid.internal.map

Class VanillaStringStringKeyValueStore

java.lang.Object

net.openhft.chronicle.core.io.SimpleCloseable

software.chronicle.datagrid.internal.map.VanillaStringStringKeyValueStore

All Implemented Interfaces:

Closeable, AutoCloseable, net.openhft.chronicle.core.io.ManagedCloseable, net.openhft.chronicle.core.io.QueryCloseable, net.openhft.chronicle.core.io.ReferenceOwner, AuthenticatedKeyValueStore<String,String>, ObjectKeyValueStore<String,String>, KeyValueStore<String,String>, StringStringKeyValueStore, SubscriptionKeyValueStore<String,String>, Assetted<KeyValueStore<String,String>>, KeyedView

public final class VanillaStringStringKeyValueStore
extends net.openhft.chronicle.core.io.SimpleCloseable
implements StringStringKeyValueStore

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
VanillaStringStringKeyValueStore(RequestContext context, @NotNull Asset asset, @NotNull SubscriptionKeyValueStore<String,net.openhft.chronicle.bytes.BytesStore> kvStore)

Method Summary

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

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, replace, replaceIfEqual, segmentFor, segments, valuesIterator

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 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

VanillaStringStringKeyValueStore

public VanillaStringStringKeyValueStore(RequestContext context,
                                        @NotNull
                                        @NotNull Asset asset,
                                        @NotNull
                                        @NotNull SubscriptionKeyValueStore<String,net.openhft.chronicle.bytes.BytesStore> kvStore)

Method Detail

keyType

@NotNull
public @NotNull Class<String> keyType()

Specified by:

keyType in interface ObjectKeyValueStore<String,String>

valueType

@NotNull
public @NotNull Class<String> valueType()

Specified by:

valueType in interface ObjectKeyValueStore<String,String>

subscription

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

Specified by:

subscription in interface SubscriptionKeyValueStore<String,String>

put

public boolean put(String key,
                   @NotNull
                   @NotNull String value)

Description copied from interface: KeyValueStore

put an entry

Specified by:

put in interface KeyValueStore<String,String>

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 @Nullable String getAndPut(String key,
                                            @NotNull
                                            @NotNull String value)

Specified by:

getAndPut in interface KeyValueStore<String,String>

remove

public boolean remove(String key)

Description copied from interface: KeyValueStore

remove a key

Specified by:

remove in interface KeyValueStore<String,String>

Parameters:

key - to remove

Returns:

true if it was removed, false if not.

getAndRemove

@Nullable
public @Nullable String getAndRemove(String key)

Specified by:

getAndRemove in interface KeyValueStore<String,String>

getUsing

@Nullable
public @Nullable String getUsing(String key,
                                           Object value)

Specified by:

getUsing in interface KeyValueStore<String,String>

longSize

public long longSize()

Specified by:

longSize in interface KeyValueStore<String,String>

keysFor

public void keysFor(int segment,
                    SubscriptionConsumer<String> kConsumer)
             throws InvalidSubscriberException

Specified by:

keysFor in interface KeyValueStore<String,String>

Throws:

InvalidSubscriberException

entriesFor

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

Specified by:

entriesFor in interface KeyValueStore<String,String>

Throws:

InvalidSubscriberException

entrySetIterator

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

Specified by:

entrySetIterator in interface KeyValueStore<String,String>

clear

public void clear()

Specified by:

clear in interface KeyValueStore<String,String>

containsValue

public boolean containsValue(String value)

Specified by:

containsValue in interface KeyValueStore<String,String>

asset

@NotNull
public @NotNull Asset asset()

Specified by:

asset in interface Assetted<KeyValueStore<String,String>>

Returns:

The Asset this resource is associated with.

underlying

public KeyValueStore underlying()

Specified by:

underlying in interface Assetted<KeyValueStore<String,String>>

Returns:

The Underlying view this view is built on.

performClose

protected void performClose()

Overrides:

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