- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 126 for Tiller (0.14 sec)
-
cmd/object-api-utils.go
if hasStringSuffixInSlice(objStr, standardExcludeCompressExtensions) || hasPattern(standardExcludeCompressContentTypes, contentType) { return true } // Filter compression includes. if len(cfg.Extensions) == 0 && len(cfg.MimeTypes) == 0 { // Nothing to filter, include everything. return false } if len(cfg.Extensions) > 0 && hasStringSuffixInSlice(objStr, cfg.Extensions) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Mar 11 11:55:34 GMT 2024 - 35.6K bytes - Viewed (1) -
utils/utils.go
package utils import ( "database/sql/driver" "fmt" "path/filepath" "reflect" "runtime" "strconv" "strings" "unicode" ) var gormSourceDir string func init() { _, file, _, _ := runtime.Caller(0) // compatible solution to get gorm source directory with various operating systems gormSourceDir = sourceDir(file) } func sourceDir(file string) string { dir := filepath.Dir(file) dir = filepath.Dir(dir)
Go - Registered: Sun May 05 09:35:13 GMT 2024 - Last Modified: Mon Apr 22 06:43:02 GMT 2024 - 3.8K bytes - Viewed (0) -
cmd/consolelogger.go
} // Subscribe starts console logging for this node. func (sys *HTTPConsoleLoggerSys) Subscribe(subCh chan log.Info, doneCh <-chan struct{}, node string, last int, logKind madmin.LogMask, filter func(entry log.Info) bool) error { // Enable console logging for remote client. if !sys.HasLogListeners() { logger.AddSystemTarget(GlobalContext, sys) } cnt := 0
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 17:57:52 GMT 2024 - 5.5K bytes - Viewed (0) -
cni/pkg/nodeagent/net.go
// this can happen if the pod was dynamically added to the mesh after it was created. // in that case, try finding the netns using procfs. filter := map[types.UID]*corev1.Pod{ pod.UID: pod, } return s.scanProcForPodsAndCache(filter) } func (s *NetServer) getOrOpenNetns(pod *corev1.Pod, netNs string) (Netns, error) { if netNs == "" { return s.getNetns(pod) } return s.openNetns(pod, netNs)
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 12.2K bytes - Viewed (1) -
internal/config/storageclass/storage-class.go
// // -- if input is RRS but RRS is not configured/initialized '-1' parity // // for RRS is assumed, the caller is expected to choose the right parity // at that point. // // -- if input is STANDARD but STANDARD is not configured/initialized '-1' parity // // is returned, the caller is expected to choose the right parity // at that point. func (sCfg *Config) GetParityForSC(sc string) (parity int) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 11.8K bytes - Viewed (0) -
internal/cachevalue/cache.go
// An Update function must be set to provide an updated value when needed. type Cache[T any] struct { // updateFn must return an updated value. // If an error is returned the cached value is not set. // Only one caller will call this function at any time, others will be blocking. // The returned value can no longer be modified once returned. // Should be set before calling Get(). updateFn func() (T, error) // ttl for a cached value.
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) -
cni/pkg/repair/netns.go
func getLinkWithDestinationOf(ip string) (netlink.Link, error) { routes, err := netlink.RouteListFiltered( netlink.FAMILY_V4, &netlink.Route{Dst: &net.IPNet{IP: net.ParseIP(ip), Mask: net.CIDRMask(32, 32)}}, netlink.RT_FILTER_DST) if err != nil { return nil, err } if len(routes) == 0 { return nil, fmt.Errorf("no routes found for %s", ip) } linkIndex := routes[0].LinkIndex return netlink.LinkByIndex(linkIndex) }
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) -
operator/cmd/mesh/manifest_shared_test.go
filters := []string{} filters = append(filters, fileSelect...) // Everything needs these filters = append(filters, "templates/_affinity.tpl", "templates/_helpers.tpl", "templates/zzz_profile.yaml") args += " --filter " + strings.Join(filters, ",") } args += " --set installPackagePath=" + string(chartSource) return runCommand(args) } // runCommand runs the given command string.
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Feb 20 22:39:28 GMT 2024 - 11.7K bytes - Viewed (1) -
cmd/admin-heal-ops.go
select { case res := <-task.respCh: if !h.reportProgress { if errors.Is(res.err, errSkipFile) { // this is only sent usually by nopHeal return nil } // Report caller of any failure return res.err } res.result.Type = healType if res.err != nil { res.result.Detail = res.err.Error() } return h.pushHealResultItem(res.result) case <-h.ctx.Done():
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 25.1K bytes - Viewed (1) -
cmd/metacache-entries.go
break } } // Append anything left. if limit < 0 || len(merged) < limit { merged = append(merged, a...) merged = append(merged, b...) } m.o = merged } // filterPrefix will filter m to only contain entries with the specified prefix. func (m *metaCacheEntriesSorted) filterPrefix(s string) { if s == "" { return } m.forwardTo(s) for i, o := range m.o { if !o.hasPrefix(s) {
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)