Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 183 for dopts (0.07 sec)

  1. cmd/object-api-common.go

    func newStorageAPI(endpoint Endpoint, opts storageOpts) (storage StorageAPI, err error) {
    	if endpoint.IsLocal {
    		storage, err := newXLStorage(endpoint, opts.cleanUp)
    		if err != nil {
    			return nil, err
    		}
    		return newXLStorageDiskIDCheck(storage, opts.healthCheck), nil
    	}
    
    	return newStorageRESTClient(endpoint, opts.healthCheck, globalGrid.Load())
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Nov 21 01:09:35 UTC 2023
    - 2.1K bytes
    - Viewed (0)
  2. cmd/erasure-sets.go

    func (s *erasureSets) DeleteObject(ctx context.Context, bucket string, object string, opts ObjectOptions) (objInfo ObjectInfo, err error) {
    	if opts.DeletePrefix && !opts.DeletePrefixObject {
    		err := s.deletePrefix(ctx, bucket, object)
    		return ObjectInfo{}, err
    	}
    	set := s.getHashedSet(object)
    	return set.DeleteObject(ctx, bucket, object, opts)
    }
    
    // DeleteObjects - bulk delete of objects
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Sep 27 10:41:37 UTC 2024
    - 37K bytes
    - Viewed (0)
  3. internal/bucket/replication/rule_test.go

    package replication
    
    import (
    	"bytes"
    	"fmt"
    	"testing"
    )
    
    func TestMetadataReplicate(t *testing.T) {
    	testCases := []struct {
    		inputConfig    string
    		opts           ObjectOpts
    		expectedResult bool
    	}{
    		// case 1 - rule with replica modification enabled; not a replica
    		{
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Sun Jan 02 17:15:06 UTC 2022
    - 4.6K bytes
    - Viewed (0)
  4. internal/http/listener.go

    		if e != nil {
    			if opts.Trace != nil {
    				opts.Trace(fmt.Sprint("listenCfg.Listen: ", e))
    			}
    
    			listenErrs[i] = e
    			continue
    		}
    
    		if opts.Trace != nil {
    			opts.Trace(fmt.Sprint("adding listener to ", l.Addr()))
    		}
    
    		listeners = append(listeners, l)
    	}
    
    	if len(listeners) == 0 {
    		// No listeners initialized, no need to continue
    		return
    	}
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Jul 23 10:53:03 UTC 2024
    - 5.6K bytes
    - Viewed (0)
  5. docs/extensions/s3zip/examples/minio-go/main.go

    	})
    	if err != nil {
    		log.Fatalln(err)
    	}
    
    	var opts minio.GetObjectOptions
    
    	// Add extract header to request:
    	opts.Set("x-minio-extract", "true")
    
    	// Download API.md from the archive
    	rd, err := s3Client.GetObject(context.Background(), "your-bucket", "path/to/file.zip/data.csv", opts)
    	if err != nil {
    		log.Fatalln(err)
    	}
    	_, err = io.Copy(os.Stdout, rd)
    	if err != nil {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Jun 14 18:04:14 UTC 2021
    - 694 bytes
    - Viewed (0)
  6. cmd/metrics-v3-cache.go

    	loadNodesUpDown := func(ctx context.Context) (v nodesOnline, err error) {
    		v.Online, v.Offline = globalNotificationSys.GetPeerOnlineCount()
    		return
    	}
    	return cachevalue.NewFromFunc(1*time.Minute,
    		cachevalue.Opts{ReturnLastGood: true},
    		loadNodesUpDown)
    }
    
    type driveIOStatMetrics struct {
    	readsPerSec    float64
    	readsKBPerSec  float64
    	readsAwait     float64
    	writesPerSec   float64
    	writesKBPerSec float64
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu May 09 00:51:34 UTC 2024
    - 8.1K bytes
    - Viewed (0)
  7. tensorflow/c/eager/c_api_experimental_test.cc

      ASSERT_TRUE(w1->Start().ok());
    
      TF_Status* status = TF_NewStatus();
      TFE_ContextOptions* opts = TFE_NewContextOptions();
      opts->session_options.options.config.set_isolate_session_state(false);
      TFE_ContextOptionsSetDevicePlacementPolicy(opts, TFE_DEVICE_PLACEMENT_SILENT);
      TFE_Context* ctx = TFE_NewContext(opts, status);
      EXPECT_EQ(TF_GetCode(status), TF_OK) << TF_Message(status);
    
      server_def.set_task_index(0);
    Registered: Tue Oct 29 12:39:09 UTC 2024
    - Last Modified: Thu Aug 03 03:14:26 UTC 2023
    - 31.5K bytes
    - Viewed (0)
  8. cmd/erasure-object_test.go

    	}
    
    	res, err := objLayer.NewMultipartUpload(ctx, "bucket1", "mpartObj1", opts)
    	if err != nil {
    		t.Fatal(err)
    	}
    	fiveMBBytes := bytes.Repeat([]byte("a"), 5*humanize.MiByte)
    	md5Hex := getMD5Hash(fiveMBBytes)
    	_, err = objLayer.PutObjectPart(ctx, "bucket1", "mpartObj1", res.UploadID, 1, mustGetPutObjReader(t, bytes.NewReader(fiveMBBytes), 5*humanize.MiByte, md5Hex, ""), opts)
    	if err != nil {
    		t.Fatal(err)
    	}
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Jan 30 20:43:25 UTC 2024
    - 36.8K bytes
    - Viewed (0)
  9. tensorflow/c/eager/c_api_unified_experimental_test.cc

          TF_NewStatus(), TF_DeleteStatus);
      TFE_ContextOptions* opts = TFE_NewContextOptions();
      TFE_ContextOptionsSetTfrt(opts, std::get<1>(GetParam()));
      TF_ExecutionContext* ctx = TF_NewEagerExecutionContext(opts, status.get());
      ASSERT_EQ(TF_OK, TF_GetCode(status.get())) << TF_Message(status.get());
      TFE_DeleteContextOptions(opts);
    
      ASSERT_EQ(TF_OK, TF_GetCode(status.get())) << TF_Message(status.get());
    
    Registered: Tue Oct 29 12:39:09 UTC 2024
    - Last Modified: Sat Oct 12 05:11:17 UTC 2024
    - 39.1K bytes
    - Viewed (0)
  10. tensorflow/c/eager/c_api_remote_test.cc

      TFE_ContextOptions* opts = TFE_NewContextOptions();
      TFE_ContextOptionsSetAsync(opts, static_cast<unsigned char>(async));
      TFE_ContextOptionsSetDevicePlacementPolicy(opts,
                                                 TFE_DEVICE_PLACEMENT_EXPLICIT);
      TFE_Context* ctx = TFE_NewContext(opts, status);
      EXPECT_EQ(TF_OK, TF_GetCode(status)) << TF_Message(status);
      TFE_DeleteContextOptions(opts);
    
    Registered: Tue Oct 29 12:39:09 UTC 2024
    - Last Modified: Wed Aug 12 00:14:22 UTC 2020
    - 5.4K bytes
    - Viewed (0)
Back to top