- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 289 for related (0.16 sec)
-
internal/mcontext/ctxt.go
type ContextTraceType string // ContextTraceKey is the key of TraceCtxt saved in a Golang context const ContextTraceKey = ContextTraceType("ctx-trace-info") // TraceCtxt holds related tracing data of a http request. type TraceCtxt struct { RequestRecorder *xhttp.RequestRecorder ResponseRecorder *xhttp.ResponseRecorder FuncName string AmzReqID string
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Dec 06 17:27:26 GMT 2022 - 1.3K bytes - Viewed (0) -
internal/rest/rpc-stats.go
} if v := atomic.LoadUint64(&globalStats.tcpDialCount); v > 0 { s.DialAvgDuration = atomic.LoadUint64(&globalStats.tcpDialTotalDur) / v } return s } // Return a function which update the global stats related to tcp connections func setupReqStatsUpdate(req *http.Request) (*http.Request, func()) { var dialStart, dialEnd int64 trace := &httptrace.ClientTrace{ ConnectStart: func(network, addr string) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Sep 29 16:27:58 GMT 2022 - 2.3K bytes - Viewed (0) -
cmd/mrf.go
versionID string versions []byte setIndex, poolIndex int queued time.Time scanMode madmin.HealScanMode } // mrfState sncapsulates all the information // related to the global background MRF. type mrfState struct { opCh chan partialOperation } // Add a partial S3 operation (put/delete) when one or more disks are offline. func (m *mrfState) addPartialOp(op partialOperation) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 23 17:15:52 GMT 2024 - 3.2K bytes - Viewed (0) -
cmd/object-api-errors.go
} // Bucket related errors. // BucketNameInvalid - bucketname provided is invalid. type BucketNameInvalid GenericError // Error returns string an error formatted as the given text. func (e BucketNameInvalid) Error() string { return "Bucket name invalid: " + e.Bucket } // Object related errors. // ObjectNameInvalid - object name provided is invalid.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun May 05 16:56:21 GMT 2024 - 21.3K bytes - Viewed (0) -
internal/config/identity/openid/openid.go
return c, nil } // ErrProviderConfigNotFound - represents a non-existing provider error. var ErrProviderConfigNotFound = errors.New("provider configuration not found") // GetConfigInfo - returns configuration and related info for the given IDP // provider. func (r *Config) GetConfigInfo(s config.Config, cfgName string) ([]madmin.IDPCfgInfo, error) { openIDConfigs, err := s.GetAvailableTargets(config.IdentityOpenIDSubSys) if err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Nov 16 04:42:31 GMT 2023 - 16.5K bytes - Viewed (0) -
cmd/api-errors.go
ErrInvalidTagDirective ErrPolicyAlreadyAttached ErrPolicyNotAttached ErrExcessData // Add new error codes here. // SSE-S3/SSE-KMS related API errors ErrInvalidEncryptionMethod ErrInvalidEncryptionKeyID // Server-Side-Encryption (with Customer provided key) related API errors. ErrInsecureSSECustomerRequest ErrSSEMultipartEncrypted ErrSSEEncryptedObject ErrInvalidEncryptionParameters
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun May 05 16:56:21 GMT 2024 - 91.4K bytes - Viewed (6) -
internal/config/callhome/callhome.go
package callhome import ( "sync" "time" "github.com/minio/minio/internal/config" "github.com/minio/pkg/v2/env" ) // Callhome related keys const ( Enable = "enable" Frequency = "frequency" ) // DefaultKVS - default KV config for subnet settings var DefaultKVS = config.KVS{ config.KV{ Key: Enable, Value: "off", },
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Sep 04 19:57:37 GMT 2023 - 2.6K bytes - Viewed (0) -
internal/config/cache/cache.go
"time" "github.com/dustin/go-humanize" "github.com/minio/minio/internal/config" xhttp "github.com/minio/minio/internal/http" "github.com/minio/pkg/v2/env" "github.com/tinylib/msgp/msgp" ) // Cache related keys const ( Enable = "enable" Endpoint = "endpoint" BlockSize = "block_size" EnvEnable = "MINIO_CACHE_ENABLE" EnvEndpoint = "MINIO_CACHE_ENDPOINT" EnvBlockSize = "MINIO_CACHE_BLOCK_SIZE" )
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) -
internal/event/target/nats.go
"github.com/minio/minio/internal/once" "github.com/minio/minio/internal/store" xnet "github.com/minio/pkg/v2/net" "github.com/nats-io/nats.go" "github.com/nats-io/stan.go" ) // NATS related constants const ( NATSAddress = "address" NATSSubject = "subject" NATSUsername = "username" NATSPassword = "password" NATSToken = "token" NATSTLS = "tls"
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Feb 27 18:11:55 GMT 2024 - 12.8K bytes - Viewed (0) -
internal/logger/config.go
cfg.AuditKafka = make(map[string]kafka.Config) if cfg, err = lookupAuditKafkaConfig(scfg, cfg); err != nil { return cfg, err } } return cfg, nil } // ValidateSubSysConfig - validates logger related config of given sub-system func ValidateSubSysConfig(ctx context.Context, scfg config.Config, subSys string) error { // Lookup for legacy environment variables first _, err := LookupConfigForSubSys(ctx, scfg, subSys)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 15.8K bytes - Viewed (0)