Skip to content

Commit

Permalink
Updated DBExtraParams
Browse files Browse the repository at this point in the history
  • Loading branch information
VaniHaripriya committed Apr 11, 2024
1 parent 97d1708 commit 3428695
Show file tree
Hide file tree
Showing 2 changed files with 7 additions and 10 deletions.
4 changes: 3 additions & 1 deletion controllers/config/defaults.go
Original file line number Diff line number Diff line change
Expand Up @@ -189,6 +189,8 @@ var (
MlmdWriterResourceRequirements = createResourceRequirement(resource.MustParse("100m"), resource.MustParse("256Mi"), resource.MustParse("100m"), resource.MustParse("256Mi"))
)

type DBExtraParams map[string]string

func createResourceRequirement(RequestsCPU resource.Quantity, RequestsMemory resource.Quantity, LimitsCPU resource.Quantity, LimitsMemory resource.Quantity) dspav1alpha1.ResourceRequirements {
return dspav1alpha1.ResourceRequirements{
Requests: &dspav1alpha1.Resources{
Expand Down Expand Up @@ -225,7 +227,7 @@ func GetCABundleFileMountPath() string {
return fmt.Sprintf("%s/%s", CustomCABundleRootMountPath, CustomDSPTrustedCAConfigMapKey)
}

func GetDefaultDBExtraParams(params interface{}, log logr.Logger) (string, error) {
func GetDefaultDBExtraParams(params DBExtraParams, log logr.Logger) (string, error) {
extraParamsJson, err := json.Marshal(params)
if err != nil {
log.Info(fmt.Sprintf("Error marshaling TLS configuration to JSON: %v", err))
Expand Down
13 changes: 4 additions & 9 deletions controllers/dspipeline_params.go
Original file line number Diff line number Diff line change
Expand Up @@ -89,11 +89,6 @@ type DBConnection struct {
Password string
ExtraParams string
}

type DBExtraParams struct {
TLS string `json:"tls"`
}

type ObjectStorageConnection struct {
Bucket string
CredentialsSecret *dspa.S3CredentialSecret
Expand Down Expand Up @@ -264,8 +259,8 @@ func (p *DSPAParams) SetupDBParams(ctx context.Context, dsp *dspa.DataSciencePip

// Assume default external connection is tls enabled
// user can override this via CustomExtraParams field
tlsParams := DBExtraParams{
TLS: "true",
tlsParams := config.DBExtraParams{
"tls": "true",
}
dbExtraParams, err := config.GetDefaultDBExtraParams(tlsParams, log)
if err != nil {
Expand Down Expand Up @@ -313,8 +308,8 @@ func (p *DSPAParams) SetupDBParams(ctx context.Context, dsp *dspa.DataSciencePip
p.DBConnection.Username = p.MariaDB.Username
p.DBConnection.DBName = p.MariaDB.DBName
// By Default OOB mariadb is not tls enabled
tlsParams := DBExtraParams{
TLS: "false",
tlsParams := config.DBExtraParams{
"tls": "false",
}
dbExtraParams, err := config.GetDefaultDBExtraParams(tlsParams, log)
if err != nil {
Expand Down

0 comments on commit 3428695

Please sign in to comment.