Package io.envoyproxy.envoy.service.network_ext_proc.v3

Class NetworkExternalProcessorGrpc.NetworkExternalProcessorStub

java.lang.Object
io.grpc.stub.AbstractStub<S>
io.grpc.stub.AbstractAsyncStub<NetworkExternalProcessorGrpc.NetworkExternalProcessorStub>
io.envoyproxy.envoy.service.network_ext_proc.v3.NetworkExternalProcessorGrpc.NetworkExternalProcessorStub
Enclosing class:
NetworkExternalProcessorGrpc
public static final class NetworkExternalProcessorGrpc.NetworkExternalProcessorStub extends io.grpc.stub.AbstractAsyncStub<NetworkExternalProcessorGrpc.NetworkExternalProcessorStub>
A stub to allow clients to do asynchronous rpc calls to service NetworkExternalProcessor. 
 NetworkExternalProcessor service defines the contract between Envoy and
 external processing servers for L4 network traffic.

  • 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 NetworkExternalProcessorGrpc.NetworkExternalProcessorStub
    build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
     
    io.grpc.stub.StreamObserver<ProcessingRequest>
    process(io.grpc.stub.StreamObserver<ProcessingResponse> responseObserver)
    Process establishes a bidirectional stream between Envoy and the external processing server.

    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 NetworkExternalProcessorGrpc.NetworkExternalProcessorStub build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
      Specified by:
      build in class io.grpc.stub.AbstractStub<NetworkExternalProcessorGrpc.NetworkExternalProcessorStub>

    • process

      public io.grpc.stub.StreamObserver<ProcessingRequest> process(io.grpc.stub.StreamObserver<ProcessingResponse> responseObserver)
       Process establishes a bidirectional stream between Envoy and the external
 processing server. Envoy sends ProcessingRequests containing network data
 and the server responds with ProcessingResponses containing processing
 decisions and potentially modified data.
 The server should handle processing timeout properly to avoid blocking
 network traffic for extended periods. Any uncaught exceptions will
 be treated as errors and will terminate the stream.
 Implementation note: The server should process requests in the order
 they are received to maintain proper sequencing of network traffic.