@@ -116,13 +116,25 @@ func buildOBClusterResponse(ctx context.Context, obcluster *v1alpha1.OBCluster)
116
116
if err != nil {
117
117
return nil , errors .Wrap (err , "failed to build obcluster overview" )
118
118
}
119
+
120
+ conn , err := utils .GetOBConnection (ctx , obcluster , "root" , "sys" , obcluster .Spec .UserSecrets .Root )
121
+ if err != nil {
122
+ logger .WithError (err ).Info ("Failed to get OceanBase database connection" )
123
+ return nil , errors .Wrapf (err , "Failed to get connection of obcluster" )
124
+ }
125
+ version , err := conn .GetVersion (ctx )
126
+ if err != nil {
127
+ logger .WithError (err ).Info ("Failed to get OceanBase database version" )
128
+ return nil , errors .Wrapf (err , "Failed to get version of obcluster" )
129
+ }
130
+
119
131
respCluster := & response.OBCluster {
120
132
OBClusterOverview : * overview ,
121
133
OBClusterExtra : response.OBClusterExtra {
122
134
RootPasswordSecret : obcluster .Spec .UserSecrets .Root ,
135
+ Version : version .Version ,
123
136
Parameters : nil ,
124
137
},
125
- // TODO: add metrics
126
138
Metrics : nil ,
127
139
}
128
140
var parameters []response.ParameterSpec
@@ -951,7 +963,7 @@ func ListOBClusterParameters(ctx context.Context, nn *param.K8sObjectIdentity) (
951
963
conn , err := utils .GetOBConnection (ctx , obcluster , "root" , "sys" , obcluster .Spec .UserSecrets .Root )
952
964
if err != nil {
953
965
logger .WithError (err ).Info ("Failed to get OceanBase database connection" )
954
- return nil , nil
966
+ return nil , errors . Wrapf ( err , "Failed to get connection go obcluster" )
955
967
}
956
968
parameters , err := conn .ListClusterParameters (ctx )
957
969
if err != nil {
0 commit comments