software.chronicle.datagrid.internal.map

Class VanillaAuthorisedMapView<K,V>

java.lang.Object

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

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

All Implemented Interfaces:

ConcurrentMap<K,V>, Function<K,V>, Map<K,V>, KeyedVisitable<K,V>, Updatable<MapView<K,V>>, MapView<K,V>, Assetted<Object>, KeyedView

public final class VanillaAuthorisedMapView<K,V>
extends VanillaMapView<K,V>
implements MapView<K,V>

Nested Class Summary

Nested classes/interfaces inherited from interface java.util.Map

Map.Entry<K,V>

Field Summary

Fields inherited from class software.chronicle.datagrid.internal.map.VanillaMapView

asset, context, keyClass, putReturnsNull, removeReturnsNull, valueType

Constructor Summary

Constructors

Constructor and Description
VanillaAuthorisedMapView(@NotNull RequestContext context, @NotNull Asset asset, @NotNull KeyValueStore<K,V> kvStore)

Method Summary

Modifier and Type	Method and Description
<V1> @NotNull Function<K,V1>	andThen(@NotNull Function<? super V,? extends V1> after)
V	apply(K k)
<A,R> R	applyTo(@NotNull net.openhft.chronicle.core.util.SerializableBiFunction<MapView<K,V>,A,R> function, A arg) Apply a function to an Updatable which is assumed to not change the visited in any significant way.
<R> R	applyTo(@NotNull net.openhft.chronicle.core.util.SerializableFunction<MapView<K,V>,R> function) Apply a function to an Updatable which is assumed to not change the visited in any significant way.
<T,R> R	applyToKey(K key, @NotNull net.openhft.chronicle.core.util.SerializableBiFunction<V,T,R> function, T argument) Apply a function which takes an argument.
<R> R	applyToKey(K key, @NotNull net.openhft.chronicle.core.util.SerializableFunction<V,R> function) Apply a function to the visitable and return the result.
@NotNull Asset	asset()
void	asyncUpdate(@NotNull net.openhft.chronicle.core.util.SerializableUpdater<MapView<K,V>> updateFunction) Update an Updatable potentially asynchronously.
<A> void	asyncUpdate(@NotNull net.openhft.chronicle.core.util.SerializableUpdaterWithArg<MapView<K,V>,A> updateFunction, A arg) Update an Updatable potentially asynchronously.
<T> void	asyncUpdateKey(K key, @NotNull net.openhft.chronicle.core.util.SerializableBiFunction<V,T,V> updateFunction, T argument) Apply a function to visitable potentially asynchronously.
void	asyncUpdateKey(K key, @NotNull net.openhft.chronicle.core.util.SerializableFunction<V,V> updateFunction) Apply a function to visitable potentially asynchronously.
void	clear()
<V1> @NotNull Function<V1,V>	compose(@NotNull Function<? super V1,? extends K> before)
V	compute(K key, BiFunction<? super K,? super V,? extends V> remappingFunction)
V	computeIfAbsent(K key, Function<? super K,? extends V> mappingFunction)
V	computeIfPresent(K key, BiFunction<? super K,? super V,? extends V> remappingFunction)
boolean	containsKey(Object key)
boolean	containsValue(Object value)
@NotNull EntrySetView<K,V>	entrySet()
void	forEach(BiConsumer<? super K,? super V> action)
V	get(Object key)
V	getAndPut(K key, V value) Explicitly get the old value before putting a new one.
V	getAndRemove(K key) Explicitly get the old value before removing.
V	getOrDefault(Object key, V defaultValue)
V	getUsing(K key, Object value) Obtain a value using a mutable buffer provided.
boolean	isEmpty()
@NotNull KeySetView<K>	keySet()
long	longSize()
V	merge(K key, V value, BiFunction<? super V,? super V,? extends V> remappingFunction)
V	put(K key, V value)
void	putAll(@NotNull Map<? extends K,? extends V> m)
V	putIfAbsent(K key, V value)
@NotNull Reference<V>	referenceFor(K key) Obtain a reference the value for a key
V	remove(Object key)
boolean	remove(@NotNull Object key, Object value)
V	replace(K key, V value)
boolean	replace(K key, V oldValue, V newValue)
void	replaceAll(BiFunction<? super K,? super V,? extends V> function)
void	set(K key, V value)
int	size()
<R> R	syncUpdate(@NotNull net.openhft.chronicle.core.util.SerializableUpdater<MapView<K,V>> updateFunction, @NotNull net.openhft.chronicle.core.util.SerializableFunction<MapView<K,V>,R> returnFunction) Apply a function to update an Updatable and apply a second function to derive some information from it.
<UA,RA,R> R	syncUpdate(@NotNull net.openhft.chronicle.core.util.SerializableUpdaterWithArg<MapView<K,V>,UA> updateFunction, UA ua, @NotNull net.openhft.chronicle.core.util.SerializableBiFunction<MapView<K,V>,RA,R> returnFunction, RA returnArgument) Apply a function to update an Updatable and apply a second function to derive some information from it.
<T,A,R> R	syncUpdateKey(K key, @NotNull net.openhft.chronicle.core.util.SerializableBiFunction<V,T,V> updateFunction, T updateArgument, @NotNull net.openhft.chronicle.core.util.SerializableBiFunction<V,A,R> returnFunction, A returnArgument) Apply a function to update the state of a visible, and apply a function to return a result object synchronously.
<R> R	syncUpdateKey(K key, @NotNull net.openhft.chronicle.core.util.SerializableFunction<V,V> updateFunction, @NotNull net.openhft.chronicle.core.util.SerializableFunction<V,R> returnFunction) Apply a function to update the state of a visible, and apply a function to return a result object synchronously.
@NotNull String	toString()
@Nullable KeyValueStore<K,V>	underlying()
@NotNull Collection<V>	values()

