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

Class ProxyServiceChannel

java.lang.Object

com.oracle.coherence.grpc.proxy.common.ProxyServiceChannel

All Implemented Interfaces:

io.grpc.stub.StreamObserver<com.oracle.coherence.grpc.messages.proxy.v1.ProxyRequest>

public class ProxyServiceChannel
extends Object
implements io.grpc.stub.StreamObserver<com.oracle.coherence.grpc.messages.proxy.v1.ProxyRequest>

A bidirectional gRPC channel that handles requests for a gRPC proxy and sends responses back down the channel.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	ProxyServiceChannel.AsyncWrapper	An async wrapper around a StreamObserver.
protected class	ProxyServiceChannel.ForwardingStreamObserver<Resp extends com.google.protobuf.Message>	A StreamObserver used to handle responses from the GrpcServiceProtocol and convert them to a ProxyResponse to send down the channel.

Constructor Summary

Constructors

Modifier	Constructor	Description
	ProxyServiceChannel(GrpcService service, io.grpc.stub.StreamObserver<com.oracle.coherence.grpc.messages.proxy.v1.ProxyResponse> observer)	Create a ProxyServiceChannel.
protected	ProxyServiceChannel(GrpcService service, io.grpc.stub.StreamObserver<com.oracle.coherence.grpc.messages.proxy.v1.ProxyResponse> observer, Supplier<Member> memberSupplier)	Create a ProxyServiceChannel.

Method Summary

Modifier and Type	Method	Description
protected void	assertInit()	Assert that this channel has received an InitRequest.
protected io.grpc.stub.StreamObserver<com.oracle.coherence.grpc.messages.proxy.v1.ProxyRequest>	async(Executor executor)	Return an async wrapper around this channel.
Serializer	getSerializer()	Return the serializer being used by the protocol.
protected void	init(long nId, com.oracle.coherence.grpc.messages.proxy.v1.InitRequest request)	Initialise this channel.
protected static Optional<GrpcServiceProtocol>	loadProtocol(String sProtocol)	Load the requested GrpcServiceProtocol.
void	onCompleted()
void	onError(Throwable t)
void	onNext(com.oracle.coherence.grpc.messages.proxy.v1.ProxyRequest request)
protected void	sendError(long nId, Throwable thrown)	Send an error message down the channel.

Methods inherited from class java.lang.Object

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

Constructor Details

ProxyServiceChannel

public ProxyServiceChannel(GrpcService service,
 io.grpc.stub.StreamObserver<com.oracle.coherence.grpc.messages.proxy.v1.ProxyResponse> observer)

Create a ProxyServiceChannel.

Parameters:

service - the parent GrpcService

observer - the StreamObserver to send responses to

ProxyServiceChannel

protected ProxyServiceChannel(GrpcService service,
 io.grpc.stub.StreamObserver<com.oracle.coherence.grpc.messages.proxy.v1.ProxyResponse> observer,
 Supplier<Member> memberSupplier)

Create a ProxyServiceChannel.

Parameters:

service - the parent GrpcService

observer - the StreamObserver to send responses to

memberSupplier - a Supplier to supply the local Member

Method Details

onNext

public void onNext(com.oracle.coherence.grpc.messages.proxy.v1.ProxyRequest request)

Specified by:

onNext in interface io.grpc.stub.StreamObserver<com.oracle.coherence.grpc.messages.proxy.v1.ProxyRequest>

onError

public void onError(Throwable t)

Specified by:

onError in interface io.grpc.stub.StreamObserver<com.oracle.coherence.grpc.messages.proxy.v1.ProxyRequest>

onCompleted

public void onCompleted()

Specified by:

onCompleted in interface io.grpc.stub.StreamObserver<com.oracle.coherence.grpc.messages.proxy.v1.ProxyRequest>

getSerializer

public Serializer getSerializer()

Return the serializer being used by the protocol.

Returns:

the serializer being used by the protocol

async

protected io.grpc.stub.StreamObserver<com.oracle.coherence.grpc.messages.proxy.v1.ProxyRequest> async(Executor executor)

Return an async wrapper around this channel.

Parameters:

executor - the Executor to use to execute tasks

Returns:

an async wrapper around this channel

init

protected void init(long nId,
 com.oracle.coherence.grpc.messages.proxy.v1.InitRequest request)

Initialise this channel.

Parameters:

nId - the message id of the init request

request - the InitRequest to use for initialisation

assertInit

protected void assertInit()

Assert that this channel has received an InitRequest.

Throws:

IllegalStateException - if this channel has not been initialized

sendError

protected void sendError(long nId,
 Throwable thrown)

Send an error message down the channel.

Parameters:

nId - the identifier of the request that the error corresponds to

thrown - the error to send

loadProtocol

protected static Optional<GrpcServiceProtocol> loadProtocol(String sProtocol)

Load the requested GrpcServiceProtocol.

Parameters:

sProtocol - the name of the protocol to load

Returns:

the requested protocol, or an empty optional if the protocol cannot be loaded