utils

package
v1.27.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 31, 2024 License: Apache-2.0 Imports: 39 Imported by: 48

Documentation

Overview

Copyright (c) 2016,2020 Uber Technologies, Inc.

Permission is hereby granted, free of charge, to any person obtaining a copy of this software and associated documentation files (the "Software"), to deal in the Software without restriction, including without limitation the rights to use, copy, modify, merge, publish, distribute, sublicense, and/or sell copies of the Software, and to permit persons to whom the Software is furnished to do so, subject to the following conditions:

The above copyright notice and this permission notice shall be included in all copies or substantial portions of the Software.

THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.

SOURCE: https://github.com/uber-go/ratelimit/blob/main/limiter_mutexbased.go EDIT: slight modification to allow setting rate limit on the fly SCOPE: LeakyBucket

Index

Constants

View Source 
const (
	RoomPrefix            = guid.RoomPrefix
	NodePrefix            = guid.NodePrefix
	ParticipantPrefix     = guid.ParticipantPrefix
	TrackPrefix           = guid.TrackPrefix
	APIKeyPrefix          = guid.APIKeyPrefix
	EgressPrefix          = guid.EgressPrefix
	IngressPrefix         = guid.IngressPrefix
	SIPTrunkPrefix        = guid.SIPTrunkPrefix
	SIPDispatchRulePrefix = guid.SIPDispatchRulePrefix
	SIPCallPrefix         = guid.SIPCallPrefix
	RPCPrefix             = guid.RPCPrefix
	WHIPResourcePrefix    = guid.WHIPResourcePrefix
	RTMPResourcePrefix    = guid.RTMPResourcePrefix
	URLResourcePrefix     = guid.URLResourcePrefix
	AgentWorkerPrefix     = guid.AgentWorkerPrefix
	AgentJobPrefix        = guid.AgentJobPrefix
	AgentDispatchPrefix   = guid.AgentDispatchPrefix
)
View Source 
const (
	GuidSize = guid.Size
)

Variables

View Source 
var (
	ErrAnachronousSample = errors.New("anachronous sample")
)
View Source 
var ErrMaxAttemptsReached = errors.New("max attempts reached")

Functions

func AggregateRTPStats added in v1.9.2 

func AggregateRTPStats(statsList []*livekit.RTPStats, gapHistogramSize int) *livekit.RTPStats

func CloneProto added in v1.22.0 

func CloneProto[T proto.Message](m T) T

func CloneProtoSlice added in v1.27.1 

func CloneProtoSlice[T proto.Message](ms []T) []T

func CloseFunc added in v1.24.0 

func CloseFunc[T CloseFuncType](fn T) io.Closer

func DeepCopy added in v1.19.2 

func DeepCopy[T any](v T) T

func EnableLockTracker added in v1.4.0 

func EnableLockTracker()

EnableLockTracker enable lock tracking background worker. This should be called during init

func ErrorIsOneOf added in v1.22.0 

func ErrorIsOneOf(err error, targets ...error) bool

func FastLogisticFunc added in v1.22.0 

func FastLogisticFunc(x0, L, k float64) func(x float64) float64

func GetMimeTypeForAudioCodec added in v1.5.1 

func GetMimeTypeForAudioCodec(codec livekit.AudioCodec) string

func GetMimeTypeForVideoCodec added in v1.5.1 

func GetMimeTypeForVideoCodec(codec livekit.VideoCodec) string

func HashedID 

func HashedID(id string) string

HashedID creates a hashed ID from a unique string

func HedgeCall added in v1.14.0 

func HedgeCall[T any](ctx context.Context, params HedgeParams[T]) (v T, err error)

race retries if the function takes too long to return |---------------- attempt 1 ----------------| | delay |--------- attempt 2 ---------|

func IsConnectionQualityHigher added in v1.26.0 

func IsConnectionQualityHigher(prev livekit.ConnectionQuality, curr livekit.ConnectionQuality) bool

