Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 8 of 8 for doinit (0.15 sec)

  1. internal/event/name.go

    // Refer http://docs.aws.amazon.com/AmazonS3/latest/dev/NotificationHowTo.html#notification-how-to-event-types-and-destinations
    // for most basic values we have since extend this and its not really much applicable other than a reference point.
    // "s3:Replication:OperationCompletedReplication" is a MinIO extension.
    type Name int
    
    // Values of event Name
    const (
    	// Single event types (does not require expansion)
    
    	ObjectAccessedGet Name = 1 + iota
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 01:11:10 GMT 2024
    - 10.4K bytes
    - Viewed (0)
  2. cmd/erasure-server-pool.go

    	defer setObjectLayer(z)
    
    	r := rand.New(rand.NewSource(time.Now().UnixNano()))
    	attempt := 1
    	for {
    		var err error
    		bootstrapTrace(fmt.Sprintf("poolMeta.Init: loading pool metadata, attempt: %d", attempt), func() {
    			err = z.Init(ctx) // Initializes all pools.
    		})
    		if err != nil {
    			if !configRetriableErrors(err) {
    				logger.Fatal(err, "Unable to initialize backend")
    			}
    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)
  3. cmd/erasure-object.go

    				continue
    			}
    		}
    
    		if offlineDrives >= (len(storageDisks)+1)/2 {
    			// if offline drives are more than 50% of the drives
    			// we have no quorum, we shouldn't proceed just
    			// fail at that point.
    			return ObjectInfo{}, toObjectErr(errErasureWriteQuorum, bucket, object)
    		}
    
    		if parityDrives >= len(storageDisks)/2 {
    			parityDrives = len(storageDisks) / 2
    		}
    
    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)
  4. cmd/object-handlers.go

    		srcInfo.metadataOnly = true
    		srcInfo.keyRotation = true
    	} else {
    		if isSourceEncrypted || isTargetEncrypted {
    			// We are not only copying just metadata instead
    			// we are creating a new object at this point, even
    			// if source and destination are same objects.
    			if !srcInfo.keyRotation {
    				srcInfo.metadataOnly = false
    			}
    		}
    
    		// Calculate the size of the target object
    		var targetSize int64
    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)
  5. cmd/common-main.go

    		}
    	}
    
    	globalDisableFreezeOnBoot = env.Get("_MINIO_DISABLE_API_FREEZE_ON_BOOT", "") == "true" || serverDebugLog
    }
    
    func loadRootCredentials() {
    	// At this point, either both environment variables
    	// are defined or both are not defined.
    	// Check both cases and authenticate them if correctly defined
    	var user, password string
    	var hasCredentials bool
    	//nolint:gocritic
    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)
  6. docs/distributed/CONFIG.md

    - Each pool expects each host in this pool has the same number of drives specified as any other host.
    - Mixing `local-path` and `distributed-path` is not allowed, doing so would cause MinIO to refuse starting the server.
    - Ellipses notation (e.g. `{1...10}`) or bracket notations are fully allowed (e.g. `{a,c,f}`) to have multiple entries in one line.
    
    Plain Text
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 15:54:03 GMT 2024
    - 4.2K bytes
    - Viewed (0)
  7. cmd/site-replication.go

    // srStateData represents the format of the current `srStateFile`.
    type srStateData struct {
    	Version int `json:"version"`
    
    	SRState srStateV1 `json:"srState"`
    }
    
    // Init - initialize the site replication manager.
    func (c *SiteReplicationSys) Init(ctx context.Context, objAPI ObjectLayer) error {
    	go c.startHealRoutine(ctx, objAPI)
    	r := rand.New(rand.NewSource(time.Now().UnixNano()))
    	for {
    		err := c.loadFromDisk(ctx, objAPI)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 01:09:56 GMT 2024
    - 184.2K bytes
    - Viewed (1)
  8. cmd/bucket-replication.go

    		}
    		rinfo.Duration = time.Since(startTime)
    	}()
    
    	rinfo.ReplicationStatus = replication.Completed
    	rinfo.Size = size
    	rinfo.ReplicationAction = rAction
    	// use core client to avoid doing multipart on PUT
    	c := &minio.Core{Client: tgt.Client}
    
    	putOpts, err := putReplicationOpts(ctx, tgt.StorageClass, objInfo)
    	if err != nil {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 01:09:56 GMT 2024
    - 112.2K bytes
    - Viewed (1)
Back to top