Methods inherited from class software.chronicle.datagrid.internal.map.VanillaMapView

checkKey, checkValue, equals, hashCode, keyType, registerKeySubscriber, registerKeySubscriber, registerSubscriber, registerSubscriber, registerTopicSubscriber, valueType

Methods inherited from class java.lang.Object

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

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

keyType, registerKeySubscriber, registerKeySubscriber, registerSubscriber, registerSubscriber, registerTopicSubscriber, valueType

Methods inherited from interface java.util.Map

equals, hashCode

Methods inherited from interface java.util.function.Function

identity

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

keyedView

Constructor Detail

VanillaAuthorisedMapView

public VanillaAuthorisedMapView(@NotNull
                                @NotNull RequestContext context,
                                @NotNull
                                @NotNull Asset asset,
                                @NotNull
                                @NotNull KeyValueStore<K,V> kvStore)

Method Detail

get

@Nullable
public V get(Object key)

Specified by:

get in interface Map<K,V>

Specified by:

get in interface KeyedVisitable<K,V>

Overrides:

get in class VanillaMapView<K,V>

Parameters:

key - to get within this collection.

Returns:

the current state of a visitable Asset

getOrDefault

public V getOrDefault(Object key,
                      V defaultValue)

Specified by:

getOrDefault in interface ConcurrentMap<K,V>

Specified by:

getOrDefault in interface Map<K,V>

put

public V put(K key,
             V value)

Specified by:

put in interface Map<K,V>

Overrides:

put in class VanillaMapView<K,V>

remove

@Nullable
public V remove(Object key)

Specified by:

remove in interface Map<K,V>

Overrides:

remove in class VanillaMapView<K,V>

getAndPut

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

Description copied from interface: MapView

Explicitly get the old value before putting a new one.

Specified by:

getAndPut in interface MapView<K,V>

Overrides:

getAndPut in class VanillaMapView<K,V>

Parameters:

key - to lookup

value - to set

Returns:

the old value or null if absent

getAndRemove

@Nullable
public V getAndRemove(K key)

Description copied from interface: MapView

Explicitly get the old value before removing.

Specified by:

getAndRemove in interface MapView<K,V>

Overrides:

getAndRemove in class VanillaMapView<K,V>

Parameters:

key - to remove

Returns:

the old value or null if absent.

getUsing

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

Description copied from interface: MapView

Obtain a value using a mutable buffer provided.

Specified by:

getUsing in interface MapView<K,V>

Overrides:

getUsing in class VanillaMapView<K,V>

Parameters:

key - to lookup.

value - a mutable buffer

