Skip to content

Commit 42a52ab

Browse files
authored
feat: capability to bulk restart workloads from application groups (#5030)
* story(bulk rotate): "wip" * story(bulk rotate): "name refactored" * story(bulk rotate): "query changed" * story(bulk rotate): "query changed" * story(bulk rotate): worker pool added * sql script added for pco * story(bulk rotate): "some checks added" * story(bulk rotate): "name issue fixed" * story(bulk rotate): "branch updated for deletion" * story(bulk rotate): "RestartPodMap to restartPodMap" * story(bulk rotate): code refactored around worker pool * story(bulk rotate): info logger * story(bulk rotate): code refactored * story(bulk rotate): code refactored * story(bulk rotate): code handled for deleted appIds * story(bulk rotate): app and env call move from method * size reduced * story(bulk rotate): only fetched desired data from pco * code refactored * comment removed * code review comment resolved * code refactored * omitempty removed * code refactored around response * not deployed issue fixed * empty check removed * code optimized * sql querry changed
1 parent e334e53 commit 42a52ab

File tree

33 files changed

+2199
-374
lines changed

33 files changed

+2199
-374
lines changed

api/deployment/DeploymentConfigRestHandler.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -230,7 +230,7 @@ func (handler *DeploymentConfigRestHandlerImpl) DownloadChart(w http.ResponseWri
230230
common.WriteJsonResp(w, fmt.Errorf("error in parsing chartRefId : %s must be integer", chartRefId), nil, http.StatusBadRequest)
231231
return
232232
}
233-
manifestByteArr, err := handler.chartRefService.GetChartInBytes(chartRefId)
233+
manifestByteArr, err := handler.chartRefService.GetChartInBytes(chartRefId, false)
234234
if err != nil {
235235
handler.Logger.Errorw("error in converting chart to bytes", "err", err)
236236
common.WriteJsonResp(w, err, nil, http.StatusInternalServerError)

api/helm-app/gRPC/applicationClient.go

Lines changed: 12 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -28,6 +28,7 @@ type HelmAppClient interface {
2828
IsReleaseInstalled(ctx context.Context, in *ReleaseIdentifier) (*BooleanResponse, error)
2929
RollbackRelease(ctx context.Context, in *RollbackReleaseRequest) (*BooleanResponse, error)
3030
TemplateChart(ctx context.Context, in *InstallReleaseRequest) (*TemplateChartResponse, error)
31+
TemplateChartBulk(ctx context.Context, in *BulkInstallReleaseRequest) (*BulkTemplateChartResponse, error)
3132
InstallReleaseWithCustomChart(ctx context.Context, in *HelmInstallCustomRequest) (*HelmInstallCustomResponse, error)
3233
GetNotes(ctx context.Context, request *InstallReleaseRequest) (*ChartNotesResponse, error)
3334
ValidateOCIRegistry(ctx context.Context, OCIRegistryRequest *RegistryCredential) (*OCIRegistryResponse, error)
@@ -293,6 +294,17 @@ func (impl *HelmAppClientImpl) TemplateChart(ctx context.Context, in *InstallRel
293294
}
294295
return response, nil
295296
}
297+
func (impl *HelmAppClientImpl) TemplateChartBulk(ctx context.Context, in *BulkInstallReleaseRequest) (*BulkTemplateChartResponse, error) {
298+
applicationClient, err := impl.getApplicationClient()
299+
if err != nil {
300+
return nil, err
301+
}
302+
response, err := applicationClient.TemplateChartBulk(ctx, in)
303+
if err != nil {
304+
return nil, err
305+
}
306+
return response, nil
307+
}
296308

297309
func (impl *HelmAppClientImpl) InstallReleaseWithCustomChart(ctx context.Context, in *HelmInstallCustomRequest) (*HelmInstallCustomResponse, error) {
298310
applicationClient, err := impl.getApplicationClient()

0 commit comments

Comments
 (0)