Atlas › Test

TestRateLimiterDelegator_Wait

Exact test identity: go.temporal.io/server/common/quotas/TestRateLimiterDelegator_Wait

Package: go.temporal.io/server/common/quotas
Suite / test hierarchy: TestRateLimiterDelegator_Wait
Test: TestRateLimiterDelegator_Wait
Introduced at: request_rate_limiter_delegator.go ×1 Frontier kind: Joint frontier
Covered ranges: 4
Covered lines: 12
Covered files: 2

Covered source

Expand a file to inspect source; the > gutter marks covered lines.

go.temporal.io/server/common/quotas/request_rate_limiter_delegator.go 9 covered LOC · 3 ranges

  24
  
  25
  
  // SetRateLimiter sets the rate limiter to delegate to.
  
  26
  >
  func (d *RequestRateLimiterDelegator) SetRateLimiter(rl RequestRateLimiter) {
  
request_rate_limiter_delegator.go

  27
  >
  	d.delegate.Store(monomorphicRequestRateLimiter{rl})
  
  28
  >
  }
  
  29
  
  30
  
  // loadDelegate returns the rate limiter that this rate limiter delegates to.
  
  31
  >
  func (d *RequestRateLimiterDelegator) loadDelegate() RequestRateLimiter {
  
request_rate_limiter_delegator.go

  32
  >
  	return d.delegate.Load().(RequestRateLimiter)
  
  33
  >
  }
  
  34
  
  35
  
  // The following methods just delegate to the underlying rate limiter.

  43
  
  }
  
  44
  
  45
  >
  func (d *RequestRateLimiterDelegator) Wait(ctx context.Context, request Request) error {
  
request_rate_limiter_delegator.go

  46
  >
  	return d.loadDelegate().Wait(ctx, request)
  
  47
  >
  }

go.temporal.io/server/common/quotas/noop_request_rate_limiter_impl.go 3 covered LOC · 1 range

Open complete file

  30
  
  	_ context.Context,
  
  31
  
  	_ Request,
  
  32
  >
  ) error {
  
noop_request_rate_limiter_impl.go

  33
  >
  	return nil
  
  34
  >
  }