- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 44 for utilnet (1.35 sec)
-
pkg/proxy/conntrack/conntrack.go
limitations under the License. */ package conntrack import ( "fmt" "strconv" "strings" v1 "k8s.io/api/core/v1" "k8s.io/klog/v2" "k8s.io/utils/exec" utilnet "k8s.io/utils/net" ) // Interface for dealing with conntrack type Interface interface { // ClearEntriesForIP deletes conntrack entries for connections of the given // protocol, to the given IP.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jan 15 18:09:05 UTC 2024 - 5.5K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/proxy/upgradeaware.go
if h.AppendLocationPath { location.Path = singleJoiningSlash(h.Location.Path, location.Path) } } clone := utilnet.CloneRequest(req) // Only append X-Forwarded-For in the upgrade path, since httputil.NewSingleHostReverseProxy // handles this in the non-upgrade path. utilnet.AppendForwardedForHeader(clone) klog.V(6).Infof("Connecting to backend proxy (direct dial) %s\n Headers: %v", &location, clone.Header)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Mar 04 19:10:30 UTC 2024 - 19.6K bytes - Viewed (0) -
cmd/kube-apiserver/app/options/options.go
limitations under the License. */ // Package options contains flags and options for initializing an apiserver package options import ( "net" "strings" "time" v1 "k8s.io/api/core/v1" utilnet "k8s.io/apimachinery/pkg/util/net" cliflag "k8s.io/component-base/cli/flag" api "k8s.io/kubernetes/pkg/apis/core" "k8s.io/kubernetes/pkg/cluster/ports"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Apr 27 12:19:56 UTC 2024 - 6.5K bytes - Viewed (0) -
pkg/controlplane/apiserver/config.go
func CreateProxyTransport() *http.Transport { var proxyDialerFn utilnet.DialFunc // Proxying to pods and services is IP-based... don't expect to be able to verify the hostname proxyTLSClientConfig := &tls.Config{InsecureSkipVerify: true} proxyTransport := utilnet.SetTransportDefaults(&http.Transport{ DialContext: proxyDialerFn, TLSClientConfig: proxyTLSClientConfig, })
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 07 17:57:37 UTC 2024 - 14.9K bytes - Viewed (0) -
pkg/scheduler/extender.go
cfg.Insecure = true } } tlsConfig, err := restclient.TLSConfigFor(&cfg) if err != nil { return nil, err } if tlsConfig != nil { return utilnet.SetTransportDefaults(&http.Transport{ TLSClientConfig: tlsConfig, }), nil } return utilnet.SetTransportDefaults(&http.Transport{}), nil } // NewHTTPExtender creates an HTTPExtender object.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 26 19:07:19 UTC 2024 - 13.4K bytes - Viewed (0) -
pkg/kubeapiserver/authorizer/config.go
limitations under the License. */ package authorizer import ( "context" "fmt" "os" "strings" "time" utilerrors "k8s.io/apimachinery/pkg/util/errors" utilnet "k8s.io/apimachinery/pkg/util/net" "k8s.io/apimachinery/pkg/util/sets" "k8s.io/apimachinery/pkg/util/wait" authzconfig "k8s.io/apiserver/pkg/apis/apiserver" "k8s.io/apiserver/pkg/apis/apiserver/load"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 21:22:55 UTC 2024 - 8K bytes - Viewed (0) -
pkg/registry/core/node/strategy.go
"k8s.io/apimachinery/pkg/api/errors" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" "k8s.io/apimachinery/pkg/fields" "k8s.io/apimachinery/pkg/labels" "k8s.io/apimachinery/pkg/runtime" "k8s.io/apimachinery/pkg/types" utilnet "k8s.io/apimachinery/pkg/util/net" "k8s.io/apimachinery/pkg/util/validation/field" "k8s.io/apiserver/pkg/registry/generic" pkgstorage "k8s.io/apiserver/pkg/storage" "k8s.io/apiserver/pkg/storage/names"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 13 23:06:39 UTC 2024 - 9K bytes - Viewed (0) -
cmd/kube-apiserver/app/options/validation_test.go
See the License for the specific language governing permissions and limitations under the License. */ package options import ( "net" "testing" utilnet "k8s.io/apimachinery/pkg/util/net" apiserveroptions "k8s.io/apiserver/pkg/server/options" utilfeature "k8s.io/apiserver/pkg/util/feature" featuregatetesting "k8s.io/component-base/featuregate/testing"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 11.4K bytes - Viewed (0) -
pkg/registry/core/service/portallocator/storage/storage_test.go
See the License for the specific language governing permissions and limitations under the License. */ package storage import ( "context" "fmt" "strings" "testing" utilnet "k8s.io/apimachinery/pkg/util/net" "k8s.io/apiserver/pkg/registry/generic" "k8s.io/apiserver/pkg/storage" etcd3testing "k8s.io/apiserver/pkg/storage/etcd3/testing" "k8s.io/apiserver/pkg/storage/storagebackend/factory"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 08 07:15:02 UTC 2024 - 8.1K bytes - Viewed (0) -
pkg/proxy/endpointslicecache.go
"k8s.io/apimachinery/pkg/util/sets" utilfeature "k8s.io/apiserver/pkg/util/feature" "k8s.io/client-go/tools/events" "k8s.io/klog/v2" "k8s.io/kubernetes/pkg/features" proxyutil "k8s.io/kubernetes/pkg/proxy/util" utilnet "k8s.io/utils/net" ) // EndpointSliceCache is used as a cache of EndpointSlice information. type EndpointSliceCache struct { // lock protects trackerByServiceMap. lock sync.Mutex
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 29 21:07:21 UTC 2024 - 11.7K bytes - Viewed (0)