balancer

Documentation

Index

• type Balancer
  • func New(user, certdir string, logging bool, initialNodes ...string) *Balancer
  • func (b *Balancer) ChooseNode() string
  • func (b *Balancer) GetAddr() string
  • func (b *Balancer) GetLiveNodes() []string
  • func (b *Balancer) GetNodeCount() int
  • func (b *Balancer) Listen(port int)
  • func (b *Balancer) WaitReady()

Types

type Balancer

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

Balancer is a simple cockroachdb load balancer with automatic node detection.

func New

func New(user, certdir string, logging bool, initialNodes ...string) *Balancer

New creates a new Balancer

func (*Balancer) ChooseNode

func (b *Balancer) ChooseNode() string

ChooseNode returns an active database node while doing simple round robin load balancing.

func (*Balancer) GetAddr

func (b *Balancer) GetAddr() string

GetAddr returns the listener address

func (*Balancer) GetLiveNodes

func (b *Balancer) GetLiveNodes() []string

GetLiveNodes returns the current live node list.

func (*Balancer) GetNodeCount

func (b *Balancer) GetNodeCount() int

GetNodeCount returns the current live node count.

func (*Balancer) Listen

func (b *Balancer) Listen(port int)

Listen starts the loadbalancer

func (*Balancer) WaitReady

func (b *Balancer) WaitReady()

WaitReady blocks until Listen is ready