Method UpdateEntityScaleSet

database/sql/scalesets.go:213–252

(ctx context.Context, entity params.ForgeEntity, scaleSetID uint, param params.UpdateScaleSetParams, callback func(old, newSet params.ScaleSet) error)

}

func (s *sqlDatabase) UpdateEntityScaleSet(ctx context.Context, entity params.ForgeEntity, scaleSetID uint, param params.UpdateScaleSetParams, callback func(old, newSet params.ScaleSet) error) (updatedScaleSet params.ScaleSet, err error) {
	var rowsAffected int64
	defer func() {
		if err == nil && rowsAffected > 0 {
			s.sendNotify(common.ScaleSetEntityType, common.UpdateOperation, updatedScaleSet)
		}
	}()
	err = s.conn.Transaction(func(tx *gorm.DB) error {
		scaleSet, err := s.getEntityScaleSet(tx, entity.EntityType, entity.ID, scaleSetID, "Instances", "Tags")
		if err != nil {
			return fmt.Errorf("error fetching scale set: %w", err)
		}

		old, err := s.sqlToCommonScaleSet(scaleSet)
		if err != nil {
			return fmt.Errorf("error converting scale set: %w", err)
		}

		updatedScaleSet, rowsAffected, err = s.updateScaleSet(tx, scaleSet, param)
		if err != nil {
			return fmt.Errorf("error updating scale set: %w", err)
		}

		if callback != nil {
			if err := callback(old, updatedScaleSet); err != nil {
				return fmt.Errorf("error executing update callback: %w", err)
			}
		}
		return nil
	})
	if err != nil {
		return params.ScaleSet{}, err
	}

	updatedScaleSet, err = s.GetScaleSetByID(ctx, scaleSetID)
	if err != nil {
		return params.ScaleSet{}, err
	}
	return updatedScaleSet, nil
}

func (s *sqlDatabase) getEntityScaleSet(tx *gorm.DB, entityType params.ForgeEntityType, entityID string, scaleSetID uint, preload ...string) (ScaleSet, error) {
	if entityID == "" {