Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 23 for movie (0.17 sec)

  1. cmd/metacache-stream_test.go

    	"testing"
    )
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Mon Sep 19 18:05:16 GMT 2022
    - 15K bytes
    - Viewed (0)
  2. internal/logger/target/kafka/kafka_scram_client_contrib.go

    		return err
    	}
    	x.ClientConversation = x.Client.NewConversation()
    	return nil
    }
    
    // Step takes a string provided from a server (or just an empty string for the
    // very first conversation step) and attempts to move the authentication
    // conversation forward.  It returns a string to be sent to the server or an
    // error if the server message is invalid.  Calling Step after a conversation
    // completes is also an error.
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Nov 09 04:04:01 GMT 2023
    - 3.3K bytes
    - Viewed (1)
  3. cmd/erasure-server-pool-decom.go

    							NoDecryption: true,
    							NoLock:       true,
    							NoAuditLog:   true,
    						})
    					if isErrObjectNotFound(err) || isErrVersionNotFound(err) {
    						// object deleted by the application, nothing to do here we move on.
    						ignore = true
    						stopFn(nil)
    						break
    					}
    					if err != nil && !ignore {
    						// if usage-cache.bin is not readable log and ignore it.
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Mon Apr 22 17:49:30 GMT 2024
    - 41.3K bytes
    - Viewed (1)
  4. internal/logger/console.go

    	// red banner along with the error message. Since the error
    	// message itself contains some colored text, we needed
    	// to use some ANSI control escapes to cursor color state
    	// and freely move in the screen.
    	for _, line := range strings.Split(errMsg, "\n") {
    		if len(line) == 0 {
    			// No more text to print, just quit.
    			break
    		}
    
    		for {
    			// Save the attributes of the current cursor helps
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Fri Feb 02 00:13:57 GMT 2024
    - 5.7K bytes
    - Viewed (0)
  5. cmd/xl-storage.go

    		}
    	}
    
    	return nil
    }
    
    // deleteFile deletes a file or a directory if its empty unless recursive
    // is set to true. If the target is successfully deleted, it will recursively
    // move up the tree, deleting empty parent directories until it finds one
    // with files in it. Returns nil for a non-empty directory even when
    // recursive is set to false.
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 84.7K bytes
    - Viewed (0)
  6. docs/metrics/prometheus/README.md

    ### 3. Configuring Prometheus
    
    #### 3.1 Authenticated Prometheus config
    
    > If MinIO is configured to expose metrics without authentication, you don't need to use `mc` to generate prometheus config. You can skip reading further and move to 3.2 section.
    
    Plain Text
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Fri Apr 12 15:49:30 GMT 2024
    - 7.1K bytes
    - Viewed (0)
  7. cmd/erasure-server-pool-rebalance.go

    							NoDecryption: true,
    							NoLock:       true,
    							NoAuditLog:   true,
    						})
    					if isErrObjectNotFound(err) || isErrVersionNotFound(err) {
    						// object deleted by the application, nothing to do here we move on.
    						ignore = true
    						stopFn(nil)
    						break
    					}
    					if err != nil {
    						failure = true
    						rebalanceLogIf(ctx, err)
    						stopFn(err)
    						continue
    					}
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Fri Apr 26 19:29:28 GMT 2024
    - 27.2K bytes
    - Viewed (0)
  8. cmd/erasure-server-pool.go

    			continue
    		}
    		err := pool.AbortMultipartUpload(ctx, bucket, object, uploadID, opts)
    		if err == nil {
    			return nil
    		}
    		if _, ok := err.(InvalidUploadID); ok {
    			// upload id not found move to next pool
    			continue
    		}
    		return err
    	}
    	return InvalidUploadID{
    		Bucket:   bucket,
    		Object:   object,
    		UploadID: uploadID,
    	}
    }
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Fri Apr 26 06:32:14 GMT 2024
    - 80.1K bytes
    - Viewed (0)
  9. internal/event/target/kafka_scram_client_contrib.go

    		return err
    	}
    	x.ClientConversation = x.Client.NewConversation()
    	return nil
    }
    
    // Step takes a string provided from a server (or just an empty string for the
    // very first conversation step) and attempts to move the authentication
    // conversation forward.  It returns a string to be sent to the server or an
    // error if the server message is invalid.  Calling Step after a conversation
    // completes is also an error.
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Nov 09 04:04:01 GMT 2023
    - 3.2K bytes
    - Viewed (0)
  10. cmd/config-migrate.go

    			URL:       &xnet.URL{},
    			AuthToken: "",
    		}
    	case "31":
    		// V31 -> V32
    		cfg.Notify.NSQ = make(map[string]target.NSQArgs)
    		cfg.Notify.NSQ["1"] = target.NSQArgs{}
    	}
    
    	// Move to latest.
    	cfg.Version = "33"
    
    	newCfg := newServerConfig()
    
    	config.SetRegion(newCfg, cfg.Region)
    	storageclass.SetStorageClass(newCfg, cfg.StorageClass)
    
    	for k, loggerArgs := range cfg.Logger.HTTP {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Wed Oct 18 18:05:24 GMT 2023
    - 5.4K bytes
    - Viewed (0)
Back to top