Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 512 for modinfo (0.07 sec)

  1. cmd/peer-rest-server.go

    	headBucketRPC                  = grid.NewSingleHandler[*grid.MSS, *VolInfo](grid.HandlerHeadBucket, grid.NewMSS, func() *VolInfo { return &VolInfo{} })
    	healBucketRPC                  = grid.NewSingleHandler[*grid.MSS, grid.NoPayload](grid.HandlerHealBucket, grid.NewMSS, grid.NewNoPayload)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 04 11:32:32 UTC 2024
    - 53.2K bytes
    - Viewed (0)
  2. cmd/admin-handlers.go

    			anonymizeAddr(&localMemInfo)
    			healthInfo.Sys.MemInfo = append(healthInfo.Sys.MemInfo, localMemInfo)
    
    			peerMemInfos := globalNotificationSys.GetMemInfo(healthCtx)
    			for _, m := range peerMemInfos {
    				anonymizeAddr(&m)
    				healthInfo.Sys.MemInfo = append(healthInfo.Sys.MemInfo, m)
    			}
    			partialWrite(healthInfo)
    		}
    	}
    
    	getAndWriteSysErrors := func() {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 04 11:32:32 UTC 2024
    - 99.7K bytes
    - Viewed (0)
  3. cmd/metrics-v3-cache.go

    	}
    
    	return cachevalue.NewFromFunc(1*time.Minute,
    		cachevalue.Opts{ReturnLastGood: true},
    		loadCPUMetrics)
    }
    
    func newMemoryMetricsCache() *cachevalue.Cache[madmin.MemInfo] {
    	loadMemoryMetrics := func(ctx context.Context) (v madmin.MemInfo, err error) {
    		var types madmin.MetricType = madmin.MetricsMem
    
    		m := collectLocalMetrics(types, collectMetricsOpts{
    			hosts: map[string]struct{}{
    				globalLocalNodeName: {},
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu May 09 00:51:34 UTC 2024
    - 8.1K bytes
    - Viewed (0)
  4. cmd/notification.go

    	}
    	return reply
    }
    
    func (sys *NotificationSys) addNodeErr(nodeInfo madmin.NodeInfo, peerClient *peerRESTClient, err error) {
    	addr := peerClient.host.String()
    	reqInfo := (&logger.ReqInfo{}).AppendTags("remotePeer", addr)
    	ctx := logger.SetReqInfo(GlobalContext, reqInfo)
    	peersLogOnceIf(ctx, err, "add-node-err-"+addr)
    	nodeInfo.SetAddr(addr)
    	nodeInfo.SetError(err.Error())
    }
    
    // GetSysErrors - Memory information
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 09 16:58:30 UTC 2024
    - 46.2K bytes
    - Viewed (0)
  5. cmd/naughty-disk_test.go

    }
    
    func (d *naughtyDisk) ListVols(ctx context.Context) (vols []VolInfo, err error) {
    	if err := d.calcError(); err != nil {
    		return nil, err
    	}
    	return d.disk.ListVols(ctx)
    }
    
    func (d *naughtyDisk) StatVol(ctx context.Context, volume string) (vol VolInfo, err error) {
    	if err := d.calcError(); err != nil {
    		return VolInfo{}, err
    	}
    	return d.disk.StatVol(ctx, volume)
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Aug 12 08:38:15 UTC 2024
    - 10.1K bytes
    - Viewed (0)
  6. cmd/peer-s3-server.go

    	buckets = make([]BucketInfo, 0, 32)
    	healBuckets := map[string]VolInfo{}
    
    	// lists all unique buckets across drives.
    	if err := listAllBuckets(ctx, localDrives, healBuckets, quorum); err != nil {
    		return nil, err
    	}
    
    	// include deleted buckets in listBuckets output
    	deletedBuckets := map[string]VolInfo{}
    
    	if opts.Deleted {
    		// lists all deleted buckets across drives.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 22 21:57:20 UTC 2024
    - 8.1K bytes
    - Viewed (0)
  7. cmd/storage-interface.go

    	// Volume operations.
    	MakeVol(ctx context.Context, volume string) (err error)
    	MakeVolBulk(ctx context.Context, volumes ...string) (err error)
    	ListVols(ctx context.Context) (vols []VolInfo, err error)
    	StatVol(ctx context.Context, volume string) (vol VolInfo, err error)
    	DeleteVol(ctx context.Context, volume string, forceDelete bool) (err error)
    
    	// WalkDir will walk a directory on disk and return a metacache stream on wr.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Aug 12 08:38:15 UTC 2024
    - 5.2K bytes
    - Viewed (0)
  8. cmd/peer-s3-client.go

    	})
    
    	ctx, cancel := context.WithTimeout(ctx, globalDriveConfig.GetMaxTimeout())
    	defer cancel()
    
    	volInfo, err := headBucketRPC.Call(ctx, conn, mss)
    	if err != nil {
    		return BucketInfo{}, toStorageErr(err)
    	}
    
    	return BucketInfo{
    		Name:    volInfo.Name,
    		Created: volInfo.Created,
    	}, nil
    }
    
    // MakeBucket creates bucket across all peers
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 13 22:26:05 UTC 2024
    - 15.4K bytes
    - Viewed (0)
  9. cmd/storage-datatypes.go

    }
    
    // VolsInfo is a collection of volume(bucket) information
    type VolsInfo []VolInfo
    
    // VolInfo - represents volume stat information.
    // The above means that any added/deleted fields are incompatible.
    //
    // The above means that any added/deleted fields are incompatible.
    //
    //msgp:tuple VolInfo
    type VolInfo struct {
    	// Name of the volume.
    	Name string
    
    	// Date and time when the volume was created.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 15:30:50 UTC 2024
    - 17.3K bytes
    - Viewed (0)
  10. cmd/admin-router.go

    		adminRouter.Methods(http.MethodGet).Path(adminVersion + "/kms/key/status").HandlerFunc(adminMiddleware(adminAPI.KMSKeyStatusHandler, traceAllFlag))
    
    		// Keep obdinfo for backward compatibility with mc
    		adminRouter.Methods(http.MethodGet).Path(adminVersion + "/obdinfo").
    			HandlerFunc(adminMiddleware(adminAPI.HealthInfoHandler))
    		// -- Health API --
    		adminRouter.Methods(http.MethodGet).Path(adminVersion + "/healthinfo").
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Sep 21 11:35:40 UTC 2024
    - 26.2K bytes
    - Viewed (0)
Back to top