Class: Gruf::Interceptors::ClientInterceptor
- Inherits:
-
GRPC::ClientInterceptor
- Object
- GRPC::ClientInterceptor
- Gruf::Interceptors::ClientInterceptor
- Includes:
- Loggable
- Defined in:
- lib/gruf/interceptors/client_interceptor.rb
Overview
Intercepts outbound client requests to provide a unified interface and request context
Instance Method Summary collapse
-
#bidi_streamer(requests: nil, call: nil, method: nil, metadata: nil) ⇒ Object
Call the interceptor from the bidi_streamer call.
-
#call(request_context:) ⇒ Object
Handles interception of outbound calls.
-
#client_streamer(requests: nil, call: nil, method: nil, metadata: nil) ⇒ Object
Call the interceptor from the client_streamer call.
-
#request_response(request: nil, call: nil, method: nil, metadata: nil) ⇒ Object
Call the interceptor from the request_response call.
-
#server_streamer(request: nil, call: nil, method: nil, metadata: nil) ⇒ Object
Call the interceptor from the server_streamer call.
Methods included from Loggable
Instance Method Details
#bidi_streamer(requests: nil, call: nil, method: nil, metadata: nil) ⇒ Object
Call the interceptor from the bidi_streamer call
111 112 113 114 115 116 117 118 119 120 121 122 |
# File 'lib/gruf/interceptors/client_interceptor.rb', line 111 def bidi_streamer(requests: nil, call: nil, method: nil, metadata: nil) rc = Gruf::Outbound::RequestContext.new( type: :bidi_streamer, requests: requests, call: call, method: method, metadata: ) call(request_context: rc) do yield end end |
#call(request_context:) ⇒ Object
Handles interception of outbound calls. Implement this in your derivative interceptor implementation.
32 33 34 35 |
# File 'lib/gruf/interceptors/client_interceptor.rb', line 32 def call(request_context:) logger.debug "Logging client interceptor for request: #{request_context.method}" yield end |
#client_streamer(requests: nil, call: nil, method: nil, metadata: nil) ⇒ Object
Call the interceptor from the client_streamer call
68 69 70 71 72 73 74 75 76 77 78 79 |
# File 'lib/gruf/interceptors/client_interceptor.rb', line 68 def client_streamer(requests: nil, call: nil, method: nil, metadata: nil) rc = Gruf::Outbound::RequestContext.new( type: :client_streamer, requests: requests, call: call, method: method, metadata: ) call(request_context: rc) do yield end end |
#request_response(request: nil, call: nil, method: nil, metadata: nil) ⇒ Object
Call the interceptor from the request_response call
46 47 48 49 50 51 52 53 54 55 56 57 |
# File 'lib/gruf/interceptors/client_interceptor.rb', line 46 def request_response(request: nil, call: nil, method: nil, metadata: nil) rc = Gruf::Outbound::RequestContext.new( type: :request_response, requests: [request], call: call, method: method, metadata: ) call(request_context: rc) do yield end end |
#server_streamer(request: nil, call: nil, method: nil, metadata: nil) ⇒ Object
Call the interceptor from the server_streamer call
90 91 92 93 94 95 96 97 98 99 100 101 |
# File 'lib/gruf/interceptors/client_interceptor.rb', line 90 def server_streamer(request: nil, call: nil, method: nil, metadata: nil) rc = Gruf::Outbound::RequestContext.new( type: :server_streamer, requests: [request], call: call, method: method, metadata: ) call(request_context: rc) do yield end end |