- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 19 for proxyNode (0.24 sec)
-
platforms/core-configuration/stdlib-serialization-codecs/src/main/kotlin/org/gradle/internal/serialize/codecs/stdlib/ProxyCodec.kt
import org.gradle.internal.serialize.graph.readClassArray import org.gradle.internal.serialize.graph.writeClassArray import java.lang.reflect.InvocationHandler import java.lang.reflect.Proxy object ProxyCodec : EncodingProducer, Decoding { override fun encodingForType(type: Class<*>): Encoding? = ProxyEncoding.takeIf { Proxy.isProxyClass(type) } override suspend fun ReadContext.decode(): Any {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Jun 04 18:56:44 UTC 2024 - 1.7K bytes - Viewed (0) -
pkg/proxy/apis/config/types.go
// will exit with an error. type ProxyMode string const ( ProxyModeIPTables ProxyMode = "iptables" ProxyModeIPVS ProxyMode = "ipvs" ProxyModeNFTables ProxyMode = "nftables" ProxyModeKernelspace ProxyMode = "kernelspace" ) func (m *ProxyMode) Set(s string) error { *m = ProxyMode(s) return nil } func (m *ProxyMode) String() string { if m != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 13:25:06 UTC 2024 - 13K bytes - Viewed (0) -
pkg/proxy/apis/config/validation/validation_test.go
expectedErrs: field.ErrorList{field.Invalid(newPath.Child("ProxyMode"), "kernelspace", "must be iptables, ipvs, nftables or blank (blank means the best-available proxy [currently iptables])")}, }, "invalid mode non-existent": { mode: kubeproxyconfig.ProxyMode("non-existing"),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 25 14:24:16 UTC 2024 - 33.3K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/httpstream/spdy/connection_test.go
var backendUrl string select { case err := <-errCh: t.Fatalf("server: error listening: %v", err) case backendUrl = <-backendUrlChan: } proxyDone := make(chan struct{}, 1) proxyUrlChan := make(chan string) go runProxy(t, backendUrl, proxyUrlChan, proxyDone, errCh) var proxyUrl string select { case err := <-errCh: t.Fatalf("error listening: %v", err) case proxyUrl = <-proxyUrlChan: }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 01 11:58:57 UTC 2023 - 7.9K bytes - Viewed (0) -
pkg/proxy/apis/config/validation/validation.go
} return allErrs } func validateProxyMode(mode kubeproxyconfig.ProxyMode, fldPath *field.Path) field.ErrorList { if runtime.GOOS == "windows" { return validateProxyModeWindows(mode, fldPath) } return validateProxyModeLinux(mode, fldPath) } func validateProxyModeLinux(mode kubeproxyconfig.ProxyMode, fldPath *field.Path) field.ErrorList { validModes := sets.New[string](
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 13:25:06 UTC 2024 - 14.6K bytes - Viewed (0) -
platforms/core-configuration/configuration-cache/src/main/kotlin/org/gradle/internal/cc/impl/services/IsolatedActionCodecsFactory.kt
import org.gradle.internal.serialize.codecs.core.jos.JavaSerializationEncodingLookup import org.gradle.internal.serialize.codecs.core.unsupportedTypes import org.gradle.internal.serialize.codecs.stdlib.ProxyCodec import org.gradle.internal.serialize.graph.codecs.BeanCodec import org.gradle.internal.serialize.graph.codecs.Bindings import org.gradle.internal.serialize.graph.codecs.BindingsBuilder
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Sat Jun 08 11:29:30 UTC 2024 - 4.9K bytes - Viewed (0) -
cmd/kube-proxy/app/server_other.go
return nil, unsupportedError } // platformCleanup removes stale kube-proxy rules that can be safely removed. func platformCleanup(ctx context.Context, mode proxyconfigapi.ProxyMode, cleanupAndExit bool) error { return unsupportedError
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 22 05:08:41 UTC 2024 - 2.2K bytes - Viewed (0) -
pkg/proxy/kubemark/hollow_proxy.go
recorder events.EventRecorder, ) *HollowProxy { return &HollowProxy{ ProxyServer: &proxyapp.ProxyServer{ Config: &proxyconfigapi.KubeProxyConfiguration{ Mode: proxyconfigapi.ProxyMode("fake"), ConfigSyncPeriod: metav1.Duration{Duration: 30 * time.Second}, OOMScoreAdj: ptr.To[int32](0), }, Client: client, Proxier: &FakeProxier{}, Broadcaster: broadcaster,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 22 05:08:41 UTC 2024 - 2.9K bytes - Viewed (0) -
cmd/kube-proxy/app/server_windows.go
} return proxier, nil } // platformCleanup removes stale kube-proxy rules that can be safely removed. func platformCleanup(ctx context.Context, mode proxyconfigapi.ProxyMode, cleanupAndExit bool) error { if cleanupAndExit { return errors.New("--cleanup-and-exit is not implemented on Windows") } return nil
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Apr 26 13:27:41 UTC 2024 - 3.9K bytes - Viewed (0) -
pkg/proxy/apis/config/v1alpha1/zz_generated.conversion.go
out.MetricsBindAddress = in.MetricsBindAddress out.BindAddressHardFail = in.BindAddressHardFail out.EnableProfiling = in.EnableProfiling out.ShowHiddenMetricsForVersion = in.ShowHiddenMetricsForVersion out.Mode = config.ProxyMode(in.Mode) if err := Convert_v1alpha1_KubeProxyIPTablesConfiguration_To_config_KubeProxyIPTablesConfiguration(&in.IPTables, &out.IPTables, s); err != nil { return err }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 31 21:33:53 UTC 2023 - 22.3K bytes - Viewed (0)