File tree 2 files changed +3
-2
lines changed
2 files changed +3
-2
lines changed Original file line number Diff line number Diff line change @@ -50,7 +50,7 @@ def decode(data, &block)
50
50
def encode ( event )
51
51
tag = event . get ( "tags" ) || "log"
52
52
epochtime = if @nanosecond_precision
53
- EventTime . new ( event . timestamp . to_i , event . timestamp . usec )
53
+ EventTime . new ( event . timestamp . to_i , event . timestamp . usec * 1000 )
54
54
else
55
55
event . timestamp . to_i
56
56
end
Original file line number Diff line number Diff line change 70
70
describe "event decoding with EventTime" do
71
71
72
72
let ( :tag ) { "mytag" }
73
- let ( :epochtime ) { LogStash ::Codecs ::Fluent ::EventTime . new ( event . timestamp . to_i , event . timestamp . usec ) }
73
+ let ( :epochtime ) { LogStash ::Codecs ::Fluent ::EventTime . new ( event . timestamp . to_i ,
74
+ event . timestamp . usec * 1000 ) }
74
75
let ( :data ) { LogStash ::Util . normalize ( event . to_hash ) }
75
76
let ( :message ) do
76
77
@packer . pack ( [ tag , epochtime , data . merge ( LogStash ::Event ::TIMESTAMP => event . timestamp . to_iso8601 ) ] )
You can’t perform that action at this time.
0 commit comments