Search Options

Results per page
Sort
Preferred Languages
Advance

Results 141 - 150 of 1,989 for error_1 (0.11 sec)

  1. internal/event/target/kafka.go

    // Validate KafkaArgs fields
    func (k KafkaArgs) Validate() error {
    	if !k.Enable {
    		return nil
    	}
    	if len(k.Brokers) == 0 {
    		return errors.New("no broker address found")
    	}
    	for _, b := range k.Brokers {
    		if _, err := xnet.ParseHost(b.String()); err != nil {
    			return err
    		}
    	}
    	if k.QueueDir != "" {
    		if !filepath.IsAbs(k.QueueDir) {
    			return errors.New("queueDir path should be absolute")
    		}
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 13.6K bytes
    - Viewed (0)
  2. cmd/iam-store.go

    	saveUserIdentity(ctx context.Context, name string, userType IAMUserType, u UserIdentity, opts ...options) error
    	saveGroupInfo(ctx context.Context, group string, gi GroupInfo) error
    	deletePolicyDoc(ctx context.Context, policyName string) error
    	deleteMappedPolicy(ctx context.Context, name string, userType IAMUserType, isGroup bool) error
    	deleteUserIdentity(ctx context.Context, name string, userType IAMUserType) error
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Oct 14 16:35:37 UTC 2024
    - 83.2K bytes
    - Viewed (0)
  3. internal/event/target/mqtt.go

    func (m MQTTArgs) Validate() error {
    	if !m.Enable {
    		return nil
    	}
    	u, err := xnet.ParseURL(m.Broker.String())
    	if err != nil {
    		return err
    	}
    	switch u.Scheme {
    	case "ws", "wss", "tcp", "ssl", "tls", "tcps":
    	default:
    		return errors.New("unknown protocol in broker address")
    	}
    	if m.QueueDir != "" {
    		if !filepath.IsAbs(m.QueueDir) {
    			return errors.New("queueDir path should be absolute")
    		}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 8.2K bytes
    - Viewed (0)
  4. docs/bucket/replication/sio-error.sh

    Poorna <******@****.***> 1716056341 -0700
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat May 18 18:19:01 UTC 2024
    - 1.7K bytes
    - Viewed (0)
  5. internal/event/target/nats.go

    }
    
    // Validate NATSArgs fields
    func (n NATSArgs) Validate() error {
    	if !n.Enable {
    		return nil
    	}
    
    	if n.Address.IsEmpty() {
    		return errors.New("empty address")
    	}
    
    	if n.Subject == "" {
    		return errors.New("empty subject")
    	}
    
    	if n.ClientCert != "" && n.ClientKey == "" || n.ClientCert == "" && n.ClientKey != "" {
    		return errors.New("cert and key must be specified as a pair")
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 12.9K bytes
    - Viewed (0)
  6. cmd/bucket-metadata.go

    	}
    }
    
    // Load - loads the metadata of bucket by name from ObjectLayer api.
    // If an error is returned the returned metadata will be default initialized.
    func readBucketMetadata(ctx context.Context, api ObjectLayer, name string) (BucketMetadata, error) {
    	if name == "" {
    		internalLogIf(ctx, errors.New("bucket name cannot be empty"), logger.WarningKind)
    		return BucketMetadata{}, errInvalidArgument
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 28 15:32:18 UTC 2024
    - 18.2K bytes
    - Viewed (0)
  7. cmd/erasure-decode.go

    			break
    		}
    
    		var err error
    		bufs, err = reader.Read(bufs)
    		if len(bufs) > 0 {
    			// Set only if there are be enough data for reconstruction.
    			// and only for expected errors, also set once.
    			if errors.Is(err, errFileNotFound) || errors.Is(err, errFileCorrupt) {
    				if derr == nil {
    					derr = err
    				}
    			}
    		} else if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 29 01:40:52 UTC 2024
    - 9.5K bytes
    - Viewed (0)
  8. cmd/erasure-server-pool-rebalance.go

    	}
    	if len(data) <= 4 {
    		return fmt.Errorf("rebalanceMeta: no data")
    	}
    
    	// Read header
    	switch binary.LittleEndian.Uint16(data[0:2]) {
    	case rebalMetaFmt:
    	default:
    		return fmt.Errorf("rebalanceMeta: unknown format: %d", binary.LittleEndian.Uint16(data[0:2]))
    	}
    	switch binary.LittleEndian.Uint16(data[2:4]) {
    	case rebalMetaVer:
    	default:
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 13:20:19 UTC 2024
    - 28.4K bytes
    - Viewed (0)
  9. cmd/bucket-handlers_test.go

    		}
    		if errorResponse.Resource != testCase.errorResponse.Resource {
    			t.Errorf("Test %d: %s: Expected the error resource to be `%s`, but instead found `%s`", i+1, instanceType, testCase.errorResponse.Resource, errorResponse.Resource)
    		}
    		if errorResponse.Message != testCase.errorResponse.Message {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 15:50:49 UTC 2024
    - 39.8K bytes
    - Viewed (0)
  10. cmd/update.go

    func releaseTagToReleaseTime(releaseTag string) (releaseTime time.Time, err error) {
    	fields := strings.Split(releaseTag, ".")
    	if len(fields) < 2 || len(fields) > 4 {
    		return releaseTime, fmt.Errorf("%s is not a valid release tag", releaseTag)
    	}
    	if fields[0] != "RELEASE" {
    		return releaseTime, fmt.Errorf("%s is not a valid release tag", releaseTag)
    	}
    	return time.Parse(MinioReleaseTagTimeLayout, fields[1])
    }
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 18.7K bytes
    - Viewed (0)
Back to top