disk

Documentation

Index

• type Disk
  • func NewDiskCache[T any](bLogger badger.Logger, options schema.GPQOptions) (*Disk[T], error)
  • func (d *Disk[T]) Close() error
  • func (d *Disk[T]) DeleteBatch(batch []*schema.DeleteMessage) error
  • func (d *Disk[T]) DeleteSingle(key []byte) error
  • func (d *Disk[T]) ItemsInDB() uint
  • func (d *Disk[T]) ProcessBatch(batch []*schema.Item[T]) error
  • func (d *Disk[T]) RestoreFromDisk() ([]*schema.Item[T], error)
  • func (d *Disk[T]) WriteSingle(key []byte, value schema.Item[T]) error

Types

type Disk

type Disk[T any] struct {
	// contains filtered or unexported fields
}

func NewDiskCache

func NewDiskCache[T any](bLogger badger.Logger, options schema.GPQOptions) (*Disk[T], error)

func (*Disk[T]) Close

func (d *Disk[T]) Close() error

func (*Disk[T]) DeleteBatch

func (d *Disk[T]) DeleteBatch(batch []*schema.DeleteMessage) error

func (*Disk[T]) DeleteSingle

func (d *Disk[T]) DeleteSingle(key []byte) error

func (*Disk[T]) ItemsInDB

func (d *Disk[T]) ItemsInDB() uint

func (*Disk[T]) ProcessBatch

func (d *Disk[T]) ProcessBatch(batch []*schema.Item[T]) error

func (*Disk[T]) RestoreFromDisk

func (d *Disk[T]) RestoreFromDisk() ([]*schema.Item[T], error)

func (*Disk[T]) WriteSingle

func (d *Disk[T]) WriteSingle(key []byte, value schema.Item[T]) error