deletebuffer

Documentation

Index

• func NewDeleteBuffer() *deleteBuffer
• type BufferItem
  • func (item *BufferItem) EntryNum() int64
  • func (item *BufferItem) Size() int64
• type DeleteBuffer
  • func NewDoubleCacheDeleteBuffer[T timed](startTs uint64, maxSize int64) DeleteBuffer[T]
  • func NewListDeleteBuffer[T timed](startTs uint64, sizePerBlock int64, labels []string) DeleteBuffer[T]
• type Item
  • func (item *Item) EntryNum() int64
  • func (item *Item) Size() int64
  • func (item *Item) Timestamp() uint64

Functions

func NewDeleteBuffer

func NewDeleteBuffer() *deleteBuffer

Types

type BufferItem

type BufferItem struct {
	PartitionID int64
	DeleteData  storage.DeleteData
}

func (*BufferItem) EntryNum

func (item *BufferItem) EntryNum() int64

func (*BufferItem) Size

func (item *BufferItem) Size() int64

type DeleteBuffer

type DeleteBuffer[T timed] interface {
	Put(T)
	ListAfter(uint64) []T
	SafeTs() uint64
	TryDiscard(uint64)
	// Size returns current size information of delete buffer: entryNum and memory
	Size() (entryNum, memorySize int64)
}

DeleteBuffer is the interface for delete buffer.

func NewDoubleCacheDeleteBuffer

func NewDoubleCacheDeleteBuffer[T timed](startTs uint64, maxSize int64) DeleteBuffer[T]

func NewListDeleteBuffer

func NewListDeleteBuffer[T timed](startTs uint64, sizePerBlock int64, labels []string) DeleteBuffer[T]

type Item

type Item struct {
	Ts   uint64
	Data []BufferItem
}

Item wraps cache item as `timed`.

func (*Item) EntryNum

func (item *Item) EntryNum() int64

func (*Item) Size

func (item *Item) Size() int64

Size implements `timed`.

func (*Item) Timestamp

func (item *Item) Timestamp() uint64

Timestamp implements `timed`.