- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 259 for Name (0.14 sec)
-
cmd/sts-datatypes.go
// in Using IAM. // // Arn is a required field Arn string // A unique identifier that contains the role ID and the role session name of // the role that is being assumed. The role ID is generated by AWS when the // role is created. // // AssumedRoleId is a required field AssumedRoleID string `xml:"AssumeRoleId"`
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 27 00:58:09 GMT 2022 - 9.9K bytes - Viewed (0) -
cmd/admin-bucket-handlers.go
} for _, file := range zr.File { reader, err := file.Open() if err != nil { rpt.SetStatus(file.Name, "", err) continue } sz := file.FileInfo().Size() slc := strings.Split(file.Name, slashSeparator) if len(slc) != 2 { // expecting bucket/configfile in the zipfile rpt.SetStatus(file.Name, "", fmt.Errorf("malformed zip - expecting format bucket/<config.json>")) continue }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:09:56 GMT 2024 - 32.5K bytes - Viewed (0) -
cmd/peer-s3-client.go
continue } for _, bi := range buckets { _, ok := resultMap[bi.Name] if ok { // Skip it, this bucket is found in another pool continue } bucketsMap[bi.Name]++ if bucketsMap[bi.Name] >= quorum { resultMap[bi.Name] = bi } } } // loop through buckets and see if some with lost quorum
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 14.8K bytes - Viewed (0) -
internal/logger/target/kafka/kafka.go
} for _, b := range h.kconfig.Brokers { if _, err := xnet.ParseHost(b.String()); err != nil { return err } } return nil } // Name returns the name of the target func (h *Target) Name() string { return "minio-kafka-audit" } // Endpoint - return kafka target func (h *Target) Endpoint() string { return "kafka" } // String - kafka string
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 10.1K bytes - Viewed (1) -
cmd/bucket-object-lock.go
apiErr := isPutRetentionAllowed(oi.Bucket, oi.Name, days, objRetention.RetainUntilDate.Time, objRetention.Mode, byPassSet, r, cred, owner) if apiErr == ErrAccessDenied { return errAuthentication } return nil } switch ret.Mode { case objectlock.RetGovernance: govPerm := isPutRetentionAllowed(oi.Bucket, oi.Name, days, objRetention.RetainUntilDate.Time, objRetention.Mode,
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Apr 22 17:49:30 GMT 2024 - 13.2K bytes - Viewed (0) -
cmd/metacache-server-pool.go
// to `.minio.sys/tmp/` for deletion. return readDirFn(pathJoin(epPath, minioMetaBucket, bucketMetaPrefix), func(name string, typ os.FileMode) error { if typ == os.ModeDir { tmpMetacacheOld := pathutil.Join(epPath, minioMetaTmpDeletedBucket, mustGetUUID()) if err := renameAll(pathJoin(epPath, minioMetaBucket, metacachePrefixForID(name, slashSeparator)), tmpMetacacheOld, epPath); err != nil && err != errFileNotFound {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 12.8K bytes - Viewed (0) -
cni/pkg/nodeagent/ztunnelserver.go
} func podToWorkload(pod *v1.Pod) *zdsapi.WorkloadInfo { namespace := pod.ObjectMeta.Namespace name := pod.ObjectMeta.Name svcAccount := pod.Spec.ServiceAccountName trustDomain := spiffe.GetTrustDomain() return &zdsapi.WorkloadInfo{ Namespace: namespace, Name: name, ServiceAccount: svcAccount, TrustDomain: trustDomain, } }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 12.4K bytes - Viewed (0) -
cmd/common-main.go
// - regular files // - "CAs" directory // - any directory which starts with ".." if file.Mode().IsRegular() || file.Name() == "CAs" || strings.HasPrefix(file.Name(), "..") { continue } if file.Mode()&os.ModeSymlink == os.ModeSymlink { file, err = Stat(filepath.Join(root.Name(), file.Name())) if err != nil { // not accessible ignore continue } if !file.IsDir() { continue
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat May 04 00:17:57 GMT 2024 - 35.8K bytes - Viewed (2) -
istioctl/pkg/multicluster/remote_secret_test.go
} for _, secret := range secrets { sa.Secrets = append(sa.Secrets, v1.ObjectReference{ Name: secret, Namespace: testNamespace, }) } return sa } func makeSecret(name, caData, token string) *v1.Secret { out := &v1.Secret{ ObjectMeta: metav1.ObjectMeta{ Name: name, Namespace: testNamespace, Annotations: map[string]string{v1.ServiceAccountNameKey: testServiceAccountName}, },
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Oct 31 14:48:28 GMT 2023 - 20.6K bytes - Viewed (0) -
cni/pkg/install/cniconfig.go
cniConfigStr = strings.ReplaceAll(cniConfigStr, "__KUBERNETES_SERVICE_PORT__", vars.k8sServicePort) cniConfigStr = strings.ReplaceAll(cniConfigStr, "__KUBERNETES_NODE_NAME__", vars.k8sNodeName) installLog.Infof("CNI config: %s", cniConfigStr) return []byte(cniConfigStr) } func writeCNIConfig(ctx context.Context, cniConfig []byte, cfg pluginConfig) (string, error) {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 10.4K bytes - Viewed (0)