weighted

package
v0.0.0-...-58fff37 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 15, 2020 License: Apache-2.0 Imports: 3 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewWeightedMemberStrategy

func NewWeightedMemberStrategy(kind string) cluster.MemberStrategy

Types

type WeightedMemberStatusValue

type WeightedMemberStatusValue struct {
	Weight int
}

func (*WeightedMemberStatusValue) IsSame

type WeightedMemberStatusValueSerializer

type WeightedMemberStatusValueSerializer struct{}

func (*WeightedMemberStatusValueSerializer) Deserialize

func (*WeightedMemberStatusValueSerializer) Serialize

type WeightedMemberStrategy

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

func (*WeightedMemberStrategy) AddMember

func (m *WeightedMemberStrategy) AddMember(member *cluster.MemberStatus)

func (*WeightedMemberStrategy) GetActivator

func (m *WeightedMemberStrategy) GetActivator() string

func (*WeightedMemberStrategy) GetAllMembers

func (m *WeightedMemberStrategy) GetAllMembers() []*cluster.MemberStatus

func (*WeightedMemberStrategy) GetPartition

func (m *WeightedMemberStrategy) GetPartition(key string) string

func (*WeightedMemberStrategy) RemoveMember

func (m *WeightedMemberStrategy) RemoveMember(member *cluster.MemberStatus)

func (*WeightedMemberStrategy) UpdateMember

func (m *WeightedMemberStrategy) UpdateMember(member *cluster.MemberStatus)

type WeightedRoundRobin

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

func NewWeightedRoundRobin

func NewWeightedRoundRobin(memberStrategy cluster.MemberStrategy) *WeightedRoundRobin

func (*WeightedRoundRobin) GetByRoundRobin

func (r *WeightedRoundRobin) GetByRoundRobin() string

func (*WeightedRoundRobin) UpdateRR

func (r *WeightedRoundRobin) UpdateRR()

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL