- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 50 for forwardly (0.17 sec)
-
cmd/metacache-entries.go
IsDir: true, Bucket: bucket, Name: currPrefix, }) } } return objects } // forwardTo will truncate m so only entries that are s or after is in the list. func (m *metaCacheEntriesSorted) forwardTo(s string) { if s == "" { return } idx := sort.Search(len(m.o), func(i int) bool { return m.o[i].name >= s }) if m.reuse {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 19 16:43:43 GMT 2024 - 23.2K bytes - Viewed (0) -
istioctl/pkg/dashboard/dashboard.go
if err != nil { return fmt.Errorf("could not build port forwarder for %s: %v", flavor, err) } if err = fw.Start(); err != nil { fw.Close() // Try the next port continue } // Close the port forwarder when the command is terminated. ClosePortForwarderOnInterrupt(fw) log.Debugf(fmt.Sprintf("port-forward to %s pod ready", flavor))
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Mon Apr 15 01:29:35 GMT 2024 - 20.5K bytes - Viewed (0) -
internal/cachevalue/cache.go
t.Once.Do(func() { t.ttl = ttl t.updateFn = update t.opts = opts }) } // Get will return a cached value or fetch a new one. // Tf the Update function returns an error the value is forwarded as is and not cached. func (t *Cache[T]) Get() (T, error) { v := t.valErr.Load() ttl := t.ttl vTime := t.lastUpdateMs.Load() tNow := time.Now().UnixMilli() if v != nil && tNow-vTime < ttl.Milliseconds() {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Mar 01 16:00:42 GMT 2024 - 4.2K bytes - Viewed (0) -
src/archive/zip/struct.go
// [ZIP specification]: https://support.pkware.com/pkzip/appnote type FileHeader struct { // Name is the name of the file. // // It must be a relative path, not start with a drive letter (such as "C:"), // and must use forward slashes instead of back slashes. A trailing slash // indicates that this file is a directory and should have no data. Name string // Comment is any arbitrary user-defined string shorter than 64KiB. Comment string
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Fri Oct 13 18:36:46 GMT 2023 - 12.1K bytes - Viewed (0) -
istioctl/pkg/multixds/gather.go
) if options.XdsViaAgents { responses, err = queryDebugSynczViaAgents(all, dr, istioNamespace, kubeClient, centralOpts, options) } else { // Self-administered case. Find all Istiods in revision using K8s, port-forward and call each in turn responses, err = queryEachShard(all, dr, istioNamespace, kubeClient, centralOpts) } if err != nil { if _, ok := err.(ControlPlaneNotFoundError); ok {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 08 08:38:19 GMT 2024 - 13.6K bytes - Viewed (0) -
cmd/endpoint-ellipses.go
var err error setIndexes, err = getSetIndexes(args, []uint64{uint64(len(args))}, setDriveCount, nil) if err != nil { return nil, err } } else { // We are in FS setup, proceed forward. setIndexes = [][]uint64{{uint64(len(args))}} } s := endpointSet{ endpoints: args, setIndexes: setIndexes, } setArgs = s.Get() } else {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 15:54:03 GMT 2024 - 14.7K bytes - Viewed (0) -
istioctl/pkg/writer/envoy/configdump/listener.go
} } return fmt.Sprintf("Inline Route: %s", strings.Join(vhosts, "; ")) } // If this is a route that matches everything and forwards to a cluster, just report the cluster. func getMatchAllCluster(er *route.RouteConfiguration) string { if len(er.GetVirtualHosts()) != 1 { return "" } vh := er.GetVirtualHosts()[0]
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed Nov 29 12:37:14 GMT 2023 - 18.1K bytes - Viewed (0) -
src/archive/zip/reader.go
} if zipinsecurepath.Value() == "0" { for _, f := range r.File { if f.Name == "" { // Zip permits an empty file name field. continue } // The zip specification states that names must use forward slashes, // so consider any backslashes in the name insecure. if !filepath.IsLocal(f.Name) || strings.Contains(f.Name, `\`) { zipinsecurepath.IncNonDefault() return ErrInsecurePath } } }
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Fri Oct 13 18:36:46 GMT 2023 - 27.7K bytes - Viewed (0) -
internal/handlers/proxy.go
) var ( // De-facto standard header keys. xForwardedFor = http.CanonicalHeaderKey("X-Forwarded-For") xForwardedHost = http.CanonicalHeaderKey("X-Forwarded-Host") xForwardedPort = http.CanonicalHeaderKey("X-Forwarded-Port") xForwardedProto = http.CanonicalHeaderKey("X-Forwarded-Proto") xForwardedScheme = http.CanonicalHeaderKey("X-Forwarded-Scheme") xRealIP = http.CanonicalHeaderKey("X-Real-IP") ) var (
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Dec 22 00:56:55 GMT 2023 - 5.1K bytes - Viewed (0) -
internal/handlers/proxy_test.go
{xForwardedScheme, "http", "http"}, {xForwardedScheme, "HTTP", "http"}, {forwarded, `For="[2001:db8:cafe::17]:4711`, ""}, // No proto {forwarded, `for=192.0.2.43, for=198.51.100.17;proto=https`, ""}, // Multiple params, will be empty. {forwarded, `for=172.32.10.15; proto=https;by=127.0.0.1;`, "https"}, // Space before proto {forwarded, `for=192.0.2.60;proto=http;by=203.0.113.43`, "http"}, // Multiple params }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Dec 22 00:56:55 GMT 2023 - 3.2K bytes - Viewed (0)