storage

package
v0.7.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 8, 2025 License: Apache-2.0 Imports: 14 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type BadgerStorage 

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

BadgerStorage implements BadgerDB-based persistent storage.

func NewBadgerStorage 

func NewBadgerStorage(config BadgerStorageConfig, logger forge.Logger) (*BadgerStorage, error)

NewBadgerStorage creates a new BadgerDB storage.

func (*BadgerStorage) Backup 

func (bs *BadgerStorage) Backup(writer any) error

Backup creates a backup of the database.

func (*BadgerStorage) Compact 

func (bs *BadgerStorage) Compact() error

Compact triggers manual compaction.

func (*BadgerStorage) Delete 

func (bs *BadgerStorage) Delete(key []byte) error

Delete deletes a key.

func (*BadgerStorage) Exists 

func (bs *BadgerStorage) Exists(key []byte) (bool, error)

Exists checks if a key exists.

func (*BadgerStorage) Get 

func (bs *BadgerStorage) Get(key []byte) ([]byte, error)

Get retrieves a value by key.

func (*BadgerStorage) GetRange 

func (bs *BadgerStorage) GetRange(start, end []byte) ([]internal.KeyValue, error)

GetRange retrieves a range of key-value pairs.

func (*BadgerStorage) Iterate 

func (bs *BadgerStorage) Iterate(prefix []byte, fn func(key, value []byte) error) error

Iterate iterates over all key-value pairs with a given prefix.

func (*BadgerStorage) ListKeys 

func (bs *BadgerStorage) ListKeys(prefix []byte) ([][]byte, error)

ListKeys lists all keys with a given prefix.

func (*BadgerStorage) RunGC 

func (bs *BadgerStorage) RunGC(discardRatio float64) error

RunGC runs garbage collection.

func (*BadgerStorage) Set 

func (bs *BadgerStorage) Set(key, value []byte) error

Set stores a key-value pair.

func (*BadgerStorage) Size 

func (bs *BadgerStorage) Size() (int64, error)

Size returns the approximate size of the database in bytes.

func (*BadgerStorage) Start 

func (bs *BadgerStorage) Start(ctx context.Context) error

Start starts the storage backend.

func (*BadgerStorage) Stop 

func (bs *BadgerStorage) Stop(ctx context.Context) error

Stop stops the storage backend.

func (*BadgerStorage) WriteBatch 

func (bs *BadgerStorage) WriteBatch(ops []internal.BatchOp) error

WriteBatch writes a batch of operations atomically.

type BadgerStorageConfig 

type BadgerStorageConfig struct {
	Path               string
	SyncWrites         bool
	ValueLogFileSize   int64
	NumVersionsToKeep  int
	NumCompactors      int
	MemTableSize       int64
	BaseTableSize      int64
	BloomFalsePositive float64
	BlockSize          int
	BlockCacheSize     int64
	IndexCacheSize     int64
	NumLevelZeroTables int
	NumLevelZeroStalls int
	ValueThreshold     int
	NumMemtables       int
	DetectConflicts    bool
	CompactL0OnClose   bool
}

BadgerStorageConfig contains BadgerDB storage configuration.

type BoltDBStorage 

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

BoltDBStorage implements BoltDB-based persistent storage.

func NewBoltDBStorage 

func NewBoltDBStorage(config BoltDBStorageConfig, logger forge.Logger) (*BoltDBStorage, error)

NewBoltDBStorage creates a new BoltDB storage.

func (*BoltDBStorage) Backup 

func (bs *BoltDBStorage) Backup(path string) error

Backup creates a backup of the database.

func (*BoltDBStorage) Compact 

func (bs *BoltDBStorage) Compact() error

Compact triggers manual compaction (BoltDB compacts automatically).

func (*BoltDBStorage) Delete 

func (bs *BoltDBStorage) Delete(key []byte) error

Delete deletes a key.

func (*BoltDBStorage) Exists 

func (bs *BoltDBStorage) Exists(key []byte) (bool, error)

Exists checks if a key exists.

func (*BoltDBStorage) Get 

func (bs *BoltDBStorage) Get(key []byte) ([]byte, error)

Get retrieves a value by key.

func (*BoltDBStorage) GetRange 

func (bs *BoltDBStorage) GetRange(start, end []byte) ([]internal.KeyValue, error)

GetRange retrieves a range of key-value pairs.

func (*BoltDBStorage) Iterate 

func (bs *BoltDBStorage) Iterate(prefix []byte, fn func(key, value []byte) error) error

Iterate iterates over all key-value pairs with a given prefix.

func (*BoltDBStorage) ListKeys 

func (bs *BoltDBStorage) ListKeys(prefix []byte) ([][]byte, error)

ListKeys lists all keys with a given prefix.

func (*BoltDBStorage) Set 

func (bs *BoltDBStorage) Set(key, value []byte) error

Set stores a key-value pair.

func (*BoltDBStorage) Size 

func (bs *BoltDBStorage) Size() (int64, error)

Size returns the size of the database in bytes.

func (*BoltDBStorage) Start 

func (bs *BoltDBStorage) Start(ctx context.Context) error

Start starts the storage backend.

func (*BoltDBStorage) Stats 

func (bs *BoltDBStorage) Stats() map[string]any

Stats returns database statistics.

func (*BoltDBStorage) Stop 

