- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 88 for responses (0.78 sec)
-
istioctl/pkg/xds/client.go
err = adscConn.Run() if err != nil { return nil, fmt.Errorf("ADSC: failed running %v", err) } err = adscConn.Send(dr) if err != nil { return nil, err } response, err := adscConn.WaitVersion(opts.Timeout, dr.TypeUrl, "") return response, err } // DialOptions constructs gRPC dial options from command line configuration func DialOptions(opts clioptions.CentralControlPlaneOptions,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Dec 19 22:42:42 UTC 2023 - 3.7K bytes - Viewed (0) -
pkg/hbone/dialer.go
} // Setup a pipe. We could just pass `conn` to `http.NewRequest`, but this has a few issues: // * Less visibility into i/o // * http will call conn.Close, which will close before we want to (finished writing response). pr, pw := io.Pipe() r, err := http.NewRequest(http.MethodConnect, url, pr) if err != nil { return fmt.Errorf("new request: %v", err) } r.Host = address // Initiate CONNECT.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 24 15:56:41 UTC 2023 - 5.1K bytes - Viewed (0) -
operator/cmd/mesh/shared.go
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Mar 29 02:29:02 UTC 2024 - 5.1K bytes - Viewed (0) -
pilot/pkg/xds/debug_test.go
if err != nil { t.Fatal(err) } rr := httptest.NewRecorder() syncz := http.HandlerFunc(s.ConfigDump) syncz.ServeHTTP(rr, req) if rr.Code != wantCode { t.Errorf("wanted response code %v, got %v", wantCode, rr.Code) } if wantCode > 399 { return nil } got := &configdump.Wrapper{} if err := got.UnmarshalJSON(rr.Body.Bytes()); err != nil { t.Fatalf(err.Error()) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jan 12 18:20:36 UTC 2024 - 7.8K bytes - Viewed (0) -
security/pkg/server/ca/server.go
serverCaLog.Debugf("Append cert chain to response, %s", string(certChainBytes)) } } if len(rootCertBytes) != 0 { respCertChain = append(respCertChain, string(rootCertBytes)) } response := &pb.IstioCertificateResponse{ CertChain: respCertChain, } s.monitoring.Success.Increment() serverCaLog.Debugf("CSR successfully signed, sans %v.", caller.Identities) return response, nil }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 28 17:35:26 UTC 2024 - 8K bytes - Viewed (0) -
istioctl/pkg/cli/mock_test.go
_, _, codec := cmdtesting.NewExternalScheme() tf.UnstructuredClient = &fake.RESTClient{ NegotiatedSerializer: resource.UnstructuredPlusDefaultContentConfig().NegotiatedSerializer, Resp: &http.Response{ StatusCode: http.StatusOK, Header: cmdtesting.DefaultHeader(), Body: cmdtesting.ObjBody(codec, cmdtesting.NewInternalType("", "", "foo")), }, } return tf }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 15 15:02:17 UTC 2023 - 1.3K bytes - Viewed (0) -
operator/pkg/metrics/monitoring.go
// ResourceUpdateTotal indicates the number of resources updated by // the operator in response to CR updates for a revision. ResourceUpdateTotal = monitoring.NewSum( "resource_update_total", "Number of resources updated by the operator", ) // ResourceDeletionTotal indicates the number of resources deleted // by the operator in response to CR update or delete operation (like
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Aug 10 15:35:03 UTC 2023 - 7K bytes - Viewed (0) -
pilot/pkg/xds/ecds.go
return nil, model.DefaultXdsLogDetails, nil } // Inserts Wasm pull secrets in ECDS response, which will be used at xds proxy for image pull. // Before forwarding to Envoy, xds proxy will remove the secret from ECDS response. secrets = e.GeneratePullSecrets(proxy, wasmSecrets, secretController) } }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Jan 16 18:25:42 UTC 2024 - 7.2K bytes - Viewed (0) -
pkg/test/echo/server/forwarder/tls.go
for n, i := range cs.PeerCertificates { pemBlock := pem.Block{ Type: "CERTIFICATE", Bytes: i.Raw, } echo.WriteBodyLine(&msgBuilder, requestID, fmt.Sprintf("Response%d=%q", n, string(pem.EncodeToMemory(&pemBlock)))) } msg := msgBuilder.String() return msg, nil } func versionName(v uint16) string { switch v { case tls.VersionTLS10: return "1.0"
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jul 11 16:27:16 UTC 2022 - 3.4K bytes - Viewed (0) -
pkg/test/echo/server/forwarder/dns.go
echo.DNSServerField.WriteForRequest(&outBuffer, requestID, req.dnsServer) for n, i := range ips { echo.WriteBodyLine(&outBuffer, requestID, fmt.Sprintf("Response%d=%s", n, i.String())) } return outBuffer.String(), nil } func (c *dnsProtocol) Close() error { return nil
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 10 18:09:08 UTC 2022 - 3.3K bytes - Viewed (0)