roundrobin

Documentation

Index

• type RoundRobin
  • func New(enableWeight bool) *RoundRobin
  • func (r *RoundRobin) Add(ep endpoint.Endpoint) error
  • func (r *RoundRobin) Refresh(eps []endpoint.Endpoint)
  • func (r *RoundRobin) Remove(ep endpoint.Endpoint) error
  • func (r *RoundRobin) Select(_ selector.Message) (endpoint.Endpoint, error)

Types

type RoundRobin

type RoundRobin struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func New

func New(enableWeight bool) *RoundRobin

func (*RoundRobin) Add

func (r *RoundRobin) Add(ep endpoint.Endpoint) error

func (*RoundRobin) Refresh

func (r *RoundRobin) Refresh(eps []endpoint.Endpoint)

func (*RoundRobin) Remove

func (r *RoundRobin) Remove(ep endpoint.Endpoint) error

func (*RoundRobin) Select

func (r *RoundRobin) Select(_ selector.Message) (endpoint.Endpoint, error)