src/journal-remote/journal-remote-write.h

   1 /* SPDX-License-Identifier: LGPL-2.1+ */
   2 #pragma once
   3
   4 /***
   5   Copyright © 2014 Zbigniew Jędrzejewski-Szmek
   6 ***/
   7
   8 #include "journal-file.h"
   9 #include "journal-importer.h"
  10
  11 typedef struct RemoteServer RemoteServer;
  12
  13 typedef struct Writer {
  14         JournalFile *journal;
  15         JournalMetrics metrics;
  16
  17         MMapCache *mmap;
  18         RemoteServer *server;
  19         char *hashmap_key;
  20
  21         uint64_t seqnum;
  22
  23         int n_ref;
  24 } Writer;
  25
  26 Writer* writer_new(RemoteServer* server);
  27 Writer* writer_free(Writer *w);
  28
  29 Writer* writer_ref(Writer *w);
  30 Writer* writer_unref(Writer *w);
  31
  32 DEFINE_TRIVIAL_CLEANUP_FUNC(Writer*, writer_unref);
  33
  34 int writer_write(Writer *s,
  35                  struct iovec_wrapper *iovw,
  36                  dual_timestamp *ts,
  37                  bool compress,
  38                  bool seal);
  39
  40 typedef enum JournalWriteSplitMode {
  41         JOURNAL_WRITE_SPLIT_NONE,
  42         JOURNAL_WRITE_SPLIT_HOST,
  43         _JOURNAL_WRITE_SPLIT_MAX,
  44         _JOURNAL_WRITE_SPLIT_INVALID = -1
  45 } JournalWriteSplitMode;