module AggregateStreams::Controls::MessageData::Metadata
Public Class Methods
causation_message_global_position()
click to toggle source
# File lib/aggregate_streams/controls/message_data/metadata.rb, line 115 def self.causation_message_global_position Messaging::Controls::Metadata.causation_message_global_position end
causation_message_position()
click to toggle source
# File lib/aggregate_streams/controls/message_data/metadata.rb, line 111 def self.causation_message_position Messaging::Controls::Metadata.causation_message_position end
causation_message_stream_name()
click to toggle source
# File lib/aggregate_streams/controls/message_data/metadata.rb, line 107 def self.causation_message_stream_name Messaging::Controls::Metadata.causation_message_stream_name end
correlation_stream_name()
click to toggle source
# File lib/aggregate_streams/controls/message_data/metadata.rb, line 119 def self.correlation_stream_name Messaging::Controls::Metadata.correlation_stream_name end
example(category: nil, stream_id: nil, stream_name: nil, position: nil, global_position: nil, causation_message_stream_name: nil, causation_message_position: nil, causation_message_global_position: nil, correlation_stream_name: nil, reply_stream_name: nil, properties: nil, local_properties: nil, schema_version: nil)
click to toggle source
# File lib/aggregate_streams/controls/message_data/metadata.rb, line 5 def self.example(category: nil, stream_id: nil, stream_name: nil, position: nil, global_position: nil, causation_message_stream_name: nil, causation_message_position: nil, causation_message_global_position: nil, correlation_stream_name: nil, reply_stream_name: nil, properties: nil, local_properties: nil, schema_version: nil) if stream_name == :none stream_name = nil else stream_name ||= stream_name(id: stream_id, category: category) end if position == :none position = nil else position ||= self.position end if global_position == :none global_position = nil else global_position ||= self.global_position end if causation_message_stream_name == :none causation_message_stream_name = nil else causation_message_stream_name ||= self.causation_message_stream_name end if causation_message_position == :none causation_message_position = nil else causation_message_position ||= self.causation_message_position end if causation_message_global_position == :none causation_message_global_position = nil else causation_message_global_position ||= self.causation_message_global_position end if correlation_stream_name == :none correlation_stream_name = nil else correlation_stream_name ||= Metadata.correlation_stream_name end if reply_stream_name == :none reply_stream_name = nil else reply_stream_name ||= Metadata.reply_stream_name end if properties == :none properties = nil else properties ||= self.properties end if local_properties == :none local_properties = nil else local_properties ||= self.local_properties end if schema_version == :none schema_version = nil else schema_version ||= Metadata.schema_version end metadata = { :stream_name => stream_name, :position => position, :global_position => global_position, :causation_message_stream_name => causation_message_stream_name, :causation_message_position => causation_message_position, :causation_message_global_position => causation_message_global_position, :correlation_stream_name => correlation_stream_name, :reply_stream_name => reply_stream_name, :properties => properties, :local_properties => local_properties, :schema_version => schema_version } metadata.delete_if { |_, v| v.nil? } metadata end
global_position()
click to toggle source
# File lib/aggregate_streams/controls/message_data/metadata.rb, line 103 def self.global_position Position::Global.example end
local_properties()
click to toggle source
# File lib/aggregate_streams/controls/message_data/metadata.rb, line 131 def self.local_properties Messaging::Controls::LocalProperties.example end
position()
click to toggle source
# File lib/aggregate_streams/controls/message_data/metadata.rb, line 99 def self.position Position.example end
properties()
click to toggle source
# File lib/aggregate_streams/controls/message_data/metadata.rb, line 127 def self.properties Messaging::Controls::Properties.example end
reply_stream_name()
click to toggle source
# File lib/aggregate_streams/controls/message_data/metadata.rb, line 123 def self.reply_stream_name Messaging::Controls::Metadata.reply_stream_name end
schema_version()
click to toggle source
# File lib/aggregate_streams/controls/message_data/metadata.rb, line 135 def self.schema_version Messaging::Controls::Metadata.schema_version end
stream_name(**args)
click to toggle source
# File lib/aggregate_streams/controls/message_data/metadata.rb, line 95 def self.stream_name(**args) StreamName.example(**args) end