selector

Documentation

Index

• Constants
• func BackupFilter[T any]() selector.Filter[T]
• func FIFOStrategy[T any]() selector.Strategy[T]
• func FailFilter[T any](maxFails int, timeout time.Duration) selector.Filter[T]
• func HashStrategy[T any]() selector.Strategy[T]
• func NewSelector[T any](strategy selector.Strategy[T], filters ...selector.Filter[T]) selector.Selector[T]
• func RandomStrategy[T any]() selector.Strategy[T]
• func RoundRobinStrategy[T any]() selector.Strategy[T]

Constants

const (
	DefaultMaxFails    = 1
	DefaultFailTimeout = 10 * time.Second
)

default options for FailFilter

Functions

func BackupFilter

func BackupFilter[T any]() selector.Filter[T]

BackupFilter filters the backup objects. An object is marked as backup if its metadata has backup flag.

func FIFOStrategy

func FIFOStrategy[T any]() selector.Strategy[T]

FIFOStrategy is a strategy for node selector. The node will be selected from first to last, and will stick to the selected node until it is failed.

func FailFilter

func FailFilter[T any](maxFails int, timeout time.Duration) selector.Filter[T]

FailFilter filters the dead objects. An object is marked as dead if its failed count is greater than MaxFails.

func HashStrategy

func HashStrategy[T any]() selector.Strategy[T]

func NewSelector

func NewSelector[T any](strategy selector.Strategy[T], filters ...selector.Filter[T]) selector.Selector[T]

func RandomStrategy

func RandomStrategy[T any]() selector.Strategy[T]

RandomStrategy is a strategy for node selector. The node will be selected randomly.

func RoundRobinStrategy

func RoundRobinStrategy[T any]() selector.Strategy[T]

RoundRobinStrategy is a strategy for node selector. The node will be selected by round-robin algorithm.