untyped

Documentation

Index

• func CloseStore(db badgerwrap.DB) error
• func GetAgeOfPartitionInHours(partitionId string) (float64, error)
• func GetPartitionDuration() time.Duration
• func GetPartitionId(timestamp time.Time) string
• func GetTimeForPartition(partitionId string) (time.Time, error)
• func GetTimeRangeForPartition(partitionId string) (time.Time, time.Time, error)
• func OpenStore(factory badgerwrap.Factory, config *Config) (badgerwrap.DB, error)
• func TestHookSetPartitionDuration(partDuration time.Duration)
• type Config

Functions

func CloseStore

func CloseStore(db badgerwrap.DB) error

func GetAgeOfPartitionInHours

func GetAgeOfPartitionInHours(partitionId string) (float64, error)

func GetPartitionDuration

func GetPartitionDuration() time.Duration

func GetPartitionId

func GetPartitionId(timestamp time.Time) string

Partitions need to be in lexicographical sorted order, so zero pad to 12 digits

func GetTimeForPartition

func GetTimeForPartition(partitionId string) (time.Time, error)

func GetTimeRangeForPartition

func GetTimeRangeForPartition(partitionId string) (time.Time, time.Time, error)

func OpenStore

func OpenStore(factory badgerwrap.Factory, config *Config) (badgerwrap.DB, error)

func TestHookSetPartitionDuration

func TestHookSetPartitionDuration(partDuration time.Duration)

Types

type Config

type Config struct {
	RootPath                 string
	ConfigPartitionDuration  time.Duration
	BadgerMaxTableSize       int64
	BadgerKeepL0InMemory     bool
	BadgerVLogFileSize       int64
	BadgerVLogMaxEntries     uint
	BadgerUseLSMOnlyOptions  bool
	BadgerEnableEventLogging bool
	BadgerNumOfCompactors    int
	BadgerNumL0Tables        int
	BadgerNumL0TablesStall   int
	BadgerSyncWrites         bool
	BadgerLevelOneSize       int64
	BadgerLevSizeMultiplier  int
	BadgerVLogFileIOMapping  bool
	BadgerDetailLogEnabled   bool
	BadgerVLogTruncate       bool
}