dynsampler

package module

Go to main page

Versions in this module

v0

v0.6.0

Jan 12, 2024

v0.5.1

Jun 26, 2023

v0.5.0

Jun 8, 2023

Changes in this version

type AvgSampleRate

+ func (a *AvgSampleRate) GetMetrics(prefix string) map[string]int64

type AvgSampleWithMin

+ func (a *AvgSampleWithMin) GetMetrics(prefix string) map[string]int64

type EMASampleRate

+ func (e *EMASampleRate) GetMetrics(prefix string) map[string]int64

type EMAThroughput

+ func (e *EMAThroughput) GetMetrics(prefix string) map[string]int64

type OnlyOnce

+ func (o *OnlyOnce) GetMetrics(prefix string) map[string]int64

type PerKeyThroughput

+ func (p *PerKeyThroughput) GetMetrics(prefix string) map[string]int64

type Sampler

+ GetMetrics func(prefix string) map[string]int64

type Static

+ func (s *Static) GetMetrics(prefix string) map[string]int64

type TotalThroughput

+ func (t *TotalThroughput) GetMetrics(prefix string) map[string]int64

type WindowedThroughput

+ func (t *WindowedThroughput) GetMetrics(prefix string) map[string]int64

v0.4.0

Mar 22, 2023

Changes in this version

type AvgSampleRate

+ ClearFrequencyDuration time.Duration

+ func (a *AvgSampleRate) GetSampleRateMulti(key string, count int) int

+ func (a *AvgSampleRate) Stop() error

type AvgSampleWithMin

+ ClearFrequencyDuration time.Duration

+ func (a *AvgSampleWithMin) GetSampleRateMulti(key string, count int) int

+ func (a *AvgSampleWithMin) Stop() error

+ type Block struct

+ type BlockList interface

+ AggregateCounts func(currentIndex int64, lookbackIndex int64) map[string]int

+ IncrementKey func(key string, keyIndex int64, count int) error

+ func NewBoundedBlockList(maxKeys int) BlockList

+ func NewUnboundedBlockList() BlockList

+ type BoundedBlockList struct

+ func (b *BoundedBlockList) AggregateCounts(currentIndex int64, lookbackIndex int64) (aggregateCounts map[string]int)

+ func (b *BoundedBlockList) IncrementKey(key string, keyIndex int64, count int) error

type EMASampleRate

+ AdjustmentIntervalDuration time.Duration

+ func (e *EMASampleRate) GetSampleRateMulti(key string, count int) int

+ func (e *EMASampleRate) Stop() error

+ type EMAThroughput struct

+ AdjustmentInterval time.Duration

+ AgeOutValue float64

+ BurstDetectionDelay uint

+ BurstMultiple float64

+ GoalThroughputPerSec int

+ InitialSampleRate int

+ MaxKeys int

+ Weight float64

+ func (e *EMAThroughput) GetSampleRate(key string) int

+ func (e *EMAThroughput) GetSampleRateMulti(key string, count int) int

+ func (e *EMAThroughput) LoadState(state []byte) error

+ func (e *EMAThroughput) SaveState() ([]byte, error)

+ func (e *EMAThroughput) Start() error

+ func (e *EMAThroughput) Stop() error

+ type IndexGenerator interface

+ DurationToIndexes func(duration time.Duration) int64

+ GetCurrentIndex func() int64

+ type MaxSizeError struct

+ func (e MaxSizeError) Error() string

type OnlyOnce

+ ClearFrequencyDuration time.Duration

+ func (o *OnlyOnce) GetSampleRateMulti(key string, count int) int

+ func (o *OnlyOnce) Stop() error

type PerKeyThroughput

+ ClearFrequencyDuration time.Duration

+ func (p *PerKeyThroughput) GetSampleRateMulti(key string, count int) int

+ func (p *PerKeyThroughput) Stop() error

type Sampler

+ GetSampleRateMulti func(string, int) int

+ Stop func() error

type Static

+ func (s *Static) GetSampleRateMulti(key string, count int) int

+ func (s *Static) Stop() error

type TotalThroughput

+ ClearFrequencyDuration time.Duration

+ func (t *TotalThroughput) GetSampleRateMulti(key string, count int) int

+ func (t *TotalThroughput) Stop() error

+ type UnboundedBlockList struct

