File tree Expand file tree Collapse file tree 1 file changed +26
-5
lines changed Expand file tree Collapse file tree 1 file changed +26
-5
lines changed Original file line number Diff line number Diff line change 1212 DummyFluentd . new
1313 }
1414
15- let ( :logger ) {
15+ let ( :internal_logger ) {
1616 @logger_io = StringIO . new
17- logger = ::Logger . new ( @logger_io )
18- Fluent ::Logger ::FluentLogger . new ( 'logger-test' , {
17+ ::Logger . new ( @logger_io )
18+ }
19+
20+ let ( :logger_config ) {
21+ {
1922 :host => 'localhost' ,
2023 :port => fluentd . port ,
21- :logger => logger ,
24+ :logger => internal_logger ,
2225 :buffer_overflow_handler => buffer_overflow_handler
23- } )
26+ }
27+ }
28+
29+ let ( :logger ) {
30+ Fluent ::Logger ::FluentLogger . new ( 'logger-test' , logger_config )
31+ }
32+
33+ let ( :logger_with_nanosec ) {
34+ Fluent ::Logger ::FluentLogger . new ( 'logger-test' , logger_config . merge ( :nanosecond_precision => true ) )
2435 }
2536
2637 let ( :buffer_overflow_handler ) { nil }
6576 expect ( logger . pending_bytesize ) . to eq 0
6677 }
6778
79+ if defined? ( Fluent ::EventTime )
80+ it ( 'success with nanosecond' ) {
81+ expect ( logger_with_nanosec . pending_bytesize ) . to eq 0
82+ expect ( logger_with_nanosec . post ( 'tag' , { 'a' => 'b' } ) ) . to be true
83+ fluentd . wait_transfer
84+ expect ( fluentd . queue . last ) . to eq [ 'logger-test.tag' , { 'a' => 'b' } ]
85+ expect ( fluentd . output . emits . first [ 1 ] ) . to be_a_kind_of ( Fluent ::EventTime )
86+ }
87+ end
88+
6889 it ( 'close after post' ) {
6990 expect ( logger ) . to be_connect
7091 logger . close
You can’t perform that action at this time.
0 commit comments