- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 139 for xds (0.06 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) -
istioctl/pkg/multixds/gather.go
} err = fw.Start() if err != nil { return nil, err } defer fw.Close() xdsOpts.Xds = fw.Address() // Use plaintext. response, err := xds.GetXdsResponse(dr, istioNamespace, tokenServiceAccount, xdsOpts, []grpc.DialOption{}) if err != nil { return nil, fmt.Errorf("could not get XDS from the agent pod %q: %v", pod.Name, err) } for _, resource := range response.GetResources() {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Mar 08 08:38:19 UTC 2024 - 13.6K bytes - Viewed (0) -
pkg/istio-agent/xds_proxy_test.go
if !proto.Equal(gotEcdsConfig, wantEcdsConfig) { t.Errorf("xds proxy wasm config conversion got %v want %v", gotEcdsConfig, wantEcdsConfig) } v1 := proxy.ecdsLastAckVersion n1 := proxy.ecdsLastNonce // reset wasm cache to a NACK cache, and recreate xds server as well to simulate a version bump proxy.wasmCache = &fakeNackCache{} f = xds.NewFakeDiscoveryServer(t, xds.FakeOptions{ ConfigString: string(ef), })
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Mar 30 04:48:02 UTC 2024 - 18.6K bytes - Viewed (0) -
pilot/pkg/xds/xds_test.go
ID: "app.app", Type: model.SidecarProxy, IPAddresses: []string{"1.1.1.1"}, ConfigNamespace: "app", } } t.Run("STATIC", func(t *testing.T) { s := xds.NewFakeDiscoveryServer(t, xds.FakeOptions{ ConfigString: scopeConfig, ConfigTemplateInput: SidecarTestConfig{ ImportedNamespaces: []string{"./*", "included/*"}, Resolution: "STATIC", }, })
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Mar 27 16:59:05 UTC 2024 - 13.8K bytes - Viewed (0) -
pilot/pkg/xds/lds_test.go
v3 "istio.io/istio/pilot/pkg/xds/v3" "istio.io/istio/pilot/test/xds" "istio.io/istio/pilot/test/xdstest" "istio.io/istio/pkg/config/labels" "istio.io/istio/pkg/config/mesh" "istio.io/istio/pkg/wellknown" "istio.io/istio/tests/util" ) // TestLDS using isolated namespaces func TestLDSIsolated(t *testing.T) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jan 12 18:20:36 UTC 2024 - 13.1K 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) -
pilot/pkg/networking/grpcgen/grpcgen_test.go
"google.golang.org/grpc/codes" "google.golang.org/grpc/credentials/insecure" xdscreds "google.golang.org/grpc/credentials/xds" "google.golang.org/grpc/metadata" "google.golang.org/grpc/resolver" "google.golang.org/grpc/serviceconfig" "google.golang.org/grpc/status" xdsgrpc "google.golang.org/grpc/xds" // To install the xds resolvers and balancers. "google.golang.org/protobuf/proto" networking "istio.io/api/networking/v1alpha3"
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Mar 28 09:04:02 UTC 2024 - 16.9K bytes - Viewed (0) -
pkg/istio-agent/xds_proxy_delta.go
} func (p *XdsProxy) handleDeltaUpstream(ctx context.Context, con *ProxyConnection, xds discovery.AggregatedDiscoveryServiceClient) error { log := proxyLog.WithLabels("id", con.conID) deltaUpstream, err := xds.DeltaAggregatedResources(ctx, grpc.MaxCallRecvMsgSize(defaultClientMaxReceiveMessageSize)) if err != nil { // Envoy logs errors again, so no need to log beyond debug level log.Debugf("failed to create delta upstream grpc client: %v", err)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 04 20:29:08 UTC 2024 - 11.7K bytes - Viewed (0)