Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for withContext (0.07 sec)

  1. build-logic/binary-compatibility/src/test/groovy/gradlebuild/binarycompatibility/PublicAPIRulesTest.groovy

            given:
            JApiCompatibility jApiType = getProperty(jApiTypeName)
            def incubatingMissingRule = withContext(new IncubatingMissingRule([:]))
            def sinceMissingRule = withContext(new SinceAnnotationMissingRule([:]))
    
            when:
            jApiType.annotations >> [deprecatedAnnotation]
            sourceFile.text = """
                @Deprecated
    Registered: Wed Nov 06 11:36:14 UTC 2024
    - Last Modified: Fri Dec 01 20:12:19 UTC 2023
    - 16K bytes
    - Viewed (0)
  2. internal/event/target/elasticsearch.go

    	resp, err := c.Ping(
    		c.Ping.WithContext(ctx),
    	)
    	if err != nil {
    		return false, store.ErrNotConnected
    	}
    	xhttp.DrainBody(resp.Body)
    	return !resp.IsError(), nil
    }
    
    func (c *esClientV7) entryExists(ctx context.Context, index string, key string) (bool, error) {
    	res, err := c.Exists(
    		index,
    		key,
    		c.Exists.WithContext(ctx),
    	)
    	if err != nil {
    		return false, err
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 15K bytes
    - Viewed (0)
  3. gorm.go

    	if config.NowFunc != nil {
    		tx.Config.NowFunc = config.NowFunc
    	}
    
    	if config.Initialized {
    		tx = tx.getInstance()
    	}
    
    	return tx
    }
    
    // WithContext change current instance db's context to ctx
    func (db *DB) WithContext(ctx context.Context) *DB {
    	return db.Session(&Session{Context: ctx})
    }
    
    // Debug start debug mode
    func (db *DB) Debug() (tx *DB) {
    	tx = db.getInstance()
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Wed Oct 09 11:29:48 UTC 2024
    - 12.1K bytes
    - Viewed (0)
  4. tests/transaction_test.go

    func TestCancelTransaction(t *testing.T) {
    	ctx := context.Background()
    	ctx, cancelFunc := context.WithCancel(ctx)
    	cancelFunc()
    
    	user := *GetUser("cancel_transaction", Config{})
    	DB.Create(&user)
    
    	err := DB.WithContext(ctx).Transaction(func(tx *gorm.DB) error {
    		var result User
    		tx.First(&result, user.ID)
    		return nil
    	})
    
    	if err == nil {
    		t.Fatalf("Transaction should get error when using cancelled context")
    	}
    }
    
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Sat Sep 14 12:58:29 UTC 2024
    - 12.9K bytes
    - Viewed (0)
  5. api/go1.7.txt

    pkg net/http, const StatusVariantAlsoNegotiates = 506
    pkg net/http, const StatusVariantAlsoNegotiates ideal-int
    pkg net/http, method (*Request) Context() context.Context
    pkg net/http, method (*Request) WithContext(context.Context) *Request
    pkg net/http, type Request struct, Response *Response
    pkg net/http, type Response struct, Uncompressed bool
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Tue Jun 28 15:08:11 UTC 2016
    - 13.6K bytes
    - Viewed (0)
  6. internal/rest/client.go

    		Method:     method,
    		URL:        &u,
    		Proto:      "HTTP/1.1",
    		ProtoMajor: 1,
    		ProtoMinor: 1,
    		Header:     make(http.Header),
    		Body:       rc,
    		Host:       u.Host,
    	}
    	req = req.WithContext(ctx)
    	if body != nil {
    		switch v := body.(type) {
    		case *bytes.Buffer:
    			req.ContentLength = int64(v.Len())
    			buf := v.Bytes()
    			req.GetBody = func() (io.ReadCloser, error) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 26 12:55:01 UTC 2024
    - 14.7K bytes
    - Viewed (0)
  7. cmd/admin-router.go

    	handlerName := getHandlerName(f, "adminAPIHandlers")
    
    	var handler http.HandlerFunc = func(w http.ResponseWriter, r *http.Request) {
    		// Update request context with `logger.ReqInfo`.
    		r = r.WithContext(newContext(r, w, handlerName))
    
    		defer logger.AuditLog(r.Context(), w, r, mustGetClaimsFromToken(r))
    
    		// Check if object layer is available, if not return error early.
    		if !handlerFlags.Has(noObjLayerFlag) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Sep 21 11:35:40 UTC 2024
    - 26.2K bytes
    - Viewed (0)
Back to top