selector

Documentation

Index

• Constants
• Variables
• func GetAvailableNodes(nodes []*livekit.Node) []*livekit.Node
• func IsAvailable(node *livekit.Node) bool
• func LimitsReached(limitConfig config.LimitConfig, nodeStats *livekit.NodeStats) bool
• type CPULoadSelector
  • func (s *CPULoadSelector) SelectNode(nodes []*livekit.Node) (*livekit.Node, error)
• type NodeSelector
  • func CreateNodeSelector(conf *config.Config) (NodeSelector, error)
• type RandomSelector
  • func (s *RandomSelector) SelectNode(nodes []*livekit.Node) (*livekit.Node, error)
• type RegionAwareSelector
  • func NewRegionAwareSelector(currentRegion string, regions []config.RegionConfig) (*RegionAwareSelector, error)
  • func (s *RegionAwareSelector) SelectNode(nodes []*livekit.Node) (*livekit.Node, error)
• type SystemLoadSelector
  • func (s *SystemLoadSelector) SelectNode(nodes []*livekit.Node) (*livekit.Node, error)

Constants

const AvailableSeconds = 5

Variables

var (
	ErrNoAvailableNodes           = errors.New("could not find any available nodes")
	ErrCurrentRegionNotSet        = errors.New("current region cannot be blank")
	ErrCurrentRegionUnknownLatLon = errors.New("unknown lat and lon for the current region")
)

var ErrUnsupportedSelector = errors.New("unsupported node selector")

Functions

func GetAvailableNodes

func GetAvailableNodes(nodes []*livekit.Node) []*livekit.Node

func IsAvailable

func IsAvailable(node *livekit.Node) bool

checks if a node has been updated recently to be considered for selection

func LimitsReached

func LimitsReached(limitConfig config.LimitConfig, nodeStats *livekit.NodeStats) bool

TODO: check remote node configured limit, instead of this node's config

Types

type CPULoadSelector

type CPULoadSelector struct {
	CPULoadLimit float32
}

CPULoadSelector eliminates nodes that have CPU usage higher than CPULoadLimit then selects a node randomly from nodes that are not overloaded

func (*CPULoadSelector) SelectNode

func (s *CPULoadSelector) SelectNode(nodes []*livekit.Node) (*livekit.Node, error)

type NodeSelector

type NodeSelector interface {
	SelectNode(nodes []*livekit.Node) (*livekit.Node, error)
}

NodeSelector selects an appropriate node to run the current session

func CreateNodeSelector

func CreateNodeSelector(conf *config.Config) (NodeSelector, error)

type RandomSelector

type RandomSelector struct {
}

RandomSelector selects an available node at random

func (*RandomSelector) SelectNode

func (s *RandomSelector) SelectNode(nodes []*livekit.Node) (*livekit.Node, error)

type RegionAwareSelector

type RegionAwareSelector struct {
	SystemLoadSelector
	CurrentRegion string
	// contains filtered or unexported fields
}

RegionAwareSelector prefers available nodes that are closest to the region of the current instance

func NewRegionAwareSelector

func NewRegionAwareSelector(currentRegion string, regions []config.RegionConfig) (*RegionAwareSelector, error)

func (*RegionAwareSelector) SelectNode

func (s *RegionAwareSelector) SelectNode(nodes []*livekit.Node) (*livekit.Node, error)

type SystemLoadSelector

type SystemLoadSelector struct {
	SysloadLimit float32
}

SystemLoadSelector eliminates nodes that surpass has a per-cpu node higher than SysloadLimit then selects a node randomly from nodes that are not overloaded

func (*SystemLoadSelector) SelectNode

func (s *SystemLoadSelector) SelectNode(nodes []*livekit.Node) (*livekit.Node, error)