trim

func ByAge ¶

func ByAge(ctx context.Context, l klevdb.Log, before time.Time) (map[int64]struct{}, int64, error)

ByAge tries to remove the messages at the start of the log before given time returns the offsets it deleted and the amount of storage freed

func ByCount ¶ added in v0.2.3

func ByCount(ctx context.Context, l klevdb.Log, max int) (map[int64]struct{}, int64, error)

func ByOffset ¶ added in v0.2.5

func ByOffset(ctx context.Context, l klevdb.Log, before int64) (map[int64]struct{}, int64, error)

ByOffset tries to remove the messages at the start of the log before offset returns the offsets it deleted and the amount of storage freed

func BySize ¶

func BySize(ctx context.Context, l klevdb.Log, sz int64) (map[int64]struct{}, int64, error)

BySize tries to remove messages until log size is less then sz returns the offsets it deleted and the amount of storage freed