@@ -14,9 +14,7 @@ import (
1414 v1 "k8s.io/api/core/v1"
1515 metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
1616 "k8s.io/apimachinery/pkg/runtime"
17- "k8s.io/apiserver/pkg/endpoints/discovery"
1817 restclient "k8s.io/client-go/rest"
19- "k8s.io/client-go/restmapper"
2018 "k8s.io/client-go/tools/clientcmd"
2119 "k8s.io/klog/v2"
2220 ctrl "sigs.k8s.io/controller-runtime"
@@ -93,7 +91,7 @@ func (o *AgentOptions) Validate() error {
9391 return fmt .Errorf ("mac prefix %s is nonstandard" , o .MACPrefix )
9492 }
9593 }
96-
94+
9795 if o .SyncPeriod .Duration < time .Minute {
9896 o .SyncPeriod .Duration = time .Minute
9997 }
@@ -220,73 +218,6 @@ func newMgr(cfg *restclient.Config, metricsBindAddress, healthyProbeAddress stri
220218 return mgr , nil
221219}
222220
223- func getLegacyAPIGroupResource () * restmapper.APIGroupResources {
224- return & restmapper.APIGroupResources {
225- Group : metav1.APIGroup {
226- Versions : []metav1.GroupVersionForDiscovery {{GroupVersion : "v1" , Version : "v1" }},
227- PreferredVersion : metav1.GroupVersionForDiscovery {GroupVersion : "v1" , Version : "v1" },
228- },
229- VersionedResources : map [string ][]metav1.APIResource {
230- "v1" : {
231- {
232- Name : "nodes" ,
233- Namespaced : false ,
234- Kind : "Node" ,
235- Verbs : metav1.Verbs {"create" , "delete" , "deletecollection" , "get" , "list" , "patch" , "update" , "watch" },
236- ShortNames : []string {"no" },
237- StorageVersionHash : discovery .StorageVersionHash ("" , "v1" , "Node" ),
238- },
239- {
240- Name : "pods" ,
241- Namespaced : true ,
242- Kind : "Pod" ,
243- Verbs : metav1.Verbs {"create" , "delete" , "deletecollection" , "get" , "list" , "patch" , "update" , "watch" },
244- ShortNames : []string {"po" },
245- StorageVersionHash : discovery .StorageVersionHash ("" , "v1" , "Pod" ),
246- },
247- {
248- Name : "services" ,
249- Namespaced : true ,
250- Kind : "Service" ,
251- Verbs : metav1.Verbs {"create" , "delete" , "deletecollection" , "get" , "list" , "patch" , "update" , "watch" },
252- ShortNames : []string {"svc" },
253- StorageVersionHash : discovery .StorageVersionHash ("" , "v1" , "Service" ),
254- },
255- },
256- },
257- }
258- }
259-
260- func getGatewayAPIGroupResource () * restmapper.APIGroupResources {
261- return & restmapper.APIGroupResources {
262- Group : metav1.APIGroup {
263- Name : v1beta1 .GroupVersion .Group ,
264- Versions : []metav1.GroupVersionForDiscovery {{GroupVersion : v1beta1 .GroupVersion .String (), Version : v1beta1 .GroupVersion .Version }},
265- PreferredVersion : metav1.GroupVersionForDiscovery {GroupVersion : v1beta1 .GroupVersion .String (), Version : v1beta1 .GroupVersion .Version },
266- },
267- VersionedResources : map [string ][]metav1.APIResource {
268- v1beta1 .GroupVersion .Version : {
269- {
270- Name : "gateways" ,
271- Namespaced : false ,
272- SingularName : "gateway" ,
273- Kind : "Gateway" ,
274- Verbs : metav1.Verbs {"create" , "delete" , "deletecollection" , "get" , "list" , "patch" , "update" , "watch" },
275- ShortNames : []string {"gw" },
276- Categories : []string {"all" },
277- StorageVersionHash : discovery .StorageVersionHash (v1beta1 .GroupVersion .Group , v1beta1 .GroupVersion .Version , "Gateway" ),
278- },
279- {
280- Name : "gateways/status" ,
281- Namespaced : false ,
282- Kind : "Gateway" ,
283- Verbs : metav1.Verbs {"get" , "patch" , "update" },
284- },
285- },
286- },
287- }
288- }
289-
290221func resolveLocalHost () string {
291222 ipv4Addr , err := net .ResolveIPAddr ("ip4" , "localhost" )
292223 if err != nil {
0 commit comments