Package io.envoyproxy.envoy.service.tap.v2alpha

Class TapSinkServiceGrpc.TapSinkServiceStub

java.lang.Object
io.grpc.stub.AbstractStub<S>
io.grpc.stub.AbstractAsyncStub<TapSinkServiceGrpc.TapSinkServiceStub>
io.envoyproxy.envoy.service.tap.v2alpha.TapSinkServiceGrpc.TapSinkServiceStub
Enclosing class:
TapSinkServiceGrpc
public static final class TapSinkServiceGrpc.TapSinkServiceStub extends io.grpc.stub.AbstractAsyncStub<TapSinkServiceGrpc.TapSinkServiceStub>
A stub to allow clients to do asynchronous rpc calls to service TapSinkService. 
 [#not-implemented-hide:] A tap service to receive incoming taps. Envoy will call
 StreamTaps to deliver captured taps to the server

  • Nested Class Summary

    Nested classes/interfaces inherited from class io.grpc.stub.AbstractStub

    io.grpc.stub.AbstractStub.StubFactory<T extends io.grpc.stub.AbstractStub<T>>

  • Method Summary

    Modifier and Type
    Method
    Description
    protected TapSinkServiceGrpc.TapSinkServiceStub
    build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
     
    io.grpc.stub.StreamObserver<StreamTapsRequest>
    streamTaps(io.grpc.stub.StreamObserver<StreamTapsResponse> responseObserver)
    Envoy will connect and send StreamTapsRequest messages forever.

    Methods inherited from class io.grpc.stub.AbstractAsyncStub

    newStub, newStub

    Methods inherited from class io.grpc.stub.AbstractStub

    getCallOptions, getChannel, withCallCredentials, withChannel, withCompression, withDeadline, withDeadlineAfter, withExecutor, withInterceptors, withMaxInboundMessageSize, withMaxOutboundMessageSize, withOption, withWaitForReady

    Methods inherited from class java.lang.Object

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

  • Method Details

    • build

      protected TapSinkServiceGrpc.TapSinkServiceStub build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
      Specified by:
      build in class io.grpc.stub.AbstractStub<TapSinkServiceGrpc.TapSinkServiceStub>

    • streamTaps

      public io.grpc.stub.StreamObserver<StreamTapsRequest> streamTaps(io.grpc.stub.StreamObserver<StreamTapsResponse> responseObserver)
       Envoy will connect and send StreamTapsRequest messages forever. It does not expect any
 response to be sent as nothing would be done in the case of failure. The server should
 disconnect if it expects Envoy to reconnect.