- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 140 for _new (0.1 sec)
-
internal/logger/config.go
EnvKafkaQueueSize = "MINIO_AUDIT_KAFKA_QUEUE_SIZE" loggerTargetNamePrefix = "logger-" auditTargetNamePrefix = "audit-" ) var ( errInvalidQueueSize = errors.New("invalid queue_size value") errInvalidBatchSize = errors.New("invalid batch_size value") ) // Default KVS for loggerHTTP and loggerAuditHTTP var ( DefaultLoggerWebhookKVS = config.KVS{ config.KV{ Key: config.Enable,
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 15.8K bytes - Viewed (0) -
cmd/kms-handlers.go
// KMSCreateKeyHandler - POST /minio/kms/v1/key/create?key-id=<master-key-id> func (a kmsAPIHandlers) KMSCreateKeyHandler(w http.ResponseWriter, r *http.Request) { // If env variable MINIO_KMS_SECRET_KEY is populated, prevent creation of new keys ctx := newContext(r, w, "KMSCreateKey") defer logger.AuditLog(ctx, w, r, mustGetClaimsFromToken(r)) objectAPI, _ := validateAdminReq(ctx, w, r, policy.KMSCreateKeyAction) if objectAPI == nil { return
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 8.2K bytes - Viewed (0) -
cmd/bucket-metadata-sys.go
if diskBuckets.Contains(bucket) { continue } // doesn't exist on disk remove from memory. delete(sys.metadataMap, bucket) globalBucketMonitor.DeleteBucket(bucket) } } // Set - sets a new metadata in-memory. // Only a shallow copy is saved and fields with references // cannot be modified without causing a race condition, // so they should be replaced atomically and not appended to, etc.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 19.8K bytes - Viewed (0) -
cmd/net_test.go
}) } } func TestExtractHostPort(t *testing.T) { testCases := []struct { addr string host string port string expectedErr error }{ {"", "", "", errors.New("unable to process empty address")}, {"localhost:9000", "localhost", "9000", nil}, {"http://:9000/", "", "9000", nil}, {"http://8.8.8.8:9000/", "8.8.8.8", "9000", nil},
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Apr 19 08:43:09 UTC 2024 - 9.3K bytes - Viewed (0) -
cmd/object-lambda-handlers.go
} duration := time.Until(cred.Expiration) if duration > time.Hour || duration < time.Hour { // Always limit to 1 hour. duration = time.Hour } clnt, err := miniogo.New(host, &miniogo.Options{ Creds: credentials.NewStaticV4(cred.AccessKey, cred.SecretKey, cred.SessionToken), Secure: secure, Transport: globalRemoteTargetTransport, Region: globalSite.Region(), })
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 10.2K bytes - Viewed (0) -
cmd/storage-rest-client.go
final = resp.Final } // We can't reuse the response since it is sent upstream. return nil }) if err != nil { return cache, toStorageErr(err) } if final == nil { return cache, errors.New("no final cache") } return *final, nil } func (client *storageRESTClient) GetDiskID() (string, error) { if !client.IsOnlineWS() { // make sure to check if the disk is offline, since the underlying
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:51:27 UTC 2024 - 27.4K bytes - Viewed (0) -
internal/http/dial_linux.go
} if opts.DriveOPTimeout != nil { // Read deadlines are sufficient for now as per various // scenarios of hung node detection, we may add Write deadlines // if needed later on. return deadlineconn.New(conn).WithReadDeadline(opts.DriveOPTimeout()), nil } return conn, nil }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed May 22 23:07:14 UTC 2024 - 4.8K bytes - Viewed (0) -
cmd/global-heal.go
if v := globalHealConfig.GetWorkers(); v > 0 { numHealers = uint64(v) } healingLogEvent(ctx, fmt.Sprintf("Healing drive '%s' - use %d parallel workers.", tracker.disk.String(), numHealers)) jt, _ := workers.New(int(numHealers)) healEntryDone := func(name string) healEntryResult { return healEntryResult{ entryDone: true, name: name, } } healEntrySuccess := func(sz uint64) healEntryResult {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 31 14:48:50 UTC 2024 - 15.1K bytes - Viewed (0) -
internal/crypto/metadata.go
} if _, ok := metadata[MetaContext]; ok { return nil, true } return nil, false } // CreateMultipartMetadata adds the multipart flag entry to metadata // and returns modified metadata. It allocates a new metadata map if // metadata is nil. func CreateMultipartMetadata(metadata map[string]string) map[string]string { if metadata == nil { return map[string]string{MetaMultipart: ""} } metadata[MetaMultipart] = ""
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 17:40:33 UTC 2024 - 6.4K bytes - Viewed (0) -
cmd/untar.go
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Apr 04 12:04:40 UTC 2024 - 6K bytes - Viewed (0)