- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 182 for xds (0.59 sec)
-
manifests/addons/dashboards/pilot.libsonnet
row.new('Push Information') + row.withPanels([ panels.timeSeries.xdsPushes( 'XDS Pushes', queries.xdsPushes, ||| Rate of XDS push operations, by type. This is incremented on a per-proxy basis. ||| ), panels.timeSeries.base( 'Events', queries.pilotEvents, ||| Size of each xDS push. ||| ), panels.timeSeries.base(
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 12 20:46:28 UTC 2024 - 2.9K bytes - Viewed (0) -
security/pkg/nodeagent/sds/sdsservice.go
w.Lock() defer w.Unlock() w.watch = &xds.WatchedResource{TypeUrl: typeURL, ResourceNames: names} } func (w *Watch) UpdateWatchedResource(_ string, f func(*xds.WatchedResource) *xds.WatchedResource) { w.Lock() defer w.Unlock() w.watch = f(w.watch) } func (w *Watch) GetID() string { // This always maps to the same local Envoy instance. return "" }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat May 25 00:20:04 UTC 2024 - 10.9K bytes - Viewed (0) -
istioctl/pkg/proxystatus/proxystatus.go
istioctl ps --xds-address istio.example.com:15012 --cert-dir ~/.istio-certs # Retrieve proxy status information via XDS from specific control plane in multi-control plane in-cluster configuration # (Select a specific control plane in an in-cluster canary Istio configuration.) istioctl ps --xds-label istio.io/rev=default `, Aliases: []string{"ps"},
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Apr 13 05:23:38 UTC 2024 - 6.2K bytes - Viewed (0) -
pilot/pkg/xds/workload_test.go
metav1beta1 "istio.io/api/type/v1beta1" securityclient "istio.io/client-go/pkg/apis/security/v1beta1" "istio.io/istio/pilot/pkg/features" "istio.io/istio/pilot/pkg/model" v3 "istio.io/istio/pilot/pkg/xds/v3" "istio.io/istio/pilot/test/xds" "istio.io/istio/pkg/config/constants" "istio.io/istio/pkg/kube/kclient/clienttest" "istio.io/istio/pkg/test" "istio.io/istio/pkg/test/util/assert" "istio.io/istio/pkg/util/sets" )
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 18 19:09:43 UTC 2024 - 15.9K bytes - Viewed (0) -
tests/integration/pilot/piggyback_test.go
args := []string{ "x", "proxy-status", "--xds-via-agents", fmt.Sprintf("%s.%s", podName, namespace), } output, _, err := istioCtl.Invoke(args) if err != nil { return err } return expectSubstrings(output, "Clusters Match", "Listeners Match", "Routes Match") }) // Test gRPC-based tapped XDS using istioctl. retry.UntilSuccessOrFail(t, func() error {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon May 13 20:55:20 UTC 2024 - 3.3K bytes - Viewed (0) -
pkg/xds/monitoring.go
typeTag = monitoring.CreateLabel("type") TotalXDSInternalErrors = monitoring.NewSum( "pilot_total_xds_internal_errors", "Total number of internal XDS errors in pilot.", ) ExpiredNonce = monitoring.NewSum( "pilot_xds_expired_nonce", "Total number of XDS requests with an expired nonce.", ) // pilot_total_xds_rejects should be used instead. This is for backwards compatibility cdsReject = monitoring.NewGauge(
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 30 00:26:45 UTC 2024 - 2.9K bytes - Viewed (0) -
pilot/pkg/xds/delta_test.go
s := xds.NewFakeDiscoveryServer(t, xds.FakeOptions{}) ads := s.ConnectDeltaADS().WithType(v3.ClusterType) ads.RequestResponseAck(nil) } func TestDeltaAdsClusterUpdate(t *testing.T) { s := xds.NewFakeDiscoveryServer(t, xds.FakeOptions{}) ads := s.ConnectDeltaADS().WithType(v3.EndpointType) nonce := "" sendEDSReqAndVerify := func(add, remove, expect []string) { t.Helper() res := ads.RequestResponseAck(&discovery.DeltaDiscoveryRequest{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 15.2K bytes - Viewed (0) -
pilot/pkg/xds/ads.go
"KNative revision, set if running in knative").Get() // DiscoveryStream is a server interface for XDS. type DiscoveryStream = xds.DiscoveryStream // DeltaDiscoveryStream is a server interface for Delta XDS. type DeltaDiscoveryStream = discovery.AggregatedDiscoveryService_DeltaAggregatedResourcesServer // DiscoveryClient is a client interface for XDS. type DiscoveryClient = discovery.AggregatedDiscoveryService_StreamAggregatedResourcesClient
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 03 08:29:05 UTC 2024 - 23.4K bytes - Viewed (0) -
pkg/istio-agent/xds_proxy.go
// Increase metric when xds connection error, for example: forgot to restart ingressgateway or sidecar after changing root CA. metrics.IstiodConnectionErrors.Increment() return err } log.Infof("connected to upstream XDS server: %s", p.istiodAddress) defer log.Debugf("disconnected from XDS server: %s", p.istiodAddress) con.upstream = upstream // Handle upstream xds recv go func() { for {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 16 22:12:28 UTC 2024 - 27.9K bytes - Viewed (0) -
pilot/pkg/xds/xdsgen.go
// limitations under the License. package xds import ( "encoding/json" "strconv" "strings" "time" core "github.com/envoyproxy/go-control-plane/envoy/config/core/v3" discovery "github.com/envoyproxy/go-control-plane/envoy/service/discovery/v3" "istio.io/istio/pilot/pkg/model" "istio.io/istio/pilot/pkg/networking/util" v3 "istio.io/istio/pilot/pkg/xds/v3" "istio.io/istio/pkg/env"
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon May 13 20:55:20 UTC 2024 - 6.3K bytes - Viewed (0)