- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 82 for Miller (0.16 sec)
-
cmd/metacache-set.go
// Sanity check, should not happen. o.FilterPrefix = "" } } // filter will apply the options and return the number of objects requested by the limit. // Will return io.EOF if there are no more entries with the same filter. // The last entry can be used as a marker to resume the listing. func (r *metacacheReader) filter(o listPathOptions) (entries metaCacheEntriesSorted, err error) { // Forward to prefix, if any
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Apr 26 19:52:52 GMT 2024 - 30.4K bytes - Viewed (0) -
istioctl/pkg/proxyconfig/proxyconfig.go
clusterConfigCmd.PersistentFlags().StringVar(&fqdn, "fqdn", "", "Filter clusters by substring of Service FQDN field") clusterConfigCmd.PersistentFlags().StringVar(&direction, "direction", "", "Filter clusters by Direction field") clusterConfigCmd.PersistentFlags().StringVar(&subset, "subset", "", "Filter clusters by substring of Subset field") clusterConfigCmd.PersistentFlags().IntVar(&port, "port", 0, "Filter clusters by Port field")
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Tue Apr 16 03:28:36 GMT 2024 - 48K bytes - Viewed (0) -
internal/bucket/replication/replication_test.go
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Mar 28 17:44:56 GMT 2024 - 32.5K bytes - Viewed (0) -
cmd/object-api-interface.go
PreserveETag string // preserves this etag during a PUT call. NoLock bool // indicates to lower layers if the caller is expecting to hold locks. ProxyRequest bool // only set for GET/HEAD in active-active replication scenario
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sat Apr 20 09:05:54 GMT 2024 - 16.9K bytes - Viewed (0) -
misc/go_android_exec/main.go
// still broken on our builders in 2023. Instead, append the exitcode to // the output and parse it from there. filter, exitStr := newExitCodeFilter(os.Stdout) args += "; echo -n " + exitStr + "$?" cmd := adbCmd("exec-out", args) cmd.Stdout = filter // If the adb subprocess somehow hangs, go test will kill this wrapper // and wait for our os.Stderr (and os.Stdout) to close as a result.
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Mon Aug 21 17:46:57 GMT 2023 - 15.3K bytes - Viewed (0) -
internal/dsync/drwmutex.go
noQuorum, err := refreshLock(ctx, dm.clnt, id, source, quorum) if err == nil && noQuorum { // Clean the lock locally and in remote nodes forceUnlock(ctx, dm.clnt, id) // Execute the caller lock loss callback if lockLossCallback != nil { lockLossCallback() } return } refreshTimer.Reset(dm.refreshInterval) } } }() }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 19.7K bytes - Viewed (0) -
internal/bucket/lifecycle/lifecycle.go
if rule.Status == Disabled { continue } if !strings.HasPrefix(obj.Name, rule.GetPrefix()) { continue } if !obj.DeleteMarker && !rule.Filter.TestTags(obj.UserTags) { continue } if !obj.DeleteMarker && !rule.Filter.BySize(obj.Size) { continue } rules = append(rules, rule) } return rules } // ObjectOpts provides information to deduce the lifecycle actions
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sat Mar 09 06:41:22 GMT 2024 - 17K bytes - Viewed (0) -
src/archive/zip/writer.go
} return nil } // CreateHeader adds a file to the zip archive using the provided [FileHeader] // for the file metadata. [Writer] takes ownership of fh and may mutate // its fields. The caller must not modify fh after calling [Writer.CreateHeader]. // // This returns a [Writer] to which the file contents should be written. // The file's contents must be written to the io.Writer before the next
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Thu Apr 04 14:28:57 GMT 2024 - 19.3K bytes - Viewed (0) -
internal/http/listener_test.go
var ip net.IP switch v := addr.(type) { case *net.IPNet: ip = v.IP case *net.IPAddr: ip = v.IP } if ip.To4() != nil { localIP4.Add(ip.String()) } } // Filter ipList by IPs those do not start with '127.'. nonLoopBackIPs := localIP4.FuncMatch(func(ip string, matchString string) bool { return !strings.HasPrefix(ip, "127.") }, "") if len(nonLoopBackIPs) == 0 {
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Mon Jun 12 16:09:28 GMT 2023 - 11.8K bytes - Viewed (0) -
cni/pkg/nodeagent/informers.go
controllers.WithGenericReconciler(s.reconcile), controllers.WithMaxAttempts(5), ) // We only need to handle pods on our node s.pods = kclient.NewFiltered[*corev1.Pod](kubeClient, kclient.Filter{FieldSelector: "spec.nodeName=" + NodeName}) s.pods.AddEventHandler(controllers.FromEventHandler(func(o controllers.Event) { s.queue.Add(o) })) // Namespaces could be anything though, so we watch all of those //
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Thu Feb 08 01:03:24 GMT 2024 - 9.9K bytes - Viewed (0)