Search Options

Results per page
Sort
Preferred Languages
Advance

Results 91 - 100 of 425 for arns (0.03 sec)

  1. buildscripts/verify-healing-empty-erasure-set.sh

    function start_minio_3_node() {
    	export MINIO_ROOT_USER=minio
    	export MINIO_ROOT_PASSWORD=minio123
    	export MINIO_ERASURE_SET_DRIVE_COUNT=6
    	export MINIO_CI_CD=1
    
    	start_port=$1
    	args=""
    	for i in $(seq 1 3); do
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 12 20:51:54 UTC 2024
    - 3.7K bytes
    - Viewed (0)
  2. internal/s3select/simdj/reader.go

    			}
    		}
    		if in.Error == io.EOF {
    			return
    		}
    	}
    }
    
    // NewReader - creates new JSON reader using readCloser.
    func NewReader(readCloser io.ReadCloser, args *json.ReaderArgs) *Reader {
    	r := Reader{
    		args:       args,
    		readCloser: &safeCloser{r: io.Reader(readCloser)},
    		decoded:    make(chan simdjson.Object, 1000),
    		input:      make(chan simdjson.Stream, 2),
    		exitReader: make(chan struct{}),
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue May 30 17:02:22 UTC 2023
    - 4.9K bytes
    - Viewed (0)
  3. prepare_stmt.go

    	}
    	return nil, ErrInvalidTransaction
    }
    
    func (db *PreparedStmtDB) ExecContext(ctx context.Context, query string, args ...interface{}) (result sql.Result, err error) {
    	stmt, err := db.prepare(ctx, db.ConnPool, false, query)
    	if err == nil {
    		result, err = stmt.ExecContext(ctx, args...)
    		if errors.Is(err, driver.ErrBadConn) {
    			db.Mux.Lock()
    			defer db.Mux.Unlock()
    			go stmt.Close()
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Thu Aug 22 11:02:05 UTC 2024
    - 6.6K bytes
    - Viewed (0)
  4. cmd/logging.go

    	}
    }
    
    func iamLogEvent(ctx context.Context, msg string, args ...interface{}) {
    	logger.Event(ctx, "iam", msg, args...)
    }
    
    func rebalanceLogIf(ctx context.Context, err error, errKind ...interface{}) {
    	logger.LogIf(ctx, "rebalance", err, errKind...)
    }
    
    func rebalanceLogEvent(ctx context.Context, msg string, args ...interface{}) {
    	logger.Event(ctx, "rebalance", msg, args...)
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jul 03 18:49:48 UTC 2024
    - 7.1K bytes
    - Viewed (0)
  5. docs/debugging/reorder-disks/main.go

    		}
    	}
    	return "", errors.New("format.json is corrupted")
    }
    
    func main() {
    	var node, args string
    
    	flag.StringVar(&node, "local-node-name", "", "the name of the local node")
    	flag.StringVar(&args, "args", "", "arguments passed to MinIO server")
    
    	flag.Parse()
    
    	localDisks, err := filterLocalDisks(node, args)
    	if err != nil {
    		log.Fatal(err)
    	}
    
    	if len(localDisks) == 0 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 5.4K bytes
    - Viewed (0)
  6. internal/event/errors.go

    }
    
    // ErrARNNotFound - ARN not found error.
    type ErrARNNotFound struct {
    	ARN ARN
    }
    
    func (err ErrARNNotFound) Error() string {
    	return fmt.Sprintf("ARN '%v' not found", err.ARN)
    }
    
    // ErrInvalidARN - invalid ARN error.
    type ErrInvalidARN struct {
    	ARN string
    }
    
    func (err ErrInvalidARN) Error() string {
    	return fmt.Sprintf("invalid ARN '%v'", err.ARN)
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jun 01 21:59:40 UTC 2021
    - 4.1K bytes
    - Viewed (0)
  7. guava-testlib/src/com/google/common/collect/testing/testers/Platform.java

     * This class is emulated in GWT.
     *
     * @author Hayward Chan
     */
    @GwtCompatible
    final class Platform {
    
      /** Format the template with args, only supports the placeholder {@code %s}. */
      static String format(String template, Object... args) {
        return String.format(Locale.ROOT, template, args);
      }
    
      /** See {@link ListListIteratorTester} */
      static int listListIteratorTesterNumIterations() {
        return 4;
      }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Dec 04 17:37:03 UTC 2017
    - 1.3K bytes
    - Viewed (0)
  8. internal/config/notify/parse.go

    			return nil, err
    		}
    		for id, args := range kafkaTargets {
    			if !args.Enable {
    				continue
    			}
    			args.TLS.RootCAs = transport.TLSClientConfig.RootCAs
    			t, err := target.NewKafkaTarget(id, args, logOnceIf)
    			if err != nil {
    				return nil, err
    			}
    			targets = append(targets, t)
    
    		}
    
    	case config.NotifyMQTTSubSys:
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 47K bytes
    - Viewed (0)
  9. internal/config/errors-utils.go

    // Msgf - Replace the current error's message
    func (u Err) Msgf(m string, args ...interface{}) Err {
    	e := u.Clone()
    	if len(args) == 0 {
    		e.msg = m
    	} else {
    		e.msg = fmt.Sprintf(m, args...)
    	}
    	return e
    }
    
    // Hint - Replace the current error's message
    func (u Err) Hint(m string, args ...interface{}) Err {
    	e := u.Clone()
    	e.hint = fmt.Sprintf(m, args...)
    	return e
    }
    
    // ErrFn function wrapper
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 14 17:11:51 UTC 2024
    - 3.8K bytes
    - Viewed (0)
  10. src/main/java/org/codelibs/core/lang/ConstructorUtil.java

         */
        public static <T> T newInstance(final Constructor<T> constructor, final Object... args)
                throws InstantiationRuntimeException, IllegalAccessRuntimeException {
            assertArgumentNotNull("constructor", constructor);
    
            try {
                return constructor.newInstance(args);
            } catch (final InstantiationException e) {
    Registered: Fri Nov 01 20:58:10 UTC 2024
    - Last Modified: Thu Mar 07 01:59:08 UTC 2024
    - 3.6K bytes
    - Viewed (0)
Back to top