ovs

Documentation

Overview

Package ovs provides a wrapper around ovs-vsctl and ovs-ofctl

Index

• Constants
• type Interface
  • func New(execer exec.Interface, bridge string) (*Interface, error)
  • func (ovsif *Interface) AddBridge(properties ...string) error
  • func (ovsif *Interface) AddPort(port string, ofportRequest int, properties ...string) (int, error)
  • func (ovsif *Interface) DeleteBridge() error
  • func (ovsif *Interface) DeletePort(port string) error
  • func (ovsif *Interface) DumpFlows() ([]string, error)
  • func (ovsif *Interface) NewTransaction() *Transaction
• type Transaction
  • func (tx *Transaction) AddFlow(flow string, args ...interface{})
  • func (tx *Transaction) DeleteFlows(flow string, args ...interface{})
  • func (tx *Transaction) EndTransaction() error

Constants

const (
	OVS_OFCTL = "ovs-ofctl"
	OVS_VSCTL = "ovs-vsctl"
)

Types

type Interface

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

func New

func New(execer exec.Interface, bridge string) (*Interface, error)

New returns a new ovs.Interface

func (*Interface) AddBridge

func (ovsif *Interface) AddBridge(properties ...string) error

AddBridge creates the bridge associated with the interface, optionally setting properties on it (as with "ovs-vsctl set Bridge ..."). If the bridge already existed, it will be destroyed and recreated.

func (*Interface) AddPort

func (ovsif *Interface) AddPort(port string, ofportRequest int, properties ...string) (int, error)

AddPort adds an interface to the bridge, requesting the indicated port number, and optionally setting properties on it (as with "ovs-vsctl set Interface ..."). Returns the allocated port number (or an error).

func (*Interface) DeleteBridge

func (ovsif *Interface) DeleteBridge() error

DeleteBridge deletes the bridge associated with the interface. (It is an error if the bridge does not exist.)

func (*Interface) DeletePort

func (ovsif *Interface) DeletePort(port string) error

DeletePort removes an interface from the bridge. (It is not an error if the interface is not currently a bridge port.)

func (*Interface) DumpFlows

func (ovsif *Interface) DumpFlows() ([]string, error)

DumpFlows dumps the flow table for the bridge and returns it as an array of strings, one per flow.

func (*Interface) NewTransaction

func (ovsif *Interface) NewTransaction() *Transaction

NewTransaction begins a new OVS transaction. If an error occurs at any step in the transaction, it will be recorded until EndTransaction(), and any further calls on the transaction will be ignored.

type Transaction

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

func (*Transaction) AddFlow

func (tx *Transaction) AddFlow(flow string, args ...interface{})

AddFlow adds a flow to the bridge. The arguments are passed to fmt.Sprintf().

func (*Transaction) DeleteFlows

func (tx *Transaction) DeleteFlows(flow string, args ...interface{})

DeleteFlows deletes all matching flows from the bridge. The arguments are passed to fmt.Sprintf().

func (*Transaction) EndTransaction

func (tx *Transaction) EndTransaction() error

EndTransaction ends an OVS transaction and returns any error that occurred during the transaction. You should not use the transaction again after calling this function.