Package io.grpc.alts.internal
Class AltsHandshakerStub
java.lang.Object
io.grpc.alts.internal.AltsHandshakerStub
An interface to the ALTS handshaker service.
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescriptionprivate class
private static class
-
Field Summary
FieldsModifier and TypeFieldDescriptionprivate final AtomicReference
<AltsHandshakerStub.ThrowableInfo> private static final long
private final io.grpc.stub.StreamObserver
<HandshakerResp> private final ArrayBlockingQueue
<com.google.common.base.Optional<HandshakerResp>> private final HandshakerServiceGrpc.HandshakerServiceStub
private io.grpc.stub.StreamObserver
<HandshakerReq> -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionvoid
close()
Close the connection.private void
Create a new writer if the writer is null.(package private) io.grpc.stub.StreamObserver
<HandshakerResp> private void
Throw exception if there is an outstanding exception.send
(HandshakerReq req) Send a handshaker request and return the handshaker response.
-
Field Details
-
reader
-
writer
-
serviceStub
-
responseQueue
-
exceptionMessage
-
HANDSHAKE_RPC_DEADLINE_SECS
private static final long HANDSHAKE_RPC_DEADLINE_SECS- See Also:
-
-
Constructor Details
-
AltsHandshakerStub
AltsHandshakerStub(HandshakerServiceGrpc.HandshakerServiceStub serviceStub) -
AltsHandshakerStub
AltsHandshakerStub() -
AltsHandshakerStub
AltsHandshakerStub(io.grpc.stub.StreamObserver<HandshakerReq> writer)
-
-
Method Details
-
getReaderForTest
io.grpc.stub.StreamObserver<HandshakerResp> getReaderForTest() -
send
Send a handshaker request and return the handshaker response.- Throws:
InterruptedException
IOException
-
createWriterIfNull
private void createWriterIfNull()Create a new writer if the writer is null. -
maybeThrowIoException
Throw exception if there is an outstanding exception.- Throws:
IOException
-
close
public void close()Close the connection.
-