lb

Documentation

Index

• Constants
• Variables
• type IPhash
  • func NewIPhash(network string, addrs []string, unreachableThreshold int, ...) (*IPhash, error)
  • func (iph *IPhash) Get(signature string) (RemoteAddr, error)
  • func (iph *IPhash) Stop()
  • func (iph *IPhash) Unreachable(addr string)
• type LoadBalancer
• type RemoteAddr

Constants

const (
	DEFAULT_THRESHOLD_INTERVAL = 30 * time.Second
)

Variables

var (
	ERROR_NO_REACHABLE_IP = errors.New("no reachable ip found.")
)

Types

type IPhash

type IPhash struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewIPhash

func NewIPhash(network string, addrs []string, unreachableThreshold int, thresholdInterval time.Duration, checkInterval time.Duration) (*IPhash, error)

func (*IPhash) Get

func (iph *IPhash) Get(signature string) (RemoteAddr, error)

func (*IPhash) Stop

func (iph *IPhash) Stop()

func (*IPhash) Unreachable

func (iph *IPhash) Unreachable(addr string)

type LoadBalancer

type LoadBalancer interface {
	Get(signature string) (RemoteAddr, error) //return addr string and error
	Unreachable(addr string)
	Stop()
}

type RemoteAddr

type RemoteAddr struct {
	AddrStr string
	IP      net.IP
	Port    int
	// contains filtered or unexported fields
}