func (bs *BoltDBStorage) Stop(ctx context.Context) error

Stop stops the storage backend.

func (*BoltDBStorage) WriteBatch 

func (bs *BoltDBStorage) WriteBatch(ops []internal.BatchOp) error

WriteBatch writes a batch of operations atomically.

type BoltDBStorageConfig 

type BoltDBStorageConfig struct {
	Path       string
	BucketName string
	Timeout    time.Duration
	NoSync     bool
	NoGrowSync bool
	ReadOnly   bool
	MmapFlags  int
}

BoltDBStorageConfig contains BoltDB storage configuration.

type MemoryStorage 

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

MemoryStorage implements an in-memory storage backend.

func NewMemoryStorage 

func NewMemoryStorage(config MemoryStorageConfig, logger forge.Logger) *MemoryStorage

NewMemoryStorage creates a new memory storage.

func (*MemoryStorage) Batch 

func (s *MemoryStorage) Batch(ops []internal.BatchOp) error

Batch executes a batch of operations.

func (*MemoryStorage) Clear 

func (s *MemoryStorage) Clear() error

Clear removes all stored data.

func (*MemoryStorage) Close 

func (s *MemoryStorage) Close() error

Close closes the storage backend.

func (*MemoryStorage) Delete 

func (s *MemoryStorage) Delete(key []byte) error

Delete deletes a key.

func (*MemoryStorage) Exists 

func (s *MemoryStorage) Exists(key []byte) (bool, error)

Exists checks if a key exists.

func (*MemoryStorage) Get 

func (s *MemoryStorage) Get(key []byte) ([]byte, error)

Get retrieves a value by key.

func (*MemoryStorage) GetRange 

func (s *MemoryStorage) GetRange(start, end []byte) ([]internal.KeyValue, error)

GetRange retrieves a range of key-value pairs.

func (*MemoryStorage) Iterate 

func (s *MemoryStorage) Iterate(prefix []byte, fn func(key, value []byte) error) error

Iterate iterates over all key-value pairs.

func (*MemoryStorage) ListKeys 

func (s *MemoryStorage) ListKeys(prefix []byte) ([][]byte, error)

ListKeys lists all keys with a given prefix.

func (*MemoryStorage) Set 

func (s *MemoryStorage) Set(key, value []byte) error

Set stores a key-value pair.

func (*MemoryStorage) Size 

func (s *MemoryStorage) Size() int

Size returns the number of stored keys.

func (*MemoryStorage) Start 

func (s *MemoryStorage) Start(ctx context.Context) error

Start starts the storage backend.

func (*MemoryStorage) Stop 

func (s *MemoryStorage) Stop(ctx context.Context) error

Stop stops the storage backend.

func (*MemoryStorage) WriteBatch 

func (s *MemoryStorage) WriteBatch(ops []internal.BatchOp) error

WriteBatch writes a batch of operations atomically.

type MemoryStorageConfig 

type MemoryStorageConfig struct {
	InitialCapacity int
}

MemoryStorageConfig contains configuration for memory storage.

type WAL 

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

WAL implements Write-Ahead Logging for consensus operations.

func NewWAL 

func NewWAL(nodeID string, config WALConfig, logger forge.Logger) (*WAL, error)

NewWAL creates a new WAL.

func (*WAL) Close 

func (w *WAL) Close() error

Close closes the WAL.

func (*WAL) GetStatistics 

func (w *WAL) GetStatistics() WALStatistics

GetStatistics returns WAL statistics.

func (*WAL) Read 

func (w *WAL) Read(ctx context.Context, startIndex uint64) ([]*WALEntry, error)

Read reads entries from the WAL.

func (*WAL) Sync 

func (w *WAL) Sync() error

Sync syncs the WAL to disk.

func (*WAL) Truncate 

func (w *WAL) Truncate(ctx context.Context, index uint64) error

Truncate truncates the WAL up to the given index.

func (*WAL) Write 

func (w *WAL) Write(ctx context.Context, entry *WALEntry) error

Write writes an entry to the WAL.

type WALConfig 

type WALConfig struct {
	Dir               string
	MaxFileSize       int64
	SyncInterval      time.Duration
	EnableCompression bool
	EnableChecksum    bool
}

WALConfig contains WAL configuration.

type WALEntry 

type WALEntry struct {
	Type      WALEntryType
	Index     uint64
	Term      uint64
	Data      []byte
	Timestamp time.Time
	Checksum  uint32
}

WALEntry represents a WAL entry.

type WALEntryType 

type WALEntryType uint8

WALEntryType represents the type of WAL entry. 

const (
	// WALEntryTypeLog log entry.
	WALEntryTypeLog WALEntryType = 1
	// WALEntryTypeMeta metadata entry.
	WALEntryTypeMeta WALEntryType = 2
	// WALEntryTypeSnapshot snapshot entry.
	WALEntryTypeSnapshot WALEntryType = 3
	// WALEntryTypeCheckpoint checkpoint entry.
	WALEntryTypeCheckpoint WALEntryType = 4
)

type WALStatistics 

type WALStatistics struct {
	TotalWrites   int64
	TotalReads    int64
	BytesWritten  int64
	BytesRead     int64
	SyncCount     int64
	RotationCount int64
	LastSync      time.Time
	LastRotation  time.Time
}

WALStatistics contains WAL statistics.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.