Search Options

Results per page
Sort
Preferred Languages
Advance

Results 191 - 200 of 1,035 for select (0.25 sec)

  1. 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
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Jan 02 17:15:06 UTC 2022
    - 4.8K bytes
    - Viewed (0)
  2. src/main/java/org/codelibs/fess/es/config/bsbhv/BsFileConfigBhv.java

            return result;
        }
    
        // ===================================================================================
        //                                                                              Select
        //                                                                              ======
        public int selectCount(CBCall<FileConfigCB> cbLambda) {
            return facadeSelectCount(createCB(cbLambda));
        }
    
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 10.8K bytes
    - Viewed (0)
  3. cni/pkg/nodeagent/cni-watcher.go

    	unixListener, err := pluginlistener.NewListener(s.sockAddress)
    	if err != nil {
    		return fmt.Errorf("failed to create CNI listener: %v", err)
    	}
    	go func() {
    		err := s.cniListenServer.Serve(unixListener)
    
    		select {
    		case <-s.ctx.Done():
    			// ctx done, we should silently go away
    			return
    		default:
    			// If the cniListener exits, at least we should record an error log
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Tue Jul 02 18:48:50 UTC 2024
    - 6.7K bytes
    - Viewed (0)
  4. docs/en/docs/advanced/security/oauth2-scopes.md

    <img src="/img/tutorial/security/image11.png">
    
    If you don't select any scope, you will be "authenticated", but when you try to access `/users/me/` or `/users/me/items/` you will get an error saying that you don't have enough permissions. You will still be able to access `/status/`.
    
    And if you select the scope `me` but not the scope `items`, you will be able to access `/users/me/` but not `/users/me/items/`.
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Tue Oct 29 11:02:16 UTC 2024
    - 13.1K bytes
    - Viewed (0)
  5. internal/event/targetlist.go

    			}
    		}(id, target)
    	}
    	wg.Wait()
    	list.totalEvents.Add(1)
    }
    
    func (list *TargetList) sendAsync(event Event, targetIDset TargetIDSet) {
    	select {
    	case list.queue <- asyncEvent{
    		ev:        event,
    		targetSet: targetIDset.Clone(),
    	}:
    	case <-list.ctx.Done():
    		list.eventsSkipped.Add(int64(len(list.queue)))
    		return
    	default:
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 9.2K bytes
    - Viewed (0)
  6. internal/grid/README.md

            fmt.Println("Got request with initial payload", p, "from", GetCaller(ctx context.Context))
            fmt.Println("Subroute:", GetSubroute(ctx))
            for {
                select {
                case <-ctx.Done():
                    return nil
                case req, ok := <-in:
                    if !ok {
                        break
                    }           
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 9.4K bytes
    - Viewed (0)
  7. .teamcity/src/main/kotlin/model/CIBuildModel.kt

        platform(true, true, true),
    
        // Cross version tests select a small set of versions to cover when run as part of this stage
        quickFeedbackCrossVersion(false, false, true),
    
        // Cross version tests select all versions to cover when run as part of this stage
        allVersionsCrossVersion(false, false, true, 240),
    
    Registered: Wed Nov 06 11:36:14 UTC 2024
    - Last Modified: Wed Oct 16 06:14:14 UTC 2024
    - 22.9K bytes
    - Viewed (0)
  8. samples/crawler/src/main/java/okhttp3/sample/Crawler.java

            return;
          }
    
          Document document = Jsoup.parse(response.body().string(), url.toString());
          for (Element element : document.select("a[href]")) {
            String href = element.attr("href");
            HttpUrl link = response.request().url().resolve(href);
            if (link == null) continue; // URL is either invalid or its scheme isn't http/https.
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Thu Aug 12 07:26:27 UTC 2021
    - 4.6K bytes
    - Viewed (0)
  9. internal/grid/grid.go

    type writerWrapper struct {
    	ch  chan<- []byte
    	ctx context.Context
    }
    
    func (w *writerWrapper) Write(p []byte) (n int, err error) {
    	buf := GetByteBufferCap(len(p))
    	buf = buf[:len(p)]
    	copy(buf, p)
    	select {
    	case w.ch <- buf:
    		return len(p), nil
    	case <-w.ctx.Done():
    		return 0, context.Cause(w.ctx)
    	}
    }
    
    // WriterToChannel will return an io.Writer that writes to the given channel.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 6.9K bytes
    - Viewed (0)
  10. .github/ISSUE_TEMPLATE/feature_addition_request.yaml

          description: Please provide use cases that actually came up in the real world.
        validations:
          required: true
    
      - type: dropdown
        attributes:
          label: Packages
          description: Please select all of the packages that are relevant to this feature request.
          multiple: true
          options:
            - com.google.common.annotations
            - com.google.common.base
            - com.google.common.cache
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Nov 17 18:47:47 UTC 2023
    - 5.8K bytes
    - Viewed (0)
Back to top