- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 79 for initialize (0.21 sec)
-
cmd/iam.go
sys.store = &IAMStoreSys{newIAMObjectStore(objAPI, sys.usersSysType)} } else { sys.store = &IAMStoreSys{newIAMEtcdStore(etcdClient, sys.usersSysType)} } } // Initialized checks if IAM is initialized func (sys *IAMSys) Initialized() bool { if sys == nil { return false } sys.Lock() defer sys.Unlock() return sys.store != 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) -
docs/sts/assume-role.go
func main() { flag.Parse() if minioUsername == "" || minioPassword == "" { flag.PrintDefaults() return } // The credentials package in minio-go provides an interface to call the // STS API. // Initialize credential options var stsOpts cr.STSAssumeRoleOptions stsOpts.AccessKey = minioUsername stsOpts.SecretKey = minioPassword if sessionPolicyFile != "" { var policy string
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 12 16:09:55 GMT 2024 - 4K bytes - Viewed (1) -
cmd/erasure-object.go
return ObjectInfo{}, toObjectErr(errInvalidArgument) } // Initialize parts metadata partsMetadata := make([]FileInfo, len(storageDisks)) fi := newFileInfo(pathJoin(minioMetaBucket, key), dataDrives, parityDrives) fi.DataDir = mustGetUUID() // Initialize erasure metadata. for index := range partsMetadata { partsMetadata[index] = fi }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun May 05 16:56:21 GMT 2024 - 77.2K bytes - Viewed (2) -
cmd/data-scanner_test.go
"github.com/minio/minio/internal/bucket/versioning" ) func TestApplyNewerNoncurrentVersionsLimit(t *testing.T) { objAPI, disks, err := prepareErasure(context.Background(), 8) if err != nil { t.Fatalf("Failed to initialize object layer: %v", err) } defer removeRoots(disks) setObjectLayer(objAPI) globalBucketMetadataSys = NewBucketMetadataSys() globalBucketObjectLockSys = &BucketObjectLockSys{}
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) -
cmd/erasure-server-pool.go
logger.Fatal(err, "Unable to initialize backend") } retry := time.Duration(r.Float64() * float64(5*time.Second)) storageLogIf(ctx, fmt.Errorf("Unable to initialize backend: %w, retrying in %s", err, retry)) time.Sleep(retry) attempt++ continue } break } return z, nil } func (z *erasureServerPools) NewNSLock(bucket string, objects ...string) RWLocker {
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/erasure-server-pool-rebalance.go
// expand and then we continue to rebalance. func (z *erasureServerPools) updateRebalanceStats(ctx context.Context) error { var ok bool for i := range z.serverPools { if z.findIndex(i) == -1 { // Also ensure to initialize rebalanceStats to indicate // its a new pool that can receive rebalanced data. z.rebalMeta.PoolStats = append(z.rebalMeta.PoolStats, &rebalanceStats{}) ok = true } } if ok {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 26 19:29:28 GMT 2024 - 27.2K bytes - Viewed (0) -
cmd/config-current.go
configLogIf(ctx, fmt.Errorf("Unable to initialize remote webhook DNS config %w", err)) } if err == nil && dnsURL != "" { bootstrapTraceMsg("initialize remote bucket DNS store") globalDNSConfig, err = dns.NewOperatorDNS(dnsURL, dns.Authentication(dnsUser, dnsPass), dns.RootCAs(globalRootCAs)) if err != nil { configLogIf(ctx, fmt.Errorf("Unable to initialize remote webhook DNS config %w", err)) } }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 20:08:20 GMT 2024 - 30.8K bytes - Viewed (0) -
cmd/object-multipart-handlers.go
case authTypeStreamingSigned, authTypeStreamingSignedTrailer: // Initialize stream signature verifier. reader, s3Error = newSignV4ChunkedReader(r, rAuthType == authTypeStreamingSignedTrailer) if s3Error != ErrNone { writeErrorResponse(ctx, w, errorCodes.ToAPIErr(s3Error), r.URL) return } case authTypeStreamingUnsignedTrailer: // Initialize stream signature verifier.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Mar 28 17:44:56 GMT 2024 - 39K bytes - Viewed (0) -
internal/logger/config.go
HTTP map[string]http.Config `json:"http"` AuditWebhook map[string]http.Config `json:"audit"` AuditKafka map[string]kafka.Config `json:"audit_kafka"` } // NewConfig - initialize new logger config. func NewConfig() Config { cfg := Config{ // Console logging is on by default Console: Console{ Enabled: true, }, HTTP: make(map[string]http.Config),
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) -
cmd/bucket-targets.go
Scheme: ep.Scheme, Online: true, } sys.hMutex.Unlock() } // newHCClient initializes an anonymous client for performing health check on the remote endpoints func newHCClient() *madmin.AnonymousClient { clnt, e := madmin.NewAnonymousClientNoEndpoint() if e != nil { bugLogIf(GlobalContext, errors.New("Unable to initialize health check client")) return nil } clnt.SetCustomTransport(globalRemoteTargetTransport)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:09:56 GMT 2024 - 20.9K bytes - Viewed (0)