- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 152 for xds (0.06 sec)
-
istioctl/pkg/xds/client.go
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. // See the License for the specific language governing permissions and // limitations under the License. package xds // xds uses ADSC to call XDS import ( "context" "crypto/tls" "fmt" "strings" discovery "github.com/envoyproxy/go-control-plane/envoy/service/discovery/v3" "google.golang.org/grpc"
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/istio-agent/xds_proxy_delta_test.go
v3 "istio.io/istio/pilot/pkg/xds/v3" "istio.io/istio/pilot/test/xds" "istio.io/istio/pkg/config/constants" "istio.io/istio/pkg/test/env" "istio.io/istio/pkg/test/util/assert" "istio.io/istio/pkg/test/util/retry" ) // Validates basic xds proxy flow by proxying one CDS requests end to end. func TestDeltaXdsProxyBasicFlow(t *testing.T) { proxy := setupXdsProxy(t) f := xds.NewFakeDiscoveryServer(t, xds.FakeOptions{})
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Mar 30 04:48:02 UTC 2024 - 6.3K bytes - Viewed (0) -
pilot/pkg/networking/apigen/apigen_test.go
"istio.io/istio/pilot/pkg/model" "istio.io/istio/pilot/test/xds" "istio.io/istio/pkg/config/schema/collections" "istio.io/istio/pkg/config/schema/gvk" ) // Creates an in-process discovery server, using the same code as Istiod, but // backed by an in-memory config and endpoint Store. func initDS(t *testing.T) *xds.FakeDiscoveryServer { ds := xds.NewFakeDiscoveryServer(t, xds.FakeOptions{}) sd := ds.MemRegistry
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jan 12 18:20:36 UTC 2024 - 2.3K 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/adstest.go
"google.golang.org/grpc" "istio.io/istio/pilot/pkg/model" v3 "istio.io/istio/pilot/pkg/xds/v3" "istio.io/istio/pkg/test" ) func NewAdsTest(t test.Failer, conn *grpc.ClientConn) *AdsTest { return NewXdsTest(t, conn, func(conn *grpc.ClientConn) (DiscoveryClient, error) { xds := discovery.NewAggregatedDiscoveryServiceClient(conn) return xds.StreamAggregatedResources(context.Background()) }) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sun Feb 04 03:39:42 UTC 2024 - 6K bytes - Viewed (0) -
pilot/pkg/networking/grpcgen/grpcecho_test.go
"fmt" "math" "net" "runtime" "strconv" "sync" "testing" "time" "google.golang.org/grpc" // To install the xds resolvers and balancers. _ "google.golang.org/grpc/xds" networking "istio.io/api/networking/v1alpha3" "istio.io/istio/pilot/test/xds" "istio.io/istio/pkg/config" "istio.io/istio/pkg/config/protocol" "istio.io/istio/pkg/config/schema/gvk" "istio.io/istio/pkg/test/echo"
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jan 12 18:20:36 UTC 2024 - 8.3K bytes - Viewed (0) -
pilot/pkg/networking/grpcgen/grpcgen.go
v3 "istio.io/istio/pilot/pkg/xds/v3" "istio.io/istio/pkg/config/host" istiolog "istio.io/istio/pkg/log" ) // Support generation of 'ApiListener' LDS responses, used for native support of gRPC. // The same response can also be used by other apps using XDS directly. // GRPC proposal: // https://github.com/grpc/proposal/blob/master/A27-xds-global-load-balancing.md //
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 23 17:08:31 UTC 2023 - 3.7K bytes - Viewed (0) -
pilot/pkg/xds/eventhandler.go
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. // See the License for the specific language governing permissions and // limitations under the License. package xds import ( v3 "istio.io/istio/pilot/pkg/xds/v3" "istio.io/istio/pkg/util/sets" ) // EventType represents the type of object we are tracking, mapping to envoy TypeUrl. type EventType = string
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Jan 30 17:25:17 UTC 2024 - 1.3K bytes - Viewed (0) -
pilot/pkg/xds/vm_test.go
"istio.io/istio/pilot/pkg/model" "istio.io/istio/pilot/test/xds" "istio.io/istio/pkg/config" "istio.io/istio/pkg/config/schema/gvk" "istio.io/istio/pkg/test" "istio.io/istio/pkg/test/util/assert" "istio.io/istio/pkg/test/util/retry" ) // TestRegistration is an e2e test for registration. Most tests are in autoregister package, but this // exercises the full XDS flow. func TestRegistration(t *testing.T) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jan 12 18:20:36 UTC 2024 - 2.3K bytes - Viewed (0)