Class CachingRlsLbClient.DataCacheEntry

java.lang.Object

io.grpc.rls.CachingRlsLbClient.CacheEntry

io.grpc.rls.CachingRlsLbClient.DataCacheEntry

Enclosing class:

CachingRlsLbClient

final class CachingRlsLbClient.DataCacheEntry
extends CachingRlsLbClient.CacheEntry

Implementation of CachingRlsLbClient.CacheEntry contains valid data.

Field Summary

Fields

Modifier and Type	Field	Description
private final List<LbPolicyConfiguration.ChildPolicyWrapper>	childPolicyWrappers
private final long	expireTime
private final long	minEvictionTime
private final RlsProtoData.RouteLookupResponse	response
private final long	staleTime

Fields inherited from class CachingRlsLbClient.CacheEntry

request

Constructor Summary

Constructors

Constructor	Description
DataCacheEntry(RlsProtoData.RouteLookupRequest request, RlsProtoData.RouteLookupResponse response)

Method Summary

Modifier and Type	Method	Description
(package private) int	calcStringSize(String target)
(package private) void	cleanup()
(package private) LbPolicyConfiguration.ChildPolicyWrapper	getChildPolicyWrapper()
(package private) LbPolicyConfiguration.ChildPolicyWrapper	getChildPolicyWrapper(String target)
(package private) String	getHeaderData()
(package private) int	getSizeBytes()
(package private) boolean	isExpired(long now)
protected boolean	isOldEnoughToBeEvicted(long now)
(package private) boolean	isStaled(long now)
(package private) void	maybeRefresh()	Refreshes cache entry by creating CachingRlsLbClient.PendingCacheEntry.
String	toString()

Methods inherited from class Object

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

Field Details

response

private final RlsProtoData.RouteLookupResponse response

minEvictionTime

private final long minEvictionTime

expireTime

private final long expireTime

staleTime

private final long staleTime

childPolicyWrappers

private final List<LbPolicyConfiguration.ChildPolicyWrapper> childPolicyWrappers

Constructor Details

DataCacheEntry

DataCacheEntry(RlsProtoData.RouteLookupRequest request,
 RlsProtoData.RouteLookupResponse response)

Method Details

maybeRefresh

void maybeRefresh()

Refreshes cache entry by creating CachingRlsLbClient.PendingCacheEntry. When the PendingCacheEntry received data from RLS server, it will replace the data entry if valid data still exists. Flow looks like following.

Timeline                       | async refresh
                               V put new cache (entry2)
entry1: Pending | hasValue | staled  |
entry2:                        | OV* | pending | hasValue | staled |

OV: old value

getChildPolicyWrapper

LbPolicyConfiguration.ChildPolicyWrapper getChildPolicyWrapper(String target)

getChildPolicyWrapper

@Nullable
LbPolicyConfiguration.ChildPolicyWrapper getChildPolicyWrapper()

getHeaderData

String getHeaderData()

calcStringSize

int calcStringSize(String target)

getSizeBytes

int getSizeBytes()

Specified by:

getSizeBytes in class CachingRlsLbClient.CacheEntry

isExpired

boolean isExpired(long now)

Specified by:

isExpired in class CachingRlsLbClient.CacheEntry

isStaled

boolean isStaled(long now)

isOldEnoughToBeEvicted

protected boolean isOldEnoughToBeEvicted(long now)

Overrides:

isOldEnoughToBeEvicted in class CachingRlsLbClient.CacheEntry

cleanup

void cleanup()

Specified by:

cleanup in class CachingRlsLbClient.CacheEntry

toString

public String toString()

Overrides:

toString in class Object