- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 2,924 for proxier (0.26 sec)
-
pkg/proxy/ipvs/ipset.go
) // IPSetVersioner can query the current ipset version. type IPSetVersioner interface { // returns "X.Y" GetVersion() (string, error) } // IPSet wraps util/ipset which is used by IPVS proxier. type IPSet struct { utilipset.IPSet // activeEntries is the current active entries of the ipset. activeEntries sets.Set[string] // handle is the util ipset interface handle. handle utilipset.Interface }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Dec 19 01:20:51 UTC 2023 - 7.3K bytes - Viewed (0) -
plugin/pkg/auth/authorizer/rbac/bootstrappolicy/policy.go
"/.well-known/openid-configuration", "/.well-known/openid-configuration/", "/openid/v1/jwks", "/openid/v1/jwks/", ).RuleOrDie(), }, }) // node-proxier role is used by kube-proxy. nodeProxierRules := []rbacv1.PolicyRule{ rbacv1helpers.NewRule("list", "watch").Groups(legacyGroup).Resources("services", "endpoints").RuleOrDie(),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 08 19:25:10 UTC 2024 - 34.4K bytes - Viewed (0) -
pkg/proxy/endpointschangetracker_test.go
"k8s.io/apimachinery/pkg/util/sets" "k8s.io/utils/ptr" ) func (proxier *FakeProxier) addEndpointSlice(slice *discovery.EndpointSlice) { proxier.endpointsChanges.EndpointSliceUpdate(slice, false) } func (proxier *FakeProxier) updateEndpointSlice(oldSlice, slice *discovery.EndpointSlice) { proxier.endpointsChanges.EndpointSliceUpdate(slice, false) } func (proxier *FakeProxier) deleteEndpointSlice(slice *discovery.EndpointSlice) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Dec 21 14:44:08 UTC 2023 - 79.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/egressselector/egress_selector_test.go
} return s.directDialerCalled, nil } type fakeProxyServerConnector struct { connectorErr bool proxierErr bool } func (f *fakeProxyServerConnector) connect(context.Context) (proxier, error) { if f.connectorErr { return nil, fmt.Errorf("fake error") } return &fakeProxier{err: f.proxierErr}, nil } type fakeProxier struct { err bool }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jan 26 22:41:29 UTC 2023 - 12.3K bytes - Viewed (0) -
pkg/proxy/iptables/proxier_test.go
Port: port, Protocol: protocol, } } 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 } type endpointExpectation struct { endpoint string isLocal bool }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 21 14:39:54 UTC 2024 - 249.9K bytes - Viewed (1) -
cmd/kubeadm/app/constants/constants.go
NodeBootstrapTokenAuthGroup = "system:bootstrappers:kubeadm:default-node-token" // KubeProxyClusterRoleName sets the name for the kube-proxy ClusterRole KubeProxyClusterRoleName = "system:node-proxier" // NodeBootstrapperClusterRoleName defines the name of the auto-bootstrapped ClusterRole for letting someone post a CSR NodeBootstrapperClusterRoleName = "system:node-bootstrapper"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jun 01 03:36:35 UTC 2024 - 32.4K bytes - Viewed (0) -
pkg/proxy/apis/config/types.go
// in an immediate IPVS resync. MinSyncPeriod metav1.Duration // scheduler is the IPVS scheduler to use Scheduler string // excludeCIDRs is a list of CIDRs which the ipvs proxier should not touch // when cleaning up ipvs services. ExcludeCIDRs []string // strictARP configures arp_ignore and arp_announce to avoid answering ARP queries // from kube-ipvs0 interface StrictARP bool
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 13:25:06 UTC 2024 - 13K bytes - Viewed (0) -
cluster/addons/fluentd-gcp/fluentd-gcp-configmap-old.yaml
time_format %m%d %H:%M:%S.%N path /var/log/kubelet.log pos_file /var/log/gcp-kubelet.log.pos tag kubelet </source> # Example: # I1118 21:26:53.975789 6 proxier.go:1096] Port "nodePort for kube-system/default-http-backend:http" (:31429/tcp) was open before and is still needed <source> @type tail format multiline multiline_flush_interval 5s
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Nov 26 07:09:07 UTC 2018 - 16.3K bytes - Viewed (0) -
cluster/addons/fluentd-gcp/fluentd-gcp-configmap.yaml
time_format %m%d %H:%M:%S.%N path /var/log/kubelet.log pos_file /var/log/gcp-kubelet.log.pos tag kubelet </source> # Example: # I1118 21:26:53.975789 6 proxier.go:1096] Port "nodePort for kube-system/default-http-backend:http" (:31429/tcp) was open before and is still needed <source> @type tail format multiline multiline_flush_interval 5s
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Nov 26 07:09:07 UTC 2018 - 18.3K bytes - Viewed (0) -
plugin/pkg/auth/authorizer/rbac/bootstrappolicy/testdata/cluster-roles.yaml
metadata: annotations: rbac.authorization.kubernetes.io/autoupdate: "true" creationTimestamp: null labels: kubernetes.io/bootstrapping: rbac-defaults name: system:node-proxier rules: - apiGroups: - "" resources: - endpoints - services verbs: - list - watch - apiGroups: - "" resources: - nodes
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 18 08:11:08 UTC 2023 - 24.1K bytes - Viewed (0)