- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 1,273 for updatePV (0.15 sec)
-
plugin/pkg/auth/authorizer/node/graph_populator.go
klog.V(5).Infof("deletePod %s/%s for node %s completed in %v", pod.Namespace, pod.Name, pod.Spec.NodeName, time.Since(startTime)) } func (g *graphPopulator) addPV(obj interface{}) { g.updatePV(nil, obj) } func (g *graphPopulator) updatePV(oldObj, obj interface{}) { pv := obj.(*corev1.PersistentVolume) // TODO: skip add if uid, pvc, and secrets are all identical between old and new g.graph.AddPV(pv) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 21:22:55 UTC 2024 - 6.5K bytes - Viewed (0) -
pkg/volume/util/operationexecutor/operation_generator.go
// VolumesInUse in the node's volume status, do not proceed, return // error. Caller will log and retry. The node status is updated // periodically by kubelet, so it may take as much as 10 seconds // before this clears. // Issue #28141 to enable on demand status updates. eventErr, detailedErr := volumeToMount.GenerateError("Volume has not been added to the list of VolumesInUse in the node's volume status", nil)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 101.4K bytes - Viewed (0) -
subprojects/core/src/test/groovy/org/gradle/api/internal/project/DefaultProjectStateRegistryTest.groovy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Apr 05 16:29:26 UTC 2024 - 24.6K bytes - Viewed (0) -
pkg/controller/daemon/update.go
cur, err = dsc.dedupCurHistories(ctx, ds, currentHistories) if err != nil { return nil, nil, err } // Update revision number if necessary if cur.Revision < currRevision { toUpdate := cur.DeepCopy() toUpdate.Revision = currRevision _, err = dsc.kubeClient.AppsV1().ControllerRevisions(ds.Namespace).Update(ctx, toUpdate, metav1.UpdateOptions{}) if err != nil { return nil, nil, err } } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 13 16:53:53 UTC 2024 - 24.4K bytes - Viewed (0) -
hack/update-translations.sh
# See the License for the specific language governing permissions and # limitations under the License. # This script updates `staging/src/k8s.io/kubectl/pkg/util/i18n/translations/kubectl/template.pot` and # generates/fixes .po and .mo files. # Usage: `update-translations.sh`. KUBE_ROOT=$(dirname "${BASH_SOURCE[0]}")/.. source "${KUBE_ROOT}/hack/lib/util.sh"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Nov 22 03:48:42 UTC 2022 - 3.7K bytes - Viewed (0) -
pilot/pkg/serviceregistry/util/xdsfake/updater.go
func NewFakeXDS() *Updater { return &Updater{ SplitEvents: false, Events: make(chan Event, 100), } } // NewWithDelegate creates a XdsUpdater reporting events via a channel. func NewWithDelegate(delegate model.XDSUpdater) *Updater { return &Updater{ Events: make(chan Event, 100), Delegate: delegate, } } // Updater is used to test the registry. type Updater struct {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Feb 29 18:40:34 UTC 2024 - 6.2K bytes - Viewed (0) -
.github/workflows/update-rbe.yml
# This Workflow updates tensorflow/tools/toolchains/remote_config/configs.bzl # to reference the most recent versions of the SIG Build Docker images. name: Update RBE Configs on: workflow_dispatch: permissions: contents: read jobs: rbe: name: Update RBE Configs runs-on: ubuntu-latest
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Wed Apr 10 15:40:34 UTC 2024 - 7.2K bytes - Viewed (0) -
pkg/controller/nodeipam/ipam/sync/sync.go
run(logger klog.Logger, sync *NodeSync) error } // updateOp handles creation and updates of a node. type updateOp struct { node *v1.Node } func (op *updateOp) String() string { if op.node == nil { return fmt.Sprintf("updateOp(nil)") } return fmt.Sprintf("updateOp(%q,%v)", op.node.Name, op.node.Spec.PodCIDR) } func (op *updateOp) run(logger klog.Logger, sync *NodeSync) error {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 07 07:50:01 UTC 2023 - 12.6K bytes - Viewed (0) -
pilot/pkg/xds/discovery_test.go
updateCh <- &model.PushRequest{Full: true} updateCh <- &model.PushRequest{Full: true} expect(0, 1) }, }, { name: "Should send full updates in batches, partial updates immediately", test: func(updateCh chan *model.PushRequest, expect func(partial, full int32)) { updateCh <- &model.PushRequest{Full: true} updateCh <- &model.PushRequest{Full: true}
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 30 00:26:45 UTC 2024 - 9.2K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/managedfields/internal/capmanagers.go
} return updaters[i] < updaters[j] }) // Merge the oldest updaters with versioned bucket managers until the number of updaters is under the cap versionToFirstManager := map[string]string{} for i, length := 0, len(updaters); i < len(updaters) && length > f.maxUpdateManagers; i++ { manager := updaters[i] vs := managed.Fields()[manager] time := managed.Times()[manager] version := string(vs.APIVersion())
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 08 21:44:00 UTC 2023 - 4.6K bytes - Viewed (0)