Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 67 for KUBERNETES (0.88 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top