Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 23 for MOVE (0.15 sec)

  1. 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 May 05 19:28:20 GMT 2024
    - Last Modified: Thu Nov 09 04:04:01 GMT 2023
    - 3.3K bytes
    - Viewed (1)
  2. 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 May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 17:57:52 GMT 2024
    - 5.8K bytes
    - Viewed (0)
  3. 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 May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 12 15:49:30 GMT 2024
    - 7.1K bytes
    - Viewed (0)
  4. 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 May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 26 19:29:28 GMT 2024
    - 27.2K bytes
    - Viewed (0)
  5. 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 May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 20:08:20 GMT 2024
    - 80.5K bytes
    - Viewed (0)
  6. internal/s3select/csv/reader.go

    func (r *Reader) Read(dst sql.Record) (sql.Record, error) {
    	// If we have have any records left, return these before any error.
    	for len(r.current) <= r.recordsRead {
    		if r.err != nil {
    			return nil, r.err
    		}
    		// Move to next block
    		item, ok := <-r.queue
    		if !ok {
    			r.err = io.EOF
    			return nil, r.err
    		}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 8.9K bytes
    - Viewed (0)
  7. cmd/metacache-stream_test.go

    	"testing"
    )
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Sep 19 18:05:16 GMT 2022
    - 15K bytes
    - Viewed (0)
  8. cmd/admin-heal-ops.go

    		select {
    		case globalBackgroundHealRoutine.tasks <- task:
    			if serverDebugLog {
    				fmt.Printf("Task in the queue: %#v\n", task)
    			}
    		default:
    			// task queue is full, no more workers, we shall move on and heal later.
    			return nil
    		}
    		// Don't wait for result
    		return nil
    	}
    
    	// respCh must be set to wait for result.
    	// We make it size 1, so a result can always be written
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 25.1K bytes
    - Viewed (1)
  9. 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 May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 15:18:21 GMT 2024
    - 41.5K bytes
    - Viewed (1)
  10. 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 May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 84.7K bytes
    - Viewed (0)
Back to top