- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 58 for Cota (0.17 sec)
-
internal/dsync/lock-args.go
Quorum int } // ResponseCode is the response code for a locking request. type ResponseCode uint8 // Response codes for a locking request. const ( RespOK ResponseCode = iota RespLockConflict RespLockNotInitialized RespLockNotFound RespErr ) // LockResp is a locking request response. type LockResp struct { Code ResponseCode Err string
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Jan 18 04:34:26 GMT 2024 - 1.7K bytes - Viewed (0) -
internal/grid/msg.go
// Op is operation type messages. type Op uint8 // HandlerID is the ID for the handler of a specific type. type HandlerID uint8 const ( // OpConnect is a connect request. OpConnect Op = iota + 1 // OpConnectResponse is a response to a connect request. OpConnectResponse // OpPing is a ping request. // If a mux id is specified that mux is pinged. // Clients send ping requests. OpPing
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Tue Nov 28 19:22:29 GMT 2023 - 7.3K bytes - Viewed (0) -
cmd/bucket-lifecycle-audit.go
type lcEventSrc uint8 //revive:disable:var-naming Underscores is used here to indicate where common prefix ends and the enumeration name begins const ( lcEventSrc_None lcEventSrc = iota lcEventSrc_Heal lcEventSrc_Scanner lcEventSrc_Decom lcEventSrc_Rebal lcEventSrc_s3HeadObject lcEventSrc_s3GetObject lcEventSrc_s3ListObjects lcEventSrc_s3PutObject lcEventSrc_s3CopyObject
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Fri Dec 01 15:56:24 GMT 2023 - 2.6K bytes - Viewed (0) -
cmd/service.go
"runtime" "syscall" xioutil "github.com/minio/minio/internal/ioutil" ) // Type of service signals currently supported. type serviceSignal int const ( serviceRestart serviceSignal = iota // Restarts the server. serviceStop // Stops the server. serviceReloadDynamic // Reload dynamic config values. serviceFreeze // Freeze all S3 API calls.
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Wed Feb 28 07:02:14 GMT 2024 - 3.8K bytes - Viewed (0) -
cmd/warm-backend.go
if _, ok := err.(BackendDown); ok { return err } return tierPermErr{ Op: tierDelete, Err: err, } } return err } type tierOp uint8 const ( _ tierOp = iota tierGet tierPut tierDelete ) func (op tierOp) String() string { switch op { case tierGet: return "GET" case tierPut: return "PUT" case tierDelete: return "DELETE" }
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Sun Apr 21 11:43:18 GMT 2024 - 3.9K bytes - Viewed (0) -
internal/logger/target/testlogger/testlogger.go
"strings" "sync/atomic" "testing" "github.com/minio/minio/internal/logger" "github.com/minio/minio/internal/logger/target/types" "github.com/minio/pkg/v2/logger/message/log" ) const ( logMessage = iota errorMessage fatalMessage ) // T is the test logger. var T = &testLogger{} func init() { logger.AddSystemTarget(context.Background(), T) } type testLogger struct {
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Tue Nov 21 01:09:35 GMT 2023 - 4K bytes - Viewed (0) -
src/cmd/asm/internal/lex/lex.go
type ScanToken rune const ( // Asm defines some two-character lexemes. We make up // a rune/ScanToken value for them - ugly but simple. LSH ScanToken = -1000 - iota // << Left shift. RSH // >> Logical right shift. ARR // -> Used on ARM for shift type 3, arithmetic right shift.
Go - Registered: Tue Apr 23 11:13:09 GMT 2024 - Last Modified: Tue Aug 29 18:31:05 GMT 2023 - 4.1K bytes - Viewed (0) -
cmd/sts-errors.go
//go:generate stringer -type=STSErrorCode -trimprefix=Err $GOFILE // Error codes, non exhaustive list - http://docs.aws.amazon.com/STS/latest/APIReference/API_AssumeRoleWithSAML.html const ( ErrSTSNone STSErrorCode = iota ErrSTSAccessDenied ErrSTSMissingParameter ErrSTSInvalidParameterValue ErrSTSWebIdentityExpiredToken ErrSTSClientGrantsExpiredToken ErrSTSInvalidClientGrantsToken ErrSTSMalformedPolicyDocument
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 5.8K bytes - Viewed (0) -
cmd/data-scanner-metric.go
} var globalScannerMetrics scannerMetrics const ( // START Realtime metrics, that only to records // last minute latencies and total operation count. scannerMetricReadMetadata scannerMetric = iota scannerMetricCheckMissing scannerMetricSaveUsage scannerMetricApplyAll scannerMetricApplyVersion scannerMetricTierObjSweep scannerMetricHealCheck scannerMetricILM scannerMetricCheckReplication
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Mon Sep 25 05:15:31 GMT 2023 - 9.1K bytes - Viewed (0) -
internal/logger/target/kafka/kafka.go
xnet "github.com/minio/pkg/v2/net" ) // the suffix for the configured queue dir where the logs will be persisted. const kafkaLoggerExtension = ".kafka.log" const ( statusClosed = iota statusOffline statusOnline ) // Config - kafka target arguments. type Config struct { Enabled bool `json:"enable"` Brokers []xnet.Host `json:"brokers"` Topic string `json:"topic"`
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 10.1K bytes - Viewed (1)