protoactor-go: github.com/AsynkronIT/protoactor-go/cluster/weighted Index | Files

package weighted

import "github.com/AsynkronIT/protoactor-go/cluster/weighted"

Index

Package Files

weighted_member_status.go weighted_member_strategy.go weighted_round_robin.go

func NewWeightedMemberStrategy Uses

func NewWeightedMemberStrategy(kind string) cluster.MemberStrategy

type WeightedMemberStatusValue Uses

type WeightedMemberStatusValue struct {
    Weight int
}

func (*WeightedMemberStatusValue) IsSame Uses

func (sv *WeightedMemberStatusValue) IsSame(val cluster.MemberStatusValue) bool

type WeightedMemberStatusValueSerializer Uses

type WeightedMemberStatusValueSerializer struct{}

func (*WeightedMemberStatusValueSerializer) FromValueBytes Uses

func (s *WeightedMemberStatusValueSerializer) FromValueBytes(val []byte) cluster.MemberStatusValue

func (*WeightedMemberStatusValueSerializer) ToValueBytes Uses

func (s *WeightedMemberStatusValueSerializer) ToValueBytes(val cluster.MemberStatusValue) []byte

type WeightedMemberStrategy Uses

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

func (*WeightedMemberStrategy) AddMember Uses

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

func (*WeightedMemberStrategy) GetActivator Uses

func (m *WeightedMemberStrategy) GetActivator() string

func (*WeightedMemberStrategy) GetAllMembers Uses

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

func (*WeightedMemberStrategy) GetPartition Uses

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

func (*WeightedMemberStrategy) RemoveMember Uses

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

func (*WeightedMemberStrategy) UpdateMember Uses

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

type WeightedRoundRobin Uses

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

func NewWeightedRoundRobin Uses

func NewWeightedRoundRobin(memberStrategy cluster.MemberStrategy) *WeightedRoundRobin

func (*WeightedRoundRobin) GetByRoundRobin Uses

func (r *WeightedRoundRobin) GetByRoundRobin() string

func (*WeightedRoundRobin) UpdateRR Uses

func (r *WeightedRoundRobin) UpdateRR()

Package weighted imports 3 packages (graph). Updated 2017-11-18. Refresh now. Tools for package owners.