- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 67 for KUBERNETES (0.88 sec)
-
pilot/pkg/networking/core/listener_test.go
svc.Resolution = model.Passthrough svc.Attributes.ServiceRegistry = provider.Kubernetes services := []*model.Service{svc} autoSvc := buildServiceWithPort("test.com", 9999, protocol.Unsupported, tnow) autoSvc.Resolution = model.Passthrough autoSvc.Attributes.ServiceRegistry = provider.Kubernetes extSvc := buildServiceWithPort("example1.com", 9999, protocol.TCP, tnow)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 93.6K bytes - Viewed (0) -
pkg/controller/endpointslice/endpointslice_controller_test.go
"k8s.io/apimachinery/pkg/util/wait" "k8s.io/client-go/informers" "k8s.io/client-go/kubernetes/fake" k8stesting "k8s.io/client-go/testing" "k8s.io/client-go/tools/cache" "k8s.io/endpointslice/topologycache" endpointsliceutil "k8s.io/endpointslice/util" "k8s.io/klog/v2/ktesting" "k8s.io/kubernetes/pkg/controller" endpointslicepkg "k8s.io/kubernetes/pkg/controller/util/endpointslice" "k8s.io/utils/pointer" )
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 08:33:32 UTC 2024 - 65.5K bytes - Viewed (0) -
pilot/pkg/model/push_context.go
// However, the Service is from Kubernetes it should take precedence over ones not. This prevents someone from // "domain squatting" on the hostname before a Kubernetes Service is created. if existing := ps.ServiceIndex.HostnameAndNamespace[s.Hostname][s.Attributes.Namespace]; existing != nil && !(existing.Attributes.ServiceRegistry != provider.Kubernetes && s.Attributes.ServiceRegistry == provider.Kubernetes) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 15 09:02:11 UTC 2024 - 91.8K bytes - Viewed (0) -
pkg/kubelet/kuberuntime/kuberuntime_manager_test.go
apitest "k8s.io/cri-api/pkg/apis/testing" podutil "k8s.io/kubernetes/pkg/api/v1/pod" "k8s.io/kubernetes/pkg/credentialprovider" "k8s.io/kubernetes/pkg/features" kubecontainer "k8s.io/kubernetes/pkg/kubelet/container" containertest "k8s.io/kubernetes/pkg/kubelet/container/testing" proberesults "k8s.io/kubernetes/pkg/kubelet/prober/results" ) var ( fakeCreatedAt int64 = 1
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 96K bytes - Viewed (0) -
pkg/workloadapi/workload.pb.go
// Name represents the name for the service. // For Kubernetes, this is the Service name. Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // Namespace represents the namespace for the service. Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"` // Hostname represents the FQDN of the service. // For Kubernetes, this would be <name>.<namespace>.svc.<cluster domain>.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 12 18:02:35 UTC 2024 - 65.9K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/controller_test.go
annotation.AlphaCanonicalServiceAccounts.Name: canonicalSaOnVM, }, []int32{8080}, map[string]string{"app": "prod-app"}, t) // Endpoints are generated by Kubernetes from pod labels and service selectors. // Here we manually create them for mocking purpose. svc1Ips := []string{"128.0.0.1"} portNames := []string{"tcp-port"}
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 85K bytes - Viewed (0) -
pkg/kubelet/pod_workers_test.go
"k8s.io/apimachinery/pkg/types" "k8s.io/apimachinery/pkg/util/sets" "k8s.io/client-go/tools/record" kubecontainer "k8s.io/kubernetes/pkg/kubelet/container" containertest "k8s.io/kubernetes/pkg/kubelet/container/testing" kubetypes "k8s.io/kubernetes/pkg/kubelet/types" "k8s.io/kubernetes/pkg/kubelet/util/queue" "k8s.io/utils/clock" clocktesting "k8s.io/utils/clock/testing" )
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 75.6K bytes - Viewed (0) -
pkg/controller/statefulset/stateful_set_utils_test.go
"k8s.io/apimachinery/pkg/runtime/schema" "k8s.io/apimachinery/pkg/types" "k8s.io/apimachinery/pkg/util/intstr" "k8s.io/klog/v2" "k8s.io/klog/v2/ktesting" podutil "k8s.io/kubernetes/pkg/api/v1/pod" "k8s.io/kubernetes/pkg/controller/history" "k8s.io/utils/ptr" ) // noopRecorder is an EventRecorder that does nothing. record.FakeRecorder has a fixed // buffer size, which causes tests to hang if that buffer's exceeded.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 05 19:06:41 UTC 2024 - 50.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher_whitebox_test.go
{ name: "RV=unset, allowWatchBookmarks=true, sendInitialEvents=nil", opts: listOptions(true, nil, ""), // Expecting RV 0, due to https://github.com/kubernetes/kubernetes/pull/123935 reverted to serving those requests from watch cache. // Set to 100, when WatchFromStorageWithoutResourceVersion is set to true. expectedWatchResourceVersion: 0, }, {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 10:12:02 UTC 2024 - 82.9K bytes - Viewed (0) -
cmd/kubeadm/app/apis/kubeadm/v1beta4/zz_generated.conversion.go
corev1 "k8s.io/api/core/v1" v1 "k8s.io/apimachinery/pkg/apis/meta/v1" conversion "k8s.io/apimachinery/pkg/conversion" runtime "k8s.io/apimachinery/pkg/runtime" bootstraptokenv1 "k8s.io/kubernetes/cmd/kubeadm/app/apis/bootstraptoken/v1" kubeadm "k8s.io/kubernetes/cmd/kubeadm/app/apis/kubeadm" ) func init() { localSchemeBuilder.Register(RegisterConversions) } // RegisterConversions adds conversion functions to the given scheme.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 16 08:34:39 UTC 2024 - 61.4K bytes - Viewed (0)