every-minute-test.js 4.0 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485
  1. var moment = require('moment');
  2. // var rotatingLogStream = require('../FileStreamRotator').getStream({filename:"/tmp/testlog-%DATE%.log", frequency:"1m", verbose: true});
  3. // var rotatingLogStream = require('../FileStreamRotator').getStream({filename:"/tmp/testlog-%DATE%.log", frequency:"custom", verbose: true, date_format: "YYYY-MM-DD.HH.mm"});
  4. // var rotatingLogStream = require('../FileStreamRotator').getStream({filename:"/tmp/testlog-%DATE%.log", frequency:"dont-rotate", verbose: true, date_format: "YYYY-MM-DD.HH.mm.ss"});
  5. // var rotatingLogStream = require('../FileStreamRotator').getStream({filename:"/tmp/testlog-%DATE%.log", frequency:"daily", verbose: true, date_format: "YYYYMMDD"});
  6. // var rotatingLogStream = require('../FileStreamRotator').getStream({filename:"/tmp/testlog-%DATE%.log", frequency:"daily", verbose: true});
  7. const symLinkName = "tail.log"
  8. var rotatingLogStream = require('../FileStreamRotator').getStream({
  9. filename: "logs/1m/testlog-%DATE%",
  10. frequency: "1m",
  11. verbose: true,
  12. date_format: "YYYY-MM-DD.HH.mm",
  13. size: "100k",
  14. max_logs: "10",
  15. audit_file: "/tmp/audit.json",
  16. end_stream: false,
  17. utc: true,
  18. extension: ".log",
  19. create_symlink: true,
  20. watch_log: true,
  21. // symlink_name: "tail.log"
  22. symlink_name: symLinkName
  23. });
  24. rotatingLogStream.on("error", function () {
  25. console.log(Date.now(), Date(), "stream error", arguments)
  26. })
  27. rotatingLogStream.on("close", function () {
  28. console.log(Date.now(), Date(), "stream closed")
  29. })
  30. rotatingLogStream.on("finish", function () {
  31. console.log(Date.now(), Date(), "stream finished")
  32. })
  33. rotatingLogStream.on("rotate", function (oldFile, newFile) {
  34. console.log(Date.now(), Date(), "stream rotated", oldFile, newFile);
  35. })
  36. rotatingLogStream.on("open", function (fd) {
  37. console.log(Date.now(), Date(), "stream open", fd);
  38. })
  39. rotatingLogStream.on("new", function (newFile) {
  40. console.log(Date.now(), Date(), "stream new", newFile);
  41. })
  42. rotatingLogStream.on("logRemoved", function (newFile) {
  43. console.log(Date.now(), Date(), "stream logRemoved", newFile);
  44. })
  45. // console.log(rotatingLogStream.on, rotatingLogStream.end, rotatingLogStream)
  46. // var rotatingLogStream1 = require('../FileStreamRotator').getStream({
  47. // filename: "/tmp/a/logs/1m-1/testlog-%DATE%.log",
  48. // frequency: "1m",
  49. // verbose: true,
  50. // date_format: "YYYY-MM-DD.HH.mm",
  51. // size: "50k",
  52. // max_logs: "10",
  53. // audit_file: "/tmp/audit-1.json",
  54. // end_stream: false
  55. // });
  56. var counter = 0;
  57. var i = setInterval(function () {
  58. counter++;
  59. rotatingLogStream.write(Date() + "\t" + "testing 1234567890-testing 1234567890-testing 1234567890-testing 1234567890-testing 1234567890-testing 1234567890-testing 1234567890-testing 1234567890-testing 1234567890-testing 1234567890-testing 1234567890-testing 1234567890-testing 1234567890-testing 1234567890-testing 1234567890-testing 1234567890-testing 1234567890-testing 1234567890-testing 1234567890-testing 1234567890-testing 1234567890-testing 1234567890-testing 1234567890-testing 1234567890-testing 1234567890-testing 1234567890-testing 1234567890-testing 1234567890-testing 1234567890-testing 1234567890\n")
  60. // rotatingLogStream1.write(Date() + "\t" + "testing 1234567890-testing 1234567890-testing 1234567890-testing 1234567890-testing 1234567890-testing 1234567890-testing 1234567890-testing 1234567890-testing 1234567890-testing 1234567890-testing 1234567890-testing 1234567890-testing 1234567890-testing 1234567890-testing 1234567890-testing 1234567890-testing 1234567890-testing 1234567890-testing 1234567890-testing 1234567890-testing 1234567890-testing 1234567890-testing 1234567890-testing 1234567890-testing 1234567890-testing 1234567890-testing 1234567890-testing 1234567890-testing 1234567890-testing 1234567890\n")
  61. if (counter == 5000) {
  62. clearInterval(i);
  63. rotatingLogStream.end("end\n");
  64. // rotatingLogStream1.end("end\n");
  65. }
  66. }, 10);
  67. // var i = setTimeout(function () {
  68. // rotatingLogStream.emit("createLog")
  69. // }, 10000);