- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 99 for xds (0.09 sec)
-
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) -
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) -
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) -
pkg/bootstrap/testdata/default_golden.json
} } }] }] } }, { "name": "xds-grpc", "type" : "STATIC", "connect_timeout": "1s", "lb_policy": "ROUND_ROBIN", "load_assignment": { "cluster_name": "xds-grpc", "endpoints": [{ "lb_endpoints": [{ "endpoint": { "address":{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 01 14:41:40 UTC 2024 - 11.9K bytes - Viewed (0) -
pkg/bootstrap/testdata/tracing_datadog_golden.json
} } }] }] } }, { "name": "xds-grpc", "type" : "STATIC", "connect_timeout": "1s", "lb_policy": "ROUND_ROBIN", "load_assignment": { "cluster_name": "xds-grpc", "endpoints": [{ "lb_endpoints": [{ "endpoint": { "address":{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 01 14:41:40 UTC 2024 - 12.8K bytes - Viewed (0) -
pkg/bootstrap/testdata/tracing_zipkin_golden.json
} } }] }] } }, { "name": "xds-grpc", "type" : "STATIC", "connect_timeout": "1s", "lb_policy": "ROUND_ROBIN", "load_assignment": { "cluster_name": "xds-grpc", "endpoints": [{ "lb_endpoints": [{ "endpoint": { "address":{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 01 14:41:40 UTC 2024 - 12.9K bytes - Viewed (0) -
pkg/istio-agent/agent_test.go
"google.golang.org/grpc/reflection" meshconfig "istio.io/api/mesh/v1alpha1" "istio.io/istio/pilot/pkg/model" "istio.io/istio/pilot/pkg/xds" v3 "istio.io/istio/pilot/pkg/xds/v3" testutil "istio.io/istio/pilot/test/util" xdsfake "istio.io/istio/pilot/test/xds" "istio.io/istio/pilot/test/xdstest" "istio.io/istio/pkg/bootstrap" "istio.io/istio/pkg/bootstrap/platform" "istio.io/istio/pkg/config/mesh"
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 16 22:12:28 UTC 2024 - 33.4K bytes - Viewed (0) -
pilot/pkg/xds/delta.go
"istio.io/istio/pilot/pkg/model" "istio.io/istio/pilot/pkg/networking/util" v3 "istio.io/istio/pilot/pkg/xds/v3" istiolog "istio.io/istio/pkg/log" "istio.io/istio/pkg/slices" "istio.io/istio/pkg/util/sets" "istio.io/istio/pkg/xds" ) var deltaLog = istiolog.RegisterScope("delta", "delta xds debugging") func (s *DiscoveryServer) StreamDeltas(stream DeltaDiscoveryStream) error {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 04:34:37 UTC 2024 - 25.6K bytes - Viewed (0)