class RubyEventStore::InstrumentedRepository
Attributes
Public Class Methods
Source
# File lib/ruby_event_store/instrumented_repository.rb, line 5 def initialize(repository, instrumentation) @repository = repository @instrumentation = instrumentation end
Public Instance Methods
Source
# File lib/ruby_event_store/instrumented_repository.rb, line 10 def append_to_stream(records, stream, expected_version) instrumentation.instrument("append_to_stream.repository.rails_event_store", events: records, stream: stream) do repository.append_to_stream(records, stream, expected_version) end end
Source
# File lib/ruby_event_store/instrumented_repository.rb, line 34 def count(specification) instrumentation.instrument("count.repository.rails_event_store", specification: specification) do repository.count(specification) end end
Source
# File lib/ruby_event_store/instrumented_repository.rb, line 22 def delete_stream(stream) instrumentation.instrument("delete_stream.repository.rails_event_store", stream: stream) do repository.delete_stream(stream) end end
Source
# File lib/ruby_event_store/instrumented_repository.rb, line 16 def link_to_stream(event_ids, stream, expected_version) instrumentation.instrument("link_to_stream.repository.rails_event_store", event_ids: event_ids, stream: stream) do repository.link_to_stream(event_ids, stream, expected_version) end end
Source
# File lib/ruby_event_store/instrumented_repository.rb, line 52 def method_missing(method_name, *arguments, **keyword_arguments, &block) if respond_to?(method_name) repository.public_send(method_name, *arguments, **keyword_arguments, &block) else super end end
Calls superclass method
Source
# File lib/ruby_event_store/instrumented_repository.rb, line 28 def read(specification) instrumentation.instrument("read.repository.rails_event_store", specification: specification) do repository.read(specification) end end
Source
# File lib/ruby_event_store/instrumented_repository.rb, line 60 def respond_to_missing?(method_name, _include_private) repository.respond_to?(method_name) end
Source
# File lib/ruby_event_store/instrumented_repository.rb, line 46 def streams_of(event_id) instrumentation.instrument("streams_of.repository.rails_event_store", event_id: event_id) do repository.streams_of(event_id) end end
Source
# File lib/ruby_event_store/instrumented_repository.rb, line 40 def update_messages(messages) instrumentation.instrument("update_messages.repository.rails_event_store", messages: messages) do repository.update_messages(messages) end end