- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 12 for durations (0.17 sec)
-
istioctl/pkg/clioptions/central.go
XdsPodPort int // CertDir is the local directory containing certificates CertDir string // Timeout is how long to wait before giving up on XDS Timeout time.Duration // InsecureSkipVerify skips client verification the server's certificate chain and host name. InsecureSkipVerify bool // XDSSAN is the expected Subject Alternative Name of the XDS server XDSSAN string
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Mon Jun 06 03:39:27 GMT 2022 - 3.2K bytes - Viewed (0) -
istioctl/pkg/util/handlers/handlers.go
} // 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) // InferPodInfoFromTypedResource gets a pod name, from an expression like Deployment/httpbin, or Deployment/productpage-v1.bookinfo
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) -
istioctl/pkg/util/handlers/handlers_test.go
return nil, fmt.Errorf("unexpected request") } }), } getFirstPodFunc = func(client corev1client.PodsGetter, namespace string, selector string, timeout time.Duration, sortBy func([]*corev1.Pod) sort.Interface) ( *corev1.Pod, int, error, ) { return attachPod(namespace), 1, nil } for _, tt := range tests { t.Run(strings.Split(tt.name, ".")[0], func(t *testing.T) {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Jun 09 18:17:49 GMT 2023 - 6.6K bytes - Viewed (0) -
cni/pkg/nodeagent/ztunnelserver.go
return z.readMessage(readWriteDeadline) } func (z *ZtunnelConnection) readMessage(timeout time.Duration) (*zdsapi.WorkloadResponse, error) { m, _, err := readProto[zdsapi.WorkloadResponse](z.u, timeout, nil) return m, err } func readProto[T any, PT interface { proto.Message *T }](c *net.UnixConn, timeout time.Duration, oob []byte) (PT, int, error) { var buf [1024]byte err := c.SetReadDeadline(time.Now().Add(timeout))
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 12.4K bytes - Viewed (0) -
operator/cmd/mesh/install.go
InFilenames []string // ReadinessTimeout is maximum time to wait for all Istio resources to be ready. wait must be true for this setting // to take effect. ReadinessTimeout time.Duration // SkipConfirmation determines whether the user is prompted for confirmation. // If set to true, the user is not prompted and a Yes response is assumed in all cases. SkipConfirmation bool
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu May 02 14:30:43 GMT 2024 - 15.5K bytes - Viewed (1) -
istioctl/pkg/metrics/metrics.go
} func getLatency(promAPI promv1.API, workloadName, workloadNamespace string, duration time.Duration, quantile float64) (time.Duration, error) { latencyQuery := fmt.Sprintf(`histogram_quantile(%f, sum(rate(%s_bucket{%s=~"%s.*", %s=~"%s.*",reporter="destination"}[%s])) by (le))`, quantile, reqDur, destWorkloadLabel, workloadName, destWorkloadNamespaceLabel, workloadNamespace, duration) letency, err := vectorValue(promAPI, latencyQuery) if err != nil {
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/pkg/wait/wait.go
"istio.io/istio/pkg/config/schema/resource" "istio.io/istio/pkg/slices" ) var ( forFlag string nameflag string proxyFlag string threshold float32 timeout time.Duration generation string verbose bool targetSchema resource.Schema ) const pollInterval = time.Second // Cmd represents the wait command func Cmd(cliCtx cli.Context) *cobra.Command {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sat Feb 17 12:24:17 GMT 2024 - 10.1K bytes - Viewed (0) -
operator/cmd/mesh/shared.go
// DryRun performs all steps except actually applying the manifests or creating output dirs/files. DryRun bool // Maximum amount of time to wait for resources to be ready after install when Wait=true. WaitTimeout time.Duration } func applyManifest(kubeClient kube.Client, client client.Client, manifestStr string, componentName name.ComponentName, opts *applyOptions, iop *v1alpha1.IstioOperator, l clog.Logger, ) error {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 29 02:29:02 GMT 2024 - 5.1K bytes - Viewed (0) -
istioctl/pkg/analyze/analyze.go
colorize bool msgOutputFormat string meshCfgFile string selectedNamespace string allNamespaces bool suppress []string analysisTimeout time.Duration recursive bool ignoreUnknown bool revisionSpecified string fileExtensions = []string{".json", ".yaml", ".yml"} ) // Analyze command func Analyze(ctx cli.Context) *cobra.Command {
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/metrics/metrics_test.go
"histogram_quantile(0.500000, sum(rate(istio_request_duration_milliseconds_bucket{destination_workload=~\"details.*\", destination_workload_namespace=~\".*\",reporter=\"destination\"}[1m0s])) by (le))": prometheus_model.Vector{ // nolint: lll &prometheus_model.Sample{Value: 2.5}, },
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed Oct 25 02:07:44 GMT 2023 - 7.9K bytes - Viewed (0)