- Sort Score
- Result 10 results
- Languages All
Results 241 - 250 of 453 for ctx_ (0.07 sec)
-
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 Nov 06 22:53:10 UTC 2024 - Last Modified: Thu Jun 15 15:02:17 UTC 2023 - 2.3K bytes - Viewed (0) -
istioctl/pkg/xds/google.go
project string } func (c *meshAuthCredentials) GetRequestMetadata(ctx context.Context, uri ...string) (map[string]string, error) { ret := map[string]string{ "x-goog-user-project": c.project, } if err := updateAuthHdrs(ctx, uri, "k8s", c.k8sCreds, ret, "x-mesh-authorization"); err != nil { return nil, err } if err := updateAuthHdrs(ctx, uri, "gcp", c.gcpCreds, ret, "authorization"); err != nil { return nil, err }
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Mon Nov 14 20:23:34 UTC 2022 - 3.4K bytes - Viewed (0) -
src/main/java/jcifs/smb/SmbEnumerationUtil.java
private static DcerpcHandle getHandle ( CIFSContext ctx, SmbResourceLocator loc, Address address, String ep ) throws MalformedURLException, DcerpcException { return DcerpcHandle.getHandle(String.format("ncacn_np:%s[endpoint=%s,address=%s]", loc.getServer(), ep, address.getHostAddress()), ctx); } static FileEntry[] doDfsRootEnum ( CIFSContext ctx, SmbResourceLocator loc, Address address ) throws IOException {
Registered: Sun Nov 03 00:10:13 UTC 2024 - Last Modified: Sat Jul 20 08:41:19 UTC 2019 - 12.5K bytes - Viewed (0) -
istioctl/pkg/internaldebug/internal-debug_test.go
}) for i, c := range cases { t.Run(fmt.Sprintf("case %d %s", i, strings.Join(c.args, " ")), func(t *testing.T) { ctx := cli.NewFakeContext(&cli.NewFakeContextOption{ IstioNamespace: "istio-system", }) if !c.noIstiod { client, err := ctx.CLIClientWithRevision(c.revision) assert.NoError(t, err) _, err = client.Kube().CoreV1().Pods("istio-system").Create(context.TODO(), &corev1.Pod{
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Fri Mar 15 08:28:50 UTC 2024 - 4.5K bytes - Viewed (0) -
cmd/bucket-lifecycle.go
if err == nil { auditLogLifecycle(es.ctx, oi, ILMFreeVersionDelete, nil, traceFn) } if ignoreNotFoundErr(err) != nil { transitionLogIf(es.ctx, err) } default: bugLogIf(es.ctx, fmt.Errorf("Invalid work type - %v", v)) } } } } func initBackgroundExpiry(ctx context.Context, objectAPI ObjectLayer) { globalExpiryState = newExpiryState(ctx, objectAPI, globalILMConfig.getExpirationWorkers())
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Oct 23 15:35:37 UTC 2024 - 33.7K bytes - Viewed (0) -
cmd/batch-expire.go
func (r BatchJobExpire) Notify(ctx context.Context, body io.Reader) error { if r.NotificationCfg.Endpoint == "" { return nil } ctx, cancel := context.WithTimeout(ctx, 10*time.Second) defer cancel() req, err := http.NewRequestWithContext(ctx, http.MethodPost, r.NotificationCfg.Endpoint, body) if err != nil { return err }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Sep 18 17:59:03 UTC 2024 - 21.9K bytes - Viewed (0) -
tensorflow/c/c_op_requires.h
#define C_OPKERNELCONTEXT_REQUIRES_OK(CTX, C_STATUS, __VA_ARGS__) \ do { \ ::tensorflow::Status _s(__VA_ARGS__); \ if (!TF_PREDICT_TRUE(_s.ok())) { \ ::tensorflow::Set_TF_Status_from_Status(C_STATUS, _s); \ TF_OpKernelContext_Failure(CTX, C_STATUS); \
Registered: Tue Nov 05 12:39:12 UTC 2024 - Last Modified: Tue Aug 02 21:35:06 UTC 2022 - 2.3K bytes - Viewed (0) -
tensorflow/c/eager/c_api_remote_test.cc
TFE_Context* ctx = TFE_NewContext(opts, status); EXPECT_EQ(TF_OK, TF_GetCode(status)) << TF_Message(status); TFE_DeleteContextOptions(opts); TFE_ContextSetServerDef(ctx, 0, serialized.data(), serialized.size(), status); EXPECT_EQ(TF_OK, TF_GetCode(status)) << TF_Message(status); TFE_TensorHandle* h0_task0 = TestMatrixTensorHandle(ctx); TFE_TensorHandle* h1_task0 = TestMatrixTensorHandle(ctx);
Registered: Tue Nov 05 12:39:12 UTC 2024 - Last Modified: Wed Aug 12 00:14:22 UTC 2020 - 5.4K bytes - Viewed (0) -
cmd/metacache-set.go
} func (o *listPathOptions) setBucketMeta(ctx context.Context) { lc, _ := globalLifecycleSys.Get(o.Bucket) vc, _ := globalBucketVersioningSys.Get(o.Bucket) // Check if bucket is object locked. rcfg, _ := globalBucketObjectLockSys.Get(o.Bucket) replCfg, _, _ := globalBucketMetadataSys.GetReplicationConfig(ctx, o.Bucket) tgts, _ := globalBucketTargetSys.ListBucketTargets(ctx, o.Bucket) o.Lifecycle = lc o.Versioning = vc
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Jul 12 16:23:16 UTC 2024 - 30.7K bytes - Viewed (0) -
istioctl/pkg/tag/tag.go
cmd.HelpFunc()(cmd, args) return nil }, } cmd.AddCommand(tagSetCommand(ctx)) cmd.AddCommand(tagGenerateCommand(ctx)) cmd.AddCommand(tagListCommand(ctx)) cmd.AddCommand(tagRemoveCommand(ctx)) return cmd } func tagSetCommand(ctx cli.Context) *cobra.Command { cmd := &cobra.Command{ Use: "set <revision-tag>", Short: "Create or modify revision tags",
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Mon Jul 22 15:40:30 UTC 2024 - 16.5K bytes - Viewed (0)