tombstones

Documentation

Index

• func NewStore() *store.TombstoneStore
• type TombstoneStore
• type Tombstones
  • func NewTombstones(store TombstoneStore) *Tombstones
  • func (x *Tombstones) AddTombstones(tx *bbolt.Tx, cmd *raft.Log, t *metastorev1.Tombstones) error
  • func (x *Tombstones) DeleteTombstones(tx *bbolt.Tx, cmd *raft.Log, tombstones ...*metastorev1.Tombstones) error
  • func (x *Tombstones) Exists(tenant string, shard uint32, block string) bool
  • func (x *Tombstones) Init(tx *bbolt.Tx) error
  • func (x *Tombstones) ListTombstones(before time.Time) iter.Iterator[*metastorev1.Tombstones]
  • func (x *Tombstones) Restore(tx *bbolt.Tx) error

Functions

func NewStore

func NewStore() *store.TombstoneStore

Types

type TombstoneStore

type TombstoneStore interface {
	StoreTombstones(*bbolt.Tx, store.TombstoneEntry) error
	DeleteTombstones(*bbolt.Tx, store.TombstoneEntry) error
	ListEntries(*bbolt.Tx) iter.Iterator[store.TombstoneEntry]
	CreateBuckets(*bbolt.Tx) error
}

type Tombstones

type Tombstones struct {
	// contains filtered or unexported fields
}

func NewTombstones

func NewTombstones(store TombstoneStore) *Tombstones

func (*Tombstones) AddTombstones

func (x *Tombstones) AddTombstones(tx *bbolt.Tx, cmd *raft.Log, t *metastorev1.Tombstones) error

func (*Tombstones) DeleteTombstones

func (x *Tombstones) DeleteTombstones(tx *bbolt.Tx, cmd *raft.Log, tombstones ...*metastorev1.Tombstones) error

func (*Tombstones) Exists

func (x *Tombstones) Exists(tenant string, shard uint32, block string) bool

func (*Tombstones) Init

func (x *Tombstones) Init(tx *bbolt.Tx) error

func (*Tombstones) ListTombstones

func (x *Tombstones) ListTombstones(before time.Time) iter.Iterator[*metastorev1.Tombstones]

func (*Tombstones) Restore

func (x *Tombstones) Restore(tx *bbolt.Tx) error