handle_record

in src/fluent-plugin-mdsd/lib/fluent/plugin/out_mdsd.rb [102:111]

• 9 lines of code
• 3 McCabe index (conditional complexity)

        def handle_record(tag, record)
            mdsdSource = @mdsdMsgMaker.create_mdsd_source(tag, @mdsdTagPatterns)
            dataStr = @mdsdMsgMaker.get_schema_value_str(record)
            return if record_too_large?(dataStr, mdsdSource)
            if not @mdsdLogger.SendDjson(mdsdSource, dataStr)
                raise "Sending data (tag=#{tag}) to mdsd failed"
            end
            @log.trace "source='#{mdsdSource}', data='#{dataStr}'"
        end