Package com.oracle.coherence.grpc.proxy.common.cache

Class NamedCacheProxyProtocol

java.lang.Object

com.oracle.coherence.grpc.proxy.common.BaseProxyProtocol<com.oracle.coherence.grpc.messages.cache.v1.NamedCacheRequest,com.oracle.coherence.grpc.messages.cache.v1.NamedCacheResponse>

com.oracle.coherence.grpc.proxy.common.cache.NamedCacheProxyProtocol

All Implemented Interfaces:

GrpcServiceProtocol<com.oracle.coherence.grpc.messages.cache.v1.NamedCacheRequest,com.oracle.coherence.grpc.messages.cache.v1.NamedCacheResponse>, NamedCacheProtocol<com.oracle.coherence.grpc.messages.cache.v1.NamedCacheRequest,com.oracle.coherence.grpc.messages.cache.v1.NamedCacheResponse>

public class NamedCacheProxyProtocol
extends BaseProxyProtocol<com.oracle.coherence.grpc.messages.cache.v1.NamedCacheRequest,com.oracle.coherence.grpc.messages.cache.v1.NamedCacheResponse>
implements NamedCacheProtocol<com.oracle.coherence.grpc.messages.cache.v1.NamedCacheRequest,com.oracle.coherence.grpc.messages.cache.v1.NamedCacheResponse>

The server side NamedCacheProtocol implementation.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected class	NamedCacheProxyProtocol.CacheListener	A NamedCacheDeactivationListener to receive truncate and destroy events for the cache.
protected class	NamedCacheProxyProtocol.ChannelStub	A stub of an Extend Channel used to handle event messages.
protected static class	NamedCacheProxyProtocol.ConnectionManagerStub	A stub for a ConnectionManager.
protected static class	NamedCacheProxyProtocol.ConnectionStub	A stub for a Connection.

Field Summary

Fields

Modifier and Type	Field	Description
protected final LongArray<com.tangosol.coherence.component.net.extend.proxy.NamedCacheProxy>	m_aProxy	An array of NamedCacheProxy instances indexed by the cache identifier.

Fields inherited from class com.oracle.coherence.grpc.proxy.common.BaseProxyProtocol

f_lock, m_ccf, m_connection, m_destroyedIds, m_eventObserver, m_proxy, m_serializer, m_service

Fields inherited from interface com.oracle.coherence.grpc.GrpcServiceProtocol

PRIORITY_NORMAL

Fields inherited from interface com.oracle.coherence.grpc.NamedCacheProtocol

PROTOCOL_NAME, SUPPORTED_VERSION, VERSION

Constructor Summary

Constructors

Constructor	Description
NamedCacheProxyProtocol()

Method Summary

