- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 61 for given (0.16 sec)
-
cni/pkg/nodeagent/pod_cache.go
log.Debug("netns inode mismatch, using the new one") } p.addToCacheUnderLock(uid, workload) return workload.Netns } // Update the cache with the given uid and nspath. Return the Netns for the given uid. // If uid is already present, a cached Netns is returned, and the given nspath is ignored. func (p *podNetnsCache) Get(uid string) Netns { // lock current snapshot pod map p.mu.RLock() defer p.mu.RUnlock()
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 4.5K bytes - Viewed (0) -
istioctl/pkg/admin/istiodconfig_test.go
want *istiodConfigLog }{ { name: "given --reset flag return reset command", args: args{ ctrzClient: ctrzClient, reset: true, outputLogLevel: "", stackTraceLevel: "", outputFormat: "", }, want: &istiodConfigLog{state: &resetState{ client: ctrzClient, }}, }, { name: "given --level flag return outputLogLevel command", args: args{
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Jun 15 15:02:17 GMT 2023 - 6.2K bytes - Viewed (0) -
cmd/net.go
ipList = set.NewStringSet() for _, ip := range mustGetLocalIPs() { if ip.To4() == nil { ipList.Add(ip.String()) } } return } // getHostIP returns IP address of given host. func getHostIP(host string) (ipList set.StringSet, err error) { addrs, err := globalDNSCache.LookupHost(GlobalContext, host) if err != nil { return ipList, err } ipList = set.NewStringSet()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Mar 26 15:00:38 GMT 2024 - 9.3K bytes - Viewed (0) -
internal/http/dial_dnscache.go
// function. LookupHost may implement an internal DNS caching implementation, lookupHost // input if nil then net.DefaultResolver.LookupHost is used. // // It dials one by one and returns first connected `net.Conn`. // If it fails to dial all IPs from cache it returns first error. If no baseDialFunc // is given, it sets default dial function. //
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Jul 03 19:30:51 GMT 2023 - 2.6K bytes - Viewed (0) -
internal/bpool/bpool.go
// BytePoolCap implements a leaky pool of []byte in the form of a bounded channel. type BytePoolCap struct { c chan []byte w int wcap int } // NewBytePoolCap creates a new BytePool bounded to the given maxSize, with new // byte arrays sized based on width. func NewBytePoolCap(maxSize uint64, width int, capwidth int) (bp *BytePoolCap) { if capwidth > 0 && capwidth < 64 {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 19 16:44:59 GMT 2024 - 2.6K bytes - Viewed (0) -
internal/event/targetidset.go
func (set TargetIDSet) add(targetID TargetID) { set[targetID] = struct{}{} } // Union - returns union with given set as new set. func (set TargetIDSet) Union(sset TargetIDSet) TargetIDSet { nset := set.Clone() for k := range sset { nset.add(k) } return nset } // Difference - returns difference with given set as new set. func (set TargetIDSet) Difference(sset TargetIDSet) TargetIDSet { nset := NewTargetIDSet()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 1.9K bytes - Viewed (0) -
cmd/bitrot.go
logger.CriticalIf(GlobalContext, errors.New("Unsupported bitrot algorithm")) return nil } } // Available reports whether the given algorithm is available. func (a BitrotAlgorithm) Available() bool { _, ok := bitrotAlgorithms[a] return ok } // String returns the string identifier for a given bitrot algorithm. // If the algorithm is not supported String panics. func (a BitrotAlgorithm) String() string {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Jan 30 20:43:25 GMT 2024 - 7.6K bytes - Viewed (0) -
internal/kms/key-manager.go
) // KeyManager is the generic interface that handles KMS key operations type KeyManager interface { // CreateKey creates a new key at the KMS with the given key ID. CreateKey(ctx context.Context, keyID string) error // DeleteKey deletes a key at the KMS with the given key ID. // Please note that is a dangerous operation. // Once a key has been deleted all data that has been encrypted with it cannot be decrypted
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Mar 01 21:09:42 GMT 2024 - 1.9K bytes - Viewed (0) -
cmd/typed-errors.go
// errServerTimeMismatch - server times are too far apart. var errServerTimeMismatch = errors.New("Server times are too far apart") // errInvalidRange - returned when given range value is not valid. var errInvalidRange = errors.New("Invalid range") // errInvalidRangeSource - returned when given range value exceeds // the source object size. var errInvalidRangeSource = errors.New("Range specified exceeds source object size")
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 5.3K bytes - Viewed (0) -
cni/pkg/repair/netns.go
if len(routes) == 0 { return nil, fmt.Errorf("no routes found for %s", ip) } linkIndex := routes[0].LinkIndex return netlink.LinkByIndex(linkIndex) } // getPodNetNs finds the network namespace for a given pod. There is not a great way to do this. Network namespaces live // under the procfs, /proc/<pid>/ns/net. In majority of cases, this is not used directly, but is rather bind mounted to
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed Dec 20 22:14:13 GMT 2023 - 4.8K bytes - Viewed (0)