Sha256: a0a3c207fb41dfa57d7a15ab0272c5d7e75961f12be71ee76c7cdd048657e22d
Contents?: true
Size: 934 Bytes
Versions: 5
Compression:
Stored size: 934 Bytes
Contents
module PgEventstore
class EventsProcessor
include PgEventstore::Extensions::CallbacksExtension
extend Forwardable
# _@param_ `handler`
%a{rbs:test:skip} def initialize: (_RawEventHandler handler, graceful_shutdown_timeout: Float | Integer) -> void
# _@param_ `raw_events`
def feed: (::Array[::Hash[untyped, untyped]] raw_events) -> void
def events_left_in_chunk: () -> Integer
def clear_chunk: () -> void
# _@param_ `raw_event`
def process_event: (::Hash[untyped, untyped] raw_event) -> void
def attach_runner_callbacks: () -> void
def process_async: () -> void
def after_runner_died: (StandardError error) -> void
def before_runner_restored: () -> void
def change_state: (*untyped args, **untyped kwargs) -> void
# _@param_ `raw_event`
def global_position: (::Hash[untyped, untyped] raw_event) -> Integer
def define_callback: () -> void
end
end
Version data entries
5 entries across 5 versions & 1 rubygems