- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 234 for discoveryv1 (0.3 sec)
-
pkg/istio-agent/xds_proxy.go
) type ( DiscoveryStream = discovery.AggregatedDiscoveryService_StreamAggregatedResourcesServer DeltaDiscoveryStream = discovery.AggregatedDiscoveryService_DeltaAggregatedResourcesServer DiscoveryClient = discovery.AggregatedDiscoveryService_StreamAggregatedResourcesClient DeltaDiscoveryClient = discovery.AggregatedDiscoveryService_DeltaAggregatedResourcesClient )
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/ads_test.go
ads := s.ConnectADS() // Send normal CDS and EDS requests _ = ads.RequestResponseAck(t, &discovery.DiscoveryRequest{TypeUrl: v3.ClusterType}) eres := ads.RequestResponseAck(t, &discovery.DiscoveryRequest{TypeUrl: v3.EndpointType, ResourceNames: []string{"my-resource"}}) // A push should get a response for both s.Discovery.ConfigUpdate(&model.PushRequest{Full: true}) ads.ExpectResponse(t) ads.ExpectResponse(t)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Jan 30 17:25:17 UTC 2024 - 30.3K bytes - Viewed (0) -
staging/src/k8s.io/cli-runtime/pkg/genericclioptions/config_flags.go
restMapperLock sync.Mutex discoveryClient discovery.CachedDiscoveryInterface discoveryClientLock sync.Mutex // If set to true, will use persistent client config, rest mapper, discovery client, and // propagate them to the places that need them, rather than // instantiating them multiple times. usePersistentConfig bool // Allows increasing burst used for discovery, this is useful
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Oct 11 15:04:11 UTC 2023 - 16.9K bytes - Viewed (0) -
Makefile.core.mk
cp manifests/charts/istio-control/istio-discovery/files/injection-template.yaml manifests/charts/istiod-remote/files cp manifests/charts/istio-control/istio-discovery/files/gateway-injection-template.yaml manifests/charts/istiod-remote/files cp manifests/charts/istio-control/istio-discovery/templates/istiod-injector-configmap.yaml manifests/charts/istiod-remote/templates
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sun Jun 02 19:53:04 UTC 2024 - 23.2K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/apiserver/customresource_discovery_controller_test.go
FakeResourceManager: aggregated.NewFakeResourceManager(), versionDiscoveryHandler: versionDiscoveryHandler{ discovery: make(map[schema.GroupVersion]*discovery.APIVersionHandler), }, groupDiscoveryHandler: groupDiscoveryHandler{ discovery: make(map[string]*discovery.APIGroupHandler), }, } return env } func TestResourceManagerExistingCRD(t *testing.T) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 18:15:22 UTC 2024 - 12K bytes - Viewed (0) -
cmd/kubeadm/app/discovery/token/token_test.go
kind: Config preferences: {} users: null ` ) tests := []struct { name string tokenID string tokenSecret string cfg *kubeadmapi.Discovery configMap *fakeConfigMap delayedJWSSignaturePatch bool expectedError bool }{ {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Jan 14 13:07:56 UTC 2024 - 10.9K bytes - Viewed (0) -
pkg/proxy/iptables/number_generated_rules_test.go
baseEp := netutils.BigForIP(netutils.ParseIPSloppy("172.16.0.1")) epPort := 8080 eps := &discovery.EndpointSlice{ ObjectMeta: metav1.ObjectMeta{ Name: "ep", Namespace: "namespace", }, AddressType: discovery.AddressTypeIPv4, Endpoints: []discovery.Endpoint{}, Ports: []discovery.EndpointPort{{ Name: ptr.To(fmt.Sprintf("%d", epPort)), Port: ptr.To(int32(epPort)),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 21 14:39:54 UTC 2024 - 13.1K bytes - Viewed (0) -
pkg/istio-agent/xds_proxy_test.go
func stream(t *testing.T, conn *grpc.ClientConn) discovery.AggregatedDiscoveryService_StreamAggregatedResourcesClient { t.Helper() adsClient := discovery.NewAggregatedDiscoveryServiceClient(conn) downstream, err := adsClient.StreamAggregatedResources(ctx) if err != nil { t.Fatal(err) } return downstream }
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/workload_test.go
// See the License for the specific language governing permissions and // limitations under the License. package xds_test import ( "context" "testing" "time" discovery "github.com/envoyproxy/go-control-plane/envoy/service/discovery/v3" corev1 "k8s.io/api/core/v1" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" "k8s.io/apimachinery/pkg/runtime" "istio.io/api/security/v1beta1"
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 18 19:09:43 UTC 2024 - 15.9K bytes - Viewed (0) -
pkg/adsc/adsc_test.go
) type testAdscRunServer struct{} var StreamHandler func(stream discovery.AggregatedDiscoveryService_StreamAggregatedResourcesServer) error func (t *testAdscRunServer) StreamAggregatedResources(stream discovery.AggregatedDiscoveryService_StreamAggregatedResourcesServer) error { return StreamHandler(stream) } func (t *testAdscRunServer) DeltaAggregatedResources(discovery.AggregatedDiscoveryService_DeltaAggregatedResourcesServer) error {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Dec 19 22:42:42 UTC 2023 - 15.4K bytes - Viewed (0)