concierge.conf

ditto {
  service-name = "concierge"

  mapping-strategy.implementation = "org.eclipse.ditto.concierge.service.ConciergeMappingStrategies"
  mapping-strategy.implementation = ${?MAPPING_STRATEGY_IMPLEMENTATION}

  concierge {
    enforcement {
      # configuration for retrieval of policies/things during enforcement via sharding
      ask-with-retry {
        # maximum duration to wait for anwers from entity shard regions
        ask-timeout = 3s
        ask-timeout = ${?ENFORCEMENT_ASK_TIMEOUT}

        # one of: OFF, NO_DELAY, FIXED_DELAY, BACKOFF_DELAY
        retry-strategy = BACKOFF_DELAY
        retry-strategy = ${?ENFORCEMENT_ASK_RETRY_STRATEGY}

        retry-attempts = 3
        retry-attempts = ${?ENFORCEMENT_ASK_TIMEOUT_RETRIES}

        fixed-delay = 5s
        fixed-delay = ${?ENFORCEMENT_ASK_FIXED_DELAY}

        backoff-delay {
          min = 100ms
          max = 10s
          # must be between 0.0 and 1.0:
          random-factor = 0.5
        }
      }

      # the buffer size used for the queue in the enforcement actor
      buffer-size = 100
      buffer-size = ${?ENFORCEMENT_BUFFER_SIZE}

      # whether to dispatch live response from channels other than subscribers of live messages.
      global-live-response-dispatching = true
      global-live-response-dispatching = ${?ENFORCEMENT_GLOBAL_LIVE_RESPONSE_DISPATCHING}

      # list of namespaces for which a special usage logging should be enabled in enforcement
      special-logging-inspected-namespaces = []
      special-logging-inspected-namespaces = ${?ENFORCEMENT_SPECIAL_LOGGING_INSPECTED_NAMESPACES}
    }

    caches {
      # configuration for retrieval of policies/things during cache update via sharding
      ask-with-retry {
        # maximum duration to wait for answers from entity shard regions
        ask-timeout = 3s
        ask-timeout = ${?CONCIERGE_CACHES_ASK_TIMEOUT}

        # one of: OFF, NO_DELAY, FIXED_DELAY, BACKOFF_DELAY
        retry-strategy = BACKOFF_DELAY
        retry-strategy = ${?CONCIERGE_CACHES_ASK_RETRY_STRATEGY}

        retry-attempts = 3
        retry-attempts = ${?CONCIERGE_CACHES_ASK_TIMEOUT_RETRIES}

        fixed-delay = 5s
        fixed-delay = ${?CONCIERGE_CACHES_ASK_FIXED_DELAY}

        backoff-delay {
          min = 100ms
          max = 10s
          # must be between 0.0 and 1.0:
          random-factor = 0.5
        }
      }

      id {
        # how many relations to cache
        maximum-size = 80000
        maximum-size = ${?AUTHORIZATION_ID_CACHE_SIZE}

        # maximum duration of inconsistency after losing a cache invalidation
        expire-after-write = 1h
        expire-after-write = ${?EXPIRE_AFTER_WRITE_ID_CACHE}

        # prolonged on each cache access by that duration
        expire-after-access = 15m
        expire-after-access = ${?EXPIRE_AFTER_ACCESS_ID_CACHE}
      }

      enforcer {
        # how many enforcers to cache
        maximum-size = 20000
        maximum-size = ${?AUTHORIZATION_ENFORCER_CACHE_SIZE}

        # maximum duration of inconsistency after losing a cache invalidation
        expire-after-write = 1h
        expire-after-write = ${?EXPIRE_AFTER_WRITE_ENFORCER_CACHE}

        # prolonged on each cache access by that duration
        expire-after-access = 15m
        expire-after-access = ${?EXPIRE_AFTER_ACCESS_ENFORCER_CACHE}
      }
    }

    things-aggregator {

      single-retrieve-thing-timeout = 30s
      single-retrieve-thing-timeout = ${?THINGS_AGGREGATOR_SINGLE_RETRIEVE_THING_TIMEOUT}

      max-parallelism = 20
      max-parallelism = ${?THINGS_AGGREGATOR_MAX_PARALLELISM}
    }
  }
}

akka {
  actor {
    deployment {
      /conciergeRoot/dispatcherActor/aggregator {
        router = round-robin-pool
        # nr-of-instances = 5
        resizer {
          lower-bound = 5
          upper-bound = 100
          messages-per-resize = 50
        }
      }
    }
  }

  cluster {
    sharding {
      role = ${ditto.service-name}
    }

    roles = [
      "concierge",
      "blocked-namespaces-aware",
      "live-signal-aware",
      "acks-aware"
    ]
  }
}

aggregator-internal-dispatcher {
  # Dispatcher is the name of the event-based dispatcher
  type = Dispatcher
  # What kind of ExecutionService to use
  executor = "fork-join-executor"
  # Configuration for the fork join pool
  fork-join-executor {
    # Min number of threads to cap factor-based parallelism number to
    parallelism-min = 4
    # Parallelism (threads) ... ceil(available processors * factor)
    parallelism-factor = 3.0
    # Max number of threads to cap factor-based parallelism number to
    parallelism-max = 32
    parallelism-max = ${?DEFAULT_DISPATCHER_PARALLELISM_MAX}
  }
  # Throughput defines the maximum number of messages to be
  # processed per actor before the thread jumps to the next actor.
  # Set to 1 for as fair as possible.
  throughput = 5
}

cached-namespace-invalidator-dispatcher {
  # one thread per actor in case the actor blocks.
  type = PinnedDispatcher
  executor = "thread-pool-executor"
}

blocked-namespaces-dispatcher {
  type = Dispatcher
  executor = "fork-join-executor"
  fork-join-executor {
    # Min number of threads to cap factor-based parallelism number to
    parallelism-min = 4
    # Parallelism (threads) ... ceil(available processors * factor)
    parallelism-factor = 3.0
    # Max number of threads to cap factor-based parallelism number to
    parallelism-max = 32
    parallelism-max = ${?DEFAULT_DISPATCHER_PARALLELISM_MAX}
  }
  throughput = 5
}

thing-id-cache-dispatcher {
  type = "Dispatcher"
  executor = "thread-pool-executor"
  thread-pool-executor {
    keep-alive-time = 60s
    fixed-pool-size = off
    max-pool-size-max = 256
    max-pool-size-max = ${?CACHE_DISPATCHER_POOL_SIZE_MAX}
    max-pool-size-max = ${?THING_ID_CACHE_DISPATCHER_POOL_SIZE_MAX}
  }
}

policy-enforcer-cache-dispatcher {
  type = "Dispatcher"
  executor = "thread-pool-executor"
  thread-pool-executor {
    keep-alive-time = 60s
    fixed-pool-size = off
    max-pool-size-max = 256
    max-pool-size-max = ${?CACHE_DISPATCHER_POOL_SIZE_MAX}
    max-pool-size-max = ${?POLICY_ENFORCER_CACHE_DISPATCHER_POOL_SIZE_MAX}
  }
}

include "concierge-extension"