- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for WithContext (0.22 sec)
-
internal/rest/rpc-stats.go
}, ConnectDone: func(network, addr string, err error) { if err == nil { atomic.StoreInt64(&dialEnd, time.Now().UnixNano()) } }, } return req.WithContext(httptrace.WithClientTrace(req.Context(), trace)), func() { if ds := atomic.LoadInt64(&dialStart); ds > 0 { if de := atomic.LoadInt64(&dialEnd); de == 0 { atomic.AddUint64(&globalStats.tcpDialErrs, 1)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Sep 29 16:27:58 GMT 2022 - 2.3K bytes - Viewed (0) -
tests/scopes_test.go
}).Find(&users1) if result.RowsAffected != 2 { t.Errorf("Should found two users's name in 1, 2, but got %v", result.RowsAffected) } var maxId int64 userTable := func(db *gorm.DB) *gorm.DB { return db.WithContext(context.Background()).Table("users") } if err := DB.Scopes(userTable).Select("max(id)").Scan(&maxId).Error; err != nil { t.Errorf("select max(id)") } } func TestComplexScopes(t *testing.T) {
Go - Registered: Sun May 05 09:35:13 GMT 2024 - Last Modified: Fri Jan 12 08:42:21 GMT 2024 - 3.3K bytes - Viewed (0) -
tests/prepared_stmt_test.go
t.Fatalf("should assign PreparedStatement Manager back to database when using PrepareStmt mode") } ctx, cancel := context.WithTimeout(context.Background(), 500*time.Millisecond) defer cancel() txCtx := tx.WithContext(ctx) user := *GetUser("prepared_stmt", Config{}) txCtx.Create(&user) var result1 User if err := txCtx.Find(&result1, user.ID).Error; err != nil { t.Fatalf("no error should happen but got %v", err)
Go - Registered: Sun May 05 09:35:13 GMT 2024 - Last Modified: Thu Mar 21 07:55:43 GMT 2024 - 4K bytes - Viewed (0) -
cmd/http-tracer.go
tc := mcontext.TraceCtxt{ AmzReqID: w.Header().Get(xhttp.AmzRequestID), RequestRecorder: reqRecorder, ResponseRecorder: respRecorder, } r = r.WithContext(context.WithValue(r.Context(), mcontext.ContextTraceKey, &tc)) reqStartTime := time.Now().UTC() h.ServeHTTP(respRecorder, r) reqEndTime := time.Now().UTC()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Nov 21 01:09:35 GMT 2023 - 5.9K bytes - Viewed (0) -
internal/handlers/forwarder.go
outReq.ProtoMajor = 1 outReq.ProtoMinor = 1 f.rewriter.Rewrite(outReq) // Disable closeNotify when method GET for http pipelining if outReq.Method == http.MethodGet { quietReq := outReq.WithContext(context.Background()) *outReq = *quietReq } } // headerRewriter is responsible for removing hop-by-hop headers and setting forwarding headers type headerRewriter struct{}
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 07 05:42:10 GMT 2023 - 5.6K bytes - Viewed (0)