- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 155 for Fprintf (0.23 sec)
-
istioctl/pkg/waypoint/waypoint.go
break } if time.Since(startTime) > waitTimeout { errorMsg := fmt.Sprintf("timed out while waiting for waypoint %v/%v", gw.Namespace, gw.Name) if err != nil { errorMsg += fmt.Sprintf(": %s", err) } return fmt.Errorf(errorMsg) } } } fmt.Fprintf(cmd.OutOrStdout(), "waypoint %v/%v applied\n", gw.Namespace, gw.Name)
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed May 08 19:45:58 GMT 2024 - 15.5K bytes - Viewed (0) -
istioctl/pkg/analyze/analyze.go
for _, aName := range analyzerNames { b.WriteString(fmt.Sprintf("* %s:\n", aName)) a := nameToAnalyzer[aName] if a.Metadata().Description != "" { b.WriteString(fmt.Sprintf(" %s\n", a.Metadata().Description)) } } return b.String() } func analyzeTargetAsString() string { if allNamespaces { return "all namespaces" } return fmt.Sprintf("namespace: %s", selectedNamespace) }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 02 08:32:06 GMT 2024 - 17K bytes - Viewed (0) -
istioctl/pkg/validate/validate.go
objLabels, err := GetTemplateLabels(un) if err != nil { return err } url := fmt.Sprintf("See %s\n", url.DeploymentRequirements) if !labels.HasCanonicalServiceName(objLabels) || !labels.HasCanonicalServiceRevision(objLabels) { fmt.Fprintf(writer, "deployment %q may not provide Istio metrics and telemetry labels: %q. "+url, fmt.Sprintf("%s/%s:", un.GetName(), un.GetNamespace()), objLabels) } return nil }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Mon Jan 22 17:58:52 GMT 2024 - 15K bytes - Viewed (0) -
istioctl/pkg/tag/tag.go
fmt.Fprintf(w, "Aborting operation.\n") return nil } } // proceed with webhook deletion err = DeleteTagWebhooks(ctx, kubeClient, tagName) if err != nil { return fmt.Errorf("failed to delete Istio revision tag MutatingConfigurationWebhook: %v", err) } fmt.Fprintf(w, "Revision tag %s removed\n", tagName) return nil }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 02 08:32:06 GMT 2024 - 16.3K bytes - Viewed (0) -
istioctl/pkg/injector/injector-list.go
return "<no pods>" } podText := strconv.Itoa(counts.pods) if counts.disabled > 0 { podText += fmt.Sprintf(" (injection disabled: %d)", counts.disabled) } if counts.needsRestart > 0 { podText += fmt.Sprintf(" NEEDS RESTART: %d", counts.needsRestart) } return fmt.Sprintf("%s: %s", injectedRevision, podText)
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Jan 04 03:08:06 GMT 2024 - 10.4K bytes - Viewed (0) -
cmd/erasure-metadata.go
fmt.Fprintf(h, "%v", meta.Erasure.Distribution) } if meta.IsRemote() { // ILM transition fields fmt.Fprint(h, meta.TransitionStatus) fmt.Fprint(h, meta.TransitionTier) fmt.Fprint(h, meta.TransitionedObjName) fmt.Fprint(h, meta.TransitionVersionID) } // If metadata says encrypted, ask for it in quorum. if etyp, ok := crypto.IsEncrypted(meta.Metadata); ok { fmt.Fprint(h, etyp)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 19.2K bytes - Viewed (1) -
cmd/bucket-replication-utils.go
// compatible behavior. if !oi.ReplicationStatus.Empty() { oi.ReplicationStatusInternal = fmt.Sprintf("%s=%s;", rcfg.Config.RoleArn, oi.ReplicationStatus) } if !oi.VersionPurgeStatus.Empty() { oi.VersionPurgeStatusInternal = fmt.Sprintf("%s=%s;", rcfg.Config.RoleArn, oi.VersionPurgeStatus) } for k, v := range userDefined {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 26.2K bytes - Viewed (0) -
istioctl/pkg/dashboard/dashboard.go
// Try the next port continue } // Close the port forwarder when the command is terminated. ClosePortForwarderOnInterrupt(fw) log.Debugf(fmt.Sprintf("port-forward to %s pod ready", flavor)) openBrowser(fmt.Sprintf(urlFormat, fw.Address()), writer, browser) // Wait for stop fw.WaitForStop() return nil } return fmt.Errorf("failure running port forward process: %v", err)
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Mon Apr 15 01:29:35 GMT 2024 - 20.5K bytes - Viewed (0) -
src/cmd/api/main_test.go
if !ok { log.Printf("%s:%d: missing proposal approval\n", filename, i+1) exitCode = 1 } else { _, err := strconv.Atoi(approval) if err != nil { log.Printf("%s:%d: malformed proposal approval #%s\n", filename, i+1, approval) exitCode = 1 } } line = strings.TrimSpace(feature) } else { if strings.Contains(line, " #") {
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Tue Apr 09 20:48:51 GMT 2024 - 31.4K bytes - Viewed (0) -
istioctl/pkg/multixds/gather.go
} return &retval, nil } func makeSan(istioNamespace, revision string) string { if revision == "" { return fmt.Sprintf("istiod.%s.svc", istioNamespace) } return fmt.Sprintf("istiod-%s.%s.svc", revision, istioNamespace) } // AllRequestAndProcessXds returns all XDS responses from 1 central or 1..N K8s cluster-based XDS servers // nolint: lll
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 08 08:38:19 GMT 2024 - 13.6K bytes - Viewed (0)