Package org.mockserver.state

Class InMemoryExpectationKeyValueStore

java.lang.Object

org.mockserver.state.InMemoryExpectationKeyValueStore

All Implemented Interfaces:

KeyValueStore<ExpectationEntry>

public class InMemoryExpectationKeyValueStore
extends Object
implements KeyValueStore<ExpectationEntry>

In-memory KeyValueStore for expectations, backed by a CircularPriorityQueue that provides identical ordering and insertion-order eviction to today's RequestMatchers internals.

This is the ONLY expectation KV implementation for phase 2a. It wraps the exact same data structures so behaviour is byte-for-byte unchanged.

Nested Class Summary

Nested classes/interfaces inherited from interface org.mockserver.state.KeyValueStore

KeyValueStore.Entry<V>

Constructor Summary

Constructors

Constructor	Description
InMemoryExpectationKeyValueStore(int maxSize)

Method Summary

Modifier and Type	Method	Description
void	addInvalidationListener(InvalidationListener listener)	Adds an invalidation listener that is notified on mutations.
void	clear()	Removes all entries.
boolean	compareAndRemove(String key, long expectedVersion)	Atomically removes the entry only if the current version matches expectedVersion.
boolean	compareAndSet(String key, long expectedVersion, ExpectationEntry value)	Atomically replaces the value only if the current version matches expectedVersion.
Stream<KeyValueStore.Entry<ExpectationEntry>>	entries()	Returns a stream of all entries.
Optional<Versioned<ExpectationEntry>>	get(String key)	Retrieves the versioned value for the given key.
CircularPriorityQueue<String,ExpectationEntry,SortableExpectationId>	getQueue()	Exposes the underlying queue so that RequestMatchers can use its iteration/sorting without re-implementing it.
long	put(String key, ExpectationEntry value)	Unconditionally puts a value, creating or replacing any existing entry.
Optional<Versioned<ExpectationEntry>>	putIfAbsent(String key, ExpectationEntry value)	Atomically inserts the value only if no entry for the key exists yet.
boolean	remove(String key)	Unconditionally removes the entry for the given key.
void	setMaxSize(int maxSize)	Update the max size (e.g. when maxExpectations changes at runtime).
int	size()	Returns the number of entries.
List<ExpectationEntry>	toSortedList()	Returns the sorted list of entries, in the same order as today's CircularPriorityQueue.toSortedList().

Methods inherited from class java.lang.Object

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

Constructor Details

InMemoryExpectationKeyValueStore

public InMemoryExpectationKeyValueStore(int maxSize)

Method Details

getQueue

public CircularPriorityQueue<String,ExpectationEntry,SortableExpectationId> getQueue()

Exposes the underlying queue so that RequestMatchers can use its iteration/sorting without re-implementing it.

get

public Optional<Versioned<ExpectationEntry>> get(String key)

Description copied from interface: KeyValueStore

Retrieves the versioned value for the given key.

Specified by:

get in interface KeyValueStore<ExpectationEntry>

Parameters:

key - the key

Returns:

the versioned value, or empty if not present

put

public long put(String key,
 ExpectationEntry value)

Description copied from interface: KeyValueStore

Unconditionally puts a value, creating or replacing any existing entry. Returns the new version.

Semantics are last-writer-wins: concurrent put calls for the same key race and the final value is whichever write lands last (mirroring ConcurrentHashMap). Callers that need to detect/avoid lost updates must use KeyValueStore.compareAndSet(java.lang.String, long, V) with the version from a prior KeyValueStore.get(java.lang.String).

Specified by:

put in interface KeyValueStore<ExpectationEntry>

Parameters:

key - the key

value - the value

Returns:

the version assigned to this write

putIfAbsent

public Optional<Versioned<ExpectationEntry>> putIfAbsent(String key,
 ExpectationEntry value)

Description copied from interface: KeyValueStore

Atomically inserts the value only if no entry for the key exists yet. If the key is already present, the store is not modified and the existing versioned value is returned. If insertion succeeds, an empty Optional is returned.

This is the create-only counterpart of KeyValueStore.put(java.lang.String, V): it never overwrites an existing entry. Callers that need last-writer-wins semantics should use KeyValueStore.put(java.lang.String, V); callers that need to detect and defer to a concurrent creator should use this method.

Specified by:

putIfAbsent in interface KeyValueStore<ExpectationEntry>

Parameters:

key - the key

value - the value to insert

Returns:

empty if the entry was created by this call; otherwise the existing versioned value that was already present

compareAndSet

public boolean compareAndSet(String key,
 long expectedVersion,
 ExpectationEntry value)

Description copied from interface: KeyValueStore

Atomically replaces the value only if the current version matches expectedVersion. Returns true on success.

Specified by:

compareAndSet in interface KeyValueStore<ExpectationEntry>

Parameters:

key - the key

expectedVersion - the version the caller last read

value - the new value

Returns:

true if the swap succeeded

compareAndRemove

public boolean compareAndRemove(String key,
 long expectedVersion)

Description copied from interface: KeyValueStore

Atomically removes the entry only if the current version matches expectedVersion. Returns true on success.

Specified by:

compareAndRemove in interface KeyValueStore<ExpectationEntry>

Parameters:

key - the key

expectedVersion - the version the caller last read

Returns:

true if the removal succeeded

remove

public boolean remove(String key)

Description copied from interface: KeyValueStore

Unconditionally removes the entry for the given key.

Specified by:

remove in interface KeyValueStore<ExpectationEntry>

Parameters:

key - the key

Returns:

true if the key was present

entries

public Stream<KeyValueStore.Entry<ExpectationEntry>> entries()

Description copied from interface: KeyValueStore

Returns a stream of all entries. The iteration order is implementation-defined (unordered for a generic KV; sorted for the expectation store).

Specified by:

entries in interface KeyValueStore<ExpectationEntry>

Returns:

stream of key-versioned-value triples

size

public int size()

Description copied from interface: KeyValueStore

Returns the number of entries.

Specified by:

size in interface KeyValueStore<ExpectationEntry>

clear

public void clear()

Description copied from interface: KeyValueStore

Removes all entries.

Specified by:

clear in interface KeyValueStore<ExpectationEntry>

addInvalidationListener

public void addInvalidationListener(InvalidationListener listener)

Description copied from interface: KeyValueStore

Adds an invalidation listener that is notified on mutations.

Specified by:

addInvalidationListener in interface KeyValueStore<ExpectationEntry>

Parameters:

listener - the listener

toSortedList

public List<ExpectationEntry> toSortedList()

Returns the sorted list of entries, in the same order as today's CircularPriorityQueue.toSortedList().

setMaxSize

public void setMaxSize(int maxSize)

Update the max size (e.g. when maxExpectations changes at runtime).