- Sort Score
- Num 10 results
- Language All
Results 231 - 240 of 870 for context_b (0.07 seconds)
-
callbacks/delete.go
rel, ok := db.Statement.Schema.Relationships.Relations[column] if !ok { continue } switch rel.Type { case schema.HasOne, schema.HasMany: queryConds := rel.ToQueryConditions(db.Statement.Context, db.Statement.ReflectValue) modelValue := reflect.New(rel.FieldSchema.ModelType).Interface() tx := db.Session(&gorm.Session{NewDB: true}).Model(modelValue) withoutConditions := false if db.Statement.Unscoped {
Created: Sun Dec 28 09:35:17 GMT 2025 - Last Modified: Sun May 25 07:40:40 GMT 2025 - 5.8K bytes - Click Count (0) -
internal/bucket/bandwidth/monitor.go
bucketMovingAvgTicker *time.Ticker // Ticker for calculating moving averages ctx context.Context // Context for generate NodeCount uint64 } // NewMonitor returns a monitor with defaults. func NewMonitor(ctx context.Context, numNodes uint64) *Monitor { m := &Monitor{ bucketsMeasurement: make(map[BucketOptions]*bucketMeasurement),
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 6K bytes - Click Count (0) -
cmd/erasure-metadata.go
// slice of FileInfo. func pickValidFileInfo(ctx context.Context, metaArr []FileInfo, modTime time.Time, etag string, quorum int) (FileInfo, error) { return findFileInfoInQuorum(ctx, metaArr, modTime, etag, quorum) } func writeAllMetadataWithRevert(ctx context.Context, disks []StorageAPI, origbucket, bucket, prefix string, files []FileInfo, quorum int, revert bool) ([]StorageAPI, error) {
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 21.3K bytes - Click Count (0) -
scripts/playwright/cookie_param_models/image01.py
def run(playwright: Playwright) -> None: browser = playwright.chromium.launch(headless=False) # Update the viewport manually context = browser.new_context(viewport={"width": 960, "height": 1080}) browser = playwright.chromium.launch(headless=False) context = browser.new_context() page = context.new_page() page.goto("http://localhost:8000/docs") page.get_by_role("link", name="/items/").click()
Created: Sun Dec 28 07:19:09 GMT 2025 - Last Modified: Tue Sep 17 18:54:10 GMT 2024 - 1.2K bytes - Click Count (0) -
internal/stmt_store/stmt_store.go
s.lru.Remove(key) } type ConnPool interface { PrepareContext(ctx context.Context, query string) (*sql.Stmt, error) } // New creates a new Stmt object for executing SQL queries. // It caches the Stmt object for future use and handles preparation and error states. // Parameters: // // ctx: Context for the request, used to carry deadlines, cancellation signals, etc.
Created: Sun Dec 28 09:35:17 GMT 2025 - Last Modified: Sun Apr 27 06:05:16 GMT 2025 - 6K bytes - Click Count (0) -
cmd/bucket-object-lock.go
} // enforceRetentionForDeletion checks if it is appropriate to remove an // object according to locking configuration when this is lifecycle/ bucket quota asking. func enforceRetentionForDeletion(ctx context.Context, objInfo ObjectInfo) (locked bool) { if objInfo.DeleteMarker { return false } lhold := objectlock.GetObjectLegalHoldMeta(objInfo.UserDefined) if lhold.Status.Valid() && lhold.Status == objectlock.LegalHoldOn {
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 08 02:38:25 GMT 2025 - 13.3K bytes - Click Count (0) -
cmd/warm-backend-minio.go
// Part size. partSize = int64(partSizeFlt) if partSize == 0 { return minPartSize, nil } return partSize, nil } func (m *warmBackendMinIO) PutWithMeta(ctx context.Context, object string, r io.Reader, length int64, meta map[string]string) (remoteVersionID, error) { partSize, err := optimalPartSize(length) if err != nil { return remoteVersionID(""), err }
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 4K bytes - Click Count (1) -
compat/maven-compat/src/main/java/org/apache/maven/toolchain/ToolchainManagerPrivate.java
* * @param type the type, must not be {@code null} * @param context the Maven session, must not be {@code null} * @since 3.0 (addition of the <code>MavenSession</code> parameter) */ ToolchainPrivate[] getToolchainsForType(String type, MavenSession context) throws MisconfiguredToolchainException; /** * Stores the toolchain into build context for later use by toolchain-aware plugins. *Created: Sun Dec 28 03:35:09 GMT 2025 - Last Modified: Wed Feb 12 13:13:28 GMT 2025 - 2.2K bytes - Click Count (0) -
internal/http/dial_linux.go
// DialContext is a function to make custom Dial for internode communications type DialContext func(ctx context.Context, network, address string) (net.Conn, error) // NewInternodeDialContext setups a custom dialer for internode communication func NewInternodeDialContext(dialTimeout time.Duration, opts TCPOptions) DialContext { return func(ctx context.Context, network, addr string) (net.Conn, error) { dialer := &net.Dialer{ Timeout: dialTimeout,
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Tue Jul 23 10:53:03 GMT 2024 - 5K bytes - Click Count (0) -
internal/grid/muxclient.go
type muxClient struct { MuxID uint64 SendSeq, RecvSeq uint32 LastPong int64 BaseFlags Flags ctx context.Context cancelFn context.CancelCauseFunc parent *Connection respWait chan<- Response respMu sync.Mutex singleResp bool closed bool stateless bool acked bool init boolCreated: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 15.9K bytes - Click Count (0)