Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 23 for Falk (0.18 sec)

  1. cmd/metacache-walk.go

    		if s.walkMu != nil {
    			s.walkMu.Unlock()
    		}
    		if err != nil {
    			// Folder could have gone away in-between
    			if err != errVolumeNotFound && err != errFileNotFound {
    				internalLogOnceIf(ctx, err, "metacache-walk-scan-dir")
    			}
    			if opts.ReportNotFound && err == errFileNotFound && current == opts.BaseDir {
    				err = errFileNotFound
    			} else {
    				err = nil
    			}
    			diskHealthCheckOK(ctx, err)
    			return err
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Mon Apr 15 08:25:46 GMT 2024
    - 12.4K bytes
    - Viewed (0)
  2. cmd/object-api-interface.go

    	ListObjectVersions(ctx context.Context, bucket, prefix, marker, versionMarker, delimiter string, maxKeys int) (result ListObjectVersionsInfo, err error)
    	// Walk lists all objects including versions, delete markers.
    	Walk(ctx context.Context, bucket, prefix string, results chan<- ObjectInfo, opts WalkOptions) error
    
    	// Object operations.
    
    	// GetObjectNInfo returns a GetObjectReader that satisfies the
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sat Apr 20 09:05:54 GMT 2024
    - 16.9K bytes
    - Viewed (0)
  3. cmd/storage-interface.go

    	ListVols(ctx context.Context) (vols []VolInfo, err error)
    	StatVol(ctx context.Context, volume string) (vol VolInfo, err error)
    	DeleteVol(ctx context.Context, volume string, forceDelete bool) (err error)
    
    	// WalkDir will walk a directory on disk and return a metacache stream on wr.
    	WalkDir(ctx context.Context, opts WalkDirOptions, wr io.Writer) error
    
    	// Metadata operations
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Tue Apr 23 17:15:52 GMT 2024
    - 4.9K bytes
    - Viewed (0)
  4. docs/en/docs/advanced/sub-applications.md

    <img src="/img/tutorial/sub-applications/image02.png">
    
    If you try interacting with any of the two user interfaces, they will work correctly, because the browser will be able to talk to each specific app or sub-app.
    
    ### Technical Details: `root_path`
    
    Plain Text
    - Registered: Sun Apr 28 07:19:10 GMT 2024
    - Last Modified: Thu Apr 18 19:53:19 GMT 2024
    - 2.9K bytes
    - Viewed (0)
  5. cmd/batch-handlers.go

    	if err != nil {
    		return err
    	}
    
    	wk, err := workers.New(workerSize)
    	if err != nil {
    		// invalid worker size.
    		return err
    	}
    
    	walkQuorum := env.Get("_MINIO_BATCH_REPLICATION_WALK_QUORUM", "strict")
    	if walkQuorum == "" {
    		walkQuorum = "strict"
    	}
    
    	retryAttempts := ri.RetryAttempts
    	retry := false
    	for attempts := 1; attempts <= retryAttempts; attempts++ {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Mon Apr 08 14:11:38 GMT 2024
    - 55.2K bytes
    - Viewed (0)
  6. cmd/peer-s3-client.go

    	return makeBucketLocal(ctx, bucket, opts)
    }
    
    func (l localPeerS3Client) DeleteBucket(ctx context.Context, bucket string, opts DeleteBucketOptions) error {
    	return deleteBucketLocal(ctx, bucket, opts)
    }
    
    // client to talk to peer Nodes.
    type remotePeerS3Client struct {
    	node  Node
    	pools []int
    
    	// Function that returns the grid connection for this peer when initialized.
    	// Will return nil if the grid connection is not initialized yet.
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 14.8K bytes
    - Viewed (0)
  7. cmd/bootstrap-peer-server.go

    func registerBootstrapRESTHandlers(gm *grid.Manager) {
    	server := &bootstrapRESTServer{}
    	logger.FatalIf(serverVerifyHandler.Register(gm, server.VerifyHandler), "unable to register handler")
    }
    
    // client to talk to bootstrap NEndpoints.
    type bootstrapRESTClient struct {
    	gridConn *grid.Connection
    }
    
    // Verify function verifies the server config.
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 7.5K bytes
    - Viewed (0)
  8. maven-core/src/main/java/org/apache/maven/ReactorReader.java

            Path outputDirectory = Paths.get(project.getBuild().getOutputDirectory());
            if (!outputDirectory.toFile().exists()) {
                return true;
            }
    
            try (Stream<Path> outputFiles = Files.walk(outputDirectory)) {
                // Not using File#lastModified() to avoid a Linux JDK8 milliseconds precision bug: JDK-8177809.
                long artifactLastModified =
    Java
    - Registered: Sun Apr 28 03:35:10 GMT 2024
    - Last Modified: Fri Apr 12 10:50:18 GMT 2024
    - 21.3K bytes
    - Viewed (0)
  9. cmd/batch-rotate.go

    	if err != nil {
    		// invalid worker size.
    		return err
    	}
    
    	retryAttempts := ri.RetryAttempts
    	ctx, cancel := context.WithCancel(ctx)
    
    	results := make(chan ObjectInfo, 100)
    	if err := api.Walk(ctx, r.Bucket, r.Prefix, results, WalkOptions{
    		Marker: lastObject,
    		Filter: selectObj,
    	}); err != nil {
    		cancel()
    		// Do not need to retry if we can't list objects on source.
    		return err
    	}
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 14.2K bytes
    - Viewed (0)
  10. cmd/iam-object-store.go

    	ch := make(chan itemOrErr)
    
    	go func() {
    		defer xioutil.SafeClose(ch)
    
    		// Allocate new results channel to receive ObjectInfo.
    		objInfoCh := make(chan ObjectInfo)
    
    		if err := objAPI.Walk(ctx, minioMetaBucket, pathPrefix, objInfoCh, WalkOptions{}); err != nil {
    			select {
    			case ch <- itemOrErr{Err: err}:
    			case <-ctx.Done():
    			}
    			return
    		}
    
    		for obj := range objInfoCh {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Fri Apr 05 21:26:41 GMT 2024
    - 19.9K bytes
    - Viewed (0)
Back to top