You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@shardingsphere.apache.org by du...@apache.org on 2022/10/27 01:56:44 UTC
[shardingsphere-on-cloud] branch main updated: chore(reconcile): add unit test for ToYaml
This is an automated email from the ASF dual-hosted git repository.
duanzhengqiang pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/shardingsphere-on-cloud.git
The following commit(s) were added to refs/heads/main by this push:
new 8a0a619 chore(reconcile): add unit test for ToYaml
new 2d91cc1 Merge pull request #104 from amarps/reconcile_unit_test_to_yaml
8a0a619 is described below
commit 8a0a6194e5a7778f4bcb4e92a4fa65932512610f
Author: senjaya <am...@gmail.com>
AuthorDate: Wed Oct 26 19:35:16 2022 +0700
chore(reconcile): add unit test for ToYaml
---
.../pkg/reconcile/reconcile_test.go | 90 ++++++++++++++++++++++
1 file changed, 90 insertions(+)
diff --git a/shardingsphere-operator/pkg/reconcile/reconcile_test.go b/shardingsphere-operator/pkg/reconcile/reconcile_test.go
index 0f066f9..d4f35ac 100644
--- a/shardingsphere-operator/pkg/reconcile/reconcile_test.go
+++ b/shardingsphere-operator/pkg/reconcile/reconcile_test.go
@@ -480,7 +480,97 @@ func Test_ConstructHPA(t *testing.T) {
}
func Test_ToYAML(t *testing.T) {
+ cases := []struct {
+ proxyCfg *v1alpha1.ShardingSphereProxyServerConfig
+ exp string
+ message string
+ }{
+ {
+ proxyCfg: &v1alpha1.ShardingSphereProxyServerConfig{},
+ exp: `mode:
+ type: ""
+ repository:
+ type: ""
+ props:
+ namespace: ""
+ server-lists: ""
+authority:
+ users: []
+ privilege: null
+`,
+ message: "Empty proxy server config should generate yaml with empty value",
+ },
+ {
+ proxyCfg: &v1alpha1.ShardingSphereProxyServerConfig{
+ Spec: v1alpha1.ProxyConfigSpec{
+ ClusterConfig: v1alpha1.ClusterConfig{
+ Type: "Cluster",
+ Repository: v1alpha1.RepositoryConfig{
+ Type: "Zookeeper",
+ Props: v1alpha1.ClusterProps{
+ Namespace: "cluster-sharding-mode",
+ ServerLists: "host1:2181,host2:2181",
+ RetryIntervalMilliseconds: 500,
+ MaxRetries: 3,
+ TimeToLiveSeconds: 60,
+ OperationTimeoutMilliseconds: 500,
+ },
+ },
+ },
+ Authority: v1alpha1.Auth{
+ Users: []v1alpha1.User{
+ {
+ User: "John",
+ Password: "123456",
+ },
+ },
+ Privilege: &v1alpha1.Privilege{
+ Type: "Admin",
+ },
+ },
+ Props: &v1alpha1.Props{
+ KernelExecutorSize: 16,
+ CheckTableMetadataEnabled: false,
+ ProxyBackendQueryFetchSize: -1,
+ CheckDuplicateTableEnabled: false,
+ ProxyFrontendExecutorSize: 0,
+ ProxyBackendExecutorSuitable: "OLAP",
+ ProxyBackendDriverType: "JDBC",
+ ProxyFrontendDatabaseProtocolType: "",
+ },
+ },
+ },
+ exp: `mode:
+ type: Cluster
+ repository:
+ type: Zookeeper
+ props:
+ namespace: cluster-sharding-mode
+ server-lists: host1:2181,host2:2181
+ retryIntervalMilliseconds: 500
+ maxRetries: 3
+ timeToLiveSeconds: 60
+ operationTimeoutMilliseconds: 500
+authority:
+ users:
+ - user: John
+ password: "123456"
+ privilege:
+ type: Admin
+props:
+ kernel-executor-size: 16
+ proxy-backend-query-fetch-size: -1
+ proxy-backend-executor-suitable: OLAP
+ proxy-backend-driver-type: JDBC
+`,
+ message: "Should generate yaml with the same value as ShardingSphereProxyServerConfig.Spec",
+ },
+ }
+ for _, c := range cases {
+ act := toYaml(c.proxyCfg)
+ assert.Equal(t, c.exp, act, c.message)
+ }
}
func Test_UpdateDeployment(t *testing.T) {