- Sort Score
- Result 10 results
- Languages All
Results 461 - 470 of 620 for uint24 (0.09 sec)
-
istioctl/pkg/writer/envoy/configdump/listener.go
) // ListenerFilter is used to pass filter information into listener based config writer print functions type ListenerFilter struct { Address string Port uint32 Type string Verbose bool } // Verify returns true if the passed listener matches the filter fields func (l *ListenerFilter) Verify(listener *listener.Listener) bool {
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Wed Nov 29 12:37:14 UTC 2023 - 18.1K bytes - Viewed (0) -
internal/event/target/postgresql.go
Password string `json:"password"` // default: no password Database string `json:"database"` // default: same as user QueueDir string `json:"queueDir"` QueueLimit uint64 `json:"queueLimit"` MaxOpenConnections int `json:"maxOpenConnections"` } // Validate PostgreSQLArgs fields func (p PostgreSQLArgs) Validate() error { if !p.Enable { return nil }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Sep 06 23:06:30 UTC 2024 - 13.3K bytes - Viewed (0) -
internal/s3select/select_test.go
} func newBytesRSC(b []byte) io.ReadSeekCloser { r := bytes.NewReader(b) segmentReader := func(offset int64) (io.ReadCloser, error) { _, err := r.Seek(offset, io.SeekStart) if err != nil { return nil, err } return io.NopCloser(r), nil } return NewObjectReadSeekCloser(segmentReader, int64(len(b))) } type testResponseWriter struct { statusCode int response []byte }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sat Dec 23 07:19:11 UTC 2023 - 76.2K bytes - Viewed (0) -
cmd/metacache.go
package cmd import ( "context" "errors" "fmt" "path" "strings" "time" "github.com/minio/pkg/v3/console" ) type scanStatus uint8 const ( scanStateNone scanStatus = iota scanStateStarted scanStateSuccess scanStateError // Time in which the initiator of a scan must have reported back. metacacheMaxRunningAge = time.Minute
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Jul 12 16:23:16 UTC 2024 - 6K bytes - Viewed (0) -
cmd/bucket-policy-handlers_test.go
recV4 := httptest.NewRecorder() // construct HTTP request for PUT bucket policy endpoint. reqV4, err := newTestSignedRequestV4(http.MethodPut, getPutPolicyURL("", testCase.bucketName), int64(testCase.policyLen), testCase.bucketPolicyReader, testCase.accessKey, testCase.secretKey, nil) if err != nil { t.Fatalf("Test %d: %s: Failed to create HTTP request for PutBucketPolicyHandler: <ERROR> %v", i+1, instanceType, err)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Jun 10 15:50:49 UTC 2024 - 32.9K bytes - Viewed (0) -
internal/config/identity/openid/jwks.go
if err != nil { return nil, errMalformedJWKRSAKey } var n, e big.Int n.SetBytes(nbuf) e.SetBytes(ebuf) return &rsa.PublicKey{ E: int(e.Int64()), N: &n, }, nil case "EC": if key.Crv == "" || key.X == "" || key.Y == "" { return nil, errMalformedJWKECKey } var curve elliptic.Curve switch key.Crv { case "P-224":
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Apr 02 23:02:35 UTC 2024 - 3.1K bytes - Viewed (0) -
cmd/warm-backend-gcs.go
destObj := object if gcs.Prefix != "" { destObj = fmt.Sprintf("%s/%s", gcs.Prefix, object) } return destObj } func (gcs *warmBackendGCS) PutWithMeta(ctx context.Context, key string, data io.Reader, length int64, meta map[string]string) (remoteVersionID, error) { object := gcs.client.Bucket(gcs.Bucket).Object(gcs.getDest(key)) w := object.NewWriter(ctx) if gcs.StorageClass != "" { w.ObjectAttrs.StorageClass = gcs.StorageClass }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Oct 31 22:10:24 UTC 2024 - 6.1K bytes - Viewed (0) -
tests/soft_delete_test.go
"testing" "github.com/jinzhu/now" "gorm.io/gorm" . "gorm.io/gorm/utils/tests" ) func TestSoftDelete(t *testing.T) { user := *GetUser("SoftDelete", Config{}) DB.Save(&user) var count int64 var age uint if DB.Model(&User{}).Where("name = ?", user.Name).Count(&count).Error != nil || count != 1 { t.Errorf("Count soft deleted record, expects: %v, got: %v", 1, count) }
Registered: Sun Nov 03 09:35:10 UTC 2024 - Last Modified: Wed Feb 01 06:40:55 UTC 2023 - 5.7K bytes - Viewed (0) -
cmd/iam.go
type IAMSys struct { // Need to keep them here to keep alignment - ref: https://golang.org/pkg/sync/atomic/#pkg-note-BUG // metrics LastRefreshTimeUnixNano uint64 LastRefreshDurationMilliseconds uint64 TotalRefreshSuccesses uint64 TotalRefreshFailures uint64 sync.Mutex iamRefreshInterval time.Duration LDAPConfig xldap.Config // only valid if usersSysType is LDAPUsers
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Oct 29 16:01:48 UTC 2024 - 74.6K bytes - Viewed (0) -
internal/kms/secret-key.go
} return &KMS{ Type: Builtin, DefaultKey: keyID, conn: secretKey{ keyID: keyID, key: key, }, latencyBuckets: defaultLatencyBuckets, latency: make([]atomic.Uint64, len(defaultLatencyBuckets)), }, nil } // secretKey is a KMS implementation that derives new DEKs // from a single key. type secretKey struct { keyID string key []byte }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sun Aug 18 06:43:03 UTC 2024 - 8.3K bytes - Viewed (0)