Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for newUploader (0.24 sec)

  1. src/cmd/vendor/golang.org/x/telemetry/internal/upload/run.go

    	uploadServerURL string
    	startTime       time.Time
    
    	cache parsedCache
    
    	logFile *os.File
    	logger  *log.Logger
    }
    
    // newUploader creates a new uploader to use for running the upload for the
    // given config.
    //
    // Uploaders should only be used for one call to [uploader.Run].
    func newUploader(rcfg RunConfig) (*uploader, error) {
    	// Determine the upload directory.
    	var dir telemetry.Dir
    	if rcfg.TelemetryDir != "" {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 15 21:12:15 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  2. pkg/kubelet/kubeletconfig/configfiles/configfiles.go

    	kubeletCodecs *serializer.CodecFactory
    	// kubeletFile is an absolute path to the file containing a serialized KubeletConfiguration
    	kubeletFile string
    }
    
    // NewFsLoader returns a Loader that loads a KubeletConfiguration from the `kubeletFile`
    func NewFsLoader(fs utilfs.Filesystem, kubeletFile string) (Loader, error) {
    	_, kubeletCodecs, err := kubeletscheme.NewSchemeAndCodecs(serializer.EnableStrict)
    	if err != nil {
    		return nil, err
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 10 17:13:59 UTC 2024
    - 3.7K bytes
    - Viewed (0)
  3. src/cmd/link/internal/ld/data_test.go

    	"testing"
    )
    
    func setUpContext(arch *sys.Arch, iself bool, ht objabi.HeadType, bm, lm string) *Link {
    	ctxt := linknew(arch)
    	ctxt.HeadType = ht
    	er := loader.ErrorReporter{}
    	ctxt.loader = loader.NewLoader(0, &er)
    	ctxt.BuildMode.Set(bm)
    	ctxt.LinkMode.Set(lm)
    	ctxt.IsELF = iself
    	ctxt.mustSetHeadType()
    	ctxt.setArchSyms()
    	return ctxt
    }
    
    // Make sure the addgotsym properly increases the symbols.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 05 19:20:01 UTC 2023
    - 2.3K bytes
    - Viewed (0)
  4. android/guava-tests/test/com/google/common/base/FinalizableReferenceQueueTest.java

      }
    
      public void testDecoupledLoader() {
        FinalizableReferenceQueue.DecoupledLoader decoupledLoader =
            new FinalizableReferenceQueue.DecoupledLoader() {
              @Override
              URLClassLoader newLoader(URL base) {
                return new DecoupledClassLoader(new URL[] {base});
              }
            };
    
        Class<?> finalizerCopy = decoupledLoader.loadFinalizer();
    
        assertNotNull(finalizerCopy);
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Mon Jun 10 19:21:11 UTC 2024
    - 4.8K bytes
    - Viewed (0)
  5. pkg/kubelet/kubeletconfig/configfiles/configfiles_test.go

    			path := filepath.Join(configDir, kubeletFile)
    			if c.file != nil {
    				if err := addFile(fs, path, *c.file); err != nil {
    					t.Fatalf("unexpected error: %v", err)
    				}
    			}
    			loader, err := NewFsLoader(fs, path)
    			if err != nil {
    				t.Fatalf("unexpected error: %v", err)
    			}
    			kc, err := loader.Load()
    
    			if c.strictErr && !runtime.IsStrictDecodingError(errors.Unwrap(err)) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jan 18 12:18:41 UTC 2023
    - 7.2K bytes
    - Viewed (0)
Back to top