nodepicker

Documentation

Index

• Variables
• type Config
• type ConsistentUniformHashNodePicker
  • func (p *ConsistentUniformHashNodePicker) PickNode(_ context.Context, config Config, shardIDs []storage.ShardID, ...) (map[storage.ShardID]metadata.RegisteredNode, error)
• type NodePicker
  • func NewConsistentUniformHashNodePicker(logger *zap.Logger) NodePicker

Variables

var ErrNoAliveNodes = coderr.NewCodeError(coderr.InvalidParams, "no alive nodes is found")

Types

type Config

type Config struct {
	NumTotalShards    uint32
	ShardAffinityRule map[storage.ShardID]scheduler.ShardAffinity
}

type ConsistentUniformHashNodePicker

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

func (*ConsistentUniformHashNodePicker) PickNode

func (p *ConsistentUniformHashNodePicker) PickNode(_ context.Context, config Config, shardIDs []storage.ShardID, registerNodes []metadata.RegisteredNode) (map[storage.ShardID]metadata.RegisteredNode, error)

type NodePicker

type NodePicker interface {
	PickNode(ctx context.Context, config Config, shardIDs []storage.ShardID, registerNodes []metadata.RegisteredNode) (map[storage.ShardID]metadata.RegisteredNode, error)
}

func NewConsistentUniformHashNodePicker

func NewConsistentUniformHashNodePicker(logger *zap.Logger) NodePicker