Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for CollectData (0.24 sec)

  1. pkg/volume/downwardapi/downwardapi.go

    	}
    
    	setupSuccess = true
    	return nil
    }
    
    // CollectData collects requested downwardAPI in data map.
    // Map's key is the requested name of file to dump
    // Map's value is the (sorted) content of the field to be dumped in the file.
    //
    // Note: this function is exported so that it can be called from the projection volume driver
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 14 06:17:25 UTC 2024
    - 10.4K bytes
    - Viewed (0)
  2. pkg/volume/projected/projected.go

    	wrapped, err := s.plugin.host.NewWrapperMounter(s.volName, wrappedVolumeSpec(), s.pod, *s.opts)
    	if err != nil {
    		return err
    	}
    
    	data, err := s.collectData(mounterArgs)
    	if err != nil {
    		klog.Errorf("Error preparing data for projected volume %v for pod %v/%v: %s", s.volName, s.pod.Namespace, s.pod.Name, err.Error())
    		return err
    	}
    
    	setupSuccess := false
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 14 06:17:25 UTC 2024
    - 12.8K bytes
    - Viewed (0)
  3. pkg/volume/projected/projected_test.go

    				pod:    pod,
    			}
    
    			gotPayload, err := myVolumeMounter.collectData(volume.MounterArgs{FsUser: tc.fsUser, FsGroup: tc.fsGroup})
    			if err != nil && (tc.wantErr == nil || tc.wantErr.Error() != err.Error()) {
    				t.Fatalf("collectData() = unexpected err: %v", err)
    			}
    			if diff := cmp.Diff(tc.wantPayload, gotPayload); diff != "" {
    				t.Errorf("collectData() = unexpected diff (-want +got):\n%s", diff)
    			}
    		})
    	}
    }
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Nov 03 18:40:48 UTC 2023
    - 40.5K bytes
    - Viewed (0)
  4. tensorflow/c/experimental/pluggable_profiler/pluggable_profiler.cc

      }
    
      Status Stop() override {
        tensorflow::TF_StatusPtr status(TF_NewStatus());
        profiler_fns_.stop(&profiler_, status.get());
        return tensorflow::StatusFromTF_Status(status.get());
      }
    
      Status CollectData(XSpace* space) override {
        tensorflow::TF_StatusPtr status(TF_NewStatus());
        // Get size of buffer required for Plugin to serialize XSpace into it.
        size_t size_in_bytes;
    Registered: Sun Jun 16 05:45:23 UTC 2024
    - Last Modified: Wed Sep 06 19:12:29 UTC 2023
    - 7.1K bytes
    - Viewed (0)
Back to top