gxselector

package

v0.3.3 Latest Latest Go to latest Published: Dec 9, 2020 License: Apache-2.0 Imports: 1 Imported by: 0

Details

View Source

const (
	MaxFails = 10
)

This section is empty.

This section is empty.

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

func NewSW(maxFails int) *SW

func (w *SW) Add(item interface{}, weight int)

Add a weighted server.

func (w *SW) All() map[interface{}]int

All returns all items.

func (w *SW) Next() SWItem

Next returns next selected server.

func (w *SW) Release(item SWItem, success bool)

func (w *SW) RemoveAll()

RemoveAll removes all weighted items.

func (w *SW) Reset()

Reset resets all current weights.

type SWItem interface {
	Index() int        // its index in all items
	Item() interface{} // ite primary item
}