Skip to content

Commit ed0045d

Browse files
committed
Support restart node list and re-elect zookeeper.
1 parent 743fbd2 commit ed0045d

File tree

192 files changed

+20791
-0
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

192 files changed

+20791
-0
lines changed

CHANGELOG

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,6 @@
1+
2025-06-12 Version: 1.0.0
2+
- Support restart node list and re-elect zookeeper.
3+
14
2025-06-12 Version: 1.0.1
25
- Generated 2025-04-29 for `WebsiteBuild`.
36

Lines changed: 76 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,76 @@
1+
/*
2+
* Licensed to the Apache Software Foundation (ASF) under one
3+
* or more contributor license agreements. See the NOTICE file
4+
* distributed with this work for additional information
5+
* regarding copyright ownership. The ASF licenses this file
6+
* to you under the Apache License, Version 2.0 (the
7+
* "License"); you may not use this file except in compliance
8+
* with the License. You may obtain a copy of the License at
9+
*
10+
* http://www.apache.org/licenses/LICENSE-2.0
11+
*
12+
* Unless required by applicable law or agreed to in writing,
13+
* software distributed under the License is distributed on an
14+
* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
15+
* KIND, either express or implied. See the License for the
16+
* specific language governing permissions and limitations
17+
* under the License.
18+
*/
19+
20+
using System.Collections.Generic;
21+
22+
namespace Aliyun.Acs.clickhouse
23+
{
24+
public class Endpoint
25+
{
26+
public static Dictionary<string, string> endpointMap = new Dictionary<string, string>()
27+
{
28+
{ "cn-shanghai-internal-test-1", "clickhouse.aliyuncs.com" },
29+
{ "cn-beijing-gov-1", "clickhouse.aliyuncs.com" },
30+
{ "cn-shenzhen-su18-b01", "clickhouse.aliyuncs.com" },
31+
{ "cn-beijing", "clickhouse.aliyuncs.com" },
32+
{ "cn-shanghai-inner", "clickhouse.aliyuncs.com" },
33+
{ "cn-shenzhen-st4-d01", "clickhouse.aliyuncs.com" },
34+
{ "cn-haidian-cm12-c01", "clickhouse.aliyuncs.com" },
35+
{ "cn-hangzhou-internal-prod-1", "clickhouse.aliyuncs.com" },
36+
{ "cn-north-2-gov-1", "clickhouse.aliyuncs.com" },
37+
{ "cn-yushanfang", "clickhouse.aliyuncs.com" },
38+
{ "cn-qingdao", "clickhouse.aliyuncs.com" },
39+
{ "cn-hongkong-finance-pop", "clickhouse.aliyuncs.com" },
40+
{ "cn-qingdao-nebula", "clickhouse.aliyuncs.com" },
41+
{ "cn-shanghai", "clickhouse.aliyuncs.com" },
42+
{ "cn-shanghai-finance-1", "clickhouse.aliyuncs.com" },
43+
{ "cn-hongkong", "clickhouse.aliyuncs.com" },
44+
{ "cn-beijing-finance-pop", "clickhouse.aliyuncs.com" },
45+
{ "cn-wuhan", "clickhouse.aliyuncs.com" },
46+
{ "us-west-1", "clickhouse.aliyuncs.com" },
47+
{ "cn-shenzhen", "clickhouse.aliyuncs.com" },
48+
{ "cn-zhengzhou-nebula-1", "clickhouse.aliyuncs.com" },
49+
{ "rus-west-1-pop", "clickhouse.aliyuncs.com" },
50+
{ "cn-shanghai-et15-b01", "clickhouse.aliyuncs.com" },
51+
{ "cn-hangzhou-bj-b01", "clickhouse.aliyuncs.com" },
52+
{ "cn-hangzhou-internal-test-1", "clickhouse.aliyuncs.com" },
53+
{ "eu-west-1-oxs", "clickhouse.aliyuncs.com" },
54+
{ "cn-zhangbei-na61-b01", "clickhouse.aliyuncs.com" },
55+
{ "cn-beijing-finance-1", "clickhouse.aliyuncs.com" },
56+
{ "cn-hangzhou-internal-test-3", "clickhouse.aliyuncs.com" },
57+
{ "cn-hangzhou-internal-test-2", "clickhouse.aliyuncs.com" },
58+
{ "cn-shenzhen-finance-1", "clickhouse.aliyuncs.com" },
59+
{ "me-east-1", "clickhouse.aliyuncs.com" },
60+
{ "cn-hangzhou-test-306", "clickhouse.aliyuncs.com" },
61+
{ "cn-shanghai-et2-b01", "clickhouse.aliyuncs.com" },
62+
{ "cn-hangzhou-finance", "clickhouse.aliyuncs.com" },
63+
{ "ap-southeast-1", "clickhouse.aliyuncs.com" },
64+
{ "cn-beijing-nu16-b01", "clickhouse.aliyuncs.com" },
65+
{ "cn-edge-1", "clickhouse.aliyuncs.com" },
66+
{ "cn-fujian", "clickhouse.aliyuncs.com" },
67+
{ "us-east-1", "clickhouse.aliyuncs.com" },
68+
{ "ap-northeast-2-pop", "clickhouse.aliyuncs.com" },
69+
{ "cn-shenzhen-inner", "clickhouse.aliyuncs.com" },
70+
{ "cn-zhangjiakou-na62-a01", "clickhouse.aliyuncs.com" },
71+
{ "cn-hangzhou", "clickhouse.aliyuncs.com" },
72+
};
73+
74+
public static string endpointRegionalType = "regional";
75+
}
76+
}
Lines changed: 143 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,143 @@
1+
/*
2+
* Licensed to the Apache Software Foundation (ASF) under one
3+
* or more contributor license agreements. See the NOTICE file
4+
* distributed with this work for additional information
5+
* regarding copyright ownership. The ASF licenses this file
6+
* to you under the Apache License, Version 2.0 (the
7+
* "License"); you may not use this file except in compliance
8+
* with the License. You may obtain a copy of the License at
9+
*
10+
* http://www.apache.org/licenses/LICENSE-2.0
11+
*
12+
* Unless required by applicable law or agreed to in writing,
13+
* software distributed under the License is distributed on an
14+
* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
15+
* KIND, either express or implied. See the License for the
16+
* specific language governing permissions and limitations
17+
* under the License.
18+
*/
19+
using System.Collections.Generic;
20+
21+
using Aliyun.Acs.Core;
22+
using Aliyun.Acs.Core.Http;
23+
using Aliyun.Acs.Core.Transform;
24+
using Aliyun.Acs.Core.Utils;
25+
using Aliyun.Acs.clickhouse.Transform;
26+
using Aliyun.Acs.clickhouse.Transform.V20191111;
27+
28+
namespace Aliyun.Acs.clickhouse.Model.V20191111
29+
{
30+
public class AllocateClusterPublicConnectionRequest : RpcAcsRequest<AllocateClusterPublicConnectionResponse>
31+
{
32+
public AllocateClusterPublicConnectionRequest()
33+
: base("clickhouse", "2019-11-11", "AllocateClusterPublicConnection", "service", "openAPI")
34+
{
35+
if (this.GetType().GetProperty("ProductEndpointMap") != null && this.GetType().GetProperty("ProductEndpointType") != null)
36+
{
37+
this.GetType().GetProperty("ProductEndpointMap").SetValue(this, Aliyun.Acs.clickhouse.Endpoint.endpointMap, null);
38+
this.GetType().GetProperty("ProductEndpointType").SetValue(this, Aliyun.Acs.clickhouse.Endpoint.endpointRegionalType, null);
39+
}
40+
Method = MethodType.POST;
41+
}
42+
43+
private long? resourceOwnerId;
44+
45+
private string connectionStringPrefix;
46+
47+
private string resourceOwnerAccount;
48+
49+
private string dBClusterId;
50+
51+
private string ownerAccount;
52+
53+
private long? ownerId;
54+
55+
public long? ResourceOwnerId
56+
{
57+
get
58+
{
59+
return resourceOwnerId;
60+
}
61+
set
62+
{
63+
resourceOwnerId = value;
64+
DictionaryUtil.Add(QueryParameters, "ResourceOwnerId", value.ToString());
65+
}
66+
}
67+
68+
public string ConnectionStringPrefix
69+
{
70+
get
71+
{
72+
return connectionStringPrefix;
73+
}
74+
set
75+
{
76+
connectionStringPrefix = value;
77+
DictionaryUtil.Add(QueryParameters, "ConnectionStringPrefix", value);
78+
}
79+
}
80+
81+
public string ResourceOwnerAccount
82+
{
83+
get
84+
{
85+
return resourceOwnerAccount;
86+
}
87+
set
88+
{
89+
resourceOwnerAccount = value;
90+
DictionaryUtil.Add(QueryParameters, "ResourceOwnerAccount", value);
91+
}
92+
}
93+
94+
public string DBClusterId
95+
{
96+
get
97+
{
98+
return dBClusterId;
99+
}
100+
set
101+
{
102+
dBClusterId = value;
103+
DictionaryUtil.Add(QueryParameters, "DBClusterId", value);
104+
}
105+
}
106+
107+
public string OwnerAccount
108+
{
109+
get
110+
{
111+
return ownerAccount;
112+
}
113+
set
114+
{
115+
ownerAccount = value;
116+
DictionaryUtil.Add(QueryParameters, "OwnerAccount", value);
117+
}
118+
}
119+
120+
public long? OwnerId
121+
{
122+
get
123+
{
124+
return ownerId;
125+
}
126+
set
127+
{
128+
ownerId = value;
129+
DictionaryUtil.Add(QueryParameters, "OwnerId", value.ToString());
130+
}
131+
}
132+
133+
public override bool CheckShowJsonItemName()
134+
{
135+
return false;
136+
}
137+
138+
public override AllocateClusterPublicConnectionResponse GetResponse(UnmarshallerContext unmarshallerContext)
139+
{
140+
return AllocateClusterPublicConnectionResponseUnmarshaller.Unmarshall(unmarshallerContext);
141+
}
142+
}
143+
}
Lines changed: 42 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,42 @@
1+
/*
2+
* Licensed to the Apache Software Foundation (ASF) under one
3+
* or more contributor license agreements. See the NOTICE file
4+
* distributed with this work for additional information
5+
* regarding copyright ownership. The ASF licenses this file
6+
* to you under the Apache License, Version 2.0 (the
7+
* "License"); you may not use this file except in compliance
8+
* with the License. You may obtain a copy of the License at
9+
*
10+
* http://www.apache.org/licenses/LICENSE-2.0
11+
*
12+
* Unless required by applicable law or agreed to in writing,
13+
* software distributed under the License is distributed on an
14+
* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
15+
* KIND, either express or implied. See the License for the
16+
* specific language governing permissions and limitations
17+
* under the License.
18+
*/
19+
using System.Collections.Generic;
20+
using Newtonsoft.Json;
21+
using Aliyun.Acs.Core;
22+
23+
namespace Aliyun.Acs.clickhouse.Model.V20191111
24+
{
25+
public class AllocateClusterPublicConnectionResponse : AcsResponse
26+
{
27+
28+
private string requestId;
29+
30+
public string RequestId
31+
{
32+
get
33+
{
34+
return requestId;
35+
}
36+
set
37+
{
38+
requestId = value;
39+
}
40+
}
41+
}
42+
}

0 commit comments

Comments
 (0)