func IsConnectionQualityLower added in v1.9.2 

func IsConnectionQualityLower(prev livekit.ConnectionQuality, curr livekit.ConnectionQuality) bool

func LocalNodeID added in v0.11.1 

func LocalNodeID() (string, error)

func LogisticFunc added in v1.22.0 

func LogisticFunc(x0, L, k float64) func(x float64) float64

func MarshalGuid added in v1.5.7 

func MarshalGuid[T livekit.Guid](id T) livekit.GuidBlock

func NewGuid 

func NewGuid(prefix string) string

func NumMutexes added in v1.4.0 

func NumMutexes() int

func ParallelExec added in v1.4.3 

func ParallelExec[T any](vals []T, parallelThreshold, step uint64, fn func(T))

ParallelExec will executes the given function with each element of vals, if len(vals) >= parallelThreshold, will execute them in parallel, with the given step size. So fn must be thread-safe.

func RandomSecret 

func RandomSecret() string

func Redact added in v1.5.10 

func Redact(s, name string) string

func RedactIdentifier added in v1.5.10 

func RedactIdentifier(identifier string) string

func RedactStreamKey added in v1.5.10 

func RedactStreamKey(url string) (string, bool)

func ToggleLockTrackerStackTraces added in v1.8.0 

func ToggleLockTrackerStackTraces(enable bool)

func UnmarshalGuid added in v1.5.7 

func UnmarshalGuid[T livekit.Guid](b livekit.GuidBlock) T

Types

type Bitmap added in v1.8.0 

type Bitmap[T bitmapNumber] struct {
	// contains filtered or unexported fields
}

func NewBitmap added in v1.8.0 

func NewBitmap[T bitmapNumber](size int) *Bitmap[T]

func (*Bitmap[T]) Clear added in v1.8.0 

func (b *Bitmap[T]) Clear(val T)

func (*Bitmap[T]) ClearRange added in v1.8.0 

func (b *Bitmap[T]) ClearRange(min, max T)

func (*Bitmap[T]) IsSet added in v1.8.0 

func (b *Bitmap[T]) IsSet(val T) bool

func (*Bitmap[T]) Len added in v1.10.0 

func (b *Bitmap[T]) Len() int

func (*Bitmap[T]) Set added in v1.8.0 

func (b *Bitmap[T]) Set(val T)

func (*Bitmap[T]) SetRange added in v1.8.0 

func (b *Bitmap[T]) SetRange(min, max T)

type Clock added in v1.14.0 

type Clock interface {
	Now() time.Time
	Sleep(time.Duration)
}

type CloseFuncType added in v1.24.0 

type CloseFuncType interface {
	~func() error | ~func()
}

type Closers added in v1.24.0 

type Closers []io.Closer

func CombineClosers added in v1.24.0 

func CombineClosers(cs ...io.Closer) Closers

func (*Closers) Close added in v1.24.0 

func (s *Closers) Close() error

type ConfigBuilder added in v1.12.0 

type ConfigBuilder[T any] interface {
	New() (*T, error)
}

type ConfigDefaulter added in v1.12.0 

type ConfigDefaulter[T any] interface {
	InitDefaults(*T) error
}

type ConfigObserver added in v1.12.0 

type ConfigObserver[T any] struct {
	// contains filtered or unexported fields
}

func NewConfigObserver added in v1.12.0 

func NewConfigObserver[T any](path string, builder ConfigBuilder[T]) (*ConfigObserver[T], *T, error)

func (*ConfigObserver[T]) Close added in v1.12.0 

func (c *ConfigObserver[T]) Close()

func (*ConfigObserver[T]) EmitConfigUpdate added in v1.12.0 

func (c *ConfigObserver[T]) EmitConfigUpdate(conf *T)

func (*ConfigObserver[T]) Load added in v1.19.2 

func (c *ConfigObserver[T]) Load() *T

