- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 791 for orange (0.15 sec)
-
logger/sql.go
} } else { for _, t := range convertibleTypes { if rv.Type().ConvertibleTo(t) { convertParams(rv.Convert(t).Interface(), idx) return } } vars[idx] = escaper + strings.ReplaceAll(fmt.Sprint(v), escaper, escaper+escaper) + escaper } } } for idx, v := range avars { convertParams(v, idx) }
Go - Registered: Sun May 05 09:35:13 GMT 2024 - Last Modified: Thu Mar 21 08:00:02 GMT 2024 - 5K bytes - Viewed (0) -
cmd/site-replication-utils_gen.go
err = msgp.WrapError(err, "BucketStatuses") return } if z.BucketStatuses == nil { z.BucketStatuses = make(map[string]ResyncStatusType, zb0002) } else if len(z.BucketStatuses) > 0 { for key := range z.BucketStatuses { delete(z.BucketStatuses, key) } } for zb0002 > 0 { zb0002-- var za0001 string var za0002 ResyncStatusType za0001, err = dc.ReadString() if err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Nov 14 15:16:40 GMT 2022 - 7.2K bytes - Viewed (0) -
clause/expression.go
inName bool afterParenthesis bool namedMap = make(map[string]interface{}, len(expr.Vars)) ) for _, v := range expr.Vars { switch value := v.(type) { case sql.NamedArg: namedMap[value.Name] = value.Value case map[string]interface{}: for k, v := range value { namedMap[k] = v } default: var appendFieldsToMap func(reflect.Value)
Go - Registered: Sun May 05 09:35:13 GMT 2024 - Last Modified: Tue Oct 10 06:45:48 GMT 2023 - 8.3K bytes - Viewed (0) -
cmd/metrics-resource.go
resourceMetricsMapMu.RLock() defer resourceMetricsMapMu.RUnlock() for _, subSys := range subSystems { stats, found := resourceMetricsMap[subSys] if found { requireAvgMax := true if subSys == driveSubsystem { requireAvgMax = false } for _, m := range stats { metrics = append(metrics, prepareResourceMetrics(m, subSys, requireAvgMax)...) } } }
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) -
clause/from.go
} // Build build from clause func (from From) Build(builder Builder) { if len(from.Tables) > 0 { for idx, table := range from.Tables { if idx > 0 { builder.WriteByte(',') } builder.WriteQuoted(table) } } else { builder.WriteQuoted(currentTable) } for _, join := range from.Joins { builder.WriteByte(' ') join.Build(builder) } } // MergeClause merge from clause
Go - Registered: Sun May 05 09:35:13 GMT 2024 - Last Modified: Wed Jul 15 02:25:10 GMT 2020 - 630 bytes - Viewed (0) -
internal/http/listener.go
for { conn, err := listener.Accept() send(acceptResult{conn, err, idx}) } } // Start separate goroutine for each TCP listener to handle connection. for idx, tcpListener := range listener.listeners { go handleListener(idx, tcpListener) } } // Accept - reads from httpListener.acceptCh for one of previously accepted TCP connection and returns the same.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 24 04:08:47 GMT 2024 - 5.6K bytes - Viewed (0) -
istioctl/pkg/multixds/gather.go
LabelSelector: fmt.Sprintf("%s=%s,!istio.io/tag", label.IoIstioRev.Name, client.Revision()), }) if err != nil { return nil, err } for _, whc := range webhooks.Items { for _, wh := range whc.Webhooks { if wh.ClientConfig.URL != nil { u, err := url.Parse(*wh.ClientConfig.URL) if err != nil { return nil, fmt.Errorf("parsing webhook URL: %w", err) }
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/metacache-manager.go
var exit bool for !exit { select { case <-t.C: case <-GlobalContext.Done(): exit = true } m.mu.RLock() for _, v := range m.buckets { if !exit { v.cleanup() } } m.mu.RUnlock() m.mu.Lock() for k, v := range m.trash { if time.Since(v.lastUpdate) > metacacheMaxRunningAge { v.delete(context.Background()) delete(m.trash, k) } }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Oct 25 00:44:15 GMT 2022 - 5.2K bytes - Viewed (0) -
internal/s3select/sql/jsonpath_test.go
"github.com/bcicen/jstream" ) func getJSONStructs(b []byte) ([]interface{}, error) { dec := jstream.NewDecoder(bytes.NewBuffer(b), 0).ObjectAsKVS() var result []interface{} for parsedVal := range dec.Stream() { result = append(result, parsedVal.Value) } if err := dec.Err(); err != nil { return nil, err } return result, nil } func TestJsonpathEval(t *testing.T) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Sep 19 18:05:16 GMT 2022 - 2.8K bytes - Viewed (0) -
cmd/typed-errors.go
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") // error returned by disks which are to be initialized are waiting for the
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)