Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 112 for updateStats (0.31 sec)

  1. staging/src/k8s.io/apiserver/pkg/storageversion/updater.go

    			return err
    		}
    		// assign the calculated status to the object just created, then update status
    		createdSV.Status = updatedSV.Status
    		_, err = c.UpdateStatus(context.TODO(), createdSV, metav1.UpdateOptions{})
    		return err
    	}
    	_, err = c.UpdateStatus(context.TODO(), updatedSV, metav1.UpdateOptions{})
    	return err
    }
    
    // localUpdateStorageVersion updates the input storageversion with given server storageversion info.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Jun 29 22:40:54 UTC 2023
    - 6.9K bytes
    - Viewed (0)
  2. pilot/pkg/autoregistration/internal/state/store.go

    				return nil
    			}
    		}
    	}
    
    	// replace the updated status
    	wle := status.UpdateConfigCondition(*cfg, condition)
    	// update the status
    	_, err := s.store.UpdateStatus(wle)
    	if err != nil {
    		return fmt.Errorf("error while updating WorkloadEntry health status for %s: %w", proxyID, err)
    	}
    	log.Debugf("updated health status of %v to %v", proxyID, condition)
    	return nil
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue May 23 17:08:31 UTC 2023
    - 3.3K bytes
    - Viewed (0)
  3. pilot/pkg/config/memory/controller.go

    			config: config,
    			event:  model.EventUpdate,
    		})
    	}
    	return
    }
    
    func (c *Controller) UpdateStatus(config config.Config) (newRevision string, err error) {
    	oldconfig := c.configStore.Get(config.GroupVersionKind, config.Name, config.Namespace)
    	if newRevision, err = c.configStore.UpdateStatus(config); err == nil {
    		c.monitor.ScheduleProcessEvent(ConfigEvent{
    			old:    *oldconfig,
    			config: config,
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Jun 26 13:54:32 UTC 2023
    - 4.7K bytes
    - Viewed (0)
  4. staging/src/k8s.io/apiserver/pkg/storageversion/manager.go

    	managedStatus map[schema.GroupResource]*updateStatus
    }
    
    type updateStatus struct {
    	done    bool
    	lastErr error
    }
    
    // NewDefaultManager creates a new defaultManager.
    func NewDefaultManager() Manager {
    	s := &defaultManager{}
    	s.completed.Store(false)
    	s.managedResourceInfos = make(map[*ResourceInfo]struct{})
    	s.managedStatus = make(map[schema.GroupResource]*updateStatus)
    	return s
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jul 14 17:47:19 UTC 2023
    - 10.5K bytes
    - Viewed (0)
  5. staging/src/k8s.io/apiextensions-apiserver/pkg/client/clientset/clientset/typed/apiextensions/v1/customresourcedefinition.go

    		Body(customResourceDefinition).
    		Do(ctx).
    		Into(result)
    	return
    }
    
    // UpdateStatus was generated because the type contains a Status member.
    // Add a +genclient:noStatus comment above the type to avoid generating UpdateStatus().
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 10:52:54 UTC 2024
    - 12K bytes
    - Viewed (0)
  6. staging/src/k8s.io/apiextensions-apiserver/pkg/client/clientset/clientset/typed/apiextensions/v1beta1/customresourcedefinition.go

    		Body(customResourceDefinition).
    		Do(ctx).
    		Into(result)
    	return
    }
    
    // UpdateStatus was generated because the type contains a Status member.
    // Add a +genclient:noStatus comment above the type to avoid generating UpdateStatus().
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 10:52:54 UTC 2024
    - 12.1K bytes
    - Viewed (0)
  7. pkg/kube/kclient/interfaces.go

    	Create(object T) (T, error)
    	// Update updates a resource, returning the newly applied resource.
    	Update(object T) (T, error)
    	// UpdateStatus updates a resource's status, returning the newly applied resource.
    	UpdateStatus(object T) (T, error)
    	// Patch patches the resource, returning the newly applied resource.
    	Patch(name, namespace string, pt apitypes.PatchType, data []byte) (T, error)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Feb 07 05:09:57 UTC 2024
    - 3.4K bytes
    - Viewed (0)
  8. staging/src/k8s.io/apiextensions-apiserver/pkg/client/clientset/clientset/typed/apiextensions/v1beta1/fake/fake_customresourcedefinition.go

    	if obj == nil {
    		return emptyResult, err
    	}
    	return obj.(*v1beta1.CustomResourceDefinition), err
    }
    
    // UpdateStatus was generated because the type contains a Status member.
    // Add a +genclient:noStatus comment above the type to avoid generating UpdateStatus().
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 18 12:23:16 UTC 2024
    - 8.5K bytes
    - Viewed (0)
  9. staging/src/k8s.io/apiextensions-apiserver/pkg/client/clientset/clientset/typed/apiextensions/v1/fake/fake_customresourcedefinition.go

    	if obj == nil {
    		return emptyResult, err
    	}
    	return obj.(*v1.CustomResourceDefinition), err
    }
    
    // UpdateStatus was generated because the type contains a Status member.
    // Add a +genclient:noStatus comment above the type to avoid generating UpdateStatus().
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 18 12:23:16 UTC 2024
    - 8.4K bytes
    - Viewed (0)
  10. tensorflow/cc/framework/scope.cc

      return impl()->graph_;
    }
    
    Status Scope::status() const { return *impl()->status_; }
    
    const std::vector<Operation>& Scope::control_deps() const {
      return impl()->control_deps_;
    }
    
    void Scope::UpdateStatus(const Status& s) const {
      impl()->status_->Update(s);
      if (impl()->exit_on_error_ && !ok()) {
        LOG(FATAL) << *impl()->status_;
      }
    }
    
    Registered: Sun Jun 16 05:45:23 UTC 2024
    - Last Modified: Sat Apr 13 05:57:22 UTC 2024
    - 20.9K bytes
    - Viewed (0)
Back to top