- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 458 for RANGE (0.23 sec)
-
istioctl/pkg/writer/ztunnel/configdump/workload.go
return true } if wf.Namespace != "" { if !strings.EqualFold(workload.Namespace, wf.Namespace) { return false } } if wf.Address != "" { var find bool for _, ip := range workload.WorkloadIPs { if strings.EqualFold(ip, wf.Address) { find = true break } } if !find { return false } } if wf.Node != "" && !strings.EqualFold(workload.Node, wf.Node) {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 23 21:30:30 GMT 2024 - 4K bytes - Viewed (0) -
cmd/namespace-lock.go
lockSource := getSource(2) start := UTCNow() const readLock = false success := make([]int, len(li.paths)) for i, path := range li.paths { if !li.ns.lock(ctx, li.volume, path, lockSource, li.opsID, readLock, timeout.Timeout()) { timeout.LogFailure() for si, sint := range success { if sint == 1 { li.ns.unlock(li.volume, li.paths[si], readLock) } }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Jun 05 23:56:35 GMT 2023 - 9.2K bytes - Viewed (0) -
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) -
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) -
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)