module EntitySnapshot::Postgres::StreamName

Public Class Methods

category(entity_class, specifier=nil) click to toggle source
# File lib/entity_snapshot/postgres/stream_name.rb, line 12
def self.category(entity_class, specifier=nil)
  *, entity_class_name = entity_class.name.split('::')

  entity_class_name = Casing::Camel.(entity_class_name)

  if specifier.nil?
    entity_class_name
  else
    "#{entity_class_name}#{specifier}"
  end
end

Public Instance Methods

snapshot_stream_name(id, category=nil) click to toggle source
# File lib/entity_snapshot/postgres/stream_name.rb, line 6
def snapshot_stream_name(id, category=nil)
  category ||= self.category

  Messaging::StreamName.stream_name(id, category, type: 'snapshot')
end