- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 133 for SELECT (0.24 sec)
-
internal/grid/debug.go
Managers []*Manager Mux []*mux.Router Hosts []string cleanupOnce sync.Once cancel context.CancelFunc } // SetupTestGrid creates a new grid for testing purposes. // Select the number of hosts to create. // Call (TestGrid).Cleanup() when done. func SetupTestGrid(n int) (*TestGrid, error) { hosts, listeners, err := getHosts(n) if err != nil { return nil, err } dialer := &net.Dialer{
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 08 18:15:27 GMT 2024 - 4.2K bytes - Viewed (0) -
cmd/object-handlers.go
for k, v := range reqParams { if header, ok := supportedHeadGetReqParams[strings.ToLower(k)]; ok { w.Header()[header] = []string{strings.Join(v, ",")} } } } // SelectObjectContentHandler - GET Object?select // ---------- // This implementation of the GET operation retrieves object content based // on an SQL expression. In the request, along with the sql expression, you must
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu May 02 20:15:54 GMT 2024 - 125.2K bytes - Viewed (0) -
internal/lsync/lrwmutex.go
r := rand.New(rand.NewSource(time.Now().UnixNano())) retryCtx, cancel := context.WithTimeout(ctx, timeout) defer cancel() for { select { case <-retryCtx.Done(): // Caller context canceled or we timedout, // return false anyways for both situations. return false default: if lm.lock(id, source, isWriteLock) { return true
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Jan 02 17:15:06 GMT 2022 - 4.8K bytes - Viewed (0) -
internal/s3select/sql/timestampfuncs.go
for _, f := range tformats { t, err = time.Parse(f, s) if err == nil { break } } return } // FormatSQLTimestamp - returns the a string representation of the // timestamp as used in S3 Select func FormatSQLTimestamp(t time.Time) string { _, zoneOffset := t.Zone() hasZone := zoneOffset != 0 hasFracSecond := t.Nanosecond() != 0 hasSecond := t.Second() != 0 hasTime := t.Hour() != 0 || t.Minute() != 0
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Jan 02 17:15:06 GMT 2022 - 4.8K bytes - Viewed (0) -
internal/grid/connection.go
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 42.6K bytes - Viewed (0) -
internal/grid/handlers.go
for { select { case <-ctx.Done(): return case v, ok := <-in: if !ok { return } input := h.NewRequest() _, err := input.UnmarshalMsg(v) if err != nil { gridLogOnceIf(ctx, err, err.Error()) } PutByteBuffer(v) // Send input select { case <-ctx.Done(): return
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) -
cmd/consolelogger.go
sys.RUnlock() // send last n console log messages in order filtered by node if cnt > 0 { for i := 0; i < last; i++ { entry := lastN[(cnt+i)%last] if (entry == log.Info{}) { continue } select { case subCh <- entry: case <-doneCh: return nil } } } return sys.pubsub.Subscribe(madmin.LogMaskAll, subCh, doneCh, filter) }
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) -
cmd/metacache-manager.go
objAPI := newObjectLayerFn() for objAPI == nil { time.Sleep(time.Second) objAPI = newObjectLayerFn() } t := time.NewTicker(time.Minute) defer t.Stop() 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()
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) -
cmd/erasure-object.go
} if ok { continue } } // in all other cases metadata is corrupt, do not read from it. onlineMeta[i] = FileInfo{} onlineDisks[i] = nil } select { case mrfCheck <- fi.ShallowCopy(): case <-ctx.Done(): return fi, onlineMeta, onlineDisks, toObjectErr(ctx.Err(), bucket, object) } return fi, onlineMeta, onlineDisks, nil }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun May 05 16:56:21 GMT 2024 - 77.2K bytes - Viewed (2) -
cmd/site-replication-metrics.go
s := SRStats{ M: make(map[string]*SRStatus), movingAvgTicker: time.NewTicker(time.Second * 2), } go s.trackEWMA() return &s } func (sr *SRStats) trackEWMA() { for { select { case <-sr.movingAvgTicker.C: sr.updateMovingAvg() case <-GlobalContext.Done(): return } } } func (sr *SRStats) updateMovingAvg() { sr.lock.Lock() defer sr.lock.Unlock()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Feb 06 06:00:45 GMT 2024 - 8.2K bytes - Viewed (0)