- Sort Score
- Num 10 results
- Language All
Results 371 - 380 of 666 for Consts (0.07 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
cmd/metrics-v3-cluster-iam.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package cmd import ( "context" "sync/atomic" "time" ) const ( lastSyncDurationMillis = "last_sync_duration_millis" pluginAuthnServiceFailedRequestsMinute = "plugin_authn_service_failed_requests_minute"
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Thu May 02 08:20:42 GMT 2024 - 4.5K bytes - Click Count (0) -
internal/store/batch.go
package store import ( "context" "errors" "sync" "time" ) // ErrBatchFull indicates that the batch is full var ErrBatchFull = errors.New("batch is full") const defaultCommitTimeout = 30 * time.Second // Batch represents an ordered batch type Batch[I any] struct { items []I limit uint32 store Store[I] quitCh chan struct{} sync.Mutex }
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Sep 06 23:06:30 GMT 2024 - 2.9K bytes - Click Count (0) -
cmd/os_unix.go
if osIsExist(err) { return nil } return err } return nil } // The buffer must be at least a block long. // refer https://github.com/golang/go/issues/24015 const blockSize = 8 << 10 // 8192 // By default at least 128 entries in single getdents call (1MiB buffer) var ( direntPool = bpool.Pool[*[]byte]{ New: func() *[]byte { buf := make([]byte, blockSize*128)
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 9.3K bytes - Click Count (0) -
cmd/untar.go
if bytes.Equal(f.header, z[:len(f.header)]) { return f.f } } return formatUnknown } //go:generate stringer -type=format -trimprefix=format $GOFILE type format int const ( formatUnknown format = iota formatGzip formatZstd formatLZ4 formatS2 formatBZ2 ) var magicHeaders = []struct { header []byte f format }{ { header: []byte{0x1f, 0x8b, 8},
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Tue Feb 18 16:25:55 GMT 2025 - 6K bytes - Click Count (2) -
cmd/xl-storage-format-utils_test.go
xhttp.AmzBucketReplicationStatus: "", xhttp.ContentType: "application/json", }, }, } for _, tt := range tests { t.Run(tt.name, func(t *testing.T) { const n = 100 want := hashDeterministicString(tt.arg) m := tt.arg for range n { if got := hashDeterministicString(m); got != want { t.Errorf("hashDeterministicString() = %v, want %v", got, want) } }Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 7.1K bytes - Click Count (0) -
cmd/object-lambda-handlers.go
Type: "IAMUser", PrincipalID: cred.ParentUser, AccessKeyID: cred.AccessKey, }, } return eventData, nil } func fwdHeadersToS3(h http.Header, w http.ResponseWriter) { const trim = "x-amz-fwd-header-" for k, v := range h { if stringsHasPrefixFold(k, trim) { w.Header()[k[len(trim):]] = v } } } func fwdStatusToAPIError(statusCode int, resp *http.Response) *APIError {
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Jul 18 21:56:31 GMT 2025 - 6.5K bytes - Click Count (0) -
internal/crypto/metadata.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package crypto import ( xhttp "github.com/minio/minio/internal/http" ) const ( // MetaMultipart indicates that the object has been uploaded // in multiple parts - via the S3 multipart API. MetaMultipart = "X-Minio-Internal-Encrypted-Multipart"
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Mon Jun 10 17:40:33 GMT 2024 - 6.4K bytes - Click Count (0) -
internal/handlers/forwarder.go
package handlers import ( "context" "net" "net/http" "net/http/httputil" "net/url" "strings" "time" "github.com/minio/minio/internal/bpool" ) const defaultFlushInterval = time.Duration(100) * time.Millisecond // Forwarder forwards all incoming HTTP requests to configured transport. type Forwarder struct { RoundTripper http.RoundTripper PassHost bool
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Tue Feb 18 16:25:55 GMT 2025 - 5.7K bytes - Click Count (0) -
internal/http/server.go
) var ( // GlobalMinIOVersion - is sent in the header to all http targets GlobalMinIOVersion string // GlobalDeploymentID - is sent in the header to all http targets GlobalDeploymentID string ) const ( // DefaultIdleTimeout for idle inactive connections DefaultIdleTimeout = 30 * time.Second // DefaultReadHeaderTimeout for very slow inactive connections DefaultReadHeaderTimeout = 30 * time.Second
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 6.5K bytes - Click Count (0) -
build-logic-commons/module-identity/src/main/kotlin/gradlebuild/identity/extension/GradleModuleExtension.kt
/** * A project extension which describes a module of a Gradle distribution. */ abstract class GradleModuleExtension(val tasks: TaskContainer, val objects: ObjectFactory) { companion object { const val NAME: String = "gradleModule" } @get:Nested abstract val identity: ModuleIdentity fun identity(action: ModuleIdentity.() -> Unit) { action(identity) } /**
Created: Wed Apr 01 11:36:16 GMT 2026 - Last Modified: Wed Mar 11 22:40:18 GMT 2026 - 4.8K bytes - Click Count (0)