- Sort Score
- Result 10 results
- Languages All
Results 1 - 8 of 8 for WithContext (0.25 sec)
-
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
Groovy - Registered: Wed May 01 11:36:15 GMT 2024 - Last Modified: Fri Dec 01 20:12:19 GMT 2023 - 16K bytes - Viewed (0) -
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 }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 15K bytes - Viewed (0) -
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()
Go - Registered: Sun Apr 28 09:35:09 GMT 2024 - Last Modified: Sun Aug 20 11:46:56 GMT 2023 - 11.6K bytes - Viewed (0) -
istioctl/pkg/wait/wait.go
ctx, cancel := context.WithTimeout(context.Background(), timeout) defer cancel() if generation == "" { w = getAndWatchResource(ctx, cliCtx) // setup version getter from kubernetes } else { w = withContext(ctx) w.Go(func(result chan string) error { result <- generation return nil }) } // wait for all deployed versions to be contained in generations t := time.NewTicker(pollInterval)
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Sat Feb 17 12:24:17 GMT 2024 - 10.1K bytes - Viewed (0) -
internal/rest/client.go
Method: http.MethodPost, 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) {
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 14K bytes - Viewed (0) -
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") } }
Go - Registered: Sun Apr 28 09:35:09 GMT 2024 - Last Modified: Sat Jun 10 13:05:19 GMT 2023 - 10.9K bytes - Viewed (0) -
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
Plain Text - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Tue Jun 28 15:08:11 GMT 2016 - 13.6K bytes - Viewed (0) -
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) {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sun Mar 10 21:09:36 GMT 2024 - 25.5K bytes - Viewed (0)