- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 22 for _code (0.13 sec)
-
istioctl/pkg/util/formatting/formatter.go
func render(m diag.Message, colorize bool) string { return fmt.Sprintf("%s%v%s [%v]%s %s", colorPrefix(m, colorize), m.Type.Level(), colorSuffix(colorize), m.Type.Code(), m.Origin(), fmt.Sprintf(m.Type.Template(), m.Parameters...), ) } func colorPrefix(m diag.Message, colorize bool) string { if !colorize { return "" } prefix, ok := colorPrefixes[m.Type.Level()]
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Jul 11 02:41:45 GMT 2023 - 3.1K bytes - Viewed (0) -
cni/pkg/nodeagent/pod_cache.go
return maps.Clone(p.currentPodCache) } // Remove and return the Netns for the given uid // No need to return NetnsCloser here it will be closed automatically on GC. // (it may be used in parallel by other parts of the code, so we want it to be used only when not used) func (p *podNetnsCache) Take(uid string) Netns { // lock current pod map p.mu.Lock() defer p.mu.Unlock() if ns, ok := p.currentPodCache[uid]; ok {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 4.5K bytes - Viewed (0) -
istioctl/pkg/util/handlers/handlers.go
if err != nil { return nil, "", "", "", err } return clientset, "", namespace, selector.String(), nil } // this is used for testing. it should not be changed in regular code. var getFirstPodFunc func(client corev1client.PodsGetter, namespace string, selector string, timeout time.Duration, sortBy func([]*corev1.Pod) sort.Interface) (*corev1.Pod, int, error)
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Feb 06 15:01:41 GMT 2024 - 6.2K bytes - Viewed (0) -
cni/pkg/nodeagent/server_test.go
constants.AmbientRedirection: constants.AmbientRedirectionEnabled, }, }, } } type fakeServer struct { mock.Mock testWG *WaitGroup // optional waitgroup, if code under test makes a number of async calls to fakeServer } func (f *fakeServer) AddPodToMesh(ctx context.Context, pod *corev1.Pod, podIPs []netip.Addr, netNs string) error { if f.testWG != nil { defer f.testWG.Done()
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 7.8K bytes - Viewed (0) -
istioctl/cmd/sysexits.go
// sysexits to signify some error running istioctl, and use 79-125 as custom // error codes for other info that we'd like to use to pass info on. const ( ExitUnknownError = 1 // for compatibility with existing exit code ExitIncorrectUsage = 64 ExitDataError = 65 // some format error with input data // below here are non-zero exit codes that don't indicate an error with istioctl itself
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Jun 15 15:02:17 GMT 2023 - 1.9K bytes - Viewed (0) -
istioctl/pkg/writer/pilot/status.go
if clientConfig.GetGenericXdsConfigs() != nil { configs = clientConfig.GetGenericXdsConfigs() return configs } // FIXME: currently removing the deprecated code below may result in functions not working // if there is a mismatch of versions between istiod and istioctl // nolint: staticcheck for _, config := range clientConfig.GetXdsConfig() { var typeURL string
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 15 04:16:55 GMT 2024 - 6.1K bytes - Viewed (0) -
operator/cmd/mesh/operator-remove.go
cmd.Print("Cancelled.\n") os.Exit(1) } l.LogAndPrintf("Removing Istio operator...") // Create an empty IOP for the purpose of populating revision. Apply code requires a non-nil IOP. var iop *iopv1alpha1.IstioOperator if orArgs.revision != "" { emptyiops := &v1alpha1.IstioOperatorSpec{Profile: "empty", Revision: orArgs.revision}
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 15 01:18:49 GMT 2024 - 5.4K bytes - Viewed (0) -
istioctl/pkg/validate/validate.go
return nil, err } // IstioOperator isn't part of pkg/config/schema/collections, // usual conversion not available. Convert unstructured to string // and ask operator code to check. un.SetCreationTimestamp(metav1.Time{}) // UnmarshalIstioOperator chokes on these by := util.ToYAML(un) iop, err := operatoristio.UnmarshalIstioOperator(by, false) if err != nil { return nil, err
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/metrics/metrics.go
reqTot, destWorkloadLabel, wname, destWorkloadNamespaceLabel, wns, duration) errRPSQuery := fmt.Sprintf(`sum(rate(%s{%s=~"%s.*", %s=~"%s.*",reporter="destination",response_code=~"[45][0-9]{2}"}[%s]))`, reqTot, destWorkloadLabel, wname, destWorkloadNamespaceLabel, wns, duration) var me *multierror.Error var err error sm := workloadMetrics{workload: workload}
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sat Apr 13 05:23:38 GMT 2024 - 8.4K bytes - Viewed (0) -
istioctl/cmd/sysexits_test.go
} func TestKnownExitStrings(t *testing.T) { for err, wantCode := range KnownErrorCode { if code := GetExitCode(err); code != wantCode { t.Errorf("For %v want %v, but is %v", err, wantCode, code) } }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Jun 15 15:02:17 GMT 2023 - 1.3K bytes - Viewed (0)