crash.software
Projects
Pull Requests
Issues
Builds
dolt
Code
Files
Commits
Branches
Tags
Pull Requests
Code Comments
Code Compare
Issues
List
Boards
Milestones
Builds
Statistics
Contributions
Source Lines
Child Projects
Projects
STRLCPY
dolt
Files
🤬
Sign In
30025a0d
ROOT
/
go
/
libraries
/
doltcore
/
remotestorage
/
hedge.go
Search
History
297 lines
|
ISO-8859-1
|
8 KB
Blame
Outline
2
4
8
No wrap
Soft wrap
Outline
Hedger
sema
:
*semaphore.Weighted
strat
:
HedgeStrategy
observer
:
DurationObserver
after
:
afterFunc
NewHedger
(maxOutstanding int64, strat HedgeStrategy, observer DurationObserver)
:
*Hedger
afterFunc
MaxHedgesPerRequest
Work
Run
:
func(ctx context.Context, n int) (interface{}, error)
Size
:
uint64
DynamicEstimator
DurationEstimator
DurationObserver
DurationEstimator
Duration
(sz uint64)
:
time.Duration
DurationObserver
Observe
(sz uint64, n int, d time.Duration, err error)
NoopObserver
NewNoopObserver
()
:
*NoopObserver
PercentileEstimator
Percentile
:
float64
histogram
:
*hdrhistogram.Histogram
mu
:
*sync.Mutex
NewPercentileEstimator
(low, high time.Duration, perc float64)
:
*PercentileEstimator
HedgeStrategy
NextTry
(sz uint64, elapsed time.Duration, n int)
:
time.Duration
FixedHedgeStrategy
FixedNextTry
:
time.Duration
NewFixedHedgeStrategy
(fixedNextTry time.Duration)
:
*FixedHedgeStrategy
EstimateStrategy
e
:
DurationEstimator
NewEstimateStrategy
(e DurationEstimator)
:
*EstimateStrategy
ExponentialHedgeStrategy
underlying
:
HedgeStrategy
NewExponentialHedgeStrategy
(u HedgeStrategy)
:
*ExponentialHedgeStrategy
MinHedgeStrategy
min
:
time.Duration
underlying
:
HedgeStrategy
NewMinHedgeStrategy
(min time.Duration, underlying HedgeStrategy)
:
*MinHedgeStrategy
*Hedger
Do
(ctx context.Context, w Work)
:
(interface{}, error)
*NoopObserver
Observe
(sz uint64, n int, d time.Duration, err error)
*PercentileEstimator
Duration
(sz uint64)
:
time.Duration
Observe
(sz uint64, n int, d time.Duration, err error)
*FixedHedgeStrategy
NextTry
(sz uint64, elapsed time.Duration, n int)
:
time.Duration
*EstimateStrategy
NextTry
(sz uint64, elapsed time.Duration, n int)
:
time.Duration
*ExponentialHedgeStrategy
NextTry
(sz uint64, elapsed time.Duration, n int)
:
time.Duration
*MinHedgeStrategy
NextTry
(sz uint64, elapsed time.Duration, n int)
:
time.Duration
All occurrences
Please wait...
Page is in error, reload to recover