kandoo

README

Kandoo

This package implements Kandoo on top of Beehive SDN/OpenFlow Controller.

To boot the first controller, run:

# go run main/main.go -addr ADDR1:PORT1

where ADDR1 is the listening address and PORT1 is the listening port.

To connect a new controller running on another machine to your first controller, run:

# go run main/main.go -addr ADDRN:PORTN -paddrs ADDR1:PORT1

All controllers will be local controllers and one of them automatically becomes the root controller.

Documentation

Index

• func RegisterApps(hive bh.Hive, threshold uint64)
• type Adder
  • func (a Adder) Rcv(msg bh.Msg, ctx bh.RcvContext) error
• type Detector
  • func (d Detector) Rcv(msg bh.Msg, ctx bh.RcvContext) error
• type ElephantDetected
• type Local
  • func (h Local) Map(msg bh.Msg, ctx bh.MapContext) bh.MappedCells
• type NonLocal
  • func (h NonLocal) Map(msg bh.Msg, ctx bh.MapContext) bh.MappedCells
• type Poller
  • func (p Poller) Rcv(msg bh.Msg, ctx bh.RcvContext) error
• type Rerouter
  • func (r Rerouter) Rcv(msg bh.Msg, ctx bh.RcvContext) error

Functions

func RegisterApps

func RegisterApps(hive bh.Hive, threshold uint64)

RegisterApps registers Kandoo applications on the hive, with the given elephant flow size threshold.

Types

type Adder

type Adder struct {
	Local
}

Adder adds a node to the dictionary when it joins the network.

func (Adder) Rcv

func (a Adder) Rcv(msg bh.Msg, ctx bh.RcvContext) error

type Detector

type Detector struct {
	Local

	ElephantThreshold uint64 // The minimum size of an elephent flow.
}

Detector implements the sample rerouting application in kandoo.

func (Detector) Rcv

func (d Detector) Rcv(msg bh.Msg, ctx bh.RcvContext) error

type ElephantDetected

type ElephantDetected struct {
	Match nom.Match
}

ElephantDetected is a message emitted when an elephant flow is detected.

type Local

type Local struct{}

Implements the map function for local handlers.

func (Local) Map

func (h Local) Map(msg bh.Msg, ctx bh.MapContext) bh.MappedCells

type NonLocal

type NonLocal struct{}

Implements the map function for nonLocal handlers.

func (NonLocal) Map

func (h NonLocal) Map(msg bh.Msg, ctx bh.MapContext) bh.MappedCells

type Poller

type Poller struct {
	Local
}

Poller polls the switches.

func (Poller) Rcv

func (p Poller) Rcv(msg bh.Msg, ctx bh.RcvContext) error

type Rerouter

type Rerouter struct {
	NonLocal
}

Rerouter implements the sample rerouting application in kandoo.

func (Rerouter) Rcv

func (r Rerouter) Rcv(msg bh.Msg, ctx bh.RcvContext) error