shard

Nov 22, 2024

Changes in this version

type ShardConfig

+ func (config *ShardConfig) NextSegmentIndex(startSegmentIndex uint64) uint64

type ShardedNode

+ func NewShardNodesFromConfig(configs []*ShardConfig) []*ShardedNode

Jul 18, 2024

Changes in this version

+ func CheckReplica(shardConfigs []*ShardConfig, expectedReplica uint) bool

+ type ShardConfig struct

+ NumShard uint64

+ ShardId uint64

+ func (config *ShardConfig) HasSegment(segmentIndex uint64) bool

+ func (config *ShardConfig) IsValid() bool

+ type ShardedNode struct

+ Config ShardConfig

+ Latency int64

+ Since int64

+ URL string

+ func Select(nodes []*ShardedNode, expectedReplica uint) ([]*ShardedNode, bool)