Modifier and Type	Method	Description
protected Optional<AsyncNamedCache<Binary,Binary>>	async(com.tangosol.coherence.component.net.extend.proxy.NamedCacheProxy proxy)	Obtain an async version of a NamedCacheProxy.
void	close()	Close this protocol.
protected com.tangosol.coherence.component.net.extend.messageFactory.NamedCacheFactory.ListenerFilterRequest	createListenerFilterRequest(com.tangosol.coherence.component.net.extend.proxy.NamedCacheProxy proxy, com.oracle.coherence.grpc.messages.cache.v1.MapListenerRequest request)
protected com.tangosol.coherence.component.net.extend.messageFactory.NamedCacheFactory.ListenerKeyRequest	createListenerKeyRequest(com.tangosol.coherence.component.net.extend.proxy.NamedCacheProxy proxy, com.oracle.coherence.grpc.messages.cache.v1.MapListenerRequest request)
protected com.google.protobuf.Any	getMessage(com.oracle.coherence.grpc.messages.cache.v1.NamedCacheRequest request)
Class<com.oracle.coherence.grpc.messages.cache.v1.NamedCacheRequest>	getRequestType()	Return the type of the request messages.
Class<com.oracle.coherence.grpc.messages.cache.v1.NamedCacheResponse>	getResponseType()	Return the type of the response messages.
Serializer	getSerializer()	Return the Serializer to use to serialize response data.
protected void	initInternal(GrpcService service, com.oracle.coherence.grpc.messages.proxy.v1.InitRequest request, int nVersion, UUID clientUUID)
protected void	onAggregate(com.tangosol.coherence.component.net.extend.proxy.NamedCacheProxy proxy, com.oracle.coherence.grpc.messages.cache.v1.NamedCacheRequest request, io.grpc.stub.StreamObserver<com.oracle.coherence.grpc.messages.cache.v1.NamedCacheResponse> observer)
protected void	onClear(com.tangosol.coherence.component.net.extend.proxy.NamedCacheProxy proxy, io.grpc.stub.StreamObserver<com.oracle.coherence.grpc.messages.cache.v1.NamedCacheResponse> observer)
protected void	onContainsEntry(com.tangosol.coherence.component.net.extend.proxy.NamedCacheProxy proxy, com.oracle.coherence.grpc.messages.cache.v1.NamedCacheRequest request, io.grpc.stub.StreamObserver<com.oracle.coherence.grpc.messages.cache.v1.NamedCacheResponse> observer)
protected void	onContainsKey(com.tangosol.coherence.component.net.extend.proxy.NamedCacheProxy proxy, com.oracle.coherence.grpc.messages.cache.v1.NamedCacheRequest request, io.grpc.stub.StreamObserver<com.oracle.coherence.grpc.messages.cache.v1.NamedCacheResponse> observer)
protected void	onContainsValue(com.tangosol.coherence.component.net.extend.proxy.NamedCacheProxy proxy, com.oracle.coherence.grpc.messages.cache.v1.NamedCacheRequest request, io.grpc.stub.StreamObserver<com.oracle.coherence.grpc.messages.cache.v1.NamedCacheResponse> observer)
protected void	onDestroyCache(int nId, io.grpc.stub.StreamObserver<com.oracle.coherence.grpc.messages.cache.v1.NamedCacheResponse> observer)
protected void	onEnsureCache(com.oracle.coherence.grpc.messages.cache.v1.EnsureCacheRequest request, io.grpc.stub.StreamObserver<com.oracle.coherence.grpc.messages.cache.v1.NamedCacheResponse> observer)
protected void	onGet(com.tangosol.coherence.component.net.extend.proxy.NamedCacheProxy proxy, com.oracle.coherence.grpc.messages.cache.v1.NamedCacheRequest request, io.grpc.stub.StreamObserver<com.oracle.coherence.grpc.messages.cache.v1.NamedCacheResponse> observer)
protected void	onGetAll(com.tangosol.coherence.component.net.extend.proxy.NamedCacheProxy proxy, com.oracle.coherence.grpc.messages.cache.v1.NamedCacheRequest request, io.grpc.stub.StreamObserver<com.oracle.coherence.grpc.messages.cache.v1.NamedCacheResponse> observer)
protected void	onIndex(com.tangosol.coherence.component.net.extend.proxy.NamedCacheProxy proxy, com.oracle.coherence.grpc.messages.cache.v1.NamedCacheRequest request, io.grpc.stub.StreamObserver<com.oracle.coherence.grpc.messages.cache.v1.NamedCacheResponse> observer)
protected void	onInvoke(com.tangosol.coherence.component.net.extend.proxy.NamedCacheProxy proxy, com.oracle.coherence.grpc.messages.cache.v1.NamedCacheRequest request, io.grpc.stub.StreamObserver<com.oracle.coherence.grpc.messages.cache.v1.NamedCacheResponse> observer)
protected void	onIsEmpty(com.tangosol.coherence.component.net.extend.proxy.NamedCacheProxy proxy, io.grpc.stub.StreamObserver<com.oracle.coherence.grpc.messages.cache.v1.NamedCacheResponse> observer)
protected void	onIsReady(com.tangosol.coherence.component.net.extend.proxy.NamedCacheProxy proxy, io.grpc.stub.StreamObserver<com.oracle.coherence.grpc.messages.cache.v1.NamedCacheResponse> observer)
protected void	onMapListener(com.tangosol.coherence.component.net.extend.proxy.NamedCacheProxy proxy, com.oracle.coherence.grpc.messages.cache.v1.NamedCacheRequest request, io.grpc.stub.StreamObserver<com.oracle.coherence.grpc.messages.cache.v1.NamedCacheResponse> observer)
protected void	onPageOfEntries(com.tangosol.coherence.component.net.extend.proxy.NamedCacheProxy proxy, com.oracle.coherence.grpc.messages.cache.v1.NamedCacheRequest request, io.grpc.stub.StreamObserver<com.oracle.coherence.grpc.messages.cache.v1.NamedCacheResponse> observer)
protected void	onPageOfKeys(com.tangosol.coherence.component.net.extend.proxy.NamedCacheProxy proxy, com.oracle.coherence.grpc.messages.cache.v1.NamedCacheRequest request, io.grpc.stub.StreamObserver<com.oracle.coherence.grpc.messages.cache.v1.NamedCacheResponse> observer)
protected void	onPut(com.tangosol.coherence.component.net.extend.proxy.NamedCacheProxy proxy, com.oracle.coherence.grpc.messages.cache.v1.NamedCacheRequest request, io.grpc.stub.StreamObserver<com.oracle.coherence.grpc.messages.cache.v1.NamedCacheResponse> observer)
protected void	onPutAll(com.tangosol.coherence.component.net.extend.proxy.NamedCacheProxy proxy, com.oracle.coherence.grpc.messages.cache.v1.NamedCacheRequest request, io.grpc.stub.StreamObserver<com.oracle.coherence.grpc.messages.cache.v1.NamedCacheResponse> observer)
protected void	onPutIfAbsent(com.tangosol.coherence.component.net.extend.proxy.NamedCacheProxy proxy, com.oracle.coherence.grpc.messages.cache.v1.NamedCacheRequest request, io.grpc.stub.StreamObserver<com.oracle.coherence.grpc.messages.cache.v1.NamedCacheResponse> observer)
protected void	onQueryEntrySet(com.tangosol.coherence.component.net.extend.proxy.NamedCacheProxy proxy, com.oracle.coherence.grpc.messages.cache.v1.NamedCacheRequest request, io.grpc.stub.StreamObserver<com.oracle.coherence.grpc.messages.cache.v1.NamedCacheResponse> observer)
protected void	onQueryKeySet(com.tangosol.coherence.component.net.extend.proxy.NamedCacheProxy proxy, com.oracle.coherence.grpc.messages.cache.v1.NamedCacheRequest request, io.grpc.stub.StreamObserver<com.oracle.coherence.grpc.messages.cache.v1.NamedCacheResponse> observer)
protected void	onQueryValues(com.tangosol.coherence.component.net.extend.proxy.NamedCacheProxy proxy, com.oracle.coherence.grpc.messages.cache.v1.NamedCacheRequest request, io.grpc.stub.StreamObserver<com.oracle.coherence.grpc.messages.cache.v1.NamedCacheResponse> observer)
protected void	onRemove(com.tangosol.coherence.component.net.extend.proxy.NamedCacheProxy proxy, com.oracle.coherence.grpc.messages.cache.v1.NamedCacheRequest request, io.grpc.stub.StreamObserver<com.oracle.coherence.grpc.messages.cache.v1.NamedCacheResponse> observer)
protected void	onRemoveMapping(com.tangosol.coherence.component.net.extend.proxy.NamedCacheProxy proxy, com.oracle.coherence.grpc.messages.cache.v1.NamedCacheRequest request, io.grpc.stub.StreamObserver<com.oracle.coherence.grpc.messages.cache.v1.NamedCacheResponse> observer)
protected void	onReplace(com.tangosol.coherence.component.net.extend.proxy.NamedCacheProxy proxy, com.oracle.coherence.grpc.messages.cache.v1.NamedCacheRequest request, io.grpc.stub.StreamObserver<com.oracle.coherence.grpc.messages.cache.v1.NamedCacheResponse> observer)
protected void	onReplaceMapping(com.tangosol.coherence.component.net.extend.proxy.NamedCacheProxy proxy, com.oracle.coherence.grpc.messages.cache.v1.NamedCacheRequest request, io.grpc.stub.StreamObserver<com.oracle.coherence.grpc.messages.cache.v1.NamedCacheResponse> observer)
protected void	onRequestInternal(com.oracle.coherence.grpc.messages.cache.v1.NamedCacheRequest request, io.grpc.stub.StreamObserver<com.oracle.coherence.grpc.messages.cache.v1.NamedCacheResponse> observer)
protected void	onSize(com.tangosol.coherence.component.net.extend.proxy.NamedCacheProxy proxy, io.grpc.stub.StreamObserver<com.oracle.coherence.grpc.messages.cache.v1.NamedCacheResponse> observer)
protected void	onTruncate(com.tangosol.coherence.component.net.extend.proxy.NamedCacheProxy proxy, io.grpc.stub.StreamObserver<com.oracle.coherence.grpc.messages.cache.v1.NamedCacheResponse> observer)
protected com.oracle.coherence.grpc.messages.cache.v1.NamedCacheResponse.Builder	response(int cacheId)	Create a NamedCacheResponse.Builder with the cache identifier set to the specified value.
protected com.oracle.coherence.grpc.messages.cache.v1.NamedCacheResponse	response(int id, com.google.protobuf.Any any)
protected com.oracle.coherence.grpc.messages.cache.v1.NamedCacheResponse.Builder	response(com.tangosol.coherence.component.net.extend.proxy.NamedCacheProxy proxy)	Create a NamedCacheResponse.Builder with the cache identifier set to the value of the cache identifier of a specified NamedCacheProxy.
protected Binary	unpackBinary(com.oracle.coherence.grpc.messages.cache.v1.NamedCacheRequest request)	Return a BytesValue from a NamedCacheRequest converted to a Binary.

