Search Options

Results per page
Sort
Preferred Languages
Advance

Results 91 - 100 of 714 for Contexto (0.17 sec)

  1. callbacks/preload.go

    			case reflect.Struct:
    				tx.AddError(rel.Field.Set(tx.Statement.Context, data, elem.Interface()))
    			case reflect.Slice, reflect.Array:
    				if reflectFieldValue.Type().Elem().Kind() == reflect.Ptr {
    					tx.AddError(rel.Field.Set(tx.Statement.Context, data, reflect.Append(reflectFieldValue, elem).Interface()))
    				} else {
    					tx.AddError(rel.Field.Set(tx.Statement.Context, data, reflect.Append(reflectFieldValue, elem.Elem()).Interface()))
    				}
    Registered: Sun Oct 27 09:35:08 UTC 2024
    - Last Modified: Wed Jun 12 10:52:33 UTC 2024
    - 11.6K bytes
    - Viewed (0)
  2. cmd/callhome.go

    package cmd
    
    import (
    	"bytes"
    	"compress/gzip"
    	"context"
    	"encoding/json"
    	"errors"
    	"fmt"
    	"math/rand"
    	"net/url"
    	"time"
    
    	"github.com/minio/madmin-go/v3"
    )
    
    var callhomeLeaderLockTimeout = newDynamicTimeout(30*time.Second, 10*time.Second)
    
    // initCallhome will start the callhome task in the background.
    func initCallhome(ctx context.Context, objAPI ObjectLayer) {
    	if !globalCallhomeConfig.Enabled() {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri May 17 16:53:34 UTC 2024
    - 5.3K bytes
    - Viewed (0)
  3. cmd/admin-handler-utils.go

    // specific error.
    func toAdminAPIErrCode(ctx context.Context, err error) APIErrorCode {
    	if errors.Is(err, errErasureWriteQuorum) {
    		return ErrAdminConfigNoQuorum
    	}
    	return toAPIErrorCode(ctx, err)
    }
    
    // wraps export error for more context
    func exportError(ctx context.Context, err error, fname, entity string) APIError {
    	if entity == "" {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed Jul 03 07:17:20 UTC 2024
    - 8.4K bytes
    - Viewed (0)
  4. cmd/warm-backend.go

    type WarmBackend interface {
    	Put(ctx context.Context, object string, r io.Reader, length int64) (remoteVersionID, error)
    	Get(ctx context.Context, object string, rv remoteVersionID, opts WarmBackendGetOpts) (io.ReadCloser, error)
    	Remove(ctx context.Context, object string, rv remoteVersionID) error
    	InUse(ctx context.Context) (bool, error)
    }
    
    const probeObject = "probeobject"
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed Jul 03 07:17:20 UTC 2024
    - 3.9K bytes
    - Viewed (0)
  5. internal/dsync/drwmutex.go

    	// Combined timeout for the lock attempt.
    	ctx, cancel := context.WithTimeout(ctx, ds.Timeouts.Acquire)
    	defer cancel()
    
    	// Special context for NetLockers - do not use timeouts.
    	// Also, pass the trace context info if found for debugging
    	netLockCtx := context.Background()
    	tc, ok := ctx.Value(mcontext.ContextTraceKey).(*mcontext.TraceCtxt)
    	if ok {
    		netLockCtx = context.WithValue(netLockCtx, mcontext.ContextTraceKey, tc)
    	}
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Sep 09 15:49:49 UTC 2024
    - 20.4K bytes
    - Viewed (0)
  6. gorm.go

    	}
    
    	if config.PropagateUnscoped {
    		txConfig.PropagateUnscoped = true
    	}
    
    	if config.Context != nil || config.PrepareStmt || config.SkipHooks {
    		tx.Statement = tx.Statement.clone()
    		tx.Statement.DB = tx
    	}
    
    	if config.Context != nil {
    		tx.Statement.Context = config.Context
    	}
    
    	if config.PrepareStmt {
    		var preparedStmt *PreparedStmtDB
    
    Registered: Sun Oct 27 09:35:08 UTC 2024
    - Last Modified: Wed Oct 09 11:29:48 UTC 2024
    - 12.1K bytes
    - Viewed (0)
  7. cmd/erasure-server-pool.go

    func (z *erasureServerPools) StorageInfo(ctx context.Context, metrics bool) StorageInfo {
    	return globalNotificationSys.StorageInfo(ctx, z, metrics)
    }
    
    func (z *erasureServerPools) NSScanner(ctx context.Context, updates chan<- DataUsageInfo, wantCycle uint32, healScanMode madmin.HealScanMode) error {
    	// Updates must be closed before we return.
    	defer xioutil.SafeClose(updates)
    
    	ctx, cancel := context.WithCancel(ctx)
    	defer cancel()
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 89.8K bytes
    - Viewed (0)
  8. cmd/iam-store.go

    	getUsersSysType() UsersSysType
    	loadPolicyDoc(ctx context.Context, policy string, m map[string]PolicyDoc) error
    	loadPolicyDocWithRetry(ctx context.Context, policy string, m map[string]PolicyDoc, retries int) error
    	loadPolicyDocs(ctx context.Context, m map[string]PolicyDoc) error
    	loadUser(ctx context.Context, user string, userType IAMUserType, m map[string]UserIdentity) error
    	loadSecretKey(ctx context.Context, user string, userType IAMUserType) (string, error)
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Oct 14 16:35:37 UTC 2024
    - 83.2K bytes
    - Viewed (0)
  9. cmd/metrics-v3-cache.go

    		nodesUpDown:         newNodesUpDownCache(),
    	}
    }
    
    type nodesOnline struct {
    	Online, Offline int
    }
    
    func newNodesUpDownCache() *cachevalue.Cache[nodesOnline] {
    	loadNodesUpDown := func(ctx context.Context) (v nodesOnline, err error) {
    		v.Online, v.Offline = globalNotificationSys.GetPeerOnlineCount()
    		return
    	}
    	return cachevalue.NewFromFunc(1*time.Minute,
    		cachevalue.Opts{ReturnLastGood: true},
    		loadNodesUpDown)
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu May 09 00:51:34 UTC 2024
    - 8.1K bytes
    - Viewed (0)
  10. cmd/healthcheck-handler.go

    				apiErr := toAPIError(r.Context(), err)
    				writeResponse(w, apiErr.HTTPStatusCode, nil, mimeNone)
    			case http.MethodGet:
    				writeErrorResponse(r.Context(), w, toAPIError(r.Context(), err), r.URL)
    			}
    			return
    		}
    	}
    
    	if globalEtcdClient != nil {
    		// Borrowed from
    		// https://github.com/etcd-io/etcd/blob/main/etcdctl/ctlv3/command/ep_command.go#L118
    		ctx, cancel := context.WithTimeout(r.Context(), defaultContextTimeout)
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed Jun 26 07:44:34 UTC 2024
    - 6.9K bytes
    - Viewed (0)
Back to top