io.zeebe.util.cache

Class ExpandableBufferCache

java.lang.Object

io.zeebe.util.cache.ExpandableBufferCache

public class ExpandableBufferCache
extends Object

LRU-cache for buffers. The buffers can have a different size. If the buffer size is greater than the given initial size then the underlying buffer is expanded.

Inspired by agrona's LongLruCache.

Constructor Summary

Constructors

Constructor and Description
ExpandableBufferCache(int cacheCapacity, int initialBufferCapacity, java.util.function.LongFunction<org.agrona.DirectBuffer> lookup) Create a new cache.

Method Summary

Modifier and Type	Method and Description
void	clear()
org.agrona.DirectBuffer	get(long key)
int	getSize()
void	put(long key, org.agrona.DirectBuffer buffer)
void	remove(long key)

Methods inherited from class java.lang.Object

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

Constructor Detail

ExpandableBufferCache

public ExpandableBufferCache(int cacheCapacity,
                             int initialBufferCapacity,
                             java.util.function.LongFunction<org.agrona.DirectBuffer> lookup)

Create a new cache.

Parameters:

cacheCapacity - capacity of the cache

initialBufferCapacity - initial capacity of the underlying expandable buffers

lookup - a function for lookup an absent value

Method Detail

get

public org.agrona.DirectBuffer get(long key)

put

public void put(long key,
                org.agrona.DirectBuffer buffer)

remove

public void remove(long key)

getSize

public int getSize()

clear

public void clear()