Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 22 for Kromer (0.15 sec)

  1. internal/config/notify/legacy.go

    		config.KV{
    			Key:   config.Enable,
    			Value: config.EnableOn,
    		},
    		config.KV{
    			Key: target.KafkaBrokers,
    			Value: func() string {
    				var brokers []string
    				for _, broker := range cfg.Brokers {
    					brokers = append(brokers, broker.String())
    				}
    				return strings.Join(brokers, config.ValueSeparator)
    			}(),
    		},
    		config.KV{
    			Key:   target.KafkaTopic,
    			Value: cfg.Topic,
    		},
    		config.KV{
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Mar 19 04:37:54 GMT 2024
    - 13.1K bytes
    - Viewed (0)
  2. internal/config/errors.go

    		`Use 'sudo setcap cap_net_bind_service=+ep /path/to/minio' to provide sufficient permissions`,
    	)
    
    	ErrTLSReadError = newErrFn(
    		"Cannot read the TLS certificate",
    		"Please check if the certificate has the proper owner and read permissions",
    		"",
    	)
    
    	ErrTLSUnexpectedData = newErrFn(
    		"Invalid TLS certificate",
    		"Please check your certificate",
    		"",
    	)
    
    	ErrTLSNoPassword = newErrFn(
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Mar 18 22:25:32 GMT 2024
    - 9.1K bytes
    - Viewed (0)
  3. docs/bucket/notifications/README.md

    MINIO_NOTIFY_AMQP_COMMENT        (sentence)  optionally add a comment to this setting
    ```
    
    Plain Text
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 84K bytes
    - Viewed (2)
  4. internal/config/notify/help.go

    			Optional:    true,
    			Type:        "on|off",
    		},
    		config.HelpKV{
    			Key:         target.AmqpDurable,
    			Description: "persist queue across broker restarts when set to 'on', default is 'off'",
    			Optional:    true,
    			Type:        "on|off",
    		},
    		config.HelpKV{
    			Key:         target.AmqpNoWait,
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Mar 19 04:37:54 GMT 2024
    - 18.8K bytes
    - Viewed (0)
  5. cmd/xl-storage_test.go

    		}
    	}
    }
    
    // Test xlStorage.VerifyFile()
    func TestXLStorageVerifyFile(t *testing.T) {
    	// We test 4 cases:
    	// 1) Whole-file bitrot check on proper file
    	// 2) Whole-file bitrot check on corrupted file
    	// 3) Streaming bitrot check on proper file
    	// 4) Streaming bitrot check on corrupted file
    
    	// create xlStorage test setup
    	storage, path, err := newXLStorageTestSetup(t)
    	if err != nil {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 11 17:45:28 GMT 2024
    - 66.7K bytes
    - Viewed (0)
  6. cmd/bucket-handlers_test.go

    		// expected Response.
    		expectedRespStatus int
    		locationResponse   []byte
    		errorResponse      APIErrorResponse
    		shouldPass         bool
    	}{
    		// Test case - 1.
    		// Tests for authenticated request and proper response.
    		{
    			bucketName:         bucketName,
    			accessKey:          credentials.AccessKey,
    			secretKey:          credentials.SecretKey,
    			expectedRespStatus: http.StatusOK,
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 39.5K bytes
    - Viewed (2)
  7. internal/config/notify/parse.go

    		}
    
    		queueDirEnv := target.EnvMQTTQueueDir
    		if k != config.Default {
    			queueDirEnv = queueDirEnv + config.Default + k
    		}
    
    		mqttArgs := target.MQTTArgs{
    			Enable:               enabled,
    			Broker:               *brokerURL,
    			Topic:                env.Get(topicEnv, kv.Get(target.MqttTopic)),
    			QoS:                  byte(qos),
    			User:                 env.Get(usernameEnv, kv.Get(target.MqttUsername)),
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 46.4K bytes
    - Viewed (0)
  8. helm-releases/minio-5.2.0.tgz

    "minio.fullname" .) | trunc 63 | trimSuffix "-" -}} {{- end -}} {{/* Properly format optional additional arguments to MinIO binary */}} {{- define "minio.extraArgs" -}} {{- range .Values.extraArgs -}} {{ " " }}{{ . }} {{- end -}} {{- end -}} {{/* Return the proper Docker Image Registry Secret Names */}} {{- define "minio.imagePullSecrets" -}} {{/* Helm 2.11 supports the assignment of a value to a variable defined in a different scope, but Helm 2.9 and 2.10 does not support it, so we need to implement this if-else...
    Others
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 10:14:37 GMT 2024
    - 21.7K bytes
    - Viewed (0)
  9. cmd/xl-storage-format-v2.go

    			// version of the object.
    			return x.setIdx(i, ventry)
    		case ObjectType:
    			return x.setIdx(i, ventry)
    		case DeleteType:
    			// Allowing delete marker to replaced with proper
    			// object data type as well, this is not S3 complaint
    			// behavior but kept here for future flexibility.
    			return x.setIdx(i, ventry)
    		}
    	}
    
    	// We did not find it, add it.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 23 05:07:37 GMT 2024
    - 63.6K bytes
    - Viewed (1)
  10. cmd/object-handlers_test.go

    		},
    		// Test case - 10.
    		// Case with proper components
    		{
    			bucketName: bucketName,
    			objectName: "etc/path/proper/.../etc",
    			byteRange:  "",
    			accessKey:  credentials.AccessKey,
    			secretKey:  credentials.SecretKey,
    
    			expectedContent: encodeResponse(getAPIErrorResponse(ctx,
    				getAPIError(ErrNoSuchKey),
    				getGetObjectURL("", bucketName, "etc/path/proper/.../etc"),
    				"", "")),
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 160K bytes
    - Viewed (0)
Back to top