lb

package

v0.4.16 Latest Latest Go to latest Published: Dec 7, 2020 License: MIT Imports: 9 Imported by: 0

Details

This section is empty.

View Source

var (
	ErrNotDialer = fmt.Errorf("error not dialer")
)

func NewLBWithConfig(conf *Config) (stream.Dialer, error)

type Config struct {
	Policy  LoadBalancePolicyEnum `json:",omitempty"`
	Dialers []*Weight
}

type LoadBalancePolicyEnum string

const (
	EnumRoundRobin LoadBalancePolicyEnum = "round_robin"
	EnumRandom     LoadBalancePolicyEnum = "random"
)

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

func NewRandom(handlers []stream.Dialer) *Random

func NewRoundRobin(handlers []stream.Dialer) *Random

func (r *Random) DialStream(ctx context.Context) (stream.Stream, error)

func (r *Random) RoundTripper() http.RoundTripper

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

func (r *RoundRobin) DialStream(ctx context.Context) (stream.Stream, error)

func (r *RoundRobin) RoundTripper() http.RoundTripper

type Weight struct {
	Weight uint `json:",omitempty"`
	Dialer stream.Dialer
}