mirrors/prometheus-operator
mirrors/prometheus-operator
1
0
Fork 0
mirror of https://github.com/prometheus-operator/prometheus-operator.git synced 2025-04-21 03:38:43 +00:00
Code Activity

Remove unused service informer

Browse source
This commit is contained in:
Fabian Reinartz 2016-10-31 09:29:45 +01:00
parent 4a89b7c864
commit c4675fef69
1 changed files with 2 additions and 7 deletions

9
pkg/controller/controller.go
View file

@ -42,7 +42,6 @@ type Controller struct {
smonInf cache.SharedIndexInformer
cmapInf cache.SharedIndexInformer
psetInf cache.SharedIndexInformer
svcInf cache.SharedIndexInformer
queue *queue
@ -113,10 +112,6 @@ func (c *Controller) Run(stopc <-chan struct{}) error {
cache.NewListWatchFromClient(c.kclient.Apps().GetRESTClient(), "petsets", api.NamespaceAll, nil),
&v1alpha1.PetSet{}, resyncPeriod, cache.Indexers{},
)
c.svcInf = cache.NewSharedIndexInformer(
cache.NewListWatchFromClient(c.kclient.Core().GetRESTClient(), "services", api.NamespaceAll, nil),
&v1.Service{}, resyncPeriod, cache.Indexers{},
)
c.promInf.AddEventHandler(cache.ResourceEventHandlerFuncs{
AddFunc: func(p interface{}) {
@ -173,9 +168,8 @@ func (c *Controller) Run(stopc <-chan struct{}) error {
go c.smonInf.Run(stopc)
go c.cmapInf.Run(stopc)
go c.psetInf.Run(stopc)
go c.svcInf.Run(stopc)
for !c.promInf.HasSynced() || !c.smonInf.HasSynced() || !c.cmapInf.HasSynced() || !c.psetInf.HasSynced() || !c.svcInf.HasSynced() {
for !c.promInf.HasSynced() || !c.smonInf.HasSynced() || !c.cmapInf.HasSynced() || !c.psetInf.HasSynced() {
time.Sleep(100 * time.Millisecond)
}
@ -318,6 +312,7 @@ func (c *Controller) reconcile(p *spec.Prometheus) error {
return err
}
// Create governing service if it doesn't exist.
svcClient := c.kclient.Core().Services(p.Namespace)
if _, err := svcClient.Create(makePetSetService(p)); err != nil && !apierrors.IsAlreadyExists(err) {
return fmt.Errorf("create petset service: %s", err)