Fix endpoints_controller unit tests

This commit is contained in:
Girish Kalele 2016-08-15 21:01:21 -07:00
parent 521b746b50
commit e105525b33

View File

@ -102,7 +102,7 @@ func TestSyncEndpointsItemsPreserveNoSelector(t *testing.T) {
ResourceVersion: "1", ResourceVersion: "1",
}, },
Subsets: []api.EndpointSubset{{ Subsets: []api.EndpointSubset{{
Addresses: []api.EndpointAddress{{IP: "6.7.8.9"}}, Addresses: []api.EndpointAddress{{IP: "6.7.8.9", NodeName: &emptyNodeName}},
Ports: []api.EndpointPort{{Port: 1000}}, Ports: []api.EndpointPort{{Port: 1000}},
}}, }},
}}) }})
@ -134,7 +134,7 @@ func TestCheckLeftoverEndpoints(t *testing.T) {
ResourceVersion: "1", ResourceVersion: "1",
}, },
Subsets: []api.EndpointSubset{{ Subsets: []api.EndpointSubset{{
Addresses: []api.EndpointAddress{{IP: "6.7.8.9"}}, Addresses: []api.EndpointAddress{{IP: "6.7.8.9", NodeName: &emptyNodeName}},
Ports: []api.EndpointPort{{Port: 1000}}, Ports: []api.EndpointPort{{Port: 1000}},
}}, }},
}}, }},
@ -164,7 +164,7 @@ func TestSyncEndpointsProtocolTCP(t *testing.T) {
ResourceVersion: "1", ResourceVersion: "1",
}, },
Subsets: []api.EndpointSubset{{ Subsets: []api.EndpointSubset{{
Addresses: []api.EndpointAddress{{IP: "6.7.8.9"}}, Addresses: []api.EndpointAddress{{IP: "6.7.8.9", NodeName: &emptyNodeName}},
Ports: []api.EndpointPort{{Port: 1000, Protocol: "TCP"}}, Ports: []api.EndpointPort{{Port: 1000, Protocol: "TCP"}},
}}, }},
}}) }})
@ -190,7 +190,7 @@ func TestSyncEndpointsProtocolTCP(t *testing.T) {
ResourceVersion: "1", ResourceVersion: "1",
}, },
Subsets: []api.EndpointSubset{{ Subsets: []api.EndpointSubset{{
Addresses: []api.EndpointAddress{{IP: "1.2.3.4", TargetRef: &api.ObjectReference{Kind: "Pod", Name: "pod0", Namespace: ns}}}, Addresses: []api.EndpointAddress{{IP: "1.2.3.4", NodeName: &emptyNodeName, TargetRef: &api.ObjectReference{Kind: "Pod", Name: "pod0", Namespace: ns}}},
Ports: []api.EndpointPort{{Port: 8080, Protocol: "TCP"}}, Ports: []api.EndpointPort{{Port: 8080, Protocol: "TCP"}},
}}, }},
}) })
@ -207,7 +207,7 @@ func TestSyncEndpointsProtocolUDP(t *testing.T) {
ResourceVersion: "1", ResourceVersion: "1",
}, },
Subsets: []api.EndpointSubset{{ Subsets: []api.EndpointSubset{{
Addresses: []api.EndpointAddress{{IP: "6.7.8.9"}}, Addresses: []api.EndpointAddress{{IP: "6.7.8.9", NodeName: &emptyNodeName}},
Ports: []api.EndpointPort{{Port: 1000, Protocol: "UDP"}}, Ports: []api.EndpointPort{{Port: 1000, Protocol: "UDP"}},
}}, }},
}}) }})
@ -232,7 +232,7 @@ func TestSyncEndpointsProtocolUDP(t *testing.T) {
ResourceVersion: "1", ResourceVersion: "1",
}, },
Subsets: []api.EndpointSubset{{ Subsets: []api.EndpointSubset{{
Addresses: []api.EndpointAddress{{IP: "1.2.3.4", TargetRef: &api.ObjectReference{Kind: "Pod", Name: "pod0", Namespace: ns}}}, Addresses: []api.EndpointAddress{{IP: "1.2.3.4", NodeName: &emptyNodeName, TargetRef: &api.ObjectReference{Kind: "Pod", Name: "pod0", Namespace: ns}}},
Ports: []api.EndpointPort{{Port: 8080, Protocol: "UDP"}}, Ports: []api.EndpointPort{{Port: 8080, Protocol: "UDP"}},
}}, }},
}) })