Class: RubyEventStore::Client
- Inherits:
-
Object
- Object
- RubyEventStore::Client
- Defined in:
- lib/ruby_event_store/client.rb
Defined Under Namespace
Classes: Page
Instance Method Summary collapse
- #append_to_stream(events, stream_name: GLOBAL_STREAM, expected_version: :any) ⇒ Object
- #delete_stream(stream_name) ⇒ Object
- #get_all_streams ⇒ Object
-
#initialize(repository:, event_broker: PubSub::Broker.new, page_size: PAGE_SIZE, metadata_proc: nil, clock: ->{ Time.now.utc }) ⇒ Client
constructor
A new instance of Client.
- #link_to_stream(event_ids, stream_name:, expected_version: :any) ⇒ Object
- #publish_event(event, stream_name: GLOBAL_STREAM, expected_version: :any) ⇒ Object
- #publish_events(events, stream_name: GLOBAL_STREAM, expected_version: :any) ⇒ Object
- #read_all_streams_backward(start: :head, count: @page_size) ⇒ Object
- #read_all_streams_forward(start: :head, count: @page_size) ⇒ Object
- #read_event(event_id) ⇒ Object
- #read_events_backward(stream_name, start: :head, count: @page_size) ⇒ Object
- #read_events_forward(stream_name, start: :head, count: @page_size) ⇒ Object
- #read_stream_events_backward(stream_name) ⇒ Object
- #read_stream_events_forward(stream_name) ⇒ Object
- #subscribe(subscriber, event_types, &proc) ⇒ Object
- #subscribe_to_all_events(subscriber, &proc) ⇒ Object
Constructor Details
#initialize(repository:, event_broker: PubSub::Broker.new, page_size: PAGE_SIZE, metadata_proc: nil, clock: ->{ Time.now.utc }) ⇒ Client
Returns a new instance of Client.
3 4 5 6 7 8 9 10 11 12 13 |
# File 'lib/ruby_event_store/client.rb', line 3 def initialize(repository:, event_broker: PubSub::Broker.new, page_size: PAGE_SIZE, metadata_proc: nil, clock: ->{ Time.now.utc }) @repository = repository @event_broker = event_broker @page_size = page_size @metadata_proc = @clock = clock end |
Instance Method Details
#append_to_stream(events, stream_name: GLOBAL_STREAM, expected_version: :any) ⇒ Object
27 28 29 30 31 32 |
# File 'lib/ruby_event_store/client.rb', line 27 def append_to_stream(events, stream_name: GLOBAL_STREAM, expected_version: :any) events = normalize_to_array(events) events.each{|event| (event) } @repository.append_to_stream(events, stream_name, expected_version) :ok end |
#delete_stream(stream_name) ⇒ Object
39 40 41 42 43 |
# File 'lib/ruby_event_store/client.rb', line 39 def delete_stream(stream_name) raise IncorrectStreamData if stream_name.nil? || stream_name.empty? @repository.delete_stream(stream_name) :ok end |
#get_all_streams ⇒ Object
81 82 83 |
# File 'lib/ruby_event_store/client.rb', line 81 def get_all_streams @repository.get_all_streams end |
#link_to_stream(event_ids, stream_name:, expected_version: :any) ⇒ Object
34 35 36 37 |
# File 'lib/ruby_event_store/client.rb', line 34 def link_to_stream(event_ids, stream_name:, expected_version: :any) @repository.link_to_stream(event_ids, stream_name, expected_version) self end |
#publish_event(event, stream_name: GLOBAL_STREAM, expected_version: :any) ⇒ Object
23 24 25 |
# File 'lib/ruby_event_store/client.rb', line 23 def publish_event(event, stream_name: GLOBAL_STREAM, expected_version: :any) publish_events([event], stream_name: stream_name, expected_version: expected_version) end |
#publish_events(events, stream_name: GLOBAL_STREAM, expected_version: :any) ⇒ Object
15 16 17 18 19 20 21 |
# File 'lib/ruby_event_store/client.rb', line 15 def publish_events(events, stream_name: GLOBAL_STREAM, expected_version: :any) append_to_stream(events, stream_name: stream_name, expected_version: expected_version) events.each do |ev| @event_broker.notify_subscribers(ev) end :ok end |
#read_all_streams_backward(start: :head, count: @page_size) ⇒ Object
72 73 74 75 |
# File 'lib/ruby_event_store/client.rb', line 72 def read_all_streams_backward(start: :head, count: @page_size) page = Page.new(@repository, start, count) @repository.read_all_streams_backward(page.start, page.count) end |
#read_all_streams_forward(start: :head, count: @page_size) ⇒ Object
67 68 69 70 |
# File 'lib/ruby_event_store/client.rb', line 67 def read_all_streams_forward(start: :head, count: @page_size) page = Page.new(@repository, start, count) @repository.read_all_streams_forward(page.start, page.count) end |
#read_event(event_id) ⇒ Object
77 78 79 |
# File 'lib/ruby_event_store/client.rb', line 77 def read_event(event_id) @repository.read_event(event_id) end |
#read_events_backward(stream_name, start: :head, count: @page_size) ⇒ Object
51 52 53 54 55 |
# File 'lib/ruby_event_store/client.rb', line 51 def read_events_backward(stream_name, start: :head, count: @page_size) raise IncorrectStreamData if stream_name.nil? || stream_name.empty? page = Page.new(@repository, start, count) @repository.read_events_backward(stream_name, page.start, page.count) end |
#read_events_forward(stream_name, start: :head, count: @page_size) ⇒ Object
45 46 47 48 49 |
# File 'lib/ruby_event_store/client.rb', line 45 def read_events_forward(stream_name, start: :head, count: @page_size) raise IncorrectStreamData if stream_name.nil? || stream_name.empty? page = Page.new(@repository, start, count) @repository.read_events_forward(stream_name, page.start, page.count) end |
#read_stream_events_backward(stream_name) ⇒ Object
62 63 64 65 |
# File 'lib/ruby_event_store/client.rb', line 62 def read_stream_events_backward(stream_name) raise IncorrectStreamData if stream_name.nil? || stream_name.empty? @repository.read_stream_events_backward(stream_name) end |
#read_stream_events_forward(stream_name) ⇒ Object
57 58 59 60 |
# File 'lib/ruby_event_store/client.rb', line 57 def read_stream_events_forward(stream_name) raise IncorrectStreamData if stream_name.nil? || stream_name.empty? @repository.read_stream_events_forward(stream_name) end |
#subscribe(subscriber, event_types, &proc) ⇒ Object
85 86 87 88 89 |
# File 'lib/ruby_event_store/client.rb', line 85 def subscribe(subscriber, event_types, &proc) @event_broker.add_subscriber(subscriber, event_types).tap do |unsub| handle_subscribe(unsub, &proc) end end |
#subscribe_to_all_events(subscriber, &proc) ⇒ Object
91 92 93 94 95 |
# File 'lib/ruby_event_store/client.rb', line 91 def subscribe_to_all_events(subscriber, &proc) @event_broker.add_global_subscriber(subscriber).tap do |unsub| handle_subscribe(unsub, &proc) end end |