func (*ConfigObserver[T]) Observe added in v1.12.0 

func (c *ConfigObserver[T]) Observe(cb func(*T)) func()

type DedupedSlice added in v1.6.0 

type DedupedSlice[T comparable] struct {
	// contains filtered or unexported fields
}

func NewDedupedSlice added in v1.6.0 

func NewDedupedSlice[T comparable](maxLen int) *DedupedSlice[T]

func (*DedupedSlice[T]) Add added in v1.6.0 

func (d *DedupedSlice[T]) Add(val T) bool

func (*DedupedSlice[T]) Clear added in v1.6.0 

func (d *DedupedSlice[T]) Clear()

func (*DedupedSlice[T]) Get added in v1.6.0 

func (d *DedupedSlice[T]) Get() []T

func (*DedupedSlice[T]) Has added in v1.6.0 

func (d *DedupedSlice[T]) Has(val T) bool

func (*DedupedSlice[T]) Len added in v1.6.0 

func (d *DedupedSlice[T]) Len() int

type ErrArray added in v1.5.6 

type ErrArray struct {
	// contains filtered or unexported fields
}

func (*ErrArray) AppendErr added in v1.5.6 

func (e *ErrArray) AppendErr(err error)

func (*ErrArray) ToError added in v1.5.6 

func (e *ErrArray) ToError() psrpc.Error

type FlowGraph added in v1.5.7 

type FlowGraph struct {
	// contains filtered or unexported fields
}

func NewFlowGraph added in v1.5.7 

func NewFlowGraph(n int64) FlowGraph

func (*FlowGraph) AddEdge added in v1.5.7 

func (g *FlowGraph) AddEdge(s, t, cap, cost int64)

type Graph added in v1.5.7 

type Graph[K comparable, N GraphNodeProps[K], E GraphEdgeProps] struct {
	// contains filtered or unexported fields
}

func NewGraph added in v1.5.7 

func NewGraph[K comparable, N GraphNodeProps[K], E GraphEdgeProps]() *Graph[K, N, E]

func (*Graph[K, N, E]) DeleteEdge added in v1.5.7 

func (g *Graph[K, N, E]) DeleteEdge(src, dst K)

func (*Graph[K, N, E]) DeleteNode added in v1.5.8 

func (g *Graph[K, N, E]) DeleteNode(id K)

func (*Graph[K, N, E]) Edge added in v1.5.7 

func (g *Graph[K, N, E]) Edge(src, dst K) (p E)

func (*Graph[K, N, E]) HasEdge added in v1.5.8 

func (g *Graph[K, N, E]) HasEdge(src, dst K) bool

func (*Graph[K, N, E]) HasNode added in v1.5.8 

func (g *Graph[K, N, E]) HasNode(id K) bool

func (*Graph[K, N, E]) InEdges added in v1.5.7 

func (g *Graph[K, N, E]) InEdges(dst K) map[K]E

func (*Graph[K, N, E]) InsertEdge added in v1.5.7 

func (g *Graph[K, N, E]) InsertEdge(src, dst K, props E)

func (*Graph[K, N, E]) InsertNode added in v1.5.7 

func (g *Graph[K, N, E]) InsertNode(props N)

func (*Graph[K, N, E]) Node added in v1.5.7 

func (g *Graph[K, N, E]) Node(id K) (props N)

func (*Graph[K, N, E]) NodeIDs added in v1.7.0 

func (g *Graph[K, N, E]) NodeIDs() []K

func (*Graph[K, N, E]) OutEdges added in v1.5.7 

func (g *Graph[K, N, E]) OutEdges(src K) map[K]E

func (*Graph[K, N, E]) ShortestPath added in v1.5.7 

func (g *Graph[K, N, E]) ShortestPath(src, dst K) ([]N, int64)

func (*Graph[K, N, E]) Size added in v1.5.7 

func (g *Graph[K, N, E]) Size() int

