- Sort Score
- Result 10 results
- Languages All
Results 91 - 100 of 115 for newCounter (0.56 sec)
-
pkg/volume/testing/volume_host.go
if spec.Volume != nil { spec.Volume.Name = wrapperVolumeName } plug, err := f.pluginMgr.FindPluginBySpec(&spec) if err != nil { return nil, err } return plug.NewMounter(&spec, pod, opts) } func (f *fakeVolumeHost) NewWrapperUnmounter(volName string, spec Spec, podUID types.UID) (Unmounter, error) { // The name of wrapper volume is set to "wrapped_{wrapped_volume_name}"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 11 09:02:45 UTC 2024 - 16.5K bytes - Viewed (0) -
pkg/volume/hostpath/host_path.go
return false, nil } func (plugin *hostPathPlugin) GetAccessModes() []v1.PersistentVolumeAccessMode { return []v1.PersistentVolumeAccessMode{ v1.ReadWriteOnce, } } func (plugin *hostPathPlugin) NewMounter(spec *volume.Spec, pod *v1.Pod, opts volume.VolumeOptions) (volume.Mounter, error) { hostPathVolumeSource, readOnly, err := getVolumeSource(spec) if err != nil { return nil, err }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 15.3K bytes - Viewed (0) -
pkg/volume/util/operationexecutor/operation_generator.go
} volumeMounter, newMounterErr := volumePlugin.NewMounter( volumeToMount.VolumeSpec, volumeToMount.Pod, volume.VolumeOptions{}) if newMounterErr != nil { eventErr, detailedErr := volumeToMount.GenerateError("MountVolume.NewMounter initialization failed", newMounterErr) return volumetypes.NewOperationContext(eventErr, detailedErr, migrated) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 101.4K bytes - Viewed (0) -
pilot/pkg/config/kube/gateway/controller.go
namespaces: namespaces, credentialsController: credsController, cluster: options.ClusterID, domain: options.DomainSuffix, statusController: atomic.NewPointer(ctl), waitForCRD: waitForCRD, } namespaces.AddEventHandler(controllers.EventHandler[*corev1.Namespace]{ UpdateFunc: func(oldNs, newNs *corev1.Namespace) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Mar 30 05:26:03 UTC 2024 - 13.5K bytes - Viewed (0) -
pkg/volume/plugins.go
// this to update the contents of the volume. RequiresRemount(spec *Spec) bool // NewMounter creates a new volume.Mounter from an API specification. // Ownership of the spec pointer in *not* transferred. // - spec: The v1.Volume spec // - pod: The enclosing pod NewMounter(spec *Spec, podRef *v1.Pod, opts VolumeOptions) (Mounter, error)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 06 16:13:15 UTC 2024 - 38.2K bytes - Viewed (0) -
cmd/admin-handlers_test.go
initAllSubsystems(ctx) initConfigSubsystem(ctx, objLayer) globalIAMSys.Init(ctx, objLayer, globalEtcdClient, 2*time.Second) // Setup admin mgmt REST API handlers. adminRouter := mux.NewRouter() registerAdminRouter(adminRouter, true) return &adminErasureTestBed{ erasureDirs: erasureDirs, objLayer: objLayer, router: adminRouter, done: cancel, }, nil }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Feb 22 06:26:06 UTC 2024 - 13.8K bytes - Viewed (0) -
pkg/volume/util/operationexecutor/operation_executor.go
// mounted to after it is attached. PodName volumetypes.UniquePodName // VolumeSpec is a volume spec containing the specification for the volume // that should be mounted. Used to create NewMounter. Used to generate // InnerVolumeSpecName. VolumeSpec *volume.Spec // outerVolumeSpecName is the podSpec.Volume[x].Name of the volume. If the
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 42.6K bytes - Viewed (0) -
pkg/volume/emptydir/empty_dir.go
return false } func (plugin *emptyDirPlugin) SupportsSELinuxContextMount(spec *volume.Spec) (bool, error) { return false, nil } func (plugin *emptyDirPlugin) NewMounter(spec *volume.Spec, pod *v1.Pod, opts volume.VolumeOptions) (volume.Mounter, error) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 21 10:18:16 UTC 2024 - 19K bytes - Viewed (0) -
pkg/volume/fc/fc.go
} func (plugin *fcPlugin) GetAccessModes() []v1.PersistentVolumeAccessMode { return []v1.PersistentVolumeAccessMode{ v1.ReadWriteOnce, v1.ReadOnlyMany, } } func (plugin *fcPlugin) NewMounter(spec *volume.Spec, pod *v1.Pod, _ volume.VolumeOptions) (volume.Mounter, error) { // Inject real implementations here, test through the internal function.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 17.4K bytes - Viewed (0) -
src/go/internal/gccgoimporter/parser.go
if *n != (types.Pointer{}) { elem := n.Elem() if elem == t { continue } p.errorf("internal error: update: pointer already set to %v, expected %v", elem, t) } *n = *types.NewPointer(t) default: p.errorf("internal error: %T on nlist", n) } } } // NamedType = TypeName [ "=" ] Type { Method } . // TypeName = ExportedName .
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Feb 02 23:14:07 UTC 2024 - 31.2K bytes - Viewed (0)