| @@ -48,6 +48,7 @@ type ( | |||||
| GpuTotal float64 `db:"gpu_total"` | GpuTotal float64 `db:"gpu_total"` | ||||
| CardTotal int64 `db:"card_total"` // 算力卡数量 | CardTotal int64 `db:"card_total"` // 算力卡数量 | ||||
| CardTopsTotal float64 `db:"card_tops_total"` // 算力总量tops | CardTopsTotal float64 `db:"card_tops_total"` // 算力总量tops | ||||
| AdapterId int64 `db:"adapter_id"` | |||||
| } | } | ||||
| ) | ) | ||||
| @@ -86,14 +87,14 @@ func (m *defaultTClusterResourceModel) FindOne(ctx context.Context, clusterId in | |||||
| } | } | ||||
| func (m *defaultTClusterResourceModel) Insert(ctx context.Context, data *TClusterResource) (sql.Result, error) { | func (m *defaultTClusterResourceModel) Insert(ctx context.Context, data *TClusterResource) (sql.Result, error) { | ||||
| query := fmt.Sprintf("insert into %s (%s) values (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)", m.table, tClusterResourceRowsExpectAutoSet) | |||||
| ret, err := m.conn.ExecCtx(ctx, query, data.ClusterId, data.ClusterName, data.ClusterType, data.CpuAvail, data.CpuTotal, data.MemAvail, data.MemTotal, data.DiskAvail, data.DiskTotal, data.GpuAvail, data.GpuTotal, data.CardTotal, data.CardTopsTotal) | |||||
| query := fmt.Sprintf("insert into %s (%s) values (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)", m.table, tClusterResourceRowsExpectAutoSet) | |||||
| ret, err := m.conn.ExecCtx(ctx, query, data.ClusterId, data.ClusterName, data.ClusterType, data.CpuAvail, data.CpuTotal, data.MemAvail, data.MemTotal, data.DiskAvail, data.DiskTotal, data.GpuAvail, data.GpuTotal, data.CardTotal, data.CardTopsTotal, data.AdapterId) | |||||
| return ret, err | return ret, err | ||||
| } | } | ||||
| func (m *defaultTClusterResourceModel) Update(ctx context.Context, data *TClusterResource) error { | func (m *defaultTClusterResourceModel) Update(ctx context.Context, data *TClusterResource) error { | ||||
| query := fmt.Sprintf("update %s set %s where `cluster_id` = ?", m.table, tClusterResourceRowsWithPlaceHolder) | query := fmt.Sprintf("update %s set %s where `cluster_id` = ?", m.table, tClusterResourceRowsWithPlaceHolder) | ||||
| _, err := m.conn.ExecCtx(ctx, query, data.ClusterName, data.ClusterType, data.CpuAvail, data.CpuTotal, data.MemAvail, data.MemTotal, data.DiskAvail, data.DiskTotal, data.GpuAvail, data.GpuTotal, data.CardTotal, data.CardTopsTotal, data.ClusterId) | |||||
| _, err := m.conn.ExecCtx(ctx, query, data.ClusterName, data.ClusterType, data.CpuAvail, data.CpuTotal, data.MemAvail, data.MemTotal, data.DiskAvail, data.DiskTotal, data.GpuAvail, data.GpuTotal, data.CardTotal, data.CardTopsTotal, data.AdapterId, data.ClusterId) | |||||
| return err | return err | ||||
| } | } | ||||