func (*Graph[K, N, E]) TopologicalSort added in v1.5.7 

func (g *Graph[K, N, E]) TopologicalSort() []N

type GraphEdge added in v1.5.7 

type GraphEdge[N, E any] struct {
	// contains filtered or unexported fields
}

type GraphEdgeProps added in v1.5.7 

type GraphEdgeProps interface {
	Length() int64
}

type GraphNode added in v1.5.7 

type GraphNode[T any] struct {
	// contains filtered or unexported fields
}

type GraphNodeProps added in v1.5.7 

type GraphNodeProps[K comparable] interface {
	ID() K
}

type HedgeParams added in v1.14.0 

type HedgeParams[T any] struct {
	Timeout       time.Duration
	RetryDelay    time.Duration
	MaxAttempts   int
	IsRecoverable func(err error) bool
	Func          func(context.Context) (T, error)
}

type KillableService added in v1.9.0 

type KillableService interface {
	Kill()
}

type LatencyAggregate added in v1.17.0 

type LatencyAggregate struct {
	// contains filtered or unexported fields
}

a ring buffer of welford mean/var summaries used to aggregate jitter and rtt.

func NewLatencyAggregate added in v1.17.0 

func NewLatencyAggregate(interval, windowLength time.Duration) *LatencyAggregate

func (*LatencyAggregate) Get added in v1.17.0 

func (a *LatencyAggregate) Get(ts time.Duration) (Welford, bool)

func (*LatencyAggregate) MarshalLogObject added in v1.17.0 

func (a *LatencyAggregate) MarshalLogObject(e zapcore.ObjectEncoder) error

func (*LatencyAggregate) Summarize added in v1.17.0 

func (a *LatencyAggregate) Summarize() Welford

aggregate the interval summaries

func (*LatencyAggregate) SummarizeLast added in v1.17.0 

func (a *LatencyAggregate) SummarizeLast(d time.Duration) Welford

func (*LatencyAggregate) Update added in v1.17.0 

func (a *LatencyAggregate) Update(ts time.Duration, v float64)

extend the ring to contain ts then merge the value into the interval summary.

type LeakyBucket added in v1.14.0 

type LeakyBucket struct {
	// contains filtered or unexported fields
}

func NewLeakyBucket added in v1.14.0 

func NewLeakyBucket(rateLimit int, slack int, clock Clock) *LeakyBucket

NewLeakyBucket initiates LeakyBucket with rateLimit, slack, and clock.

rateLimit is defined as the number of request per second.

slack is defined as the number of allowed requests before limiting. e.g. when slack=5, LeakyBucket will allow 5 requests to pass through Take without a sleep as long as these requests are under perRequest duration.

func (*LeakyBucket) Take added in v1.14.0 

func (lb *LeakyBucket) Take() time.Time

Take blocks to ensure that the time spent between multiple Take calls is on average time.Second/rate.

Take is THREAD SAFE and BLOCKING.

func (*LeakyBucket) Update added in v1.14.0 

func (lb *LeakyBucket) Update(rateLimit int, slack int)

Update sets the underlying rate limit and slack. The setting may not be applied immediately.

Update is THREAD SAFE and NON-BLOCKING.

type MinCostMaxFlow added in v1.5.7 

type MinCostMaxFlow struct {
	// contains filtered or unexported fields
}

func (*MinCostMaxFlow) ComputeMaxFlow added in v1.5.7 

func (f *MinCostMaxFlow) ComputeMaxFlow(g FlowGraph, s, t int64) (flow, cost int64)

func (*MinCostMaxFlow) Flow added in v1.5.7 

func (f *MinCostMaxFlow) Flow(s, t int64) int64

type MultitonService added in v1.9.0 

type MultitonService[K comparable] struct {
	// contains filtered or unexported fields
}

func (*MultitonService[K]) Kill added in v1.9.0 

func (s *MultitonService[K]) Kill()

