aboutsummaryrefslogtreecommitdiffstats
path: root/extras/hs-test/netconfig.go
diff options
context:
space:
mode:
Diffstat (limited to 'extras/hs-test/netconfig.go')
-rw-r--r--extras/hs-test/netconfig.go108
1 files changed, 40 insertions, 68 deletions
diff --git a/extras/hs-test/netconfig.go b/extras/hs-test/netconfig.go
index 5c8613c70a8..9e259ab1c06 100644
--- a/extras/hs-test/netconfig.go
+++ b/extras/hs-test/netconfig.go
@@ -19,8 +19,8 @@ type (
InterfaceIndex = interface_types.InterfaceIndex
NetConfig interface {
- Configure() error
- Unconfigure()
+ configure() error
+ unconfigure()
Name() string
Type() string
}
@@ -72,7 +72,7 @@ var (
}
)
-func NewNetworkInterface(cfg NetDevConfig, a *Addresser) (*NetInterface, error) {
+func newNetworkInterface(cfg NetDevConfig, a *Addresser) (*NetInterface, error) {
var newInterface *NetInterface = &NetInterface{}
var err error
newInterface.addresser = a
@@ -98,7 +98,7 @@ func NewNetworkInterface(cfg NetDevConfig, a *Addresser) (*NetInterface, error)
if n, ok := ip.(NetDevConfig)["network"]; ok {
newInterface.networkNumber = n.(int)
}
- newInterface.ip4Address, err = newInterface.addresser.NewIp4Address(
+ newInterface.ip4Address, err = newInterface.addresser.newIp4Address(
newInterface.networkNumber,
)
if err != nil {
@@ -112,24 +112,24 @@ func NewNetworkInterface(cfg NetDevConfig, a *Addresser) (*NetInterface, error)
peer := cfg["peer"].(NetDevConfig)
- if newInterface.peer, err = NewNetworkInterface(peer, a); err != nil {
+ if newInterface.peer, err = newNetworkInterface(peer, a); err != nil {
return &NetInterface{}, err
}
return newInterface, nil
}
-func (n *NetInterface) ConfigureUpState() error {
- err := SetDevUp(n.Name(), "")
+func (n *NetInterface) configureUpState() error {
+ err := setDevUp(n.Name(), "")
if err != nil {
return fmt.Errorf("set link up failed: %v", err)
}
return nil
}
-func (n *NetInterface) ConfigureNetworkNamespace() error {
+func (n *NetInterface) configureNetworkNamespace() error {
if n.networkNamespace != "" {
- err := LinkSetNetns(n.name, n.networkNamespace)
+ err := linkSetNetns(n.name, n.networkNamespace)
if err != nil {
return err
}
@@ -137,9 +137,9 @@ func (n *NetInterface) ConfigureNetworkNamespace() error {
return nil
}
-func (n *NetInterface) ConfigureAddress() error {
+func (n *NetInterface) configureAddress() error {
if n.ip4Address != "" {
- if err := AddAddress(
+ if err := addAddress(
n.Name(),
n.ip4Address,
n.networkNamespace,
@@ -151,35 +151,35 @@ func (n *NetInterface) ConfigureAddress() error {
return nil
}
-func (n *NetInterface) Configure() error {
+func (n *NetInterface) configure() error {
cmd := ipCommandMap[n.Type()](n)
_, err := cmd.CombinedOutput()
if err != nil {
return fmt.Errorf("creating interface '%v' failed: %v", n.Name(), err)
}
- if err := n.ConfigureUpState(); err != nil {
+ if err := n.configureUpState(); err != nil {
return err
}
- if err := n.ConfigureNetworkNamespace(); err != nil {
+ if err := n.configureNetworkNamespace(); err != nil {
return err
}
- if err := n.ConfigureAddress(); err != nil {
+ if err := n.configureAddress(); err != nil {
return err
}
if n.peer != nil && n.peer.name != "" {
- if err := n.Peer().ConfigureUpState(); err != nil {
+ if err := n.peer.configureUpState(); err != nil {
return err
}
- if err := n.Peer().ConfigureNetworkNamespace(); err != nil {
+ if err := n.peer.configureNetworkNamespace(); err != nil {
return err
}
- if err := n.Peer().ConfigureAddress(); err != nil {
+ if err := n.peer.configureAddress(); err != nil {
return err
}
}
@@ -187,8 +187,8 @@ func (n *NetInterface) Configure() error {
return nil
}
-func (n *NetInterface) Unconfigure() {
- DelLink(n.name)
+func (n *NetInterface) unconfigure() {
+ delLink(n.name)
}
func (n *NetInterface) Name() string {
@@ -199,41 +199,21 @@ func (n *NetInterface) Type() string {
return n.category
}
-func (n *NetInterface) SetAddress(address string) {
- n.ip4Address = address
-}
-
-func (n *NetInterface) SetIndex(index InterfaceIndex) {
- n.index = index
-}
-
-func (n *NetInterface) Index() InterfaceIndex {
- return n.index
-}
-
-func (n *NetInterface) AddressWithPrefix() AddressWithPrefix {
+func (n *NetInterface) addressWithPrefix() AddressWithPrefix {
address, _ := ip_types.ParseAddressWithPrefix(n.ip4Address)
return address
}
-func (n *NetInterface) IP4AddressWithPrefix() IP4AddressWithPrefix {
+func (n *NetInterface) ip4AddressWithPrefix() IP4AddressWithPrefix {
ip4Prefix, _ := ip_types.ParseIP4Prefix(n.ip4Address)
ip4AddressWithPrefix := ip_types.IP4AddressWithPrefix(ip4Prefix)
return ip4AddressWithPrefix
}
-func (n *NetInterface) IP4AddressString() string {
+func (n *NetInterface) ip4AddressString() string {
return strings.Split(n.ip4Address, "/")[0]
}
-func (n *NetInterface) HwAddress() MacAddress {
- return n.hwAddress
-}
-
-func (n *NetInterface) Peer() *NetInterface {
- return n.peer
-}
-
func (b *NetConfigBase) Name() string {
return b.name
}
@@ -242,22 +222,22 @@ func (b *NetConfigBase) Type() string {
return b.category
}
-func NewNetNamespace(cfg NetDevConfig) (NetworkNamespace, error) {
+func newNetNamespace(cfg NetDevConfig) (NetworkNamespace, error) {
var networkNamespace NetworkNamespace
networkNamespace.name = cfg["name"].(string)
networkNamespace.category = NetNs
return networkNamespace, nil
}
-func (ns *NetworkNamespace) Configure() error {
+func (ns *NetworkNamespace) configure() error {
return addDelNetns(ns.name, true)
}
-func (ns *NetworkNamespace) Unconfigure() {
+func (ns *NetworkNamespace) unconfigure() {
addDelNetns(ns.name, false)
}
-func NewBridge(cfg NetDevConfig) (NetworkBridge, error) {
+func newBridge(cfg NetDevConfig) (NetworkBridge, error) {
var bridge NetworkBridge
bridge.name = cfg["name"].(string)
bridge.category = Bridge
@@ -272,16 +252,16 @@ func NewBridge(cfg NetDevConfig) (NetworkBridge, error) {
return bridge, nil
}
-func (b *NetworkBridge) Configure() error {
- return AddBridge(b.name, b.interfaces, b.networkNamespace)
+func (b *NetworkBridge) configure() error {
+ return addBridge(b.name, b.interfaces, b.networkNamespace)
}
-func (b *NetworkBridge) Unconfigure() {
- DelBridge(b.name, b.networkNamespace)
+func (b *NetworkBridge) unconfigure() {
+ delBridge(b.name, b.networkNamespace)
}
-func DelBridge(brName, ns string) error {
- err := SetDevDown(brName, ns)
+func delBridge(brName, ns string) error {
+ err := setDevDown(brName, ns)
if err != nil {
return err
}
@@ -294,15 +274,15 @@ func DelBridge(brName, ns string) error {
return nil
}
-func SetDevUp(dev, ns string) error {
+func setDevUp(dev, ns string) error {
return setDevUpDown(dev, ns, true)
}
-func SetDevDown(dev, ns string) error {
+func setDevDown(dev, ns string) error {
return setDevUpDown(dev, ns, false)
}
-func DelLink(ifName string) {
+func delLink(ifName string) {
cmd := exec.Command("ip", "link", "del", ifName)
cmd.Run()
}
@@ -339,15 +319,7 @@ func addDelNetns(name string, isAdd bool) error {
return nil
}
-func AddNetns(nsName string) error {
- return addDelNetns(nsName, true)
-}
-
-func DelNetns(nsName string) error {
- return addDelNetns(nsName, false)
-}
-
-func LinkSetNetns(ifName, ns string) error {
+func linkSetNetns(ifName, ns string) error {
cmd := exec.Command("ip", "link", "set", "dev", ifName, "up", "netns", ns)
err := cmd.Run()
if err != nil {
@@ -356,7 +328,7 @@ func LinkSetNetns(ifName, ns string) error {
return nil
}
-func NewCommand(s []string, ns string) *exec.Cmd {
+func newCommand(s []string, ns string) *exec.Cmd {
return appendNetns(s, ns)
}
@@ -390,7 +362,7 @@ func addDelBridge(brName, ns string, isAdd bool) error {
return nil
}
-func AddBridge(brName string, ifs []string, ns string) error {
+func addBridge(brName string, ifs []string, ns string) error {
err := addDelBridge(brName, ns, true)
if err != nil {
return err
@@ -405,7 +377,7 @@ func AddBridge(brName string, ifs []string, ns string) error {
return errors.New(s)
}
}
- err = SetDevUp(brName, ns)
+ err = setDevUp(brName, ns)
if err != nil {
return err
}