Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 50 for netutils (0.38 sec)

  1. staging/src/k8s.io/apiextensions-apiserver/pkg/cmd/server/options/options.go

    	"k8s.io/apiserver/pkg/util/openapi"
    	"k8s.io/apiserver/pkg/util/proxy"
    	"k8s.io/apiserver/pkg/util/webhook"
    	scheme "k8s.io/client-go/kubernetes/scheme"
    	corev1 "k8s.io/client-go/listers/core/v1"
    	netutils "k8s.io/utils/net"
    )
    
    const defaultEtcdPathPrefix = "/registry/apiextensions.kubernetes.io"
    
    // CustomResourceDefinitionsServerOptions describes the runtime options of an apiextensions-apiserver.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 07 17:57:37 UTC 2024
    - 6K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apimachinery/pkg/util/net/util_test.go

    	"io"
    	"net"
    	"net/http"
    	"net/http/httptest"
    	"net/url"
    	"os"
    	"sync/atomic"
    	"syscall"
    	"testing"
    	"time"
    
    	"golang.org/x/net/http2"
    
    	netutils "k8s.io/utils/net"
    )
    
    func getIPNet(cidr string) *net.IPNet {
    	_, ipnet, _ := netutils.ParseCIDRSloppy(cidr)
    	return ipnet
    }
    
    func TestIPNetEqual(t *testing.T) {
    	testCases := []struct {
    		ipnet1 *net.IPNet
    		ipnet2 *net.IPNet
    		expect bool
    	}{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 20 19:02:55 UTC 2023
    - 4.3K bytes
    - Viewed (0)
  3. pkg/proxy/conntrack/cleanup.go

    */
    
    package conntrack
    
    import (
    	v1 "k8s.io/api/core/v1"
    	"k8s.io/apimachinery/pkg/util/sets"
    	"k8s.io/klog/v2"
    	"k8s.io/kubernetes/pkg/proxy"
    	proxyutil "k8s.io/kubernetes/pkg/proxy/util"
    	netutils "k8s.io/utils/net"
    )
    
    // CleanStaleEntries takes care of flushing stale conntrack entries for services and endpoints.
    func CleanStaleEntries(ct Interface, svcPortMap proxy.ServicePortMap,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Jan 15 18:09:05 UTC 2024
    - 5.2K bytes
    - Viewed (0)
  4. staging/src/k8s.io/apiserver/pkg/util/webhook/client.go

    	"k8s.io/apimachinery/pkg/runtime/serializer"
    	utilerrors "k8s.io/apimachinery/pkg/util/errors"
    	"k8s.io/apiserver/pkg/util/x509metrics"
    	"k8s.io/client-go/rest"
    	"k8s.io/utils/lru"
    	netutils "k8s.io/utils/net"
    )
    
    const (
    	defaultCacheSize = 200
    )
    
    // ClientConfig defines parameters required for creating a hook client.
    type ClientConfig struct {
    	Name     string
    	URL      string
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Jan 04 09:09:10 UTC 2024
    - 7.3K bytes
    - Viewed (0)
  5. pkg/controller/nodeipam/ipam/sync/sync_test.go

    	"k8s.io/klog/v2"
    	"k8s.io/klog/v2/ktesting"
    	"k8s.io/kubernetes/pkg/controller/nodeipam/ipam/cidrset"
    	"k8s.io/kubernetes/pkg/controller/nodeipam/ipam/test"
    	netutils "k8s.io/utils/net"
    
    	v1 "k8s.io/api/core/v1"
    )
    
    var (
    	_, clusterCIDRRange, _ = netutils.ParseCIDRSloppy("10.1.0.0/16")
    )
    
    type fakeEvent struct {
    	nodeName string
    	reason   string
    }
    
    type fakeAPIs struct {
    	aliasRange    *net.IPNet
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jul 05 23:39:52 UTC 2023
    - 7.6K bytes
    - Viewed (0)
  6. pkg/proxy/apis/config/v1alpha1/defaults.go

    	logsapi "k8s.io/component-base/logs/api/v1"
    	"k8s.io/kubernetes/pkg/cluster/ports"
    	"k8s.io/kubernetes/pkg/kubelet/qos"
    	proxyutil "k8s.io/kubernetes/pkg/proxy/util"
    	netutils "k8s.io/utils/net"
    	"k8s.io/utils/ptr"
    )
    
    func addDefaultingFuncs(scheme *kruntime.Scheme) error {
    	return RegisterDefaults(scheme)
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Oct 31 21:33:53 UTC 2023
    - 5.2K bytes
    - Viewed (0)
  7. pkg/controller/endpointslicemirroring/utils.go

    	"k8s.io/client-go/tools/cache"
    	"k8s.io/client-go/tools/leaderelection/resourcelock"
    	endpointsliceutil "k8s.io/endpointslice/util"
    	"k8s.io/kubernetes/pkg/apis/discovery/validation"
    	netutils "k8s.io/utils/net"
    )
    
    // addrTypePortMapKey is used to uniquely identify groups of endpoint ports and
    // address types.
    type addrTypePortMapKey string
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jul 11 18:08:12 UTC 2023
    - 8.8K bytes
    - Viewed (0)
  8. cmd/kubeadm/app/phases/certs/renewal/readwriter_test.go

    import (
    	"crypto"
    	"crypto/x509"
    	"fmt"
    	"net"
    	"os"
    	"path/filepath"
    	"testing"
    	"time"
    
    	"k8s.io/client-go/tools/clientcmd"
    	certutil "k8s.io/client-go/util/cert"
    	"k8s.io/client-go/util/keyutil"
    	netutils "k8s.io/utils/net"
    
    	kubeadmconstants "k8s.io/kubernetes/cmd/kubeadm/app/constants"
    	kubeconfigutil "k8s.io/kubernetes/cmd/kubeadm/app/util/kubeconfig"
    	"k8s.io/kubernetes/cmd/kubeadm/app/util/pkiutil"
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu May 30 15:17:24 UTC 2024
    - 9.5K bytes
    - Viewed (0)
  9. analysis/analysis-api-standalone/analysis-api-standalone-native/tests/org/jetbrains/kotlin/analysis/api/standalone/konan/fir/test/cases/session/builder/testUtils.kt

    Ilya Kirillov <******@****.***> 1699267786 +0100
    Registered: Wed Jun 12 09:53:16 UTC 2024
    - Last Modified: Thu Nov 16 13:31:53 UTC 2023
    - 1.5K bytes
    - Viewed (0)
  10. cmd/kubeadm/app/discovery/https/https.go

    See the License for the specific language governing permissions and
    limitations under the License.
    */
    
    package https
    
    import (
    	"io"
    	"net/http"
    	"time"
    
    	netutil "k8s.io/apimachinery/pkg/util/net"
    	"k8s.io/client-go/tools/clientcmd"
    	clientcmdapi "k8s.io/client-go/tools/clientcmd/api"
    
    	"k8s.io/kubernetes/cmd/kubeadm/app/discovery/file"
    )
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Nov 24 04:29:10 UTC 2022
    - 1.5K bytes
    - Viewed (0)
Back to top