func (*MultitonService[K]) Replace added in v1.9.0 

func (s *MultitonService[K]) Replace(k K, v KillableService) func()

type Mutex added in v1.4.0 

type Mutex struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func (*Mutex) Lock added in v1.4.0 

func (m *Mutex) Lock()

func (*Mutex) Unlock added in v1.5.7 

func (m *Mutex) Unlock()

type Promise added in v1.14.0 

type Promise[T any] struct {
	Result T
	Err    error
	// contains filtered or unexported fields
}

func GoPromise added in v1.14.0 

func GoPromise[T any](f func() (T, error)) *Promise[T]

func NewPromise added in v1.14.0 

func NewPromise[T any]() *Promise[T]

func NewResolvedPromise added in v1.14.0 

func NewResolvedPromise[T any](result T, err error) *Promise[T]

func (*Promise[T]) Done added in v1.14.0 

func (p *Promise[T]) Done() <-chan struct{}

func (*Promise[T]) Resolve added in v1.14.0 

func (p *Promise[T]) Resolve(result T, err error)

func (*Promise[T]) Resolved added in v1.14.0 

func (p *Promise[T]) Resolved() bool

type ProtoProxy added in v1.5.5 

type ProtoProxy[T proto.Message] struct {
	// contains filtered or unexported fields
}

ProtoProxy is a caching proxy for protobuf messages that may be expensive to compute. It is used to avoid unnecessary re-generation of Protobufs

func NewProtoProxy added in v1.5.5 

func NewProtoProxy[T proto.Message](refreshInterval time.Duration, updateFn func() T) *ProtoProxy[T]

NewProtoProxy creates a new ProtoProxy that regenerates underlying values at a cadence of refreshInterval this should be used for updates that should be sent periodically, but does not have the urgency of immediate delivery updateFn should provide computations required to generate the protobuf if refreshInterval is 0, then proxy will only update on MarkDirty(true)

func (*ProtoProxy[T]) Get added in v1.5.5 

func (p *ProtoProxy[T]) Get() T

func (*ProtoProxy[T]) MarkDirty added in v1.5.5 

func (p *ProtoProxy[T]) MarkDirty(immediate bool) <-chan struct{}

func (*ProtoProxy[T]) Stop added in v1.5.5 

func (p *ProtoProxy[T]) Stop()

func (*ProtoProxy[T]) Updated added in v1.5.5 

func (p *ProtoProxy[T]) Updated() <-chan struct{}

type RWMutex added in v1.4.0 

type RWMutex struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func (*RWMutex) Lock added in v1.4.0 

func (m *RWMutex) Lock()

func (*RWMutex) RLock added in v1.4.0 

func (m *RWMutex) RLock()

func (*RWMutex) RUnlock added in v1.5.7 

func (m *RWMutex) RUnlock()

func (*RWMutex) Unlock added in v1.5.7 

func (m *RWMutex) Unlock()

type SimpleGraphEdge added in v1.7.0 

type SimpleGraphEdge struct{}

func (SimpleGraphEdge) Length added in v1.7.0 

func (e SimpleGraphEdge) Length() int64

type SimulatedClock added in v1.14.0 

type SimulatedClock struct {
	clock.Mock
}

type StuckLock added in v1.5.7 

type StuckLock struct {
	// contains filtered or unexported fields
}

func ScanTrackedLocks added in v1.4.0 

func ScanTrackedLocks(threshold time.Duration) []*StuckLock

ScanTrackedLocks check all lock trackers

func ScanTrackedLocksI added in v1.4.0 

func ScanTrackedLocksI(threshold time.Duration, n int) []*StuckLock

ScanTrackedLocksI check lock trackers incrementally n at a time

func (*StuckLock) FirstLockedAtStack added in v1.5.7 

func (d *StuckLock) FirstLockedAtStack() string

func (*StuckLock) HeldSince added in v1.5.7 

