Search Options

Results per page
Sort
Preferred Languages
Advance

Results 421 - 430 of 526 for mock (0.02 sec)

  1. cmd/admin-handlers.go

    	thisAddr, err := xnet.ParseHost(globalLocalNodeName)
    	if err != nil {
    		writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL)
    		return
    	}
    
    	globalProfilerMu.Lock()
    	defer globalProfilerMu.Unlock()
    
    	if globalProfiler == nil {
    		globalProfiler = make(map[string]minioProfiler, 10)
    	}
    
    	// Stop profiler of all types if already running
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 04 11:32:32 UTC 2024
    - 99.7K bytes
    - Viewed (0)
  2. tests/migrate_test.go

    			Migrator: m,
    		}
    	}
    	m := DB.Migrator()
    	mockM := wrapMockMigrator(m)
    
    	type NotTriggerUpdate struct {
    		ID  uint
    		F1  uint16
    		F2  uint32
    		F3  int
    		F4  int64
    		F5  string
    		F6  float32
    		F7  float64
    		F8  time.Time
    		F9  bool
    		F10 []byte
    	}
    
    	var err error
    	err = mockM.DropTable(&NotTriggerUpdate{})
    	AssertEqual(t, err, nil)
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Mon Mar 18 11:24:16 UTC 2024
    - 56.2K bytes
    - Viewed (0)
  3. internal/logger/logger.go

    	}
    	req.RLock()
    	defer req.RUnlock()
    
    	API := "SYSTEM"
    	switch {
    	case req.API != "":
    		API = req.API
    	case subsystem != "":
    		API += "." + subsystem
    	}
    
    	// Copy tags. We hold read lock already.
    	tags := make(map[string]interface{}, len(req.tags))
    	for _, entry := range req.tags {
    		tags[entry.Key] = entry.Val
    	}
    
    	// Get the cause for the Error
    	deploymentID := req.DeploymentID
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 22 09:43:48 UTC 2024
    - 12.4K bytes
    - Viewed (0)
  4. docs/bucket/versioning/README.md

        }
      }
    }
    ```
    
    ## Explore Further
    
    - [Use `minio-java` SDK with MinIO Server](https://min.io/docs/minio/linux/developers/java/minio-java.html)
    - [Object Lock and Immutablity Guide](https://min.io/docs/minio/linux/administration/object-management/object-retention.html)
    - [MinIO Admin Complete Guide](https://min.io/docs/minio/linux/reference/minio-mc-admin.html)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu May 04 21:43:52 UTC 2023
    - 11.9K bytes
    - Viewed (0)
  5. architecture/ambient/ztunnel-cni-lifecycle.md

    For more information on the rules, see the [CNI README](../../cni/README.md).
    This is done by an HTTP server running on `/var/run/istio-cni/pluginevent.sock`.
    
    An alternative flow is when a pod is enrolled into ambient mode after it starts up.
    In this case, the CNI Agent is watching for Pod events from the API server directly and performing the same setup.
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Jul 17 23:10:17 UTC 2024
    - 9.4K bytes
    - Viewed (0)
  6. docs/de/docs/deployment/docker.md

        Hier werden wir die Datei `requirements.txt` generieren.
    
    3. Installiere Poetry in dieser Docker-Phase.
    
    4. Kopiere die Dateien `pyproject.toml` und `poetry.lock` in das Verzeichnis `/tmp`.
    
        Da es `./poetry.lock*` verwendet (endet mit einem `*`), stürzt es nicht ab, wenn diese Datei noch nicht verfügbar ist.
    
    5. Generiere die Datei `requirements.txt`.
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Mon Aug 12 21:47:53 UTC 2024
    - 39K bytes
    - Viewed (0)
  7. src/cmd/asm/internal/asm/testdata/arm64error.s

    	STP	(R26, R27), 700(R2)                              // ERROR "cannot use REGTMP as source"
    	MOVK	$0, R10                                          // ERROR "zero shifts cannot be handled correctly"
    	MOVK	$(0<<32), R10                                    // ERROR "zero shifts cannot be handled correctly"
    	TLBI	PLDL1KEEP                                        // ERROR "illegal argument"
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Fri Dec 08 03:28:17 UTC 2023
    - 37.8K bytes
    - Viewed (0)
  8. tensorflow/c/eager/parallel_device/parallel_device_lib.cc

    // Allows a single op at a time to be launched without blocking.
    //
    // DeviceThread itself is thread-safe, in that StartExecute will block if there
    // is a pending execution. Since StartExecute is equivalent to grabbing a lock,
    // multiple DeviceThreads should always be accessed in the same order to avoid
    // deadlocks.
    class DeviceThread {
     public:
      // Starts a background thread waiting for `StartExecute`.
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Mon Oct 21 04:14:14 UTC 2024
    - 25.9K bytes
    - Viewed (0)
  9. cmd/bucket-policy-handlers_test.go

    				if _, ok := err.(BucketExists); !ok {
    					t.Logf("unexpected error: %T: %v", err, err)
    					return
    				}
    				mu.Lock()
    				errs++
    				mu.Unlock()
    				return
    			}
    			mu.Lock()
    			ok++
    			mu.Unlock()
    		}()
    	}
    	close(start)
    	wg.Wait()
    	if ok != 1 {
    		t.Fatalf("want 1 ok, got %d", ok)
    	}
    	if errs != n-1 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 15:50:49 UTC 2024
    - 32.9K bytes
    - Viewed (0)
  10. cmd/erasure-healing_test.go

    	}
    
    	setDisks := func(newDisks ...StorageAPI) {
    		objLayer.(*erasureServerPools).serverPools[0].erasureDisksMu.Lock()
    		copy(disks, newDisks)
    		objLayer.(*erasureServerPools).serverPools[0].erasureDisksMu.Unlock()
    	}
    	getDisk := func(n int) StorageAPI {
    		objLayer.(*erasureServerPools).serverPools[0].erasureDisksMu.Lock()
    		disk := disks[n]
    		objLayer.(*erasureServerPools).serverPools[0].erasureDisksMu.Unlock()
    		return disk
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 49K bytes
    - Viewed (0)
Back to top