roundrobin

package
v0.0.0-...-bc1b0c2 Latest Latest
Warning

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

Go to latest
Published: Sep 13, 2024 License: BSD-3-Clause Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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(msg selector.Message) (endpoint.Endpoint, error)

Jump to

Keyboard shortcuts

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