- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 28 for eval (0.13 sec)
-
internal/bucket/lifecycle/lifecycle.go
StorageClass string } // Eval returns the lifecycle event applicable now. func (lc Lifecycle) Eval(obj ObjectOpts) Event { return lc.eval(obj, time.Now().UTC()) } // eval returns the lifecycle event applicable at the given now. If now is the // zero value of time.Time, it returns the upcoming lifecycle event. func (lc Lifecycle) eval(obj ObjectOpts, now time.Time) Event { var events []Event
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:11:10 GMT 2024 - 17.5K bytes - Viewed (0) -
internal/s3select/select.go
outputRecord.Reset() } else { // Create new one outputRecord = s3Select.outputRecord() outputQueue[len(outputQueue)-1] = outputRecord } outputRecord, err = s3Select.statement.Eval(*inputRecord, outputRecord) if outputRecord == nil || err != nil { // This should not be written. // Remove it from the queue. outputQueue = outputQueue[:len(outputQueue)-1] if err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Nov 06 22:26:08 GMT 2023 - 21K bytes - Viewed (0) -
cmd/bucket-lifecycle.go
// This is to be called after a successful upload of an object (version). func enqueueTransitionImmediate(obj ObjectInfo, src lcEventSrc) { if lc, err := globalLifecycleSys.Get(obj.Bucket); err == nil { switch event := lc.Eval(obj.ToLifecycleOpts()); event.Action { case lifecycle.TransitionAction, lifecycle.TransitionVersionAction: globalTransitionState.queueTransitionTask(obj, event, src) } } }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 17 05:09:58 GMT 2024 - 33.1K bytes - Viewed (0) -
cmd/batch-expire.go
// UnmarshalYAML - BatchJobExpirePurge extends unmarshal to extract line, col func (p *BatchJobExpirePurge) UnmarshalYAML(val *yaml.Node) error { type purge BatchJobExpirePurge var tmp purge err := val.Decode(&tmp) if err != nil { return err } *p = BatchJobExpirePurge(tmp) p.line, p.col = val.Line, val.Column return nil } // Validate returns nil if value is valid, ie > 0.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 21K bytes - Viewed (1) -
cni/pkg/plugin/sidecar_redirect.go
if _, ok := annotationRegistry[name]; !ok { return false, "", fmt.Errorf("no registered annotation with name=%s", name) } // use annotation value if present if val, found := annotations[annotationRegistry[name].key]; found { if err := annotationRegistry[name].validator(val); err != nil { return true, annotationRegistry[name].defaultVal, err
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 10.6K bytes - Viewed (0) -
cmd/metrics-resource.go
if !found { metric = ResourceMetric{ Name: name, Labels: labels, } } if isCumulative { metric.Current = val - metric.Cumulative metric.Cumulative = val } else { metric.Current = val } if metric.Current > metric.Max { metric.Max = val } metric.Sum += metric.Current metric.Count++ metric.Avg = metric.Sum / float64(metric.Count)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 23 23:56:12 GMT 2024 - 17.4K bytes - Viewed (0) -
internal/grid/handlers.go
func GetCaller(ctx context.Context) *RemoteClient { val, _ := ctx.Value(ctxCallerKey{}).(*RemoteClient) return val } // GetSubroute returns caller information from contexts provided to handlers. func GetSubroute(ctx context.Context) string { val, _ := ctx.Value(ctxSubrouteKey{}).(string) return val } func setCaller(ctx context.Context, cl *RemoteClient) context.Context {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 23 17:15:52 GMT 2024 - 27.1K bytes - Viewed (0) -
operator/cmd/mesh/test-util_test.go
g.Expect(err).Should(BeNil(), "path %s should exist (%s)", path, err) g.Expect(f).Should(BeTrue(), "path %s should exist", path) return got.Node } // toMap transforms a comma separated key:value list (e.g. "a:aval, b:bval") to a map. func toMap(s string) map[string]any { out := make(map[string]any) for _, l := range strings.Split(s, ",") { l = strings.TrimSpace(l) kv := strings.Split(l, ":") if len(kv) != 2 {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Oct 31 14:48:28 GMT 2023 - 15.3K bytes - Viewed (0) -
cmd/signature-v2.go
for _, query := range queries { key := query val := "" index := strings.Index(query, "=") if index != -1 { key = query[:index] val = query[index+1:] } keyval[key] = val } var canonicalQueries []string for _, key := range resourceList { val, ok := keyval[key] if !ok { continue } if val == "" { canonicalQueries = append(canonicalQueries, key)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 12.2K bytes - Viewed (0) -
scan.go
Go - Registered: Sun May 05 09:35:13 GMT 2024 - Last Modified: Fri Apr 26 09:53:11 GMT 2024 - 9.8K bytes - Viewed (0)