dragonflyoss
/
dragonfly
mirror of https://github.com/dragonflyoss/dragonfly.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Tune dragonfly to Remove Old Entries & Use Longtext to fit larger warming jobs (#4145) 

* Tune dragonfly to fit our usecase by:

* use longtext to fit larger clusters

* fix scheduler and seed-client register logic

* Remove commented out lines.
This commit is contained in:
e-ngo 2025-07-03 05:46:21 -07:00 committed by GitHub
parent 1a132f534e
commit b66c49f3a9
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
2 changed files with 2 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
manager/models/models.go
View File

@ -88,7 +88,7 @@ func (m JSONMap) GormDataType() string {
} }
func (JSONMap) GormDBDataType(db *gorm.DB, field *schema.Field) string { func (JSONMap) GormDBDataType(db *gorm.DB, field *schema.Field) string {
return "text" return "longtext"
} }
type Array []string type Array []string
@ -137,5 +137,5 @@ func (Array) GormDataType() string {
} }
func (Array) GormDBDataType(db *gorm.DB, field *schema.Field) string { func (Array) GormDBDataType(db *gorm.DB, field *schema.Field) string {
return "text" return "longtext"
} }

4
manager/rpcserver/manager_server_v2.go
View File

@ -238,8 +238,6 @@ func (s *managerServerV2) UpdateSeedPeer(ctx context.Context, req *managerv2.Upd
seedPeer := models.SeedPeer{} seedPeer := models.SeedPeer{}
if err := s.db.WithContext(ctx).First(&seedPeer, models.SeedPeer{ if err := s.db.WithContext(ctx).First(&seedPeer, models.SeedPeer{
Hostname: req.Hostname, Hostname: req.Hostname,
IP: req.Ip,
Port: req.Port,
SeedPeerClusterID: uint(req.SeedPeerClusterId), SeedPeerClusterID: uint(req.SeedPeerClusterId),
}).Error; err != nil { }).Error; err != nil {
if errors.Is(err, gorm.ErrRecordNotFound) { if errors.Is(err, gorm.ErrRecordNotFound) {
@ -452,8 +450,6 @@ func (s *managerServerV2) UpdateScheduler(ctx context.Context, req *managerv2.Up
scheduler := models.Scheduler{} scheduler := models.Scheduler{}
if err := s.db.WithContext(ctx).First(&scheduler, models.Scheduler{ if err := s.db.WithContext(ctx).First(&scheduler, models.Scheduler{
Hostname: req.Hostname, Hostname: req.Hostname,
IP: req.Ip,
Port: req.Port,
SchedulerClusterID: uint(req.SchedulerClusterId), SchedulerClusterID: uint(req.SchedulerClusterId),
}).Error; err != nil { }).Error; err != nil {
if errors.Is(err, gorm.ErrRecordNotFound) { if errors.Is(err, gorm.ErrRecordNotFound) {