Commit a88910e7 authored by Paul Asmuth's avatar Paul Asmuth
Browse files

fn-feedtail: --print_time flag

parent 05ba0dd0
Loading
Loading
Loading
Loading
+15 −1
Original line number Diff line number Diff line
@@ -86,6 +86,15 @@ int main(int argc, const char** argv) {
      "max_spread_secs",
      "<num>");

  flags.defineFlag(
      "print_time",
      fnord::cli::FlagParser::T_SWITCH,
      false,
      NULL,
      NULL,
      "print_time",
      "");

  flags.defineFlag(
      "loglevel",
      fnord::cli::FlagParser::T_STRING,
@@ -114,6 +123,7 @@ int main(int argc, const char** argv) {
  size_t buffer_size = flags.getInt("buffer_size");
  size_t commit_size = flags.getInt("commit_size");
  size_t max_spread_secs = flags.getInt("max_spread_secs");
  size_t print_time = flags.isSet("print_time");

  /* set up input feed reader */
  feeds::RemoteFeedReader feed_reader(&rpc_client);
@@ -177,8 +187,12 @@ int main(int argc, const char** argv) {
        break;
      }

      if (print_time) {
        fnord::iputs("[$0] $1", entry.get().time, entry.get().data);
      } else {
        fnord::iputs("$0", entry.get().data);
      }
    }

    if (flags.isSet("statefile")) {
      auto stream_offsets = feed_reader.streamOffsets();