admin/kubesphere
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

add s2i support

Browse Source
This commit is contained in:
runzexia
2019-03-22 13:08:59 +08:00
committed by zryfish
parent 9566549f08
commit 12c4cd9f30
49 changed files with 4016 additions and 2440 deletions
Download Patch File Download Diff File Expand all files Collapse all files

21
pkg/informers/informers.go
View File

@@ -18,24 +18,37 @@
package informers
import (
"kubesphere.io/kubesphere/pkg/simple/client/k8s"
"sync"
"time"
s2iInformers "github.com/kubesphere/s2ioperator/pkg/client/informers/externalversions"
"k8s.io/client-go/informers"
"kubesphere.io/kubesphere/pkg/simple/client/k8s"
)
const defaultResync = 600 * time.Second
var (
once sync.Once
informerFactory informers.SharedInformerFactory
k8sOnce sync.Once
s2iOnce sync.Once
informerFactory informers.SharedInformerFactory
s2iInformerFactory s2iInformers.SharedInformerFactory
)
func SharedInformerFactory() informers.SharedInformerFactory {
once.Do(func() {
k8sOnce.Do(func() {
k8sClient := k8s.Client()
informerFactory = informers.NewSharedInformerFactory(k8sClient, defaultResync)
})
return informerFactory
}
func S2iSharedInformerFactory() s2iInformers.SharedInformerFactory {
s2iOnce.Do(func() {
k8sClient := k8s.S2iClient()
s2iInformerFactory = s2iInformers.NewSharedInformerFactory(k8sClient, defaultResync)
})
return s2iInformerFactory
}