- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 235 for created (0.15 sec)
-
internal/kms/policy-manager.go
"github.com/minio/kms-go/kes" ) // PolicyManager is the generic interface that handles KMS policy] operations type PolicyManager interface { // DescribePolicy describes a policy by returning its metadata. // e.g. who created the policy at which point in time. DescribePolicy(ctx context.Context, policy string) (*kes.PolicyInfo, error) // GetPolicy gets a policy from KMS. GetPolicy(ctx context.Context, policy string) (*kes.Policy, error)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Mar 01 21:09:42 GMT 2024 - 1.3K bytes - Viewed (0) -
internal/logger/target/kafka/kafka_scram_client_contrib.go
} } // KafkaSHA256 is a function that returns a crypto/sha256 hasher and should be used // to create Client objects configured for SHA-256 hashing. var KafkaSHA256 scram.HashGeneratorFcn = sha256.New // KafkaSHA512 is a function that returns a crypto/sha512 hasher and should be used // to create Client objects configured for SHA-512 hashing. var KafkaSHA512 scram.HashGeneratorFcn = sha512.New
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Nov 09 04:04:01 GMT 2023 - 3.3K bytes - Viewed (1) -
cmd/erasure-server-pool.go
buckets, err = z.s3Peer.ListBuckets(ctx, opts) if err != nil { return nil, err } for i := range buckets { createdAt, err := globalBucketMetadataSys.CreatedAt(buckets[i].Name) if err == nil { buckets[i].Created = createdAt } } return buckets, nil }, ) return listBucketsCache.Get() }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 20:08:20 GMT 2024 - 80.5K bytes - Viewed (0) -
cmd/data-scanner_test.go
if err != nil { t.Fatalf("Failed to marshal versioning config: %v", err) } bucket := "bucket" obj := "obj-1" now := time.Now() meta := BucketMetadata{ Name: bucket, Created: now, LifecycleConfigXML: lcXML, VersioningConfigXML: vcfgXML, VersioningConfigUpdatedAt: now, LifecycleConfigUpdatedAt: now, lifecycleConfig: &lc,
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 11:18:58 GMT 2024 - 6.9K bytes - Viewed (0) -
internal/grid/types.go
func (p *JSONPool[T]) NewJSONWith(val *T) *JSON[T] { var j JSON[T] j.p = p j.val = val return &j } // Value returns the underlying value. // If not set yet, a new value is created. func (j *JSON[T]) Value() *T { if j.val == nil { j.val = j.p.new() } return j.val } // ValueOrZero returns the underlying value. // If the underlying value is nil, a zero value is returned.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Apr 01 23:42:09 GMT 2024 - 15.4K bytes - Viewed (0) -
cmd/sts-handlers_test.go
defer cancel() // Create project buckets buckets := []string{"projecta", "projectb", "projectaorb", "other"} for _, bucket := range buckets { err := s.client.MakeBucket(ctx, bucket, minio.MakeBucketOptions{}) if err != nil { c.Fatalf("bucket create error: %v", err) } } // Create policies for polName, polContent := range policyProjectsMap {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 25 15:50:16 GMT 2024 - 85.7K bytes - Viewed (0) -
cmd/storage-datatypes_test.go
package cmd import ( "bytes" "encoding/gob" "io" "testing" "time" "github.com/tinylib/msgp/msgp" ) func BenchmarkDecodeVolInfoMsgp(b *testing.B) { v := VolInfo{ Name: "uuid", Created: time.Now(), } var buf bytes.Buffer msgp.Encode(&buf, &v) rd := msgp.NewEndlessReader(buf.Bytes(), b) dc := msgp.NewReader(rd) b.Log("Size:", buf.Len(), "bytes") b.SetBytes(1) b.ReportAllocs()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Sep 19 18:05:16 GMT 2022 - 9.4K bytes - Viewed (0) -
cmd/server_test.go
// The following is the test flow. // 1. Create bucket. // 2. Insert Object. // 3. Use "X-Amz-Copy-Source" header to copy the previously created object. // 4. Validate the content of copied object. func (s *TestSuiteCommon) TestCopyObject(c *check) { // generate a random bucket name. bucketName := getRandomBucketName() // HTTP request to create the bucket.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 108K bytes - Viewed (0) -
cmd/iam.go
if args.IsOwner { return true } // If the credential is temporary, perform STS related checks. ok, parentUser, err := sys.IsTempUser(args.AccountName) if err != nil { return false } if ok { return sys.IsAllowedSTS(args, parentUser) } // If the credential is for a service account, perform related check ok, parentUser, err = sys.IsServiceAccount(args.AccountName) if err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 25 21:28:16 GMT 2024 - 71.1K bytes - Viewed (1) -
cmd/object-handlers.go
w.Header()[strings.ToLower(xhttp.AmzCopySourceVersionID)] = []string{srcOpts.VersionID} } // Write success response. writeSuccessResponseXML(w, encodedSuccessResponse) // Notify object created event. sendEvent(eventArgs{ EventName: event.ObjectCreatedCopy, BucketName: dstBucket, Object: objInfo, ReqParams: extractReqParams(r), RespElements: extractRespElements(w),
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu May 02 20:15:54 GMT 2024 - 125.2K bytes - Viewed (0)