Returns:

the value.

longSize

public long longSize()

Specified by:

longSize in interface MapView<K,V>

Overrides:

longSize in class VanillaMapView<K,V>

Returns:

the size as a long value.

clear

public void clear()

Specified by:

clear in interface Map<K,V>

Overrides:

clear in class VanillaMapView<K,V>

containsValue

public boolean containsValue(Object value)

Specified by:

containsValue in interface Map<K,V>

Overrides:

containsValue in class VanillaMapView<K,V>

asset

@NotNull
public @NotNull Asset asset()

Specified by:

asset in interface Assetted<Object>

Overrides:

asset in class VanillaMapView<K,V>

Returns:

The Asset this resource is associated with.

underlying

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

Specified by:

underlying in interface Assetted<Object>

Overrides:

underlying in class VanillaMapView<K,V>

Returns:

The Underlying view this view is built on.

keySet

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

Specified by:

keySet in interface Map<K,V>

Specified by:

keySet in interface MapView<K,V>

Overrides:

keySet in class VanillaMapView<K,V>

values

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

Specified by:

values in interface Map<K,V>

Overrides:

values in class VanillaMapView<K,V>

isEmpty

public boolean isEmpty()

Specified by:

isEmpty in interface Map<K,V>

Overrides:

isEmpty in class VanillaMapView<K,V>

containsKey

public boolean containsKey(Object key)

Specified by:

containsKey in interface Map<K,V>

Overrides:

containsKey in class VanillaMapView<K,V>

set

public void set(K key,
                V value)

Specified by:

set in interface KeyedVisitable<K,V>

Overrides:

set in class VanillaMapView<K,V>

Parameters:

key - to set within this collection.

value - replace the current state of the visitable Asset

putAll

public void putAll(@NotNull
                   @NotNull Map<? extends K,? extends V> m)

Specified by:

putAll in interface Map<K,V>

Overrides:

putAll in class VanillaMapView<K,V>

entrySet

@NotNull
public @NotNull EntrySetView<K,V> entrySet()

Specified by:

entrySet in interface Map<K,V>

Specified by:

entrySet in interface MapView<K,V>

Overrides:

entrySet in class VanillaMapView<K,V>

putIfAbsent

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

Specified by:

putIfAbsent in interface ConcurrentMap<K,V>

Specified by:

putIfAbsent in interface Map<K,V>

Overrides:

putIfAbsent in class VanillaMapView<K,V>

remove

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

Specified by:

remove in interface ConcurrentMap<K,V>

Specified by:

remove in interface Map<K,V>

Overrides:

remove in class VanillaMapView<K,V>

replace

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

Specified by:

replace in interface ConcurrentMap<K,V>

Specified by:

replace in interface Map<K,V>

Overrides:

replace in class VanillaMapView<K,V>

replace

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

Specified by:

replace in interface ConcurrentMap<K,V>

Specified by:

replace in interface Map<K,V>

Overrides:

replace in class VanillaMapView<K,V>

referenceFor

@NotNull
public @NotNull Reference<V> referenceFor(K key)

Description copied from interface: MapView

Obtain a reference the value for a key

Specified by:

referenceFor in interface MapView<K,V>

Overrides:

referenceFor in class VanillaMapView<K,V>

Parameters:

key - to bind the reference to

Returns:

a reference object.

toString

@NotNull
public @NotNull String toString()

Overrides:

toString in class VanillaMapView<K,V>

apply

@Nullable
public V apply(K k)

Specified by:

apply in interface Function<K,V>

Specified by:

apply in interface MapView<K,V>

size

public int size()

Specified by:

size in interface Map<K,V>

Specified by:

size in interface MapView<K,V>

forEach

public void forEach(BiConsumer<? super K,? super V> action)

Specified by:

forEach in interface ConcurrentMap<K,V>

Specified by:

forEach in interface Map<K,V>

replaceAll

public void replaceAll(BiFunction<? super K,? super V,? extends V> function)

Specified by:

replaceAll in interface ConcurrentMap<K,V>

Specified by:

replaceAll in interface Map<K,V>

computeIfAbsent

public V computeIfAbsent(K key,
                         Function<? super K,? extends V> mappingFunction)

Specified by:

