roundrobin

package
v0.0.0-...-ff27e19 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jul 24, 2014 License: MIT Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
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)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL