- Sort Score
- Result 10 results
- Languages All
Results 91 - 100 of 212 for copts (0.03 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)