- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 41 for Kissling (0.15 sec)
-
docs/debugging/xl-meta/main.go
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 24 17:56:22 GMT 2024 - 20.2K bytes - Viewed (1) -
internal/crypto/metadata_test.go
}, // 1 { ExpectedErr: Errorf("The object metadata is missing the internal sealed key for SSE-S3"), Metadata: map[string]string{MetaIV: "", MetaAlgorithm: ""}, DataKey: []byte{}, KeyID: "", SealedKey: SealedKey{}, }, // 2 { ExpectedErr: Errorf("The object metadata is missing the internal KMS key-ID for SSE-S3"),
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Feb 02 00:13:57 GMT 2024 - 18.7K bytes - Viewed (0) -
cmd/erasure-object_test.go
buf := make([]byte, smallFileThreshold*16) if _, err = io.ReadFull(crand.Reader, buf); err != nil { t.Fatal(err) } // Test use case 1: All disks are online, xl.meta are present, but data are missing _, err = obj.PutObject(ctx, bucket, object, mustGetPutObjReader(t, bytes.NewReader(buf), int64(len(buf)), "", ""), opts) if err != nil { t.Fatal(err) } for _, disk := range xl.getDisks() {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Jan 30 20:43:25 GMT 2024 - 36.8K bytes - Viewed (0) -
cmd/bucket-targets.go
lastOnline time.Time lastHCAt time.Time offlineDuration time.Duration latency latencyStat } // isOffline returns current liveness result of remote target. Add endpoint to // healthCheck map if missing and default to online status func (sys *BucketTargetSys) isOffline(ep *url.URL) bool { sys.hMutex.RLock() defer sys.hMutex.RUnlock() if h, ok := sys.hc[ep.Host]; ok { return !h.Online } go sys.initHC(ep)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:09:56 GMT 2024 - 20.9K bytes - Viewed (0) -
cmd/erasure-server-pool-rebalance.go
} z.rebalMu.Unlock() return nil } // updates rebalance.bin from let's say 2 pool setup in the middle // of a rebalance, was expanded can cause z.rebalMeta to be outdated // due to a missing new pool. This function tries to handle this // scenario, albeit rare it seems to have occurred in the wild. // // since we do not explicitly disallow it, but it is okay for them // expand and then we continue to rebalance.
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) -
cmd/xl-storage-disk-id-check.go
if contextCanceled(ctx) { return ctx, done, ctx.Err() } if p.health.status.Load() != diskHealthOK { return ctx, done, errFaultyDisk } // Verify if the disk is not stale // - missing format.json (unformatted drive) // - format.json is valid but invalid 'uuid' if err = p.checkDiskStale(); err != nil { return ctx, done, err } // Disallow recursive tracking to avoid deadlocks.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 33K bytes - Viewed (0) -
cmd/object-multipart-handlers.go
return } clientETag, err := etag.FromContentMD5(r.Header) if err != nil { writeErrorResponse(ctx, w, errorCodes.ToAPIErr(ErrInvalidDigest), r.URL) return } // if Content-Length is unknown/missing, throw away size := r.ContentLength rAuthType := getRequestAuthType(r) // For auth type streaming signature, we need to gather a different content length. switch rAuthType {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Mar 28 17:44:56 GMT 2024 - 39K bytes - Viewed (0) -
docs/site-replication/run-multi-site-ldap.sh
if [ $? -ne 0 ]; then echo "policy mapping missing, exiting.." exit_1 fi ./mc admin user info minio2 "uid=dillon,ou=people,ou=swengg,dc=min,dc=io" if [ $? -ne 0 ]; then echo "policy mapping missing, exiting.." exit_1 fi ./mc admin user info minio3 "uid=dillon,ou=people,ou=swengg,dc=min,dc=io" if [ $? -ne 0 ]; then echo "policy mapping missing, exiting.." exit_1 fi # LDAP simple user
Shell Script - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Feb 14 04:51:23 GMT 2024 - 10K bytes - Viewed (1) -
internal/logger/target/kafka/kafka.go
// Sending a value on logCh must hold read lock on logChMu (to avoid closing) logCh chan interface{} logChMu sync.RWMutex // store to persist and replay the logs to the target // to avoid missing events when the target is down. store store.Store[interface{}] storeCtxCancel context.CancelFunc initKafkaOnce once.Init initQueueStoreOnce once.Init client sarama.Client
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 10.1K bytes - Viewed (1) -
docs/site-replication/run-multi-site-minio-idp.sh
./mc admin user info minio1 foobar if [ $? -ne 0 ]; then echo "policy mapping missing on 'minio1', exiting.." exit_1 fi ./mc admin user info minio2 foobar if [ $? -ne 0 ]; then echo "policy mapping missing on 'minio2', exiting.." exit_1 fi ./mc admin user info minio3 foobar if [ $? -ne 0 ]; then echo "policy mapping missing on 'minio3', exiting.." exit_1 fi
Shell Script - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Mar 07 00:19:24 GMT 2024 - 11.9K bytes - Viewed (0)