Search Options

Results per page
Sort
Preferred Languages
Advance

Results 91 - 100 of 677 for Contexto (0.15 sec)

  1. internal/logger/audit.go

    // SetAuditEntry sets Audit info in the context.
    func SetAuditEntry(ctx context.Context, audit *audit.Entry) context.Context {
    	if ctx == nil {
    		LogIf(context.Background(), "audit", fmt.Errorf("context is nil"))
    		return nil
    	}
    	return context.WithValue(ctx, contextAuditKey, audit)
    }
    
    // GetAuditEntry returns Audit entry if set.
    func GetAuditEntry(ctx context.Context) *audit.Entry {
    	if ctx != nil {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Sep 24 17:13:00 UTC 2024
    - 4.6K bytes
    - Viewed (0)
  2. internal/dsync/dsync-client_test.go

    }
    
    func (restClient *ReconnectRESTClient) Lock(ctx context.Context, args LockArgs) (status bool, err error) {
    	return restClient.Call("/v1/lock", args)
    }
    
    func (restClient *ReconnectRESTClient) RUnlock(ctx context.Context, args LockArgs) (status bool, err error) {
    	return restClient.Call("/v1/runlock", args)
    }
    
    func (restClient *ReconnectRESTClient) Unlock(ctx context.Context, args LockArgs) (status bool, err error) {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Jan 20 17:36:09 UTC 2022
    - 4.4K bytes
    - Viewed (0)
  3. tensorflow/c/eager/c_api_unified_experimental.h

    // Creates a new TensorFlow function. A Function is an execution context, and as
    // such it can trace operations through TF_ExecuteOperation. After completing
    // tracing, a function can be obtained by TF_FinalizeFunction.
    TF_ExecutionContext* TF_CreateFunction(const char* fn_name, TF_Status* status);
    
    // Creates a context for eager execution of operations.
    TF_ExecutionContext* TF_NewEagerExecutionContext(TFE_ContextOptions*,
    Registered: Tue Oct 29 12:39:09 UTC 2024
    - Last Modified: Sun Oct 24 11:27:00 UTC 2021
    - 7K bytes
    - Viewed (0)
  4. tests/transaction_test.go

    		user2 = *GetUser("transaction-nested-2", Config{})
    	)
    
    	if err := transaction(context.Background(), DB, func(ctx context.Context, tx *gorm.DB) error {
    		tx.Create(&user)
    
    		if err := tx.First(&User{}, "name = ?", user.Name).Error; err != nil {
    			t.Fatalf("Should find saved record")
    		}
    
    		if err := transaction(ctx, tx, func(ctx context.Context, tx1 *gorm.DB) error {
    			tx1.Create(&user1)
    
    Registered: Sun Oct 27 09:35:08 UTC 2024
    - Last Modified: Sat Sep 14 12:58:29 UTC 2024
    - 12.9K bytes
    - Viewed (0)
  5. cmd/batch-expire.go

    	return nil
    }
    
    // Notify notifies notification endpoint if configured regarding job failure or success.
    func (r BatchJobExpire) Notify(ctx context.Context, body io.Reader) error {
    	if r.NotificationCfg.Endpoint == "" {
    		return nil
    	}
    
    	ctx, cancel := context.WithTimeout(ctx, 10*time.Second)
    	defer cancel()
    
    	req, err := http.NewRequestWithContext(ctx, http.MethodPost, r.NotificationCfg.Endpoint, body)
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed Sep 18 17:59:03 UTC 2024
    - 21.9K bytes
    - Viewed (0)
  6. 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)
  7. schema/field.go

    	Schema                 *Schema
    	EmbeddedSchema         *Schema
    	OwnerSchema            *Schema
    	ReflectValueOf         func(context.Context, reflect.Value) reflect.Value
    	ValueOf                func(context.Context, reflect.Value) (value interface{}, zero bool)
    	Set                    func(context.Context, reflect.Value, interface{}) error
    	Serializer             SerializerInterface
    	NewValuePool           FieldNewValuePool
    
    Registered: Sun Oct 27 09:35:08 UTC 2024
    - Last Modified: Mon Apr 15 03:20:20 UTC 2024
    - 32K bytes
    - Viewed (0)
  8. 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)
  9. src/cmd/cgo/ast.go

    	ctxSelector
    )
    
    // walk walks the AST x, calling visit(f, x, context) for each node.
    func (f *File) walk(x interface{}, context astContext, visit func(*File, interface{}, astContext)) {
    	visit(f, x, context)
    	switch n := x.(type) {
    	case *ast.Expr:
    		f.walk(*n, context, visit)
    
    	// everything else just recurs
    	default:
    		f.walkUnexpected(x, context, visit)
    
    	case nil:
    
    Registered: Tue Oct 29 11:13:09 UTC 2024
    - Last Modified: Mon Oct 14 15:47:06 UTC 2024
    - 14.3K bytes
    - Viewed (0)
  10. 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)
Back to top