Skip to content
Permalink

Comparing changes

This is a direct comparison between two commits made in this repository or its related repositories. View the default comparison for this range or learn more about diff comparisons.

Open a pull request

Create a new pull request by comparing changes across two branches. If you need to, you can also . Learn more about diff comparisons here.
base repository: filodb/FiloDB
Failed to load repositories. Confirm that selected base ref is valid, then try again.
Loading
base: 072a25485e323e649372e5f3fedd05dd862f1286
Choose a base ref
..
head repository: filodb/FiloDB
Failed to load repositories. Confirm that selected head ref is valid, then try again.
Loading
compare: 6ad22b408225332a9a675f86e53c17e0ac22804b
Choose a head ref
Showing with 5 additions and 3 deletions.
  1. +5 −3 coordinator/src/main/scala/filodb.coordinator/TenantIngestionMetering.scala
Original file line number Diff line number Diff line change
@@ -1,20 +1,22 @@
package filodb.coordinator

import java.util.concurrent.{TimeUnit, TimeoutException}
import java.util.concurrent.{TimeoutException, TimeUnit}
import java.util.concurrent.locks.ReentrantReadWriteLock

import scala.concurrent.duration.FiniteDuration
import scala.util.{Failure, Success}

import akka.actor.ActorRef
import com.typesafe.scalalogging.StrictLogging
import kamon.Kamon
import kamon.tag.TagSet
import monix.execution.Scheduler.Implicits.{global => scheduler}

import filodb.coordinator.client.Client
import filodb.coordinator.client.QueryCommands.LogicalPlan2Query
import filodb.core.DatasetRef
import filodb.query.{QueryError, QueryResult, TsCardinalities}

import java.util.concurrent.locks.ReentrantReadWriteLock

object QueryThrottle {
// currently just add this diff to the interval if the timeout rate exceeds THRESHOLD
protected val INTERVAL_DIFF = FiniteDuration(5L, TimeUnit.MINUTES)