Method updateSvc

pkg/controllers/cache/cache.go:260–287

updateSvc updates the cache with the given retina service.

(svc *common.RetinaSvc)

// updateSvc updates the cache with the given retina service.
func (c *Cache) updateSvc(svc *common.RetinaSvc) error {
	// TODO check if a service already exists here
	ip, err := svc.GetPrimaryIP()
	if err != nil {
		c.l.Error("updateSvc: error getting primary IP for service", zap.String("service", svc.Key()), zap.Error(err))
		return err
	}

	// delete if any existing object is using this IP
	// send a delete event for the existing object
	err = c.deleteByIP(ip, svc.Key())
	if err != nil {
		c.l.Error("updateSvc: error deleting existing object for IP",
			zap.String("svc", svc.Key()),
			zap.String("ip", ip),
			zap.Error(err),
		)
		return err
	}

	c.ipToSvcKey[ip] = svc.Key()
	c.svcMap[svc.Key()] = svc

	// notify pubsub
	c.publish(EventTypeSvcAdded, svc)

	return nil
}

// UpdateRetinaNode updates the cache with the given retina node.
func (c *Cache) UpdateRetinaNode(node *common.RetinaNode) error {