balancer

Documentation

Index

• Constants
• func NameForReplicationFactor(replicationFactor uint16) string
• func NewConsistentHashringBuilder(hasher consistent.HasherFunc, replicationFactor uint16, spread uint8) balancer.Builder
• func ServiceConfigForBalancerName(balancerName string) string

Constants

const (

	// CtxKey is the key for the grpc request's context.Context which points to
	// the key to hash for the request. The value it points to must be []byte
	CtxKey ctxKey = "requestKey"
)

Functions

func NameForReplicationFactor

func NameForReplicationFactor(replicationFactor uint16) string

NameForReplicationFactor returns the name of the balancer for a given replication factor

func NewConsistentHashringBuilder

func NewConsistentHashringBuilder(hasher consistent.HasherFunc, replicationFactor uint16, spread uint8) balancer.Builder

NewConsistentHashringBuilder creates a new balancer.Builder that will create a consistent hashring balancer with the given config. Before making a connection, register it with grpc with: `balancer.Register(consistent.NewConsistentHashringBuilder(hasher, factor, spread))`

func ServiceConfigForBalancerName

func ServiceConfigForBalancerName(balancerName string) string

ServiceConfigForBalancerName provides the gRPC service configuration string for a hashring balancer with a specific replication factor by its name