computeIfAbsent in interface ConcurrentMap<K,V>

Specified by:

computeIfAbsent in interface Map<K,V>

computeIfPresent

public V computeIfPresent(K key,
                          BiFunction<? super K,? super V,? extends V> remappingFunction)

Specified by:

computeIfPresent in interface ConcurrentMap<K,V>

Specified by:

computeIfPresent in interface Map<K,V>

compute

public V compute(K key,
                 BiFunction<? super K,? super V,? extends V> remappingFunction)

Specified by:

compute in interface ConcurrentMap<K,V>

Specified by:

compute in interface Map<K,V>

merge

public V merge(K key,
               V value,
               BiFunction<? super V,? super V,? extends V> remappingFunction)

Specified by:

merge in interface ConcurrentMap<K,V>

Specified by:

merge in interface Map<K,V>

compose

@NotNull
public <V1> @NotNull Function<V1,V> compose(@NotNull
                                                     @NotNull Function<? super V1,? extends K> before)

Specified by:

compose in interface Function<K,V>

andThen

@NotNull
public <V1> @NotNull Function<K,V1> andThen(@NotNull
                                                     @NotNull Function<? super V,? extends V1> after)

Specified by:

andThen in interface Function<K,V>

applyToKey

@Nullable
public <R> R applyToKey(K key,
                                  @NotNull
                                  @NotNull net.openhft.chronicle.core.util.SerializableFunction<V,R> function)

Description copied from interface: KeyedVisitable

Apply a function to the visitable and return the result. This function is assumed to not change the value in any significant way.

Specified by:

applyToKey in interface KeyedVisitable<K,V>

Type Parameters:

R - data type to return.

Parameters:

key - to visit within this collection.

function - to apply e.g. call a getter

Returns:

the result of the code called.

asyncUpdateKey

public void asyncUpdateKey(K key,
                           @NotNull
                           @NotNull net.openhft.chronicle.core.util.SerializableFunction<V,V> updateFunction)

Description copied from interface: KeyedVisitable

Apply a function to visitable potentially asynchronously. This function is assumed to replace the value and trigger and events or replicated changes.

Specified by:

asyncUpdateKey in interface KeyedVisitable<K,V>

Parameters:

key - to visit within this collection.

updateFunction - to update the state of the visibility.

syncUpdateKey

@Nullable
public <R> R syncUpdateKey(K key,
                                     @NotNull
                                     @NotNull net.openhft.chronicle.core.util.SerializableFunction<V,V> updateFunction,
                                     @NotNull
                                     @NotNull net.openhft.chronicle.core.util.SerializableFunction<V,R> returnFunction)

Description copied from interface: KeyedVisitable

Apply a function to update the state of a visible, and apply a function to return a result object synchronously.

Specified by:

syncUpdateKey in interface KeyedVisitable<K,V>

Type Parameters:

R - data type to return.

Parameters:

key - to update within this collection.

updateFunction - update to apply to the value.

returnFunction - derive an object to return

Returns:

the result of the code called.

applyToKey

@Nullable
public <T,R> R applyToKey(K key,
                                    @NotNull
                                    @NotNull net.openhft.chronicle.core.util.SerializableBiFunction<V,T,R> function,
                                    T argument)

Description copied from interface: KeyedVisitable

Apply a function which takes an argument. This argument may contain a combination of data. This function is assumed to not change the value in any significant way.

Specified by:

applyToKey in interface KeyedVisitable<K,V>

Type Parameters:

T - type of the argument

R - type of the return value.

Parameters:

key - to visit within this collection.

function - to apply

argument - for the functions use.

Returns:

data derived.

asyncUpdateKey

public <T> void asyncUpdateKey(K key,
                               @NotNull
                               @NotNull net.openhft.chronicle.core.util.SerializableBiFunction<V,T,V> updateFunction,
                               T argument)

Description copied from interface: KeyedVisitable

Apply a function to visitable potentially asynchronously. This argument may contain a combination of data. This function is assumed to replace the value and trigger and events or replicated changes.

Specified by:

asyncUpdateKey in interface KeyedVisitable<K,V>

Type Parameters:

T - type of the argument

Parameters:

key - to update within this collection

updateFunction - to update the state of the visitable.

