Versions in this module Expand all Collapse all v0 v0.0.2 Apr 8, 2024 Changes in this version type AsynchronousTemporalQueue + func (q *AsynchronousTemporalQueue) CloseSample() + func (q *AsynchronousTemporalQueue) Empty() bool + func (q *AsynchronousTemporalQueue) StartSample(sampleRate int, sampleWeights sync.Map) v0.0.1 Apr 7, 2024 Changes in this version + func Maximum[T constraints.Ordered](lhs, rhs T) bool + func Minimum[T constraints.Ordered](lhs, rhs T) bool + func NewAsynchronousTemporalQueueItem() *asynchronousTemporalQueueItem + type AsynchronousTemporalQueue struct + func NewAsynchronousTemporalQueue() *AsynchronousTemporalQueue + func (q *AsynchronousTemporalQueue) CloseChannel(key string) + func (q *AsynchronousTemporalQueue) CreateChannel(key string) + func (q *AsynchronousTemporalQueue) Head(key string) (values map[string]any, NTP int64, ok bool) + func (q *AsynchronousTemporalQueue) Pop() (values map[string]any, NTP int64, ok bool) + func (q *AsynchronousTemporalQueue) Push(key string, value any, NTP int64) + type PriorityQueue struct + func NewMaxPriorityQueue[T any, P constraints.Ordered]() *PriorityQueue[T, P] + func NewMinPriorityQueue[T any, P constraints.Ordered]() *PriorityQueue[T, P] + func NewPriorityQueue[T any, P constraints.Ordered](heuristic func(lhs, rhs P) bool) *PriorityQueue[T, P] + func (pq *PriorityQueue[T, P]) Empty() bool + func (pq *PriorityQueue[T, P]) Head() (value T, priority P, ok bool) + func (pq *PriorityQueue[T, P]) Pop() (value T, priority P, ok bool) + func (pq *PriorityQueue[T, P]) Push(value T, priority P) + func (pq *PriorityQueue[T, P]) Size() uint
Go to main page