Methods inherited from class com.oracle.coherence.grpc.proxy.common.BaseProxyProtocol

complete, complete, complete, complete, complete, complete, completeKeyValue, completeMapStream, completeMapStream, completeSetStream, completeSetStream, fromBinary, fromByteString, fromByteString, init, onRequest, unpack

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.oracle.coherence.grpc.GrpcServiceProtocol

getPriority, init, onError, onRequest

Methods inherited from interface com.oracle.coherence.grpc.NamedCacheProtocol

getProtocol, getSupportedVersion, getVersion

Field Details

m_aProxy

protected final LongArray<com.tangosol.coherence.component.net.extend.proxy.NamedCacheProxy> m_aProxy

An array of NamedCacheProxy instances indexed by the cache identifier.

Constructor Details

NamedCacheProxyProtocol

public NamedCacheProxyProtocol()

Method Details

getRequestType

public Class<com.oracle.coherence.grpc.messages.cache.v1.NamedCacheRequest> getRequestType()

Description copied from interface: GrpcServiceProtocol

Return the type of the request messages.

Specified by:

getRequestType in interface GrpcServiceProtocol<com.oracle.coherence.grpc.messages.cache.v1.NamedCacheRequest,com.oracle.coherence.grpc.messages.cache.v1.NamedCacheResponse>