argument - for the functions use.

syncUpdateKey

@Nullable
public <T,A,R> R syncUpdateKey(K key,
                                         @NotNull
                                         @NotNull net.openhft.chronicle.core.util.SerializableBiFunction<V,T,V> updateFunction,
                                         @Nullable
                                         T updateArgument,
                                         @NotNull
                                         @NotNull net.openhft.chronicle.core.util.SerializableBiFunction<V,A,R> returnFunction,
                                         @Nullable
                                         A returnArgument)

Description copied from interface: KeyedVisitable

Apply a function to update the state of a visible, and apply a function to return a result object synchronously. This argument may contain a combination of data. Optionally the arguments could be null.

Specified by:

syncUpdateKey in interface KeyedVisitable<K,V>

Type Parameters:

T - update argument type.

A - return argument type.

R - data type to return.

Parameters:

key - to update within this collection

updateFunction - update to apply to the value.

updateArgument - for the update function to use.

returnFunction - derive an object to return

returnArgument - for the return value function to use

Returns:

the result of the code called.

applyTo

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

Description copied from interface: Updatable

Apply a function to an Updatable which is assumed to not change the visited in any significant way. This might not trigger an event.

Specified by:

applyTo in interface Updatable<MapView<K,V>>

Type Parameters:

R - return type.

Parameters:

function - to apply to derive data from this Updatable.

Returns:

derived data.

asyncUpdate

public void asyncUpdate(@NotNull
                        @NotNull net.openhft.chronicle.core.util.SerializableUpdater<MapView<K,V>> updateFunction)

Description copied from interface: Updatable

Update an Updatable potentially asynchronously. This function is assumed to update Updatable.

Specified by:

asyncUpdate in interface Updatable<MapView<K,V>>

Parameters:

updateFunction - to apply.

syncUpdate

@Nullable
public <R> R syncUpdate(@NotNull
                                  @NotNull net.openhft.chronicle.core.util.SerializableUpdater<MapView<K,V>> updateFunction,
                                  @NotNull
                                  @NotNull net.openhft.chronicle.core.util.SerializableFunction<MapView<K,V>,R> returnFunction)

Description copied from interface: Updatable

Apply a function to update an Updatable and apply a second function to derive some information from it.

Specified by:

syncUpdate in interface Updatable<MapView<K,V>>

Type Parameters:

R - data type to return.

Parameters:

updateFunction - to apply the update.

returnFunction - to derive some data

Returns:

value derived.

applyTo

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

Description copied from interface: Updatable

Apply a function to an Updatable which is assumed to not change the visited in any significant way. This might not trigger an event.

Specified by:

applyTo in interface Updatable<MapView<K,V>>

Type Parameters:

A - argument type.

R - return type.

Parameters:

function - to apply to derive data from this Updatable.

arg - argument to apply

Returns:

derived data.

asyncUpdate

public <A> void asyncUpdate(@NotNull
                            @NotNull net.openhft.chronicle.core.util.SerializableUpdaterWithArg<MapView<K,V>,A> updateFunction,
                            A arg)

Description copied from interface: Updatable

Update an Updatable potentially asynchronously. This function is assumed to update Updatable.

Specified by:

asyncUpdate in interface Updatable<MapView<K,V>>

Type Parameters:

A - argument type.

Parameters:

updateFunction - to apply.

arg - argument to apply

syncUpdate

@Nullable
public <UA,RA,R> R syncUpdate(@NotNull
                                        @NotNull net.openhft.chronicle.core.util.SerializableUpdaterWithArg<MapView<K,V>,UA> updateFunction,
                                        UA ua,
                                        @NotNull
                                        @NotNull net.openhft.chronicle.core.util.SerializableBiFunction<MapView<K,V>,RA,R> returnFunction,
                                        RA returnArgument)

Description copied from interface: Updatable

Apply a function to update an Updatable and apply a second function to derive some information from it.

Specified by:

syncUpdate in interface Updatable<MapView<K,V>>

Type Parameters:

UA - update argument type

RA - return argument type

R - return type

Parameters:

updateFunction - to apply the update.

ua - update argument

returnFunction - to derive some data

returnArgument - return argument

Returns:

a value derived from applying the provided parameters