roundrobin

Documentation

Index

• Variables
• func NewBalancer() rpc.Exchange
• type Balancer
  • func (b *Balancer) HandleInterrupt(msg rpc.Interrupt)
  • func (b *Balancer) HandleProgress(msg rpc.Progress)
  • func (b *Balancer) HandleReply(msg rpc.Reply)
  • func (b *Balancer) HandleRequest(msg rpc.Request, srcEndpoint rpc.Endpoint)
  • func (b *Balancer) HandleStreamFrame(msg rpc.StreamFrame)
  • func (b *Balancer) RegisterMethod(appName string, endpoint rpc.Endpoint, method string) error
  • func (b *Balancer) UnregisterApp(appName string)
  • func (b *Balancer) UnregisterEndpoint(endpoint rpc.Endpoint)
  • func (b *Balancer) UnregisterMethod(appName string, method string)

Variables

var ErrMethodAlreadyRegistered = errors.New("Method already registered")

Functions

func NewBalancer

func NewBalancer() rpc.Exchange

Types

type Balancer

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

func (*Balancer) HandleInterrupt

func (b *Balancer) HandleInterrupt(msg rpc.Interrupt)

func (*Balancer) HandleProgress

func (b *Balancer) HandleProgress(msg rpc.Progress)

func (*Balancer) HandleReply

func (b *Balancer) HandleReply(msg rpc.Reply)

func (*Balancer) HandleRequest

func (b *Balancer) HandleRequest(msg rpc.Request, srcEndpoint rpc.Endpoint)

func (*Balancer) HandleStreamFrame

func (b *Balancer) HandleStreamFrame(msg rpc.StreamFrame)

func (*Balancer) RegisterMethod

func (b *Balancer) RegisterMethod(appName string, endpoint rpc.Endpoint, method string) error

func (*Balancer) UnregisterApp

func (b *Balancer) UnregisterApp(appName string)

func (*Balancer) UnregisterEndpoint

func (b *Balancer) UnregisterEndpoint(endpoint rpc.Endpoint)

func (*Balancer) UnregisterMethod

func (b *Balancer) UnregisterMethod(appName string, method string)