Versions in this module Expand all Collapse all v1 v1.2.7 Oct 10, 2023 Changes in this version + var ErrNoAliveNodes = coderr.NewCodeError(coderr.InvalidParams, "no alive nodes is found") + type Config struct + NumTotalShards uint32 + ShardAffinityRule map[storage.ShardID]scheduler.ShardAffinity + type ConsistentUniformHashNodePicker struct + func (p *ConsistentUniformHashNodePicker) PickNode(_ context.Context, config Config, shardIDs []storage.ShardID, ...) (map[storage.ShardID]metadata.RegisteredNode, error) + type NodePicker interface + PickNode func(ctx context.Context, config Config, shardIDs []storage.ShardID, ...) (map[storage.ShardID]metadata.RegisteredNode, error) + func NewConsistentUniformHashNodePicker(logger *zap.Logger) NodePicker