Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 19 for Tier (0.09 sec)

  1. cmd/warm-backend.go

    	case madmin.Azure:
    		d, err = newWarmBackendAzure(*tier.Azure, tier.Name)
    	case madmin.GCS:
    		d, err = newWarmBackendGCS(*tier.GCS, tier.Name)
    	case madmin.MinIO:
    		d, err = newWarmBackendMinIO(*tier.MinIO, tier.Name)
    	default:
    		return nil, errTierTypeUnsupported
    	}
    	if err != nil {
    		tierLogIf(ctx, err)
    		return nil, errTierInvalidConfig
    	}
    
    	if probe {
    		if err = checkWarmBackend(ctx, d); err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 4K bytes
    - Viewed (0)
  2. cmd/warm-backend-s3.go

    		Secure:    u.Scheme == "https",
    		Transport: globalRemoteTargetTransport,
    	}
    	client, err := minio.New(u.Host, opts)
    	if err != nil {
    		return nil, err
    	}
    	client.SetAppInfo(fmt.Sprintf("s3-tier-%s", tier), ReleaseTag)
    
    	core := &minio.Core{Client: client}
    	return &warmBackendS3{
    		client:       client,
    		core:         core,
    		Bucket:       conf.Bucket,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 5.7K bytes
    - Viewed (0)
  3. cmd/bucket-lifecycle.go

    			}
    			t.activeTasks.Add(-1)
    		}
    	}
    }
    
    func (t *transitionState) addLastDayStats(tier string, ts tierStats) {
    	t.lastDayMu.Lock()
    	defer t.lastDayMu.Unlock()
    
    	if _, ok := t.lastDayStats[tier]; !ok {
    		t.lastDayStats[tier] = &lastDayTierStats{}
    	}
    	t.lastDayStats[tier].addStats(ts)
    }
    
    func (t *transitionState) getDailyAllTierStats() DailyAllTierStats {
    	t.lastDayMu.RLock()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Oct 23 15:35:37 UTC 2024
    - 33.7K bytes
    - Viewed (0)
  4. docs/bucket/lifecycle/setup_ilm_transition.sh

    ./mc mb --ignore-existing sitea/bucket
    ./mc mb --ignore-existing siteb/bucket
    
    sleep 10s
    
    ## Add warm tier
    ./mc ilm tier add minio sitea WARM-TIER --endpoint http://localhost:9004 --access-key minioadmin --secret-key minioadmin --bucket bucket
    
    ## Add ILM rules
    ./mc ilm add sitea/bucket --transition-days 0 --transition-tier WARM-TIER
    ./mc ilm rule list sitea/bucket
    
    ./mc cp README.md sitea/bucket/README.md
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 2.8K bytes
    - Viewed (0)
  5. cmd/warm-backend-azure.go

    	for k, v := range meta {
    		azMeta[k] = to.Ptr(v)
    	}
    	resp, err := az.clnt.UploadStream(ctx, az.Bucket, az.getDest(object), io.LimitReader(r, length), &azblob.UploadStreamOptions{
    		Concurrency: 4,
    		AccessTier:  az.tier(), // set tier if specified
    		Metadata:    azMeta,
    	})
    	if err != nil {
    		return "", azureToObjectError(err, az.Bucket, az.getDest(object))
    	}
    	vid := ""
    	if resp.VersionID != nil {
    		vid = *resp.VersionID
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 7K bytes
    - Viewed (0)
  6. cmd/warm-backend-minio.go

    		Transport:       globalRemoteTargetTransport,
    		TrailingHeaders: true,
    	}
    	client, err := minio.New(u.Host, opts)
    	if err != nil {
    		return nil, err
    	}
    	client.SetAppInfo(fmt.Sprintf("minio-tier-%s", tier), ReleaseTag)
    
    	core := &minio.Core{Client: client}
    	return &warmBackendMinIO{
    		warmBackendS3{
    			client: client,
    			core:   core,
    			Bucket: conf.Bucket,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 4K bytes
    - Viewed (0)
  7. cmd/warm-backend-gcs.go

    		return nil, err
    	}
    
    	client, err := storage.NewClient(context.Background(),
    		option.WithCredentialsJSON(credsJSON),
    		option.WithScopes(storage.ScopeReadWrite),
    		option.WithUserAgent(fmt.Sprintf("gcs-tier-%s", tier)+SlashSeparator+ReleaseTag),
    	)
    	if err != nil {
    		return nil, err
    	}
    	return &warmBackendGCS{client, conf.Bucket, conf.Prefix, conf.StorageClass}, nil
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 6.1K bytes
    - Viewed (0)
  8. cmd/data-usage-cache.go

    	for tier, st := range other.Tiers {
    		ats.Tiers[tier] = ats.Tiers[tier].add(st)
    	}
    }
    
    func (ats *allTierStats) clone() *allTierStats {
    	if ats == nil {
    		return nil
    	}
    	dst := *ats
    	dst.Tiers = make(map[string]tierStats, len(ats.Tiers))
    	for tier, st := range ats.Tiers {
    		dst.Tiers[tier] = st
    	}
    	return &dst
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 15:30:50 UTC 2024
    - 34.7K bytes
    - Viewed (0)
  9. cmd/erasure-metadata.go

    	// from latestFileInfo to get the quorum
    	return dataBlocks, writeQuorum, nil
    }
    
    const (
    	tierFVID     = "tier-free-versionID"
    	tierFVMarker = "tier-free-marker"
    	tierSkipFVID = "tier-skip-fvid"
    )
    
    // SetTierFreeVersionID sets free-version's versionID. This method is used by
    // object layer to pass down a versionID to set for a free-version that may be
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 21.3K bytes
    - Viewed (0)
  10. cmd/storage-datatypes.go

    	// TransitionedObjName is the object name on the remote tier corresponding
    	// to object (version) on the source tier.
    	TransitionedObjName string `msg:"to"`
    	// TransitionTier is the storage class label assigned to remote tier.
    	TransitionTier string `msg:"tt"`
    	// TransitionVersionID stores a version ID of the object associate
    	// with the remote tier.
    	TransitionVersionID string `msg:"tv"`
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 15:30:50 UTC 2024
    - 17.3K bytes
    - Viewed (0)
Back to top