func (d *StuckLock) HeldSince() time.Time

func (*StuckLock) NumGoroutineHeld added in v1.5.7 

func (d *StuckLock) NumGoroutineHeld() int

func (*StuckLock) NumGoroutineWaiting added in v1.5.7 

func (d *StuckLock) NumGoroutineWaiting() int

type SystemClock added in v1.14.0 

type SystemClock struct{}

func (SystemClock) Now added in v1.14.0 

func (SystemClock) Now() time.Time

func (SystemClock) Sleep added in v1.14.0 

func (SystemClock) Sleep(d time.Duration)

type TimedAggregator added in v1.5.9 

type TimedAggregator[T timedAggregatorNumber] struct {
	// contains filtered or unexported fields
}

func NewTimedAggregator added in v1.5.9 

func NewTimedAggregator[T timedAggregatorNumber](params TimedAggregatorParams) *TimedAggregator[T]

func (*TimedAggregator[T]) AddSample added in v1.5.9 

func (t *TimedAggregator[T]) AddSample(val T) error

func (*TimedAggregator[T]) AddSampleAt added in v1.5.9 

func (t *TimedAggregator[T]) AddSampleAt(val T, at time.Time) error

func (*TimedAggregator[T]) GetAggregate added in v1.5.9 

func (t *TimedAggregator[T]) GetAggregate() (T, time.Duration)

func (*TimedAggregator[T]) GetAggregateAndRestartAt added in v1.5.9 

func (t *TimedAggregator[T]) GetAggregateAndRestartAt(at time.Time) (T, time.Duration, error)

func (*TimedAggregator[T]) GetAggregateAt added in v1.5.9 

func (t *TimedAggregator[T]) GetAggregateAt(at time.Time) (T, time.Duration, error)

func (*TimedAggregator[T]) GetAverage added in v1.5.9 

func (t *TimedAggregator[T]) GetAverage() float64

func (*TimedAggregator[T]) GetAverageAndRestartAt added in v1.5.9 

func (t *TimedAggregator[T]) GetAverageAndRestartAt(at time.Time) (float64, error)

func (*TimedAggregator[T]) GetAverageAt added in v1.5.9 

func (t *TimedAggregator[T]) GetAverageAt(at time.Time) (float64, error)

func (*TimedAggregator[T]) Reset added in v1.5.9 

func (t *TimedAggregator[T]) Reset()

func (*TimedAggregator[T]) Restart added in v1.5.9 

func (t *TimedAggregator[T]) Restart()

func (*TimedAggregator[T]) RestartAt added in v1.5.9 

func (t *TimedAggregator[T]) RestartAt(at time.Time)

type TimedAggregatorParams added in v1.5.9 

type TimedAggregatorParams struct {
	CapNegativeValues bool
}

type TimedVersion added in v1.4.3 

type TimedVersion uint64

func TimedVersionFromProto added in v1.4.3 

func TimedVersionFromProto(proto *livekit.TimedVersion) TimedVersion

func TimedVersionFromTime added in v1.4.3 

func TimedVersionFromTime(t time.Time) TimedVersion

func (TimedVersion) After added in v1.4.3 

func (t TimedVersion) After(other TimedVersion) bool

func (TimedVersion) Compare added in v1.4.3 

func (t TimedVersion) Compare(other TimedVersion) int

func (*TimedVersion) Downgrade added in v1.9.4 

func (t *TimedVersion) Downgrade(other TimedVersion) bool

func (TimedVersion) GormDataType added in v1.10.0 

func (t TimedVersion) GormDataType() string

func (TimedVersion) IsZero added in v1.5.5 

func (t TimedVersion) IsZero() bool

func (TimedVersion) Load added in v1.4.3 

func (t TimedVersion) Load() TimedVersion

func (*TimedVersion) Scan added in v1.9.4 

func (t *TimedVersion) Scan(src interface{}) (err error)

func (*TimedVersion) Store added in v1.4.3 

