Search Options

Results per page
Sort
Preferred Languages
Advance

Results 91 - 100 of 212 for copts (0.09 sec)

  1. cmd/healthcheck-handler.go

    		return
    	}
    
    	ctx, cancel := context.WithTimeout(ctx, globalAPIConfig.getClusterDeadline())
    	defer cancel()
    
    	opts := HealthOptions{
    		Maintenance:    r.Form.Get("maintenance") == "true",
    		DeploymentType: r.Form.Get("deployment-type"),
    	}
    	result := objLayer.Health(ctx, opts)
    	w.Header().Set(xhttp.MinIOWriteQuorum, strconv.Itoa(result.WriteQuorum))
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed Jun 26 07:44:34 UTC 2024
    - 6.9K bytes
    - Viewed (0)
  2. tensorflow/c/eager/c_api_remote_test_util.cc

      TF_Status* status = TF_NewStatus();
      TFE_ContextOptions* opts = TFE_NewContextOptions();
      TFE_ContextOptionsSetAsync(opts, static_cast<unsigned char>(async));
      TFE_ContextOptionsSetDevicePlacementPolicy(opts, TFE_DEVICE_PLACEMENT_SILENT);
      TFE_Context* ctx = TFE_NewContext(opts, status);
      EXPECT_EQ(TF_GetCode(status), TF_OK) << TF_Message(status);
      TFE_DeleteContextOptions(opts);
    
    Registered: Tue Oct 29 12:39:09 UTC 2024
    - Last Modified: Fri Dec 11 22:56:03 UTC 2020
    - 9.1K bytes
    - Viewed (0)
  3. cmd/encryption-v1_test.go

    	for i, test := range getDefaultOptsTests {
    		opts, err := getDefaultOpts(test.headers, test.copySource, test.metadata)
    		if test.err != err {
    			t.Errorf("Case %d: expected err: %v , actual err: %v", i, test.err, err)
    		}
    		if err == nil {
    			if opts.ServerSideEncryption == nil && test.encryptionType != "" {
    				t.Errorf("Case %d: expected opts to be of %v encryption type", i, test.encryptionType)
    			}
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Sat Sep 24 04:17:08 UTC 2022
    - 19.9K bytes
    - Viewed (0)
  4. istioctl/pkg/multicluster/remote_secret_test.go

    	secret := makeSecret("secret", "caData", "token")
    
    	type tc struct {
    		name string
    		opts RemoteSecretOptions
    		objs []runtime.Object
    
    		want       *v1.Secret
    		wantErrStr string
    	}
    
    	commonCases := []tc{
    		{
    			name: "missing service account",
    			opts: RemoteSecretOptions{
    				ServiceAccountName: testServiceAccountName,
    				KubeOptions: KubeOptions{
    Registered: Wed Oct 30 22:53:10 UTC 2024
    - Last Modified: Thu Oct 24 17:36:49 UTC 2024
    - 20.7K bytes
    - Viewed (0)
  5. internal/cachevalue/cache_test.go

    	select {
    	case <-sl.C:
    	case <-ctx.Done():
    		return ctx.Err()
    	}
    
    	return nil
    }
    
    func TestCacheCtx(t *testing.T) {
    	cache := New[time.Time]()
    	t.Parallel()
    	cache.InitOnce(2*time.Second, Opts{},
    		func(ctx context.Context) (time.Time, error) {
    			return time.Now(), slowCaller(ctx)
    		},
    	)
    
    	ctx, cancel := context.WithCancel(context.Background())
    	cancel() // cancel context to test.
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu May 09 00:51:34 UTC 2024
    - 2.7K bytes
    - Viewed (0)
  6. internal/hash/reader.go

    // callers to indicate if they want to disable md5sum checksum.
    func NewReaderWithOpts(ctx context.Context, src io.Reader, opts Options) (*Reader, error) {
    	// return hard limited reader
    	return newReader(ctx, src, opts.Size, opts.MD5Hex, opts.SHA256Hex, opts.ActualSize, opts.DisableMD5, opts.ForceMD5)
    }
    
    // NewReader returns a new Reader that wraps src and computes
    // MD5 checksum of everything it reads as ETag.
    //
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Sep 19 12:59:07 UTC 2024
    - 10.9K bytes
    - Viewed (0)
  7. cmd/veeam-sos-api.go

    }
    
    func veeamSOSAPIHeadObject(ctx context.Context, bucket, object string, opts ObjectOptions) (ObjectInfo, error) {
    	gr, err := veeamSOSAPIGetObject(ctx, bucket, object, nil, opts)
    	if gr != nil {
    		gr.Close()
    		return gr.ObjInfo, nil
    	}
    	return ObjectInfo{}, err
    }
    
    func veeamSOSAPIGetObject(ctx context.Context, bucket, object string, rs *HTTPRangeSpec, opts ObjectOptions) (gr *GetObjectReader, err error) {
    	var buf []byte
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Aug 15 00:34:56 UTC 2024
    - 8.8K bytes
    - Viewed (0)
  8. tensorflow/c/eager/parallel_device/parallel_device_remote_test.cc

    TEST(PARALLEL_DEVICE, TestRemoteBasic) {
      std::unique_ptr<TFE_ContextOptions, decltype(&TFE_DeleteContextOptions)> opts(
          TFE_NewContextOptions(), TFE_DeleteContextOptions);
      std::unique_ptr<TF_Status, decltype(&TF_DeleteStatus)> status(
          TF_NewStatus(), TF_DeleteStatus);
      std::unique_ptr<TFE_Context, decltype(&TFE_DeleteContext)> context(
          TFE_NewContext(opts.get(), status.get()), TFE_DeleteContext);
    Registered: Tue Oct 29 12:39:09 UTC 2024
    - Last Modified: Wed Jul 10 07:18:05 UTC 2024
    - 6.8K bytes
    - Viewed (0)
  9. tensorflow/c/eager/dlpack_test.cc

    }
    
    TEST(DLPack, HandleFromDLPackStrides) {
      TF_Status* status = TF_NewStatus();
      TFE_ContextOptions* opts = TFE_NewContextOptions();
      TFE_Context* ctx = TFE_NewContext(opts, status);
      ASSERT_EQ(TF_OK, TF_GetCode(status)) << TF_Message(status);
      TFE_DeleteContextOptions(opts);
    
      TestHandleFromDLPack(status, ctx, {}, {});
      TestHandleFromDLPack(status, ctx, {4}, {});
    Registered: Tue Oct 29 12:39:09 UTC 2024
    - Last Modified: Fri Jun 30 03:04:46 UTC 2023
    - 4.4K bytes
    - Viewed (0)
  10. istioctl/pkg/proxyconfig/clusters.go

    func ClustersCommand(ctx cli.Context) *cobra.Command {
    	var opts clioptions.ControlPlaneOptions
    	cmd := &cobra.Command{
    		Use:   "remote-clusters",
    		Short: "Lists the remote clusters each istiod instance is connected to.",
    		RunE: func(cmd *cobra.Command, args []string) error {
    			kubeClient, err := ctx.CLIClientWithRevision(opts.Revision)
    			if err != nil {
    				return err
    			}
    Registered: Wed Oct 30 22:53:10 UTC 2024
    - Last Modified: Thu Jun 15 15:02:17 UTC 2023
    - 2.3K bytes
    - Viewed (0)
Back to top