Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 1,946 for proxier (0.16 sec)

  1. pkg/proxy/metaproxier/meta_proxier.go

    // proxy rules.
    func (proxier *metaProxier) Sync() {
    	proxier.ipv4Proxier.Sync()
    	proxier.ipv6Proxier.Sync()
    }
    
    // SyncLoop runs periodic work.  This is expected to run as a
    // goroutine or as the main loop of the app.  It does not return.
    func (proxier *metaProxier) SyncLoop() {
    	go proxier.ipv6Proxier.SyncLoop() // Use go-routine here!
    	proxier.ipv4Proxier.SyncLoop()    // never returns
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Jan 21 14:28:37 UTC 2024
    - 5.9K bytes
    - Viewed (0)
  2. cmd/kube-proxy/app/server_windows.go

    	return
    }
    
    // createProxier creates the proxy.Provider
    func (s *ProxyServer) createProxier(ctx context.Context, config *proxyconfigapi.KubeProxyConfiguration, dualStackMode, initOnly bool) (proxy.Provider, error) {
    	if initOnly {
    		return nil, fmt.Errorf("--init-only is not implemented on Windows")
    	}
    
    	var proxier proxy.Provider
    	var err error
    
    	if dualStackMode {
    		proxier, err = winkernel.NewDualStackProxier(
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Apr 26 13:27:41 UTC 2024
    - 3.9K bytes
    - Viewed (0)
  3. pkg/proxy/healthcheck/proxier_health.go

    	hs.lastUpdatedMap[ipFamily] = hs.clock.Now()
    }
    
    // QueuedUpdate should be called when the proxier receives a Service or Endpoints event
    // from API Server containing information that requires updating service rules. It
    // indicates that the proxier for the given IP family has received changes but has not
    // yet pushed them to its backend. If the proxier does not call Updated within the
    // healthTimeout time then it will be considered unhealthy.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Oct 16 10:41:18 UTC 2023
    - 8K bytes
    - Viewed (0)
  4. 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)
  5. cluster/addons/kube-proxy/kube-proxy-rbac.yaml

      labels:
        addonmanager.kubernetes.io/mode: Reconcile
    subjects:
      - kind: ServiceAccount
        name: kube-proxy
        namespace: kube-system
    roleRef:
      kind: ClusterRole
      name: system:node-proxier
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Jun 03 18:46:08 UTC 2019
    - 488 bytes
    - Viewed (0)
  6. plugin/pkg/auth/authorizer/rbac/bootstrappolicy/testdata/cluster-role-bindings.yaml

        creationTimestamp: null
        labels:
          kubernetes.io/bootstrapping: rbac-defaults
        name: system:node-proxier
      roleRef:
        apiGroup: rbac.authorization.k8s.io
        kind: ClusterRole
        name: system:node-proxier
      subjects:
      - apiGroup: rbac.authorization.k8s.io
        kind: User
        name: system:kube-proxy
    - apiVersion: rbac.authorization.k8s.io/v1
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Sep 11 19:01:47 UTC 2020
    - 5.7K bytes
    - Viewed (0)
  7. pkg/proxy/types.go

    limitations under the License.
    */
    
    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)
  8. 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)
  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