- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 165 for xds (0.13 sec)
-
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) -
pilot/pkg/xds/rds_test.go
// limitations under the License. package xds_test import ( "fmt" "testing" discovery "github.com/envoyproxy/go-control-plane/envoy/service/discovery/v3" v3 "istio.io/istio/pilot/pkg/xds/v3" "istio.io/istio/pilot/test/xds" ) func TestRDS(t *testing.T) { tests := []struct { name string node string routes []string }{ { "sidecar_new", sidecarID(app3Ip, "app3"),
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jan 12 18:20:36 UTC 2024 - 2.1K bytes - Viewed (0) -
pilot/pkg/xds/debug_test.go
discovery "github.com/envoyproxy/go-control-plane/envoy/service/discovery/v3" "istio.io/istio/istioctl/pkg/util/configdump" "istio.io/istio/pilot/pkg/model" "istio.io/istio/pilot/pkg/xds" v3 "istio.io/istio/pilot/pkg/xds/v3" xdsfake "istio.io/istio/pilot/test/xds" ) func TestSyncz(t *testing.T) { t.Run("return the sent and ack status of adsClient connections", func(t *testing.T) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jan 12 18:20:36 UTC 2024 - 7.8K 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) -
pilot/pkg/xds/nds_test.go
"github.com/google/go-cmp/cmp" "google.golang.org/protobuf/testing/protocmp" "istio.io/istio/pilot/pkg/model" "istio.io/istio/pilot/pkg/util/protoconv" v3 "istio.io/istio/pilot/pkg/xds/v3" "istio.io/istio/pilot/test/xds" "istio.io/istio/pkg/config/constants" dnsProto "istio.io/istio/pkg/dns/proto" ) func TestNDS(t *testing.T) { cases := []struct { name string meta model.NodeMetadata
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Mar 27 16:59:05 UTC 2024 - 4.6K bytes - Viewed (0) -
pilot/pkg/networking/core/extension/wasmplugin.go
Name: wasmPlugin.ResourceName, ConfigType: &hcm.HttpFilter_ConfigDiscovery{ ConfigDiscovery: &core.ExtensionConfigSource{ ConfigSource: defaultConfigSource, TypeUrls: []string{ xds.WasmHTTPFilterType, xds.RBACHTTPFilterType, }, }, }, } } func toEnvoyNetworkFilter(wasmPlugin *model.WasmPluginWrapper) *listener.Filter { return &listener.Filter{ Name: wasmPlugin.ResourceName,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 15 09:02:11 UTC 2024 - 5.4K bytes - Viewed (0) -
tests/fuzz/xds_fuzzer.go
"istio.io/istio/pilot/pkg/model" "istio.io/istio/pilot/test/xds" ) func init() { testing.Init() } func FuzzXds(data []byte) int { t := &testing.T{} // Use crd.ParseInputs to verify data _, _, err := crd.ParseInputs(string(data)) if err != nil { return 0 } s := xds.NewFakeDiscoveryServer(t, xds.FakeOptions{ ConfigString: string(data), }) proxy := s.SetupProxy(&model.Proxy{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jan 12 18:20:36 UTC 2024 - 1.1K bytes - Viewed (0)