TheHive-Project/elastic4play#46 Docs on migration streams configuration

thehive-backend/conf/reference.conf

@@ -118,3 +118,82 @@ dblist.name = dblist
 audit.name = audit
 # Name of the ElasticSearch type used to store attachment /!\ Don't change this value
 datastore.name = data
+
+migration {
+//  stream {
+//    # Initial size of buffers used in stream elements
+//    initial-input-buffer-size = 4
+//    # Maximum size of buffers used in stream elements
+//    max-input-buffer-size = 16
+//
+//    # Fully qualified config path which holds the dispatcher configuration
+//    # to be used by ActorMaterializer when creating Actors.
+//    # When this value is left empty, the default-dispatcher will be used.
+//    dispatcher = ""
+//
+//    # Cleanup leaked publishers and subscribers when they are not used within a given
+//    # deadline
+//    subscription-timeout {
+//      # when the subscription timeout is reached one of the following strategies on
+//      # the "stale" publisher:
+//      # cancel - cancel it (via `onError` or subscribing to the publisher and
+//      #          `cancel()`ing the subscription right away
+//      # warn   - log a warning statement about the stale element (then drop the
+//      #          reference to it)
+//      # noop   - do nothing (not recommended)
+//      mode = cancel
+//
+//      # time after which a subscriber / publisher is considered stale and eligible
+//      # for cancelation (see `akka.stream.subscription-timeout.mode`)
+//      timeout = 5s
+//    }
+//
+//    # Enable additional troubleshooting logging at DEBUG log level
+//    debug-logging = off
+//
+//    # Maximum number of elements emitted in batch if downstream signals large demand
+//    output-burst-limit = 1000
+//
+//    # Enable automatic fusing of all graphs that are run. For short-lived streams
+//    # this may cause an initial runtime overhead, but most of the time fusing is
+//    # desirable since it reduces the number of Actors that are created.
+//    # Deprecated, since Akka 2.5.0, setting does not have any effect.
+//    auto-fusing = on
+//
+//    # Those stream elements which have explicit buffers (like mapAsync, mapAsyncUnordered,
+//    # buffer, flatMapMerge, Source.actorRef, Source.queue, etc.) will preallocate a fixed
+//    # buffer upon stream materialization if the requested buffer size is less than this
+//    # configuration parameter. The default is very high because failing early is better
+//    # than failing under load.
+//    #
+//    # Buffers sized larger than this will dynamically grow/shrink and consume more memory
+//    # per element than the fixed size buffers.
+//    max-fixed-buffer-size = 1000000000
+//
+//    # Maximum number of sync messages that actor can process for stream to substream communication.
+//    # Parameter allows to interrupt synchronous processing to get upsteam/downstream messages.
+//    # Allows to accelerate message processing that happening withing same actor but keep system responsive.
+//    sync-processing-limit = 1000
+//
+//    debug {
+//      # Enables the fuzzing mode which increases the chance of race conditions
+//      # by aggressively reordering events and making certain operations more
+//      # concurrent than usual.
+//      # This setting is for testing purposes, NEVER enable this in a production
+//      # environment!
+//      # To get the best results, try combining this setting with a throughput
+//      # of 1 on the corresponding dispatchers.
+//      fuzzing-mode = off
+//    }
+//
+//    io.tcp {
+//      # The outgoing bytes are accumulated in a buffer while waiting for acknoledgment
+//      # of pending write. This improves throughput for small messages (frames) without
+//      # sacrificing latency. While waiting for the ack the stage will eagerly pull
+//      # from upstream until the buffer exceeds this size. That means that the buffer may hold
+//      # slightly more bytes than this limit (at most one element more). It can be set to 0
+//      # to disable the usage of the buffer.
+//      write-buffer-size = 16 KiB
+//    }
+//  }
+}