Skip to content

Commit f0f090e

Browse files
author
Yongli Chen
authored
This PR moves cni related code from network package to cni. (Azure#131)
* configure dnssuffix & dnsServerList * add dns info to conflist * change case for dns info * remove hardcoding * remove hardcoding * parse k8s pod info * add AdditionalArgs and Dns info to conflist * serialize policies * program route info * start addressign ipam ip leak * fix 1) ip inconsistency in k8s & pod. 2) IP leak in IPAM. * remove comments * separate windows & linux * remove dnsServers * remove comments * address comments * add dns verification * abstract linux policy struct * remove setPolicies * separte Windows & Linux code * change package * add policy structure to Linux * move policy code to policy.go * fix network_linux func signature * restructure policy pkg
1 parent c6c23a7 commit f0f090e

File tree

4 files changed

+26
-26
lines changed

4 files changed

+26
-26
lines changed

cni/network/network_linux.go

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,10 +1,12 @@
11
package network
22

33
import (
4+
"github.com/Azure/azure-container-networking/cni"
5+
"github.com/Azure/azure-container-networking/network"
46
cniTypesCurr "github.com/containernetworking/cni/pkg/types/current"
57
)
68

79
// handleConsecutiveAdd is a dummy function for Linux platform.
8-
func handleConsecutiveAdd(containerId, endpointId string, nwInfo *NetworkInfo, nwCfg *NetworkConfig) (*cniTypesCurr.Result, error) {
10+
func handleConsecutiveAdd(containerId, endpointId string, nwInfo *network.NetworkInfo, nwCfg *cni.NetworkConfig) (*cniTypesCurr.Result, error) {
911
return nil, nil
1012
}

network/policy/policy.go

Lines changed: 23 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,23 @@
1+
package policy
2+
3+
import (
4+
"encoding/json"
5+
)
6+
7+
type CNIPolicyType string
8+
9+
type Policy struct {
10+
Type CNIPolicyType
11+
Data json.RawMessage
12+
}
13+
14+
// SerializePolicies serializes policies to json.
15+
func SerializePolicies(policyType CNIPolicyType, policies []Policy) []json.RawMessage {
16+
var jsonPolicies []json.RawMessage
17+
for _, policy := range policies {
18+
if policy.Type == policyType {
19+
jsonPolicies = append(jsonPolicies, policy.Data)
20+
}
21+
}
22+
return jsonPolicies
23+
}

network/policy/policy_linux.go

Lines changed: 0 additions & 3 deletions
This file was deleted.

network/policy/policy_windows.go

Lines changed: 0 additions & 22 deletions
Original file line numberDiff line numberDiff line change
@@ -1,29 +1,7 @@
11
package policy
22

3-
import (
4-
"encoding/json"
5-
)
6-
7-
type CNIPolicyType string
8-
93
const (
104
NetworkPolicy CNIPolicyType = "NetworkPolicy"
115
EndpointPolicy CNIPolicyType = "EndpointPolicy"
126
OutBoundNatPolicy CNIPolicyType = "OutBoundNatPolicy"
137
)
14-
15-
type Policy struct {
16-
Type CNIPolicyType
17-
Data json.RawMessage
18-
}
19-
20-
// SerializePolicies serializes policies to json.
21-
func SerializePolicies(policyType CNIPolicyType, policies []Policy) []json.RawMessage {
22-
var jsonPolicies []json.RawMessage
23-
for _, policy := range policies {
24-
if policy.Type == policyType {
25-
jsonPolicies = append(jsonPolicies, policy.Data)
26-
}
27-
}
28-
return jsonPolicies
29-
}

0 commit comments

Comments
 (0)