- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for completeSync (0.22 sec)
-
pkg/kubelet/pod_workers.go
} return nil } // completeSync is invoked when syncPod completes successfully and indicates the pod is now terminal and should // be terminated. This happens when the natural pod lifecycle completes - any pod which is not RestartAlways // exits. Unnatural completions, such as evictions, API driven deletion or phase transition, are handled by // UpdatePod. func (p *podWorkers) completeSync(podUID types.UID) { p.podLock.Lock()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Apr 02 13:22:37 UTC 2024 - 74.8K bytes - Viewed (0) -
pkg/volume/util/types/types.go
func (o *GeneratedOperations) Run() (eventErr, detailedErr error) { var context OperationContext if o.CompleteFunc != nil { c := CompleteFuncParam{ Err: &context.DetailedErr, Migrated: &context.Migrated, } defer o.CompleteFunc(c) } if o.EventRecorderFunc != nil { defer o.EventRecorderFunc(&eventErr) } // Handle panic, if any, from operationFunc()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jan 31 17:23:56 UTC 2024 - 5.2K bytes - Viewed (0) -
pkg/volume/volume_linux.go
err := walkDeep(dir, func(path string, info os.FileInfo, err error) error { if err != nil { return err } return changeFilePermission(path, fsGroup, mounter.GetAttributes().ReadOnly, info) }) if completeFunc != nil { completeFunc(types.CompleteFuncParam{ Err: &err, }) } return err } func changeFilePermission(filename string, fsGroup *int64, readonly bool, info os.FileInfo) error {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 03 19:34:37 UTC 2023 - 6.5K bytes - Viewed (0) -
pkg/volume/volume_unsupported.go
package volume import ( v1 "k8s.io/api/core/v1" "k8s.io/kubernetes/pkg/volume/util/types" ) func SetVolumeOwnership(mounter Mounter, dir string, fsGroup *int64, fsGroupChangePolicy *v1.PodFSGroupChangePolicy, completeFunc func(types.CompleteFuncParam)) error { return nil
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 03 19:34:37 UTC 2023 - 886 bytes - Viewed (0) -
pkg/volume/util/operationexecutor/operation_generator.go
return volumetypes.NewOperationContext(nil, nil, false) } return volumetypes.GeneratedOperations{ OperationName: "verify_volumes_are_attached_per_node", OperationFunc: volumesAreAttachedFunc, CompleteFunc: util.OperationCompleteHook(util.GetFullQualifiedPluginNameForVolume("<n/a>", nil), "verify_volumes_are_attached_per_node"), EventRecorderFunc: nil, // nil because we do not want to generate event on error }, 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) -
pkg/volume/util/operationexecutor/operation_generator_test.go
volumetesting "k8s.io/kubernetes/pkg/volume/testing" "k8s.io/kubernetes/pkg/volume/util" volumetypes "k8s.io/kubernetes/pkg/volume/util/types" ) // this method just tests the volume plugin name that's used in CompleteFunc, the same plugin is also used inside the // generated func so there is no need to test the plugin name that's used inside generated function func TestOperationGenerator_GenerateUnmapVolumeFunc_PluginName(t *testing.T) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 16.2K bytes - Viewed (0)