Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 100 for justru (0.2 sec)

  1. cmd/os-rename_nolinux.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package cmd
    
    import (
    	"os"
    )
    
    // RenameSys is low level call in case of non-Linux this just uses os.Rename()
    func RenameSys(src, dst string) (err error) {
    	return os.Rename(src, dst)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Feb 15 01:09:38 GMT 2024
    - 985 bytes
    - Viewed (0)
  2. internal/logger/target/kafka/kafka_scram_client_contrib.go

    	if err != nil {
    		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
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Nov 09 04:04:01 GMT 2023
    - 3.3K bytes
    - Viewed (1)
  3. cmd/xl-storage-meta-inline.go

    			keys = append(keys, foundKey)
    			plSize += len(foundKey)
    		} else {
    			keys = append(keys, []byte(newKey))
    			plSize += len(newKey)
    			found = true
    		}
    	}
    	// If not found, just return.
    	if !found {
    		return false
    	}
    
    	// Reserialize...
    	x.serialize(plSize, keys, vals)
    	return true
    }
    
    // remove will remove one or more keys.
    // Returns true if any key was found.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 9.5K bytes
    - Viewed (0)
  4. internal/logger/console.go

    	// 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
    			// us save the text color of the passed error message
    			ansiSaveAttributes()
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 17:57:52 GMT 2024
    - 5.8K bytes
    - Viewed (0)
  5. cmd/untar.go

    			wg.Wait()
    			extra := ""
    			if n > 0 {
    				extra = fmt.Sprintf(" after %d successful object(s)", n)
    			}
    			return fmt.Errorf("tar file error: %w%s", err, extra)
    
    		// if the header is nil, just skip it (not sure how this happens)
    		case header == nil:
    			continue
    		}
    
    		name := header.Name
    		switch path.Clean(name) {
    		case ".", slashSeparator:
    			continue
    		}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 6K bytes
    - Viewed (0)
  6. docs/kms/README.md

    ## Quick Start
    
    Plain Text
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 7.1K bytes
    - Viewed (0)
  7. helm/minio/README.md

    ```
    
    When using `Cilium` as a CNI in your cluster, please edit the `flavor` field to `cilium`.
    
    With NetworkPolicy enabled, traffic will be limited to just port 9000.
    
    For more precise policy, set `networkPolicy.allowExternal=true`. This will
    only allow pods with the generated client label to connect to MinIO.
    This label will be displayed in the output of a successful install.
    Plain Text
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Jan 24 07:27:57 GMT 2024
    - 10.9K bytes
    - Viewed (0)
  8. cmd/object-handlers.go

    					// this basically means that we do not have the Data for the object
    					// cached yet
    					update = true
    				})
    				if !update {
    					// No update is needed means we have written already to the client just return here.
    					return
    				}
    			}
    		}
    
    		if errors.Is(err, cache.ErrKeyMissing) {
    			update = true
    		}
    	}
    
    	// Validate pre-conditions if any.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu May 02 20:15:54 GMT 2024
    - 125.2K bytes
    - Viewed (0)
  9. internal/s3select/select.go

    		// make a buffer with a reasonable capacity.
    		return bytes.NewBuffer(make([]byte, 0, maxRecordSize))
    	},
    }
    
    var bufioWriterPool = sync.Pool{
    	New: func() interface{} {
    		// io.Discard is just used to create the writer. Actual destination
    		// writer is set later by Reset() before using it.
    		return bufio.NewWriter(xioutil.Discard)
    	},
    }
    
    // UnmarshalXML - decodes XML data.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Nov 06 22:26:08 GMT 2023
    - 21K bytes
    - Viewed (0)
  10. cmd/erasure-server-pool-rebalance.go

    				if filterLifecycle(bucket, version.Name, version) {
    					expired++
    					continue
    				}
    
    				// any object with only single DEL marker we don't need
    				// to rebalance, just skip it, this also includes
    				// any other versions that have already expired.
    				remainingVersions := len(fivs.Versions) - expired
    				if version.Deleted && remainingVersions == 1 {
    					rebalanced++
    					continue
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 26 19:29:28 GMT 2024
    - 27.2K bytes
    - Viewed (0)
Back to top