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
109 110 111 112 113 114 115 116 117 118 119 120 |
# File 'lib/gruf/interceptors/client_interceptor.rb', line 109 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.
30 31 32 33 |
# File 'lib/gruf/interceptors/client_interceptor.rb', line 30 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
66 67 68 69 70 71 72 73 74 75 76 77 |
# File 'lib/gruf/interceptors/client_interceptor.rb', line 66 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
44 45 46 47 48 49 50 51 52 53 54 55 |
# File 'lib/gruf/interceptors/client_interceptor.rb', line 44 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
88 89 90 91 92 93 94 95 96 97 98 99 |
# File 'lib/gruf/interceptors/client_interceptor.rb', line 88 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 |