Returns:

the type of the request messages

getResponseType

public Class<com.oracle.coherence.grpc.messages.cache.v1.NamedCacheResponse> getResponseType()

Description copied from interface: GrpcServiceProtocol

Return the type of the response messages.

Specified by:

getResponseType in interface GrpcServiceProtocol<com.oracle.coherence.grpc.messages.cache.v1.NamedCacheRequest,com.oracle.coherence.grpc.messages.cache.v1.NamedCacheResponse>

Returns:

the type of the response messages

getSerializer

public Serializer getSerializer()

Description copied from interface: GrpcServiceProtocol

Return the Serializer to use to serialize response data.

Specified by:

getSerializer in interface GrpcServiceProtocol<com.oracle.coherence.grpc.messages.cache.v1.NamedCacheRequest,com.oracle.coherence.grpc.messages.cache.v1.NamedCacheResponse>

Overrides:

getSerializer in class BaseProxyProtocol<com.oracle.coherence.grpc.messages.cache.v1.NamedCacheRequest,com.oracle.coherence.grpc.messages.cache.v1.NamedCacheResponse>

Returns:

the Serializer to use to serialize response data

close

public void close()

Description copied from interface: GrpcServiceProtocol

Close this protocol.

Specified by:

close in interface GrpcServiceProtocol<com.oracle.coherence.grpc.messages.cache.v1.NamedCacheRequest,com.oracle.coherence.grpc.messages.cache.v1.NamedCacheResponse>

Overrides:

close in class BaseProxyProtocol<com.oracle.coherence.grpc.messages.cache.v1.NamedCacheRequest,com.oracle.coherence.grpc.messages.cache.v1.NamedCacheResponse>

initInternal

protected void initInternal(GrpcService service,
 com.oracle.coherence.grpc.messages.proxy.v1.InitRequest request,
 int nVersion,
 UUID clientUUID)

Specified by:

initInternal in class BaseProxyProtocol<com.oracle.coherence.grpc.messages.cache.v1.NamedCacheRequest,com.oracle.coherence.grpc.messages.cache.v1.NamedCacheResponse>

response

protected com.oracle.coherence.grpc.messages.cache.v1.NamedCacheResponse response(int id,
 com.google.protobuf.Any any)

Specified by:

response in class BaseProxyProtocol<com.oracle.coherence.grpc.messages.cache.v1.NamedCacheRequest,com.oracle.coherence.grpc.messages.cache.v1.NamedCacheResponse>

getMessage

protected com.google.protobuf.Any getMessage(com.oracle.coherence.grpc.messages.cache.v1.NamedCacheRequest request)

Specified by:

getMessage in class BaseProxyProtocol<com.oracle.coherence.grpc.messages.cache.v1.NamedCacheRequest,com.oracle.coherence.grpc.messages.cache.v1.NamedCacheResponse>

onRequestInternal

protected void onRequestInternal(com.oracle.coherence.grpc.messages.cache.v1.NamedCacheRequest request,
 io.grpc.stub.StreamObserver<com.oracle.coherence.grpc.messages.cache.v1.NamedCacheResponse> observer)

Specified by:

onRequestInternal in class BaseProxyProtocol<com.oracle.coherence.grpc.messages.cache.v1.NamedCacheRequest,com.oracle.coherence.grpc.messages.cache.v1.NamedCacheResponse>

onAggregate

protected void onAggregate(com.tangosol.coherence.component.net.extend.proxy.NamedCacheProxy proxy,
 com.oracle.coherence.grpc.messages.cache.v1.NamedCacheRequest request,
 io.grpc.stub.StreamObserver<com.oracle.coherence.grpc.messages.cache.v1.NamedCacheResponse> observer)

onClear

protected void onClear(com.tangosol.coherence.component.net.extend.proxy.NamedCacheProxy proxy,
 io.grpc.stub.StreamObserver<com.oracle.coherence.grpc.messages.cache.v1.NamedCacheResponse> observer)

onContainsEntry

protected void onContainsEntry(com.tangosol.coherence.component.net.extend.proxy.NamedCacheProxy proxy,
 com.oracle.coherence.grpc.messages.cache.v1.NamedCacheRequest request,
 io.grpc.stub.StreamObserver<com.oracle.coherence.grpc.messages.cache.v1.NamedCacheResponse> observer)

onContainsKey

protected void onContainsKey(com.tangosol.coherence.component.net.extend.proxy.NamedCacheProxy proxy,
 com.oracle.coherence.grpc.messages.cache.v1.NamedCacheRequest request,
 io.grpc.stub.StreamObserver<com.oracle.coherence.grpc.messages.cache.v1.NamedCacheResponse> observer)

onContainsValue

protected void onContainsValue(com.tangosol.coherence.component.net.extend.proxy.NamedCacheProxy proxy,
 com.oracle.coherence.grpc.messages.cache.v1.NamedCacheRequest request,
 io.grpc.stub.StreamObserver<com.oracle.coherence.grpc.messages.cache.v1.NamedCacheResponse> observer)

onDestroyCache

protected void onDestroyCache(int nId,
 io.grpc.stub.StreamObserver<com.oracle.coherence.grpc.messages.cache.v1.NamedCacheResponse> observer)

onEnsureCache

protected void onEnsureCache(com.oracle.coherence.grpc.messages.cache.v1.EnsureCacheRequest request,
 io.grpc.stub.StreamObserver<com.oracle.coherence.grpc.messages.cache.v1.NamedCacheResponse> observer)

onGet

protected void onGet(com.tangosol.coherence.component.net.extend.proxy.NamedCacheProxy proxy,
 com.oracle.coherence.grpc.messages.cache.v1.NamedCacheRequest request,
 io.grpc.stub.StreamObserver<com.oracle.coherence.grpc.messages.cache.v1.NamedCacheResponse> observer)

onGetAll

protected void onGetAll(com.tangosol.coherence.component.net.extend.proxy.NamedCacheProxy proxy,
 com.oracle.coherence.grpc.messages.cache.v1.NamedCacheRequest request,
 io.grpc.stub.StreamObserver<com.oracle.coherence.grpc.messages.cache.v1.NamedCacheResponse> observer)

onIndex

