Class QueueConfig

    • Constructor Detail

      • QueueConfig

        public QueueConfig()
        No args constructor for use in serialization
    • Method Detail

      • getBatchSendDeadline

        public String getBatchSendDeadline()
        batchSendDeadline defines the maximum time a sample will wait in buffer.
      • setBatchSendDeadline

        public void setBatchSendDeadline​(String batchSendDeadline)
        batchSendDeadline defines the maximum time a sample will wait in buffer.
      • getCapacity

        public Integer getCapacity()
        capacity defines the number of samples to buffer per shard before we start dropping them.
      • setCapacity

        public void setCapacity​(Integer capacity)
        capacity defines the number of samples to buffer per shard before we start dropping them.
      • getMaxBackoff

        public String getMaxBackoff()
        maxBackoff defines the maximum retry delay.
      • setMaxBackoff

        public void setMaxBackoff​(String maxBackoff)
        maxBackoff defines the maximum retry delay.
      • getMaxRetries

        public Integer getMaxRetries()
        maxRetries defines the maximum number of times to retry a batch on recoverable errors.
      • setMaxRetries

        public void setMaxRetries​(Integer maxRetries)
        maxRetries defines the maximum number of times to retry a batch on recoverable errors.
      • getMaxSamplesPerSend

        public Integer getMaxSamplesPerSend()
        maxSamplesPerSend defines the maximum number of samples per send.
      • setMaxSamplesPerSend

        public void setMaxSamplesPerSend​(Integer maxSamplesPerSend)
        maxSamplesPerSend defines the maximum number of samples per send.
      • getMaxShards

        public Integer getMaxShards()
        maxShards defines the maximum number of shards, i.e. amount of concurrency.
      • setMaxShards

        public void setMaxShards​(Integer maxShards)
        maxShards defines the maximum number of shards, i.e. amount of concurrency.
      • getMinBackoff

        public String getMinBackoff()
        minBackoff defines the initial retry delay. Gets doubled for every retry.
      • setMinBackoff

        public void setMinBackoff​(String minBackoff)
        minBackoff defines the initial retry delay. Gets doubled for every retry.
      • getMinShards

        public Integer getMinShards()
        minShards defines the minimum number of shards, i.e. amount of concurrency.
      • setMinShards

        public void setMinShards​(Integer minShards)
        minShards defines the minimum number of shards, i.e. amount of concurrency.
      • getRetryOnRateLimit

        public Boolean getRetryOnRateLimit()
        retryOnRateLimit defines the retry upon receiving a 429 status code from the remote-write storage.


        This is an *experimental feature*, it may change in any upcoming release in a breaking way.

      • setRetryOnRateLimit

        public void setRetryOnRateLimit​(Boolean retryOnRateLimit)
        retryOnRateLimit defines the retry upon receiving a 429 status code from the remote-write storage.


        This is an *experimental feature*, it may change in any upcoming release in a breaking way.

      • getSampleAgeLimit

        public String getSampleAgeLimit()
        sampleAgeLimit drops samples older than the limit. It requires Prometheus >= v2.50.0 or Thanos >= v0.32.0.
      • setSampleAgeLimit

        public void setSampleAgeLimit​(String sampleAgeLimit)
        sampleAgeLimit drops samples older than the limit. It requires Prometheus >= v2.50.0 or Thanos >= v0.32.0.
      • getAdditionalProperties

        public Map<String,​Object> getAdditionalProperties()
      • setAdditionalProperty

        public void setAdditionalProperty​(String name,
                                          Object value)
      • setAdditionalProperties

        public void setAdditionalProperties​(Map<String,​Object> additionalProperties)