Search Options

Results per page
Sort
Preferred Languages
Advance

Results 571 - 580 of 2,442 for there (0.1 sec)

  1. internal/kms/secret-key.go

    // ciphertext.
    //
    // UnmarshalJSON provides backward-compatible unmarsahaling
    // of existing ciphertext. In the past, ciphertexts were
    // JSON-encoded. Now, ciphertexts are binary-encoded.
    // Therefore, there is no MarshalJSON implementation.
    func (c *ciphertext) UnmarshalJSON(text []byte) error {
    	const (
    		IVSize    = 16
    		NonceSize = 12
    
    		AES256GCM        = "AES-256-GCM-HMAC-SHA-256"
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Aug 18 06:43:03 UTC 2024
    - 8.3K bytes
    - Viewed (0)
  2. internal/s3select/sql/value.go

    // it returns false only if there is a conversion failure.
    func (v Value) bytesToInt() (int64, bool) {
    	bytes, _ := v.ToBytes()
    	i, err := strconv.ParseInt(strings.TrimSpace(string(bytes)), 10, 64)
    	return i, err == nil
    }
    
    // Converts untyped value into float. The bool return implies success
    // - it returns false only if there is a conversion failure.
    func (v Value) bytesToFloat() (float64, bool) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Feb 25 20:31:19 UTC 2022
    - 20.2K bytes
    - Viewed (0)
  3. cmd/metrics-realtime.go

    			CollectedAt: UTCNow(),
    		}
    		cm, err := c.Times(false)
    		if err != nil {
    			m.Errors = append(m.Errors, fmt.Sprintf("%s: %v (cpuTimes)", byHostName, err.Error()))
    		} else {
    			// not collecting per-cpu stats, so there will be only one element
    			if len(cm) == 1 {
    				m.Aggregated.CPU.TimesStat = &cm[0]
    			} else {
    				m.Errors = append(m.Errors, fmt.Sprintf("%s: Expected one CPU stat, got %d", byHostName, len(cm)))
    			}
    		}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Jun 01 05:16:24 UTC 2024
    - 6.3K bytes
    - Viewed (0)
  4. .github/actions/notify-translations/app/main.py

                        body=done_translation_message,
                    )
                    logging.info(f"Marked as done in comment: {updated_comment.url}")
            else:
                logging.info(
                    f"There doesn't seem to be anything to be done about PR #{pr.number}"
                )
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Mon Jul 29 23:35:07 UTC 2024
    - 12.4K bytes
    - Viewed (0)
  5. cmd/metacache-stream.go

    func (r *metacacheReader) checkInit() {
    	if r.creator == nil || r.err != nil {
    		return
    	}
    	r.err = r.creator()
    	r.creator = nil
    }
    
    // peek will return the name of the next object.
    // Will return io.EOF if there are no more objects.
    // Should be used sparingly.
    func (r *metacacheReader) peek() (metaCacheEntry, error) {
    	r.checkInit()
    	if r.err != nil {
    		return metaCacheEntry{}, r.err
    	}
    	if r.current.name != "" {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Apr 04 12:04:40 UTC 2024
    - 19.5K bytes
    - Viewed (0)
  6. internal/kms/context.go

    		// U+2029 is PARAGRAPH SEPARATOR.
    		// They are both technically valid characters in JSON strings,
    		// but don't work in JSONP, which has to be evaluated as JavaScript,
    		// and can lead to security holes there. It is valid JSON to
    		// escape them, so we do so unconditionally.
    		// See http://timelessrepo.com/json-isnt-a-javascript-subset for discussion.
    		if c == '\u2028' || c == '\u2029' {
    			if start < i {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Jan 02 17:15:06 UTC 2022
    - 6K bytes
    - Viewed (0)
  7. tests/prepared_stmt_test.go

    		t.Errorf("Failed to commit transaction, got error %v\n", err)
    	}
    
    	if result := db.Where("name=?", "zzjin").Delete(&User{}); result.Error != nil || result.RowsAffected != 1 {
    		t.Fatalf("Failed, got error: %v, rows affected: %v", result.Error, result.RowsAffected)
    	}
    
    	tx2 := db.Begin()
    	if result := tx2.Where("name=?", "zzjin").Delete(&User{}); result.Error != nil || result.RowsAffected != 0 {
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Thu Aug 22 11:02:05 UTC 2024
    - 8.5K bytes
    - Viewed (0)
  8. cmd/peer-rest-client.go

    	go func() {
    		for {
    			client.doListen(ctx, listenCh, v)
    			select {
    			case <-ctx.Done():
    				return
    			default:
    				// There was error in the REST request, retry after sometime as probably the peer is down.
    				time.Sleep(5 * time.Second)
    			}
    		}
    	}()
    }
    
    // Trace - send http trace request to peer nodes
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 09 16:58:30 UTC 2024
    - 26.1K bytes
    - Viewed (0)
  9. istioctl/pkg/tag/generate.go

    	WebhookName string
    	// ManifestsPath specifies where the manifests to render the mutatingwebhook can be found.
    	// TODO(Monkeyanator) once we stop using Helm templating remove this.
    	ManifestsPath string
    	// Generate determines whether we should just generate the webhooks without applying. This
    	// applying is not done here, but we are looser with checks when doing generate.
    	Generate bool
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Oct 09 16:05:45 UTC 2024
    - 13.3K bytes
    - Viewed (0)
  10. android/guava/src/com/google/common/util/concurrent/ListenableFuture.java

       * The listener will run when the {@code Future}'s computation is {@linkplain Future#isDone()
       * complete} or, if the computation is already complete, immediately.
       *
       * <p>There is no guaranteed ordering of execution of listeners, but any listener added through
       * this method is guaranteed to be called once the computation is complete.
       *
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Jun 26 21:13:41 UTC 2023
    - 8K bytes
    - Viewed (0)
Back to top