Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for siteResyncStatus (0.23 sec)

  1. cmd/site-replication-utils.go

    	TotBuckets                    int                         `json:"totbuckets" msg:"tb"`
    	TargetReplicationResyncStatus `json:"currSt" msg:"cst"`
    }
    
    func (s *SiteResyncStatus) clone() SiteResyncStatus {
    	if s == nil {
    		return SiteResyncStatus{}
    	}
    	o := *s
    	o.BucketStatuses = make(map[string]ResyncStatusType, len(s.BucketStatuses))
    	maps.Copy(o.BucketStatuses, s.BucketStatuses)
    	return o
    }
    
    const (
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 8.8K bytes
    - Viewed (0)
  2. cmd/site-replication-utils_gen_test.go

    	}
    }
    
    func BenchmarkMarshalMsgSiteResyncStatus(b *testing.B) {
    	v := SiteResyncStatus{}
    	b.ReportAllocs()
    	b.ResetTimer()
    	for i := 0; i < b.N; i++ {
    		v.MarshalMsg(nil)
    	}
    }
    
    func BenchmarkAppendMsgSiteResyncStatus(b *testing.B) {
    	v := SiteResyncStatus{}
    	bts := make([]byte, 0, v.Msgsize())
    	bts, _ = v.MarshalMsg(bts[0:0])
    	b.SetBytes(int64(len(bts)))
    	b.ReportAllocs()
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Mon Nov 14 15:16:40 UTC 2022
    - 2.4K bytes
    - Viewed (0)
  3. cmd/site-replication-utils_gen.go

    package cmd
    
    // Code generated by github.com/tinylib/msgp DO NOT EDIT.
    
    import (
    	"github.com/tinylib/msgp/msgp"
    )
    
    // DecodeMsg implements msgp.Decodable
    func (z *SiteResyncStatus) DecodeMsg(dc *msgp.Reader) (err error) {
    	var field []byte
    	_ = field
    	var zb0001 uint32
    	zb0001, err = dc.ReadMapHeader()
    	if err != nil {
    		err = msgp.WrapError(err)
    		return
    	}
    	for zb0001 > 0 {
    		zb0001--
    		field, err = dc.ReadMapKeyPtr()
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Mon Nov 14 15:16:40 UTC 2022
    - 7.2K bytes
    - Viewed (0)
  4. cmd/site-replication.go

    	siteResyncMetaVersion   = siteResyncMetaVersionV1
    	siteResyncSaveInterval  = 10 * time.Second
    )
    
    func newSiteResyncStatus(dID string, buckets []BucketInfo) SiteResyncStatus {
    	now := UTCNow()
    	s := SiteResyncStatus{
    		Version:        siteResyncMetaVersion,
    		Status:         ResyncStarted,
    		DeplID:         dID,
    		TotBuckets:     len(buckets),
    		BucketStatuses: make(map[string]ResyncStatusType),
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 184.7K bytes
    - Viewed (0)
Back to top