func (t *TimedVersion) Store(other TimedVersion)

func (TimedVersion) String added in v1.4.3 

func (t TimedVersion) String() string

func (TimedVersion) Time added in v1.4.3 

func (t TimedVersion) Time() time.Time

func (TimedVersion) ToProto added in v1.4.3 

func (t TimedVersion) ToProto() *livekit.TimedVersion

func (*TimedVersion) Update added in v1.4.3 

func (t *TimedVersion) Update(other TimedVersion) bool

func (*TimedVersion) Upgrade added in v1.9.4 

func (t *TimedVersion) Upgrade(other TimedVersion) bool

func (TimedVersion) Value added in v1.9.4 

func (t TimedVersion) Value() (driver.Value, error)

type TimedVersionGenerator added in v1.4.3 

type TimedVersionGenerator interface {
	Next() TimedVersion
}

func NewDefaultTimedVersionGenerator added in v1.4.3 

func NewDefaultTimedVersionGenerator() TimedVersionGenerator

type TimeoutQueue added in v1.6.0 

type TimeoutQueue[T any] struct {
	// contains filtered or unexported fields
}

func (*TimeoutQueue[T]) IterateAfter added in v1.6.0 

func (q *TimeoutQueue[T]) IterateAfter(timeout time.Duration) TimeoutQueueIterator[T]

func (*TimeoutQueue[T]) IterateRemoveAfter added in v1.6.0 

func (q *TimeoutQueue[T]) IterateRemoveAfter(timeout time.Duration) TimeoutQueueIterator[T]

func (*TimeoutQueue[T]) Remove added in v1.6.0 

func (q *TimeoutQueue[T]) Remove(i *TimeoutQueueItem[T])

func (*TimeoutQueue[T]) Reset added in v1.6.0 

func (q *TimeoutQueue[T]) Reset(i *TimeoutQueueItem[T]) bool

type TimeoutQueueItem added in v1.6.0 

type TimeoutQueueItem[T any] struct {
	Value T
	// contains filtered or unexported fields
}

type TimeoutQueueIterator added in v1.17.0 

type TimeoutQueueIterator[T any] struct {
	// contains filtered or unexported fields
}

func (*TimeoutQueueIterator[T]) Item added in v1.17.0 

func (i *TimeoutQueueIterator[T]) Item() *TimeoutQueueItem[T]

func (*TimeoutQueueIterator[T]) Next added in v1.17.0 

func (i *TimeoutQueueIterator[T]) Next() bool

type Welford added in v1.5.9 

type Welford struct {
	// contains filtered or unexported fields
}

Welford implements Welford's online algorithm for variance SEE: https://en.wikipedia.org/wiki/Algorithms_for_calculating_variance#Welford's_online_algorithm

func WelfordMerge added in v1.5.9 

func WelfordMerge(ws ...Welford) Welford

func (Welford) Count added in v1.5.9 

func (w Welford) Count() float64

func (Welford) Mean added in v1.5.9 

func (w Welford) Mean() float64

func (*Welford) Reset added in v1.5.9 

func (w *Welford) Reset()

func (Welford) StdDev added in v1.5.9 

func (w Welford) StdDev() float64

func (*Welford) Update added in v1.5.9 

func (w *Welford) Update(v float64)

func (Welford) Value added in v1.5.9 

func (w Welford) Value() (mean, variance, sampleVariance float64)

func (Welford) Variance added in v1.5.9 

func (w Welford) Variance() float64

type WorkerGroup added in v1.5.2 

type WorkerGroup struct {
	// contains filtered or unexported fields
}

func (*WorkerGroup) Go added in v1.5.2 

func (w *WorkerGroup) Go(fn func())

func (*WorkerGroup) Wait added in v1.5.2 

func (w *WorkerGroup) Wait()

Source Files

View all Source files

Directories

Path Synopsis
the missing go error package
 the missing go error package

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.