lib/fluent/plugin/out_newrelic.rb in fluent-plugin-newrelic-0.2.3 vs lib/fluent/plugin/out_newrelic.rb in fluent-plugin-newrelic-0.2.4
- old
+ new
@@ -77,18 +77,18 @@
packaged
end
def write(chunk)
payload = {
- 'logs' => [],
'common' => {
'attributes' => {
'plugin' => {
'type' => 'fluentd',
'version' => NewrelicFluentdOutput::VERSION,
}
}
- }
+ },
+ 'logs' => []
}
chunk.msgpack_each do |ts, record|
next unless record.is_a? Hash
next if record.empty?
payload['logs'].push(package_record(record, ts))