storage

package

v0.0.0-...-d0cb44a Latest Latest Go to latest Published: May 27, 2025 License: MIT Imports: 16 Imported by: 0

Details

View Source

const (
	HealInterval = 5 * time.Minute
	MinReplicas  = 3
)

This section is empty.

This section is empty.

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

func NewBadgerStore(dir string) (*BadgerStore, error)

func (s *BadgerStore) Close() error

func (s *BadgerStore) DeleteObject(bucket, key string) error

func (s *BadgerStore) DeleteObjectVersion(ctx context.Context, bucket, key, versionID string) error

func (s *BadgerStore) GetObject(bucket, key string) ([]byte, error)

func (s *BadgerStore) PurgeDeletedObjects(ctx context.Context, retention time.Duration) error

func (s *BadgerStore) PutObject(bucket, key string, data []byte) error

func (s *BadgerStore) SelfHeal(ctx context.Context) error

func (s *BadgerStore) SoftDeleteObject(ctx context.Context, bucket, key string) error

func (s *BadgerStore) StoreDAG(ctx context.Context, node *dag.MerkleNode) error

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

func NewPostgresStore(connStr string) (*PostgresStore, error)

func (s *PostgresStore) Migrate() error

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

func NewQuotaManager(store *BadgerStore) *QuotaManager

func (q *QuotaManager) CheckQuota(ctx context.Context, bucket string, size int64) error

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

func NewReplicator(store *BadgerStore, dht *p2p.DHTOperations) *Replicator

func (r *Replicator) EnsureReplicas(ctx context.Context) error

func (r *Replicator) Replicate(ctx context.Context, bucket, key string) error

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

func NewStorageManager(store *BadgerStore) *StorageManager