Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 147 for onetmp (0.21 sec)

  1. pilot/pkg/serviceregistry/mock/discovery.go

    	// external services have no instances
    	if service.External() {
    		return ""
    	}
    	ipa, ise := netip.ParseAddr(service.DefaultAddress)
    	if ise != nil {
    		return ""
    	}
    	ip := ipa.As4()
    	ip[2] = byte(1)
    	ip[3] = byte(version)
    	return netip.AddrFrom4(ip).String()
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Aug 07 18:40:05 UTC 2023
    - 3.7K bytes
    - Viewed (0)
  2. pkg/controller/servicecidrs/servicecidrs_controller.go

    	for _, cidr := range serviceCIDR.Spec.CIDRs {
    		if prefix, err := netip.ParsePrefix(cidr); err == nil { // if is empty err will not be nil
    			c.tree.WalkPath(prefix, func(k netip.Prefix, v sets.Set[string]) bool {
    				serviceCIDRs.Insert(v.UnsortedList()...)
    				return false
    			})
    			c.tree.WalkPrefix(prefix, func(k netip.Prefix, v sets.Set[string]) bool {
    				serviceCIDRs.Insert(v.UnsortedList()...)
    				return false
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 18K bytes
    - Viewed (0)
  3. src/net/ipsock_posix.go

    		}
    		return &sa, nil
    	}
    	return nil, &AddrError{Err: "invalid address family", Addr: ip.String()}
    }
    
    func addrPortToSockaddrInet4(ap netip.AddrPort) (syscall.SockaddrInet4, error) {
    	// ipToSockaddrInet4 has special handling here for zero length slices.
    	// We do not, because netip has no concept of a generic zero IP address.
    	addr := ap.Addr()
    	if !addr.Is4() {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 29 17:58:53 UTC 2024
    - 8.6K bytes
    - Viewed (0)
  4. pkg/test/framework/components/istio/ingress/interface.go

    // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
    // See the License for the specific language governing permissions and
    // limitations under the License.
    
    package ingress
    
    import (
    	"net/netip"
    
    	"istio.io/istio/pkg/test/framework/components/cluster"
    	"istio.io/istio/pkg/test/framework/components/echo"
    )
    
    type Instances []Instance
    
    func (i Instances) Callers() echo.Callers {
    	var out echo.Callers
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Feb 29 17:13:34 UTC 2024
    - 2.3K bytes
    - Viewed (0)
  5. staging/src/k8s.io/apiserver/pkg/cel/ip.go

    limitations under the License.
    */
    
    package cel
    
    import (
    	"fmt"
    	"math"
    	"net/netip"
    	"reflect"
    
    	"github.com/google/cel-go/cel"
    	"github.com/google/cel-go/common/types"
    	"github.com/google/cel-go/common/types/ref"
    )
    
    // IP provides a CEL representation of an IP address.
    type IP struct {
    	netip.Addr
    }
    
    var (
    	IPType = cel.OpaqueType("net.IP")
    )
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Dec 15 11:02:33 UTC 2023
    - 2.1K bytes
    - Viewed (0)
  6. tools/istio-iptables/pkg/config/validation.go

    // See the License for the specific language governing permissions and
    // limitations under the License.
    
    package config
    
    import (
    	"fmt"
    	"net/netip"
    )
    
    const (
    	// Due to implementation constraints, we have to impose a limit on the
    	// number of owner groups whose outgoing traffic should be redirected
    	// to Envoy.
    	//
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jan 11 02:38:28 UTC 2024
    - 2K bytes
    - Viewed (0)
  7. pkg/api/service/warnings.go

    WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
    See the License for the specific language governing permissions and
    limitations under the License.
    */
    
    package service
    
    import (
    	"fmt"
    	"net/netip"
    
    	"k8s.io/apimachinery/pkg/util/validation/field"
    	api "k8s.io/kubernetes/pkg/apis/core"
    	"k8s.io/kubernetes/pkg/apis/core/helper"
    )
    
    func GetWarningsForService(service, oldService *api.Service) []string {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jul 26 22:57:57 UTC 2023
    - 4.2K bytes
    - Viewed (0)
  8. pilot/pkg/serviceregistry/kube/controller/ambient/waypoints.go

    		ServiceAccounts: slices.Sort(serviceAccounts),
    	}
    }
    
    func getGatewayAddrs(gw *v1beta1.Gateway) []netip.Addr {
    	// Currently, we only look at one address. Probably this should be made more robust
    	ip, err := netip.ParseAddr(gw.Status.Addresses[0].Value)
    	if err == nil {
    		return []netip.Addr{ip}
    	}
    	log.Errorf("Unable to parse IP address in status of %v/%v/%v", gvk.KubernetesGateway, gw.Namespace, gw.Name)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Jun 12 18:02:28 UTC 2024
    - 11.1K bytes
    - Viewed (0)
  9. src/net/tcpsock.go

    //
    // If a is nil, a zero value is returned.
    func (a *TCPAddr) AddrPort() netip.AddrPort {
    	if a == nil {
    		return netip.AddrPort{}
    	}
    	na, _ := netip.AddrFromSlice(a.IP)
    	na = na.WithZone(a.Zone)
    	return netip.AddrPortFrom(na, uint16(a.Port))
    }
    
    // Network returns the address's network name, "tcp".
    func (a *TCPAddr) Network() string { return "tcp" }
    
    func (a *TCPAddr) String() string {
    	if a == nil {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Apr 15 03:10:07 UTC 2024
    - 13.7K bytes
    - Viewed (0)
  10. .gitignore

    .idea/csv-plugin.xml
    .idea/libraries-with-intellij-classes.xml
    .idea/misc.xml
    .idea/protoeditor.xml
    node_modules/
    .rpt2_cache/
    libraries/tools/kotlin-test-js-runner/lib/
    local.properties
    buildSrcTmp/
    distTmp/
    outTmp/
    /test.output
    /kotlin-native/dist
    kotlin-ide/
    .kotlin/
    Registered: Wed Jun 12 09:53:16 UTC 2024
    - Last Modified: Wed Feb 21 15:38:02 UTC 2024
    - 1.2K bytes
    - Viewed (0)
Back to top