Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func Deletes ¶
func Deletes(ctx context.Context, l klevdb.Log, before time.Time) (map[int64]struct{}, int64, error)
Deletes tries to remove messages with nil value before given time.
It will not remove messages for keys it sees before that offset.
This is similar to removing keys, which were deleted (e.g. value set to nil)
and are therfore no longer relevant/active.
returns the offsets it deleted and the amount of storage freed
func Updates ¶
func Updates(ctx context.Context, l klevdb.Log, before time.Time) (map[int64]struct{}, int64, error)
Updates tries to remove messages before given time that are repeated
further in the log leaving only the last message for a given key.
This is similar to removing the old value updates,
leaving only the current value (last update) for a key.
returns the offsets it deleted and the amount of storage freed
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.