selector

Documentation

Index

• Constants
• func GetSelectorBuilder(selectorName string) (selectorBuilder, error)
• type LoadBalanceSelector
  • func CreateNewSelector(selectorName string, config *conf.EventMeshHttpClientConfig) (LoadBalanceSelector, error)
• type MeshNode
• type RandomLoadSelector
  • func (s *RandomLoadSelector) GetType() string
  • func (s *RandomLoadSelector) Select() MeshNode
• type WeightRandomLoadSelector
  • func NewWeightRandomLoadSelector(clusterGroup []MeshNode) (*WeightRandomLoadSelector, error)
  • func (s *WeightRandomLoadSelector) GetType() string
  • func (s *WeightRandomLoadSelector) Select() MeshNode
• type WeightRoundRobinLoadSelector
  • func NewWeightRoundRobinLoadSelector(clusterGroup []MeshNode) (*WeightRoundRobinLoadSelector, error)
  • func (s *WeightRoundRobinLoadSelector) GetType() string
  • func (s *WeightRoundRobinLoadSelector) Select() MeshNode
• type WeightRoundRobinMeshNode

Constants

const RandomSelectorType = "random"

const WeightRandomSelectorType = "weight_random"

const WeightRoundRobinSelectorType = "weight_round_robin"

Functions

func GetSelectorBuilder

func GetSelectorBuilder(selectorName string) (selectorBuilder, error)

Types

type LoadBalanceSelector

type LoadBalanceSelector interface {
	Select() MeshNode
	GetType() string
}

func CreateNewSelector

func CreateNewSelector(selectorName string, config *conf.EventMeshHttpClientConfig) (LoadBalanceSelector, error)

type MeshNode

type MeshNode struct {
	Addr   string
	Weight int64
}

type RandomLoadSelector

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

func (*RandomLoadSelector) GetType

func (s *RandomLoadSelector) GetType() string

func (*RandomLoadSelector) Select

func (s *RandomLoadSelector) Select() MeshNode

type WeightRandomLoadSelector

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

func NewWeightRandomLoadSelector

func NewWeightRandomLoadSelector(clusterGroup []MeshNode) (*WeightRandomLoadSelector, error)

func (*WeightRandomLoadSelector) GetType

func (s *WeightRandomLoadSelector) GetType() string

func (*WeightRandomLoadSelector) Select

func (s *WeightRandomLoadSelector) Select() MeshNode

type WeightRoundRobinLoadSelector

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

func NewWeightRoundRobinLoadSelector

func NewWeightRoundRobinLoadSelector(clusterGroup []MeshNode) (*WeightRoundRobinLoadSelector, error)

func (*WeightRoundRobinLoadSelector) GetType

func (s *WeightRoundRobinLoadSelector) GetType() string

func (*WeightRoundRobinLoadSelector) Select

func (s *WeightRoundRobinLoadSelector) Select() MeshNode

type WeightRoundRobinMeshNode

type WeightRoundRobinMeshNode struct {
	MeshNode
	// contains filtered or unexported fields
}