Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 239 for Proxier (0.14 sec)

  1. staging/src/k8s.io/apimachinery/pkg/util/httpstream/spdy/roundtripper_test.go

    			expectedTLSConfig: &tls.Config{InsecureSkipVerify: true},
    			errMsg:            "SpdyRoundTripper: UpgradeTransport is mutually exclusive to TLSConfig or Proxier",
    		},
    		"Proxier with UpgradeTransport: error": {
    			proxier:           func(req *http.Request) (*url.URL, error) { return nil, nil },
    			upgradeTransport:  &http.Transport{TLSClientConfig: &tls.Config{InsecureSkipVerify: true}},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Oct 23 22:33:38 UTC 2023
    - 32.7K bytes
    - Viewed (0)
  2. cmd/kubemark/app/hollow_node.go

    	fs.BoolVar(&c.UseRealProxier, "use-real-proxier", true, "Has no effect.")
    	_ = fs.MarkDeprecated("use-real-proxier", "This flag is deprecated and will be removed in a future release.")
    	fs.DurationVar(&c.ProxierSyncPeriod, "proxier-sync-period", 30*time.Second, "Has no effect.")
    	_ = fs.MarkDeprecated("proxier-sync-period", "This flag is deprecated and will be removed in a future release.")
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 14 08:58:18 UTC 2024
    - 11K bytes
    - Viewed (0)
  3. cmd/kube-proxy/app/server_other.go

    // platformSetup is called after setting up the ProxyServer, but before creating the
    // Proxier. It should fill in any platform-specific fields and perform other
    // platform-specific setup.
    func (s *ProxyServer) platformSetup(ctx context.Context) error {
    	return unsupportedError
    }
    
    // platformCheckSupported is called immediately before creating the Proxier, to check
    // what IP families are supported (and whether the configuration is usable at all).
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 22 05:08:41 UTC 2024
    - 2.2K bytes
    - Viewed (0)
  4. pkg/proxy/healthcheck/healthcheck_test.go

    	// Should return 200 "OK" after processing update for both IPv4 and IPv6 proxiers.
    	hs.Updated(v1.IPv4Protocol)
    	hs.Updated(v1.IPv6Protocol)
    	fakeClock.Step(5 * time.Second)
    	testHTTPHandler(hsTest, http.StatusOK, t)
    
    	// If IPv6 proxier is late for an update but IPv4 proxier is not then updating IPv4 proxier should have no effect.
    	hs.QueuedUpdate(v1.IPv6Protocol)
    	fakeClock.Step(25 * time.Second)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Apr 26 13:27:41 UTC 2024
    - 21.4K bytes
    - Viewed (0)
  5. pkg/proxy/endpoint.go

    	ZoneHints() sets.Set[string]
    }
    
    // BaseEndpointInfo contains base information that defines an endpoint.
    // This could be used directly by proxier while processing endpoints,
    // or can be used for constructing a more specific EndpointInfo struct
    // defined by the proxier if needed.
    type BaseEndpointInfo struct {
    	// Cache this values to improve performance
    	ip   string
    	port int
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Dec 21 14:38:25 UTC 2023
    - 4.4K bytes
    - Viewed (0)
  6. pkg/proxy/types.go

    */
    
    package proxy
    
    import (
    	"fmt"
    
    	v1 "k8s.io/api/core/v1"
    	"k8s.io/apimachinery/pkg/types"
    	"k8s.io/kubernetes/pkg/proxy/config"
    )
    
    // Provider is the interface provided by proxier implementations.
    type Provider interface {
    	config.EndpointSliceHandler
    	config.ServiceHandler
    	config.NodeHandler
    	config.ServiceCIDRHandler
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Jan 21 14:28:37 UTC 2024
    - 1.7K bytes
    - Viewed (0)
  7. pkg/proxy/ipvs/proxier_test.go

    }
    
    func makeServiceMap(proxier *Proxier, allServices ...*v1.Service) {
    	for i := range allServices {
    		proxier.OnServiceAdd(allServices[i])
    	}
    
    	proxier.mu.Lock()
    	defer proxier.mu.Unlock()
    	proxier.servicesSynced = true
    }
    
    func makeEndpointSliceMap(proxier *Proxier, allEpSlices ...*discovery.EndpointSlice) {
    	for i := range allEpSlices {
    		proxier.OnEndpointSliceAdd(allEpSlices[i])
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Apr 27 01:31:57 UTC 2024
    - 186.8K bytes
    - Viewed (0)
  8. pkg/proxy/servicechangetracker_test.go

    		fake.addService(allServices[i])
    	}
    }
    
    func (proxier *FakeProxier) addService(service *v1.Service) {
    	proxier.serviceChanges.Update(nil, service)
    }
    
    func (proxier *FakeProxier) updateService(oldService *v1.Service, service *v1.Service) {
    	proxier.serviceChanges.Update(oldService, service)
    }
    
    func (proxier *FakeProxier) deleteService(service *v1.Service) {
    	proxier.serviceChanges.Update(service, nil)
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 33.7K bytes
    - Viewed (0)
  9. cmd/kubeadm/app/phases/addons/proxy/proxy_test.go

      namespace: kube-system
    ---
    apiVersion: rbac.authorization.k8s.io/v1
    kind: ClusterRoleBinding
    metadata:
      creationTimestamp: null
      name: kubeadm:node-proxier
    roleRef:
      apiGroup: rbac.authorization.k8s.io
      kind: ClusterRole
      name: system:node-proxier
    subjects:
    - kind: ServiceAccount
      name: kube-proxy
      namespace: kube-system
    ---
    apiVersion: rbac.authorization.k8s.io/v1
    kind: Role
    metadata:
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Feb 18 11:14:32 UTC 2024
    - 8.7K bytes
    - Viewed (0)
  10. pkg/proxy/kubemark/hollow_proxy.go

    				Mode:             proxyconfigapi.ProxyMode("fake"),
    				ConfigSyncPeriod: metav1.Duration{Duration: 30 * time.Second},
    				OOMScoreAdj:      ptr.To[int32](0),
    			},
    
    			Client:      client,
    			Proxier:     &FakeProxier{},
    			Broadcaster: broadcaster,
    			Recorder:    recorder,
    			NodeRef: &v1.ObjectReference{
    				Kind:      "Node",
    				Name:      nodeName,
    				UID:       types.UID(nodeName),
    				Namespace: "",
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 22 05:08:41 UTC 2024
    - 2.9K bytes
    - Viewed (0)
Back to top