- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 21 for Seguin (0.21 sec)
-
cmd/erasure-multipart.go
return result, nil } // ListObjectParts - lists all previously uploaded parts for a given // object and uploadID. Takes additional input of part-number-marker // to indicate where the listing should begin from. // // Implements S3 compatible ListObjectParts API. The resulting // ListPartsInfo structure is marshaled directly into XML and // replied back to the client.
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 43K bytes - Viewed (0) -
tests/prepared_stmt_test.go
t.Fatalf("no error should happen but got %v", err) } } func TestPreparedStmtFromTransaction(t *testing.T) { db := DB.Session(&gorm.Session{PrepareStmt: true, SkipDefaultTransaction: true}) tx := db.Begin() defer func() { if r := recover(); r != nil { tx.Rollback() } }() if err := tx.Error; err != nil { t.Errorf("Failed to start transaction, got error %v\n", err) }
Go - Registered: Sun Apr 28 09:35:09 GMT 2024 - Last Modified: Thu Mar 21 07:55:43 GMT 2024 - 4K bytes - Viewed (0) -
tests/connpool_test.go
} }() db, err := gorm.Open(mysql.New(mysql.Config{Conn: conn, DisableWithReturning: true})) if err != nil { t.Fatalf("Should open db success, but got %v", err) } tx := db.Begin() user := *GetUser("transaction", Config{}) if err = tx.Save(&user).Error; err != nil { t.Fatalf("No error should raise, but got %v", err) }
Go - Registered: Sun Apr 28 09:35:09 GMT 2024 - Last Modified: Tue Feb 06 02:54:40 GMT 2024 - 5.5K bytes - Viewed (0) -
scan.go
Go - Registered: Sun Apr 28 09:35:09 GMT 2024 - Last Modified: Fri Apr 26 09:53:11 GMT 2024 - 9.8K bytes - Viewed (0) -
prepare_stmt.go
db.Mux.Unlock() // prepare completed defer close(cacheStmt.prepared) // Reason why cannot lock conn.PrepareContext // suppose the maxopen is 1, g1 is creating record and g2 is querying record. // 1. g1 begin tx, g1 is requeue because of waiting for the system call, now `db.ConnPool` db.numOpen == 1. // 2. g2 select lock `conn.PrepareContext(ctx, query)`, now db.numOpen == db.maxOpen , wait for release.
Go - Registered: Sun Apr 28 09:35:09 GMT 2024 - Last Modified: Thu Mar 28 08:47:39 GMT 2024 - 6.4K bytes - Viewed (0) -
cni/pkg/plugin/plugin.go
return nil } for _, excludeNs := range conf.Kubernetes.ExcludeNamespaces { if podNamespace == excludeNs { log.Infof("pod namespace excluded") return nil } } // Begin ambient plugin logic // For ambient pods, this is all the logic we need to run if conf.AmbientEnabled { log.Debugf("istio-cni ambient cmdAdd podName: %s - checking if ambient enabled", podName)
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Sat Feb 10 00:31:55 GMT 2024 - 10.4K bytes - Viewed (0) -
internal/event/target/kafka_scram_client_contrib.go
*scram.Client *scram.ClientConversation scram.HashGeneratorFcn } // Begin constructs a SCRAM client component based on a given hash.Hash // factory receiver. This constructor will normalize the username, password // and authzID via the SASLprep algorithm, as recommended by RFC-5802. If // SASLprep fails, the method returns an error. func (x *XDGSCRAMClient) Begin(userName, password, authzID string) (err error) {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Nov 09 04:04:01 GMT 2023 - 3.2K bytes - Viewed (0) -
cmd/signature-v4-parser_test.go
expectedAuthField: signValues{}, expectedErrCode: ErrAuthHeaderEmpty, }, // Test case - 2. // Test case with no sign v4 Algorithm prefix. // A valid authorization string should begin(prefix) { inputV4AuthStr: "no-singv4AlgorithmPrefix", expectedAuthField: signValues{}, expectedErrCode: ErrSignatureVersionNotSupported, }, // Test case - 3.
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 27.4K bytes - Viewed (0) -
cmd/admin-handlers-users.go
objectAPI, _ := validateAdminReq(ctx, w, r, policy.CreatePolicyAdminAction) if objectAPI == nil { return } vars := mux.Vars(r) policyName := vars["name"] // Policy has space characters in begin and end reject such inputs. if hasSpaceBE(policyName) { writeErrorResponseJSON(ctx, w, errorCodes.ToAPIErr(ErrAdminResourceInvalidArgument), r.URL) return } // Error out if Content-Length is missing.
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 25 15:50:16 GMT 2024 - 77.3K bytes - Viewed (0) -
tests/preload_test.go
}, }, }, } DB.Create(&users) query := make([]string, 0) sess := DB.Session(&gorm.Session{Logger: Tracer{ Logger: DB.Config.Logger, Test: func(ctx context.Context, begin time.Time, fc func() (sql string, rowsAffected int64), err error) { sql, _ := fc() query = append(query, sql) }, }}) var result []User err := sess. Joins("Manager").
Go - Registered: Sun Apr 28 09:35:09 GMT 2024 - Last Modified: Thu Apr 25 12:21:03 GMT 2024 - 14.9K bytes - Viewed (0)