blockcleaner

Documentation

Index

• type BlockRemovalContext
• type Config
  • func (cfg *Config) RegisterFlagsWithPrefix(prefix string, f *flag.FlagSet)
• type DeletionMarkers
  • func NewDeletionMarkers(db *bbolt.DB, cfg *Config, logger log.Logger, reg prometheus.Registerer) *DeletionMarkers
  • func (m *DeletionMarkers) FindExpiredMarkers(now int64) map[string]*BlockRemovalContext
  • func (m *DeletionMarkers) IsMarked(blockId string) bool
  • func (m *DeletionMarkers) Load()
  • func (m *DeletionMarkers) Mark(shard uint32, tenant string, blockId string, deletedTs int64) error
  • func (m *DeletionMarkers) Reload(db *bbolt.DB)
  • func (m *DeletionMarkers) Remove(markers map[string]*BlockRemovalContext) error

Types

type BlockRemovalContext

type BlockRemovalContext struct {
	Shard    uint32
	Tenant   string
	ExpiryTs int64
}

type Config

type Config struct {
	CompactedBlocksCleanupInterval time.Duration `yaml:"compacted_blocks_cleanup_interval"`
	CompactedBlocksCleanupDelay    time.Duration `yaml:"compacted_blocks_cleanup_delay"`
}

func (*Config) RegisterFlagsWithPrefix

func (cfg *Config) RegisterFlagsWithPrefix(prefix string, f *flag.FlagSet)

type DeletionMarkers

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

func NewDeletionMarkers

func NewDeletionMarkers(db *bbolt.DB, cfg *Config, logger log.Logger, reg prometheus.Registerer) *DeletionMarkers

func (*DeletionMarkers) FindExpiredMarkers

func (m *DeletionMarkers) FindExpiredMarkers(now int64) map[string]*BlockRemovalContext

func (*DeletionMarkers) IsMarked

func (m *DeletionMarkers) IsMarked(blockId string) bool

func (*DeletionMarkers) Load

func (m *DeletionMarkers) Load()

func (*DeletionMarkers) Mark

func (m *DeletionMarkers) Mark(shard uint32, tenant string, blockId string, deletedTs int64) error

func (*DeletionMarkers) Reload

func (m *DeletionMarkers) Reload(db *bbolt.DB)

func (*DeletionMarkers) Remove

func (m *DeletionMarkers) Remove(markers map[string]*BlockRemovalContext) error