- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 226 for Input (0.27 sec)
-
cmd/xl-storage-errors.go
return errors.Is(err, syscall.ENOSPC) } // Invalid argument, unsupported flags such as O_DIRECT func isSysErrInvalidArg(err error) bool { return errors.Is(err, syscall.EINVAL) } // Input/output error func isSysErrIO(err error) bool { return errors.Is(err, syscall.EIO) } // Check if the given error corresponds to EISDIR (is a directory). func isSysErrIsDir(err error) bool {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Mar 06 16:56:29 GMT 2023 - 3.8K bytes - Viewed (0) -
helm/minio/templates/_helper_create_bucket.txt
# Ensure bucket exists, purging if asked to createBucket() { BUCKET=$1 POLICY=$2 PURGE=$3 VERSIONING=$4 OBJECTLOCKING=$5 # Purge the bucket, if set & exists # Since PURGE is user input, check explicitly for `true` if [ $PURGE = true ]; then if checkBucketExists $BUCKET; then echo "Purging bucket '$BUCKET'." set +e # don't exit if this fails ${MC} rm -r --force myminio/$BUCKET
Plain Text - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Jan 12 18:18:57 GMT 2024 - 3.5K bytes - Viewed (0) -
cmd/batch-rotate.go
Key string `yaml:"key" json:"key"` Context string `yaml:"context" json:"context"` kmsContext kms.Context `msg:"-"` } // Validate validates input key rotation encryption options. func (e BatchJobKeyRotateEncryption) Validate() error { if e.Type != sses3 && e.Type != ssekms { return errInvalidArgument }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 14.2K bytes - Viewed (0) -
docs/batch-jobs/README.md
- Fine grained filtering is available to pick relevant objects from source to copy from MinIO batch jobs framework also provides - Retrying a failed job automatically driven by user input - Monitoring job progress in real-time - Send notifications upon completion or failure to user configured target Following YAML describes the structure of a replication job, each value is documented and self-describing.
Plain Text - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Oct 06 06:00:43 GMT 2022 - 4.8K bytes - Viewed (0) -
cmd/http-tracer.go
// no subscribers nothing to trace. return } tt := madmin.TraceInternal if strings.HasPrefix(tc.FuncName, "s3.") { tt = madmin.TraceS3 } // Calculate input body size with headers reqHeaders := r.Header.Clone() reqHeaders.Set("Host", r.Host) if len(r.TransferEncoding) == 0 { reqHeaders.Set("Content-Length", strconv.Itoa(int(r.ContentLength))) } else {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Nov 21 01:09:35 GMT 2023 - 5.9K bytes - Viewed (0) -
cmd/typed-errors.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package cmd import ( "errors" ) // errInvalidArgument means that input argument is invalid. var errInvalidArgument = errors.New("Invalid arguments specified") // errMethodNotAllowed means that method is not allowed. var errMethodNotAllowed = errors.New("Method not allowed")
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 5.3K bytes - Viewed (0) -
internal/config/cache/cache.go
clnt *http.Client } var configLock sync.RWMutex // Enabled - indicates if cache is enabled or not func (c *Config) Enabled() bool { return c.Enable && c.Endpoint != "" } // MatchesSize verifies if input 'size' falls under cacheable threshold func (c Config) MatchesSize(size int64) bool { configLock.RLock() defer configLock.RUnlock() return c.Enable && c.BlockSize > 0 && size <= c.BlockSize }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 5.6K bytes - Viewed (0) -
cmd/erasure-sets_test.go
if crcHashElement := hashKey("UNKNOWN", "This will fail", 0, testUUID); crcHashElement != -1 { t.Errorf("Test: Expected \"-1\" but got \"%v\"", crcHashElement) } } // TestNewErasure - tests initialization of all input disks // and constructs a valid `Erasure` object func TestNewErasureSets(t *testing.T) { ctx, cancel := context.WithCancel(context.Background()) defer cancel() nDisks := 16 // Maximum disks.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Feb 12 07:21:56 GMT 2024 - 6.9K bytes - Viewed (0) -
internal/event/target/mqtt.go
"github.com/minio/minio/internal/once" "github.com/minio/minio/internal/store" xnet "github.com/minio/pkg/v2/net" ) const ( reconnectInterval = 5 * time.Second storePrefix = "minio" ) // MQTT input constants const ( MqttBroker = "broker" MqttTopic = "topic" MqttQoS = "qos" MqttUsername = "username" MqttPassword = "password"
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Oct 07 15:07:38 GMT 2023 - 8.2K bytes - Viewed (0) -
cmd/bucket-replication.go
// Either already satisfied or worker count changed while we waited for the lock. return } for len(p.workers) < n { input := make(chan ReplicationWorkerOperation, 10000) p.workers = append(p.workers, input) go p.AddWorker(input, &p.activeWorkers) } for len(p.workers) > n { worker := p.workers[len(p.workers)-1] p.workers = p.workers[:len(p.workers)-1]
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:09:56 GMT 2024 - 112.2K bytes - Viewed (1)