balancer2go

README

balancer2go

Simple golang balancer library

See the test file for wroking examples.

API docs here.

Continous integration:

Documentation

Overview

Simple RPC client balancer

Index

• type Balancer
  • func NewBalancer() *Balancer
  • func (bl *Balancer) AddClient(address string, client Worker)
  • func (bl *Balancer) Balance() (result Worker)
  • func (bl *Balancer) GetClient(address string) (c Worker, exists bool)
  • func (bl *Balancer) GetClientAddresses() []string
  • func (bl *Balancer) RemoveClient(address string)
  • func (bl *Balancer) Shutdown(shutdownMethod string)
• type Worker

Types

type Balancer

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

The main balancer type

func NewBalancer

func NewBalancer() *Balancer

Constructor for RateList holding one slice for addreses and one slice for connections.

func (*Balancer) AddClient

func (bl *Balancer) AddClient(address string, client Worker)

Adds a client to the two internal map.

func (*Balancer) Balance

func (bl *Balancer) Balance() (result Worker)

Returns the next available connection at each call looping at the end of connections.

func (*Balancer) GetClient

func (bl *Balancer) GetClient(address string) (c Worker, exists bool)

Returns a client for the specifed address.

func (*Balancer) GetClientAddresses

func (bl *Balancer) GetClientAddresses() []string

Returns a string slice with all client addresses

func (*Balancer) RemoveClient

func (bl *Balancer) RemoveClient(address string)

Removes a client from the map locking the readers and reseting the balancer index.

func (*Balancer) Shutdown

func (bl *Balancer) Shutdown(shutdownMethod string)

Sends a shotdown call to the clients

type Worker

type Worker interface {
	Call(serviceMethod string, args interface{}, reply interface{}) error
	Close() error
}

Interface for RPC clients