Package io.envoyproxy.envoy.service.accesslog.v2

Class AccessLogServiceGrpc.AccessLogServiceStub

java.lang.Object
io.grpc.stub.AbstractStub<S>
io.grpc.stub.AbstractAsyncStub<AccessLogServiceGrpc.AccessLogServiceStub>
io.envoyproxy.envoy.service.accesslog.v2.AccessLogServiceGrpc.AccessLogServiceStub
Enclosing class:
AccessLogServiceGrpc
public static final class AccessLogServiceGrpc.AccessLogServiceStub extends io.grpc.stub.AbstractAsyncStub<AccessLogServiceGrpc.AccessLogServiceStub>
A stub to allow clients to do asynchronous rpc calls to service AccessLogService. 
 Service for streaming access logs from Envoy to an access log 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 AccessLogServiceGrpc.AccessLogServiceStub
    build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
     
    io.grpc.stub.StreamObserver<StreamAccessLogsMessage>
    streamAccessLogs(io.grpc.stub.StreamObserver<StreamAccessLogsResponse> responseObserver)
    Envoy will connect and send StreamAccessLogsMessage 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 AccessLogServiceGrpc.AccessLogServiceStub build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
      Specified by:
      build in class io.grpc.stub.AbstractStub<AccessLogServiceGrpc.AccessLogServiceStub>

    • streamAccessLogs

      public io.grpc.stub.StreamObserver<StreamAccessLogsMessage> streamAccessLogs(io.grpc.stub.StreamObserver<StreamAccessLogsResponse> responseObserver)
       Envoy will connect and send StreamAccessLogsMessage 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. In the future we may decide to add a different
 API for "critical" access logs in which Envoy will buffer access logs for some period of time
 until it gets an ACK so it could then retry. This API is designed for high throughput with the
 expectation that it might be lossy.