distributed

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

type BucketConfig struct {
	Name   string
	Region string
	Type   string
	Public bool
}

type Config struct {
	// DataDir is the root directory for distributed node storage
	DataDir string

	// BadgerDir is the directory for the Badger KV database (used when DBClient is nil)
	BadgerDir string

	// Reed-Solomon configuration
	DataShards   int
	ParityShards int

	// Hash ring configuration
	PartitionCount    int
	ReplicationFactor int

	// QUIC server base port (each node uses BasePort + nodeNum)
	QuicBasePort int

	// UseQUIC enables QUIC-based shard distribution (requires QUIC servers to be running)
	UseQUIC bool

	// Nodes configuration (from cluster.toml)
	Nodes []NodeConfig

	// Buckets configuration (from cluster.toml)
	Buckets []BucketConfig

	// DBClient holds configuration for the distributed database client
	// When set, uses distributed s3db for global state instead of local BadgerDB
	DBClient *DBClientConfig
}

type DBClientConfig struct {
	Nodes           []string // List of DB node addresses
	AccessKeyID     string   // AWS-style access key ID
	SecretAccessKey string   // AWS-style secret access key
	Region          string   // Region for signing (default: us-east-1)
}

type DeletedObjectInfo struct {
	Bucket         string   `json:"bucket"`
	Key            string   `json:"key"`
	ObjectHash     [32]byte `json:"object_hash"`
	DeletedAt      int64    `json:"deleted_at"`       // Unix timestamp
	DataShardNodes []uint32 `json:"data_shard_nodes"` // Which nodes had data shards
	ParityNodes    []uint32 `json:"parity_nodes"`     // Which nodes had parity shards
}

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

type GlobalState interface {
	// Get retrieves a value by key from the specified table
	Get(table string, key []byte) ([]byte, error)

	// Set stores a key-value pair in the specified table
	Set(table string, key []byte, value []byte) error

	// Delete removes a key from the specified table
	Delete(table string, key []byte) error

	// Exists checks if a key exists in the specified table
	Exists(table string, key []byte) (bool, error)

	// ListKeys returns all keys with the given prefix in the specified table
	ListKeys(table string, prefix []byte) ([][]byte, error)

	// Scan iterates over all keys with the given prefix
	Scan(table string, prefix []byte, fn func(key, value []byte) error) error

	// Close closes the state store
	Close() error
}

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

type NodeConfig struct {
	ID     int
	Host   string
	Port   int
	Path   string
	DB     bool
	DBPort int
	DBPath string
	Leader bool
	Epoch  int
}

type ObjectShardReader struct {
	File        *os.File
	WALFileInfo wal.WALFileInfo
}

type ObjectToShardNodes struct {
	Object           [32]byte
	Size             int64
	DataShardNodes   []uint32
	ParityShardNodes []uint32
}