app

Documentation

Index

• type BaseProcessor
  • func (r *BaseProcessor) Dependencies() []string
  • func (r *BaseProcessor) Init() error
  • func (r *BaseProcessor) Name() string
  • func (r *BaseProcessor) Next() (next Processor, ok bool)
  • func (r *BaseProcessor) OnDeviceDown(finder network.Finder, device *network.Device) error
  • func (r *BaseProcessor) OnDeviceUp(finder network.Finder, device *network.Device) error
  • func (r *BaseProcessor) OnPacketIn(finder network.Finder, ingress *network.Port, eth *protocol.Ethernet) error
  • func (r *BaseProcessor) OnPortDown(finder network.Finder, port *network.Port) error
  • func (r *BaseProcessor) OnPortUp(finder network.Finder, port *network.Port) error
  • func (r *BaseProcessor) OnTopologyChange(finder network.Finder) error
  • func (r *BaseProcessor) PacketOut(egress *network.Port, packet []byte) error
  • func (r *BaseProcessor) SetNext(next Processor)
• type Processor

Types

type BaseProcessor

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

func (*BaseProcessor) Dependencies

func (r *BaseProcessor) Dependencies() []string

func (*BaseProcessor) Init

func (r *BaseProcessor) Init() error

func (*BaseProcessor) Name

func (r *BaseProcessor) Name() string

func (*BaseProcessor) Next

func (r *BaseProcessor) Next() (next Processor, ok bool)

func (*BaseProcessor) OnDeviceDown

func (r *BaseProcessor) OnDeviceDown(finder network.Finder, device *network.Device) error

func (*BaseProcessor) OnDeviceUp

func (r *BaseProcessor) OnDeviceUp(finder network.Finder, device *network.Device) error

func (*BaseProcessor) OnPacketIn

func (r *BaseProcessor) OnPacketIn(finder network.Finder, ingress *network.Port, eth *protocol.Ethernet) error

func (*BaseProcessor) OnPortDown

func (r *BaseProcessor) OnPortDown(finder network.Finder, port *network.Port) error

func (*BaseProcessor) OnPortUp

func (r *BaseProcessor) OnPortUp(finder network.Finder, port *network.Port) error

func (*BaseProcessor) OnTopologyChange

func (r *BaseProcessor) OnTopologyChange(finder network.Finder) error

func (*BaseProcessor) PacketOut

func (r *BaseProcessor) PacketOut(egress *network.Port, packet []byte) error

func (*BaseProcessor) SetNext

func (r *BaseProcessor) SetNext(next Processor)

type Processor

type Processor interface {
	Dependencies() []string
	fmt.Stringer
	Init() error
	// Name returns the application name that is globally unique
	Name() string
	network.EventListener
	Next() (next Processor, ok bool)
	SetNext(Processor)
}

Processor should prepare to be executed by multiple goroutines simultaneously.