Documentation
¶
Overview ¶
The hwm package contains the HighWatermarkTracker;
Index ¶
- type HighWatermarkTracker
- func (trie *HighWatermarkTracker) DeleteOldKeys(hwmLimit uint64) []string
- func (trie *HighWatermarkTracker) StartTrackingDeletions()
- func (trie *HighWatermarkTracker) StopTrackingDeletions()
- func (trie *HighWatermarkTracker) StoreDeletion(key string, newModIdx uint64) []string
- func (trie *HighWatermarkTracker) StoreUpdate(key string, newModIdx uint64) (oldModIdx uint64)
- func (trie *HighWatermarkTracker) ToMap() map[string]uint64
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type HighWatermarkTracker ¶
type HighWatermarkTracker struct {
// contains filtered or unexported fields
}
HighWatermarkTracker: map that tracks the highest value seen for each key. Supports temporary tracking of deletions in order to resolve concurrent updates.
func NewHighWatermarkTracker ¶
func NewHighWatermarkTracker() *HighWatermarkTracker
func (*HighWatermarkTracker) DeleteOldKeys ¶
func (trie *HighWatermarkTracker) DeleteOldKeys(hwmLimit uint64) []string
func (*HighWatermarkTracker) StartTrackingDeletions ¶
func (trie *HighWatermarkTracker) StartTrackingDeletions()
func (*HighWatermarkTracker) StopTrackingDeletions ¶
func (trie *HighWatermarkTracker) StopTrackingDeletions()
func (*HighWatermarkTracker) StoreDeletion ¶
func (trie *HighWatermarkTracker) StoreDeletion(key string, newModIdx uint64) []string
func (*HighWatermarkTracker) StoreUpdate ¶
func (trie *HighWatermarkTracker) StoreUpdate(key string, newModIdx uint64) (oldModIdx uint64)
func (*HighWatermarkTracker) ToMap ¶
func (trie *HighWatermarkTracker) ToMap() map[string]uint64
Source Files
Click to show internal directories.
Click to hide internal directories.