- Sort Score
- Result 10 results
- Languages All
Results 121 - 130 of 686 for discoveryv1 (0.19 sec)
-
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) -
staging/src/k8s.io/api/apidiscovery/v2/generated.proto
// freshness marks whether a group version's discovery document is up to date. // "Current" indicates the discovery document was recently // refreshed. "Stale" indicates the discovery document could not // be retrieved and the returned discovery document may be // significantly out of date. Clients that require the latest // version of the discovery information be retrieved before
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 28 15:34:11 UTC 2024 - 7.8K 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) -
cmd/kubeadm/app/discovery/token/token.go
klog.V(1).Infof("[discovery] Created cluster-info discovery client, requesting info from %q", endpoint) insecureClusterInfo, err := getClusterInfo(client, insecureBootstrapConfig, token, interval, timeout) if err != nil { return nil, err } // Validate the token in the cluster info insecureKubeconfigBytes, err := validateClusterInfoToken(insecureClusterInfo, token) if err != nil { return nil, err
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Jan 14 13:07:56 UTC 2024 - 10.1K bytes - Viewed (0) -
pilot/pkg/networking/core/configgen.go
package core import ( core "github.com/envoyproxy/go-control-plane/envoy/config/core/v3" listener "github.com/envoyproxy/go-control-plane/envoy/config/listener/v3" discovery "github.com/envoyproxy/go-control-plane/envoy/service/discovery/v3" meshconfig "istio.io/api/mesh/v1alpha1" "istio.io/istio/pilot/pkg/model" dnsProto "istio.io/istio/pkg/dns/proto" )
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Mar 28 17:09:02 UTC 2024 - 3.1K bytes - Viewed (0) -
security/pkg/nodeagent/sds/sdsservice.go
core "github.com/envoyproxy/go-control-plane/envoy/config/core/v3" tls "github.com/envoyproxy/go-control-plane/envoy/extensions/transport_sockets/tls/v3" discovery "github.com/envoyproxy/go-control-plane/envoy/service/discovery/v3" sds "github.com/envoyproxy/go-control-plane/envoy/service/secret/v3" "github.com/google/uuid" uberatomic "go.uber.org/atomic" "google.golang.org/grpc" "google.golang.org/grpc/codes"
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat May 25 00:20:04 UTC 2024 - 10.9K bytes - Viewed (0) -
pkg/controller/endpointslice/endpointslice_controller.go
v1 "k8s.io/api/core/v1" discovery "k8s.io/api/discovery/v1" apierrors "k8s.io/apimachinery/pkg/api/errors" "k8s.io/apimachinery/pkg/labels" utilruntime "k8s.io/apimachinery/pkg/util/runtime" "k8s.io/apimachinery/pkg/util/wait" utilfeature "k8s.io/apiserver/pkg/util/feature" coreinformers "k8s.io/client-go/informers/core/v1" discoveryinformers "k8s.io/client-go/informers/discovery/v1" clientset "k8s.io/client-go/kubernetes"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 08:33:32 UTC 2024 - 23.6K bytes - Viewed (0)