io.envoyproxy.controlplane.cache

Class CacheStatusInfo<T>

java.lang.Object

io.envoyproxy.controlplane.cache.CacheStatusInfo<T>

All Implemented Interfaces:

StatusInfo<T>

@ThreadSafe
public class CacheStatusInfo<T>
extends Object
implements StatusInfo<T>

CacheStatusInfo provides a default implementation of StatusInfo for use in Cache implementations.

Constructor Summary

Constructors

Constructor and Description
CacheStatusInfo(T nodeGroup)

Method Summary

Modifier and Type	Method and Description
long	lastWatchRequestTime() Returns the timestamp of the last discovery watch request.
T	nodeGroup() Returns the node grouping represented by this status, generated via NodeGroup#hash(Node).
int	numWatches() Returns the number of open watches.
void	removeWatch(long watchId) Removes the given watch from the tracked collection of watches.
void	setLastWatchRequestTime(long lastWatchRequestTime) Sets the timestamp of the last discovery watch request.
void	setWatch(long watchId, Watch watch) Adds the given watch to the tracked collection of watches.
void	watchesRemoveIf(BiFunction<Long,Watch,Boolean> filter) Iterate over all tracked watches and execute the given function.
Set<Long>	watchIds() Returns the set of IDs for all watched currently being tracked.

Methods inherited from class java.lang.Object

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

Constructor Detail

CacheStatusInfo

public CacheStatusInfo(T nodeGroup)

Method Detail

lastWatchRequestTime

public long lastWatchRequestTime()

Returns the timestamp of the last discovery watch request.

Specified by:

lastWatchRequestTime in interface StatusInfo<T>

nodeGroup

public T nodeGroup()

Returns the node grouping represented by this status, generated via NodeGroup#hash(Node).

Specified by:

nodeGroup in interface StatusInfo<T>

numWatches

public int numWatches()

Returns the number of open watches.

Specified by:

numWatches in interface StatusInfo<T>

removeWatch

public void removeWatch(long watchId)

Removes the given watch from the tracked collection of watches.

Parameters:

watchId - the ID for the watch that should be removed

setLastWatchRequestTime

public void setLastWatchRequestTime(long lastWatchRequestTime)

Sets the timestamp of the last discovery watch request.

Parameters:

lastWatchRequestTime - the latest watch request timestamp

setWatch

public void setWatch(long watchId,
                     Watch watch)

Adds the given watch to the tracked collection of watches.

Parameters:

watchId - the ID for the watch that should be added

watch - the watch that should be added

watchIds

public Set<Long> watchIds()

Returns the set of IDs for all watched currently being tracked.

watchesRemoveIf

public void watchesRemoveIf(BiFunction<Long,Watch,Boolean> filter)

Iterate over all tracked watches and execute the given function. If it returns true, then the watch is removed from the tracked collection. If it returns false, then the watch is not removed.

Parameters:

filter - the function to execute on each watch