+ func (b *UnboundedBlockList) AggregateCounts(currentIndex int64, lookbackIndex int64) map[string]int

+ func (b *UnboundedBlockList) IncrementKey(key string, keyIndex int64, count int) error

+ type UnixSecondsIndexGenerator struct

+ DurationPerIndex time.Duration

+ func (g *UnixSecondsIndexGenerator) DurationToIndexes(duration time.Duration) int64

+ func (g *UnixSecondsIndexGenerator) GetCurrentIndex() int64

+ type WindowedThroughput struct

+ GoalThroughputPerSec float64

+ LookbackFrequencyDuration time.Duration

+ MaxKeys int

+ UpdateFrequencyDuration time.Duration

+ func (t *WindowedThroughput) GetSampleRate(key string) int

+ func (t *WindowedThroughput) GetSampleRateMulti(key string, count int) int

+ func (t *WindowedThroughput) LoadState(state []byte) error

+ func (t *WindowedThroughput) SaveState() ([]byte, error)

+ func (t *WindowedThroughput) Start() error

+ func (t *WindowedThroughput) Stop() error

v0.3.0

Dec 7, 2022

v0.2.1

Aug 7, 2019

v0.2.0

Aug 1, 2019

Changes in this version

type AvgSampleRate

+ func (a *AvgSampleRate) LoadState(state []byte) error

+ func (a *AvgSampleRate) SaveState() ([]byte, error)

type AvgSampleWithMin

+ func (a *AvgSampleWithMin) LoadState(state []byte) error

+ func (a *AvgSampleWithMin) SaveState() ([]byte, error)

+ type EMASampleRate struct

+ AdjustmentInterval int

+ AgeOutValue float64

+ BurstDetectionDelay uint

+ BurstMultiple float64

+ GoalSampleRate int

+ MaxKeys int

+ Weight float64

+ func (e *EMASampleRate) GetSampleRate(key string) int

+ func (e *EMASampleRate) LoadState(state []byte) error

+ func (e *EMASampleRate) SaveState() ([]byte, error)

+ func (e *EMASampleRate) Start() error

type OnlyOnce

+ func (o *OnlyOnce) LoadState(state []byte) error

+ func (o *OnlyOnce) SaveState() ([]byte, error)

type PerKeyThroughput

+ func (p *PerKeyThroughput) LoadState(state []byte) error

+ func (p *PerKeyThroughput) SaveState() ([]byte, error)

type Sampler

+ LoadState func([]byte) error

+ SaveState func() ([]byte, error)

type Static

+ func (s *Static) LoadState(state []byte) error

+ func (s *Static) SaveState() ([]byte, error)

type TotalThroughput

+ func (t *TotalThroughput) LoadState(state []byte) error

+ func (t *TotalThroughput) SaveState() ([]byte, error)

v0.1.0

May 22, 2019

Changes in this version

+ type AvgSampleRate struct

+ ClearFrequencySec int

+ GoalSampleRate int

+ MaxKeys int

+ func (a *AvgSampleRate) GetSampleRate(key string) int

+ func (a *AvgSampleRate) Start() error

+ type AvgSampleWithMin struct

+ ClearFrequencySec int

+ GoalSampleRate int

+ MaxKeys int

+ MinEventsPerSec int

+ func (a *AvgSampleWithMin) GetSampleRate(key string) int

+ func (a *AvgSampleWithMin) Start() error

+ type OnlyOnce struct

+ ClearFrequencySec int

+ func (o *OnlyOnce) GetSampleRate(key string) int

+ func (o *OnlyOnce) Start() error

+ type PerKeyThroughput struct

+ ClearFrequencySec int

+ MaxKeys int

+ PerKeyThroughputPerSec int

+ func (p *PerKeyThroughput) GetSampleRate(key string) int

+ func (p *PerKeyThroughput) Start() error

+ type Sampler interface

+ GetSampleRate func(string) int

+ Start func() error

+ type Static struct

+ Default int

+ Rates map[string]int

+ func (s *Static) GetSampleRate(key string) int

+ func (s *Static) Start() error

+ type TotalThroughput struct

+ ClearFrequencySec int

+ GoalThroughputPerSec int

+ MaxKeys int

+ func (t *TotalThroughput) GetSampleRate(key string) int

+ func (t *TotalThroughput) Start() error

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL