lib/rflow/components/log.rb in rflow-1.3.0 vs lib/rflow/components/log.rb in rflow-1.3.1
- old
+ new
@@ -1,24 +1,63 @@
class RFlow
+ # @!parse
+ # class Message
+ # class Data
+ # # RFlow format defined for log messages which can be emitted by components.
+ # # Of course the real class is {RFlow::Message}
+ # # with type +RFlow::Message::Data::Log+.
+ # class Log
+ # # @!attribute timestamp
+ # # The timestamp of the log, in ms since epoch.
+ # # @return [Integer]
+ #
+ # # @!attribute level
+ # # The log level (INFO, WARN, ERROR, etc.).
+ # # @return [String]
+ #
+ # # @!attribute text
+ # # The text of the log message.
+ # # @return [String]
+ #
+ # # Just here to force Yard to create documentation.
+ # # @!visibility private
+ # def initialize; end
+ # end
+ # end
+ # end
+
+ # Components.
module Components
+ # @!visibility private
module Log
+ # @!visibility private
module Extensions
+ # @!visibility private
module LogExtension
+ # @!visibility private
def self.extended(base_data)
base_data.data_object ||= {'timestamp' => 0, 'level' => 'INFO', 'text' => ''}
end
+ # @!visibility private
def timestamp; data_object['timestamp']; end
+ # @!visibility private
def timestamp=(new_timestamp); data_object['timestamp'] = new_timestamp; end
+ # @!visibility private
def level; data_object['level']; end
+ # @!visibility private
def level=(new_level); data_object['level'] = new_level; end
+ # @!visibility private
def text; data_object['text']; end
+ # @!visibility private
def text=(new_text); data_object['text'] = new_text; end
end
end
+ # @!visibility private
SCHEMA_DIRECTORY = ::File.expand_path(::File.join(::File.dirname(__FILE__), '..', '..', '..', 'schema'))
+ # @!visibility private
SCHEMA_FILES = {
'log.avsc' => 'RFlow::Message::Data::Log',
}
SCHEMA_FILES.each do |file_name, data_type_name|