storage

type BBoltBackupConfig struct {
	// Directory specifies the directory in which the BBolt backup should be written.
	Directory string `koanf:"directory"`
	// Interval specifies the time between backups.
	Interval time.Duration `koanf:"interval"`
}

type BBoltConfig struct {
	// Backup specifies backup config for the database.
	Backup BBoltBackupConfig `koanf:"backup"`
	// LockTimeout specifies the maximum time to wait for acquiring a lock on the database before giving up and returning an error.
	LockTimeout time.Duration `koanf:"locktimeout"`
}

type Class int

type Config struct {
	BBolt BBoltConfig `koanf:"bbolt"`
	Redis RedisConfig `koanf:"redis"`
	// Debug specifies whether to enable debug logging for the storage engine, e.g. performance metrics and query logging.
	Debug bool `koanf:"debug"`
}

type Engine interface {
	core.Engine
	core.Configurable
	core.Runnable

	// GetProvider returns the Provider for the given module.
	GetProvider(moduleName string) Provider
}

type KVBackedLeiaStore interface {
	leia.Store
	// AddConfiguration adds a configuration for a collection to the store.
	// This is needed to know the kind of collection, the backup shelf name and the iterate query to fetch the documents.
	AddConfiguration(config LeiaBackupConfiguration)
	// HandleRestore migrates the data from the backup store to the leia.Store if needed.
	// It's up to the caller to create the indices on the leia.Collections first before calling this method.
	HandleRestore() error
}

type LeiaBackupConfiguration struct {
	// CollectionName is the name of the collection in the leia.Store.
	CollectionName string
	CollectionType leia.CollectionType
	// BackupShelf is the name of the shelf in the backup store.
	BackupShelf string
	// SearchQuery is used to fill the backup shelf if not present.
	SearchQuery leia.QueryPath
}

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

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

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

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

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

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

type Provider interface {
	// GetKVStore returns a key-value store. Stores are identified by a name.
	// When identical name is passed the same store is returned.
	// Names must be alphanumeric, non-zero strings.
	GetKVStore(name string, class Class) (stoabs.KVStore, error)
}

type RedisConfig struct {
	Address  string              `koanf:"address"`
	Username string              `koanf:"username"`
	Password string              `koanf:"password"`
	Database string              `koanf:"database"`
	TLS      RedisTLSConfig      `koanf:"tls"`
	Sentinel RedisSentinelConfig `koanf:"sentinel"`
}

type RedisSentinelConfig struct {
	Master   string   `koanf:"master"`
	Nodes    []string `koanf:"nodes"`
	Username string   `koanf:"username"`
	Password string   `koanf:"password"`
}

type RedisTLSConfig struct {
	TrustStoreFile string `koanf:"truststorefile"`
}

type StaticKVStoreProvider struct {
	Store stoabs.KVStore
}