protected void onIndex(com.tangosol.coherence.component.net.extend.proxy.NamedCacheProxy proxy,
 com.oracle.coherence.grpc.messages.cache.v1.NamedCacheRequest request,
 io.grpc.stub.StreamObserver<com.oracle.coherence.grpc.messages.cache.v1.NamedCacheResponse> observer)

onInvoke

protected void onInvoke(com.tangosol.coherence.component.net.extend.proxy.NamedCacheProxy proxy,
 com.oracle.coherence.grpc.messages.cache.v1.NamedCacheRequest request,
 io.grpc.stub.StreamObserver<com.oracle.coherence.grpc.messages.cache.v1.NamedCacheResponse> observer)

onIsEmpty

protected void onIsEmpty(com.tangosol.coherence.component.net.extend.proxy.NamedCacheProxy proxy,
 io.grpc.stub.StreamObserver<com.oracle.coherence.grpc.messages.cache.v1.NamedCacheResponse> observer)

onIsReady

protected void onIsReady(com.tangosol.coherence.component.net.extend.proxy.NamedCacheProxy proxy,
 io.grpc.stub.StreamObserver<com.oracle.coherence.grpc.messages.cache.v1.NamedCacheResponse> observer)

onMapListener

protected void onMapListener(com.tangosol.coherence.component.net.extend.proxy.NamedCacheProxy proxy,
 com.oracle.coherence.grpc.messages.cache.v1.NamedCacheRequest request,
 io.grpc.stub.StreamObserver<com.oracle.coherence.grpc.messages.cache.v1.NamedCacheResponse> observer)

createListenerKeyRequest

protected com.tangosol.coherence.component.net.extend.messageFactory.NamedCacheFactory.ListenerKeyRequest createListenerKeyRequest(com.tangosol.coherence.component.net.extend.proxy.NamedCacheProxy proxy,
 com.oracle.coherence.grpc.messages.cache.v1.MapListenerRequest request)

createListenerFilterRequest

protected com.tangosol.coherence.component.net.extend.messageFactory.NamedCacheFactory.ListenerFilterRequest createListenerFilterRequest(com.tangosol.coherence.component.net.extend.proxy.NamedCacheProxy proxy,
 com.oracle.coherence.grpc.messages.cache.v1.MapListenerRequest request)

onPageOfEntries

protected void onPageOfEntries(com.tangosol.coherence.component.net.extend.proxy.NamedCacheProxy proxy,
 com.oracle.coherence.grpc.messages.cache.v1.NamedCacheRequest request,
 io.grpc.stub.StreamObserver<com.oracle.coherence.grpc.messages.cache.v1.NamedCacheResponse> observer)

onPageOfKeys

protected void onPageOfKeys(com.tangosol.coherence.component.net.extend.proxy.NamedCacheProxy proxy,
 com.oracle.coherence.grpc.messages.cache.v1.NamedCacheRequest request,
 io.grpc.stub.StreamObserver<com.oracle.coherence.grpc.messages.cache.v1.NamedCacheResponse> observer)

onPut

protected void onPut(com.tangosol.coherence.component.net.extend.proxy.NamedCacheProxy proxy,
 com.oracle.coherence.grpc.messages.cache.v1.NamedCacheRequest request,
 io.grpc.stub.StreamObserver<com.oracle.coherence.grpc.messages.cache.v1.NamedCacheResponse> observer)

onPutAll

protected void onPutAll(com.tangosol.coherence.component.net.extend.proxy.NamedCacheProxy proxy,
 com.oracle.coherence.grpc.messages.cache.v1.NamedCacheRequest request,
 io.grpc.stub.StreamObserver<com.oracle.coherence.grpc.messages.cache.v1.NamedCacheResponse> observer)

onPutIfAbsent

protected void onPutIfAbsent(com.tangosol.coherence.component.net.extend.proxy.NamedCacheProxy proxy,
 com.oracle.coherence.grpc.messages.cache.v1.NamedCacheRequest request,
 io.grpc.stub.StreamObserver<com.oracle.coherence.grpc.messages.cache.v1.NamedCacheResponse> observer)

onQueryEntrySet

protected void onQueryEntrySet(com.tangosol.coherence.component.net.extend.proxy.NamedCacheProxy proxy,
 com.oracle.coherence.grpc.messages.cache.v1.NamedCacheRequest request,
 io.grpc.stub.StreamObserver<com.oracle.coherence.grpc.messages.cache.v1.NamedCacheResponse> observer)

