Class: Gruf::Interceptors::ActiveRecord::ConnectionReset

Inherits:

ServerInterceptor

• Object
• Base
• ServerInterceptor
• Gruf::Interceptors::ActiveRecord::ConnectionReset

Defined in:

lib/gruf/interceptors/active_record/connection_reset.rb

Overview

Resets the ActiveRecord connection to maintain accurate connected state in the thread pool

Instance Attribute Summary

Attributes inherited from Base

#error, #options, #request

Instance Method Summary

• #call ⇒ Object

  Reset any ActiveRecord connections after a gRPC service is called.

Methods included from Errors::Helpers

#fail!

Methods inherited from Base

#initialize

Constructor Details

This class inherits a constructor from Gruf::Interceptors::Base

Instance Method Details

#call ⇒ Object

Reset any ActiveRecord connections after a gRPC service is called. Because of the way gRPC manages its connection pool, we need to ensure that this is done to properly

# File 'lib/gruf/interceptors/active_record/connection_reset.rb', line 29

def call
  ::ActiveRecord::Base.establish_connection if enabled? && !::ActiveRecord::Base.connection.active?

  yield
ensure
  ::ActiveRecord::Base.clear_active_connections! if enabled?
end