mirror of https://github.com/k3s-io/k3s
Merge pull request #17952 from upmc-enterprises/dns_fix
commit
9c0e777567
|
@ -86,8 +86,10 @@ type kube2sky struct {
|
||||||
etcdMutationTimeout time.Duration
|
etcdMutationTimeout time.Duration
|
||||||
// A cache that contains all the endpoints in the system.
|
// A cache that contains all the endpoints in the system.
|
||||||
endpointsStore kcache.Store
|
endpointsStore kcache.Store
|
||||||
// A cache that contains all the servicess in the system.
|
// A cache that contains all the services in the system.
|
||||||
servicesStore kcache.Store
|
servicesStore kcache.Store
|
||||||
|
// A cache that contains all the pods in the system.
|
||||||
|
podsStore kcache.Store
|
||||||
// Lock for controlling access to headless services.
|
// Lock for controlling access to headless services.
|
||||||
mlock sync.Mutex
|
mlock sync.Mutex
|
||||||
}
|
}
|
||||||
|
@ -583,7 +585,7 @@ func main() {
|
||||||
|
|
||||||
ks.endpointsStore = watchEndpoints(kubeClient, &ks)
|
ks.endpointsStore = watchEndpoints(kubeClient, &ks)
|
||||||
ks.servicesStore = watchForServices(kubeClient, &ks)
|
ks.servicesStore = watchForServices(kubeClient, &ks)
|
||||||
ks.servicesStore = watchPods(kubeClient, &ks)
|
ks.podsStore = watchPods(kubeClient, &ks)
|
||||||
|
|
||||||
select {}
|
select {}
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue