Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for rebalSaveOpts (0.2 sec)

  1. cmd/erasure-server-pool-rebalance_gen.go

    )
    
    // DecodeMsg implements msgp.Decodable
    func (z *rebalSaveOpts) DecodeMsg(dc *msgp.Reader) (err error) {
    	{
    		var zb0001 uint8
    		zb0001, err = dc.ReadUint8()
    		if err != nil {
    			err = msgp.WrapError(err)
    			return
    		}
    		(*z) = rebalSaveOpts(zb0001)
    	}
    	return
    }
    
    // EncodeMsg implements msgp.Encodable
    func (z rebalSaveOpts) EncodeMsg(en *msgp.Writer) (err error) {
    	err = en.WriteUint8(uint8(z))
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Mar 21 17:21:35 GMT 2024
    - 26.8K bytes
    - Viewed (0)
  2. cmd/erasure-server-pool-rebalance.go

    		}(setIdx)
    	}
    
    	wk.Wait()
    	return nil
    }
    
    type rebalSaveOpts uint8
    
    const (
    	rebalSaveStats rebalSaveOpts = iota
    	rebalSaveStoppedAt
    )
    
    func (z *erasureServerPools) saveRebalanceStats(ctx context.Context, poolIdx int, opts rebalSaveOpts) error {
    	lock := z.serverPools[0].NewNSLock(minioMetaBucket, rebalMetaName)
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Fri Apr 26 19:29:28 GMT 2024
    - 27.2K bytes
    - Viewed (0)
Back to top