Class: StatelyDB::Common::ErrorInterceptor

Inherits:
GRPC::ClientInterceptor
  • Object
show all
Defined in:
lib/common/error_interceptor.rb

Overview

GRPC interceptor to convert errors to StatelyDB::Error

Instance Method Summary collapse

Instance Method Details

#bidi_streamer(requests:, call:, method:, metadata:) ⇒ Object

bidirectional streaming interceptor



32
33
34
35
36
 
# File 'lib/common/error_interceptor.rb', line 32

def bidi_streamer(requests:, call:, method:, metadata:) # rubocop:disable Lint/UnusedMethodArgument
  yield
rescue Exception => e
  raise StatelyDB::Error.from(e)
end

#client_streamer(requests:, call:, method:, metadata:) ⇒ Object

client streaming interceptor



18
19
20
21
22
 
# File 'lib/common/error_interceptor.rb', line 18

def client_streamer(requests:, call:, method:, metadata:) # rubocop:disable Lint/UnusedMethodArgument
  yield
rescue Exception => e
  raise StatelyDB::Error.from(e)
end

#request_response(request:, call:, method:, metadata:) ⇒ Object

client unary interceptor



11
12
13
14
15
 
# File 'lib/common/error_interceptor.rb', line 11

def request_response(request:, call:, method:, metadata:) # rubocop:disable Lint/UnusedMethodArgument
  yield
rescue Exception => e
  raise StatelyDB::Error.from(e)
end

#server_streamer(request:, call:, method:, metadata:) ⇒ Object

server streaming interceptor



25
26
27
28
29
 
# File 'lib/common/error_interceptor.rb', line 25

def server_streamer(request:, call:, method:, metadata:) # rubocop:disable Lint/UnusedMethodArgument
  yield
rescue Exception => e
  raise StatelyDB::Error.from(e)
end