lb

Documentation

Index

• Variables
• func NewLBWithConfig(conf *Config) (stream.Dialer, error)
• type Config
• type LB
  • func NewLB(policy balance.Policy, dialers []stream.Dialer) *LB
  • func (l *LB) DialStream(ctx context.Context) (stm stream.Stream, err error)
  • func (l *LB) Policy() balance.Policy
  • func (l *LB) String() string
  • func (l *LB) Targets() []stream.Dialer
• type Weight

Variables

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

Functions

func NewLBWithConfig

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

Types

type Config

type Config struct {
	Policy  balance.Policy
	Dialers []*Weight
}

type LB

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

func NewLB

func NewLB(policy balance.Policy, dialers []stream.Dialer) *LB

func (*LB) DialStream

func (l *LB) DialStream(ctx context.Context) (stm stream.Stream, err error)

func (*LB) Policy

func (l *LB) Policy() balance.Policy

func (*LB) String

func (l *LB) String() string

func (*LB) Targets

func (l *LB) Targets() []stream.Dialer

type Weight

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