onQueryKeySet

protected void onQueryKeySet(com.tangosol.coherence.component.net.extend.proxy.NamedCacheProxy proxy,
 com.oracle.coherence.grpc.messages.cache.v1.NamedCacheRequest request,
 io.grpc.stub.StreamObserver<com.oracle.coherence.grpc.messages.cache.v1.NamedCacheResponse> observer)

onQueryValues

protected void onQueryValues(com.tangosol.coherence.component.net.extend.proxy.NamedCacheProxy proxy,
 com.oracle.coherence.grpc.messages.cache.v1.NamedCacheRequest request,
 io.grpc.stub.StreamObserver<com.oracle.coherence.grpc.messages.cache.v1.NamedCacheResponse> observer)

onRemove

protected void onRemove(com.tangosol.coherence.component.net.extend.proxy.NamedCacheProxy proxy,
 com.oracle.coherence.grpc.messages.cache.v1.NamedCacheRequest request,
 io.grpc.stub.StreamObserver<com.oracle.coherence.grpc.messages.cache.v1.NamedCacheResponse> observer)

onRemoveMapping

protected void onRemoveMapping(com.tangosol.coherence.component.net.extend.proxy.NamedCacheProxy proxy,
 com.oracle.coherence.grpc.messages.cache.v1.NamedCacheRequest request,
 io.grpc.stub.StreamObserver<com.oracle.coherence.grpc.messages.cache.v1.NamedCacheResponse> observer)

onReplace

protected void onReplace(com.tangosol.coherence.component.net.extend.proxy.NamedCacheProxy proxy,
 com.oracle.coherence.grpc.messages.cache.v1.NamedCacheRequest request,
 io.grpc.stub.StreamObserver<com.oracle.coherence.grpc.messages.cache.v1.NamedCacheResponse> observer)

onReplaceMapping

protected void onReplaceMapping(com.tangosol.coherence.component.net.extend.proxy.NamedCacheProxy proxy,
 com.oracle.coherence.grpc.messages.cache.v1.NamedCacheRequest request,
 io.grpc.stub.StreamObserver<com.oracle.coherence.grpc.messages.cache.v1.NamedCacheResponse> observer)

onSize

protected void onSize(com.tangosol.coherence.component.net.extend.proxy.NamedCacheProxy proxy,
 io.grpc.stub.StreamObserver<com.oracle.coherence.grpc.messages.cache.v1.NamedCacheResponse> observer)

onTruncate

protected void onTruncate(com.tangosol.coherence.component.net.extend.proxy.NamedCacheProxy proxy,
 io.grpc.stub.StreamObserver<com.oracle.coherence.grpc.messages.cache.v1.NamedCacheResponse> observer)

response

protected com.oracle.coherence.grpc.messages.cache.v1.NamedCacheResponse.Builder response(com.tangosol.coherence.component.net.extend.proxy.NamedCacheProxy proxy)

Create a NamedCacheResponse.Builder with the cache identifier set to the value of the cache identifier of a specified NamedCacheProxy.

Parameters:

proxy - the NamedCacheProxy to use to set the cache identifier

Returns:

a NamedCacheResponse.Builder with the cache identifier set to the NamedCacheProxy cache identifier

response

protected com.oracle.coherence.grpc.messages.cache.v1.NamedCacheResponse.Builder response(int cacheId)

Create a NamedCacheResponse.Builder with the cache identifier set to the specified value.

Parameters:

cacheId - the cache identifier

Returns:

a NamedCacheResponse.Builder with the cache identifier set to the specified value

async

protected Optional<AsyncNamedCache<Binary,Binary>> async(com.tangosol.coherence.component.net.extend.proxy.NamedCacheProxy proxy)

Obtain an async version of a NamedCacheProxy.

Parameters:

proxy - the NamedCacheProxy to get the async cache for

Returns:

an Optional containing the AsyncNamedCache or an empty Optional if the underlying cache does not support async behaviour.

unpackBinary

protected Binary unpackBinary(com.oracle.coherence.grpc.messages.cache.v1.NamedCacheRequest request)

Return a BytesValue from a NamedCacheRequest converted to a Binary.

Parameters:

request - the NamedCacheRequest to get the BytesValue from

Returns:

the BytesValue from a NamedCacheRequest converted to a Binary