Versions in this module Expand all Collapse all v0 v0.0.1 Oct 25, 2020 Changes in this version + func NewWeightedMemberStrategy(kind string) cluster.MemberStrategy + type WeightedMemberStatusValue struct + Weight int + func (sv *WeightedMemberStatusValue) IsSame(val cluster.MemberStatusValue) bool + type WeightedMemberStatusValueSerializer struct + func (s *WeightedMemberStatusValueSerializer) Deserialize(val string) cluster.MemberStatusValue + func (s *WeightedMemberStatusValueSerializer) Serialize(val cluster.MemberStatusValue) string + type WeightedMemberStrategy struct + func (m *WeightedMemberStrategy) AddMember(member *cluster.MemberStatus) + func (m *WeightedMemberStrategy) GetActivator() string + func (m *WeightedMemberStrategy) GetAllMembers() []*cluster.MemberStatus + func (m *WeightedMemberStrategy) GetPartition(key string) string + func (m *WeightedMemberStrategy) RemoveMember(member *cluster.MemberStatus) + func (m *WeightedMemberStrategy) UpdateMember(member *cluster.MemberStatus) + type WeightedRoundRobin struct + func NewWeightedRoundRobin(memberStrategy cluster.MemberStrategy) *WeightedRoundRobin + func (r *WeightedRoundRobin) GetByRoundRobin() string + func (r *WeightedRoundRobin) UpdateRR()