streaming log reader plugin implementation