lb

Documentation

Index

• Constants
• Variables
• type KeyLbNotifier
  • func NewEtcdLoadBalancer(ctx context.Context, cli *clientv3.Client, path string, myTarget string, ...) (KeyLbNotifier, error)
• type KeyLoadBalancer
  • func NewStaticLB(mykey string, allKeys []string) KeyLoadBalancer
  • func NewStaticLbFromIndexes(prefix string, myIndex, all int) KeyLoadBalancer
• type LbEvent
  • func NewAddedEvent(target string) *LbEvent
  • func NewLbStoppedEvent() *LbEvent
  • func NewRemovedEvent(target string) *LbEvent
• type LbNotifier
• type Option
  • func WithSetleTime(d time.Duration) Option
  • func WithSubPath(subPath string) Option

Constants

const (
	TargetAdded   = "Added"
	TargetRemoved = "Removed"
	LbStopped     = "LbStopped"
)

Variables

var (
	DownErr   = errors.New("lb down")
	PausedErr = errors.New("lb paused")
)

Types

type KeyLbNotifier

type KeyLbNotifier interface {
	KeyLoadBalancer
	LbNotifier
}

func NewEtcdLoadBalancer

func NewEtcdLoadBalancer(ctx context.Context, cli *clientv3.Client, path string, myTarget string, opts ...Option) (KeyLbNotifier, error)

type KeyLoadBalancer

type KeyLoadBalancer interface {
	Target(key string, waitSettleTime bool) (string, error)
	Close()
}

func NewStaticLB

func NewStaticLB(mykey string, allKeys []string) KeyLoadBalancer

func NewStaticLbFromIndexes

func NewStaticLbFromIndexes(prefix string, myIndex, all int) KeyLoadBalancer

type LbEvent

type LbEvent struct {
	CreatedOn time.Time
	Event     string
	Target    string
}

func NewAddedEvent

func NewAddedEvent(target string) *LbEvent

func NewLbStoppedEvent

func NewLbStoppedEvent() *LbEvent

func NewRemovedEvent

func NewRemovedEvent(target string) *LbEvent

type LbNotifier

type LbNotifier interface {
	Notify() <-chan *LbEvent
	NotifyBulk() <-chan []*LbEvent
}

type Option

type Option func(config *optionalConfig)

func WithSetleTime

func WithSetleTime(d time.Duration) Option

func WithSubPath

func WithSubPath(subPath string) Option