Skip to content

Commit 428452b

Browse files
wtrockiuidoyen
andauthored
fix: add cos connectors mock (#317) (#318)
Co-authored-by: Ashique Ansari <nasiba.ansari@gmail.com>
1 parent 2176005 commit 428452b

File tree

5 files changed

+19357
-4
lines changed

5 files changed

+19357
-4
lines changed
Lines changed: 38 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,38 @@
1+
{
2+
"kind": "ConnectorClusterList",
3+
"page": 1,
4+
"size": 3,
5+
"total": 3,
6+
"items": [
7+
{
8+
"id": "c8kssjroqs0t3bbcohl0",
9+
"kind": "ConnectorCluster",
10+
"href": "/api/connector_mgmt/v1/kafka_connector_clusters/c8kssjroqs0t3bbcohl0",
11+
"owner": "mock-user",
12+
"created_at": "2022-03-10T10:09:19.859921Z",
13+
"modified_at": "2022-03-10T10:12:30.293656Z",
14+
"name": "connector-cluster-1",
15+
"status": { "state": "ready" }
16+
},
17+
{
18+
"id": "c8nhhjfih07jt7jv6480",
19+
"kind": "ConnectorCluster",
20+
"href": "/api/connector_mgmt/v1/kafka_connector_clusters/c8nhhjfih07jt7jv6480",
21+
"owner": "mock-user",
22+
"created_at": "2022-03-14T10:28:29.549184Z",
23+
"modified_at": "2022-03-14T10:54:52.74668Z",
24+
"name": "connector-cluster-2",
25+
"status": { "state": "disconnected" }
26+
},
27+
{
28+
"id": "c818ca4alharh4tcb7m0",
29+
"kind": "ConnectorCluster",
30+
"href": "/api/connector_mgmt/v1/kafka_connector_clusters/c818ca4alharh4tcb7m0",
31+
"owner": "mock-user",
32+
"created_at": "2022-02-08T15:03:04.00474Z",
33+
"modified_at": "2022-03-11T16:05:01.280693Z",
34+
"name": "connector-cluster-3",
35+
"status": { "state": "ready" }
36+
}
37+
]
38+
}
Lines changed: 255 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,255 @@
1+
{
2+
"kind": "ConnectorList",
3+
"page": 1,
4+
"size": 7,
5+
"total": 7,
6+
"items": [
7+
{
8+
"id": "c8b3h6ldsp2m5g2vmlug",
9+
"kind": "Connector",
10+
"href": "/api/connector_mgmt/v1/kafka_connectors/c8b3h6ldsp2m5g2vmlug",
11+
"owner": "mock-user",
12+
"created_at": "2022-02-23T13:37:30.240914Z",
13+
"modified_at": "2022-03-11T13:43:42.847719Z",
14+
"name": "mongodb_sink",
15+
"connector_type_id": "mongodb_sink_0.1",
16+
"channel": "stable",
17+
"deployment_location": {
18+
"kind": "addon",
19+
"cluster_id": "c818ca4alharh4tcb7m0"
20+
},
21+
"desired_state": "deleted",
22+
"resource_version": 407,
23+
"kafka": {
24+
"id": "c8b308vrvd7dl597mp4g",
25+
"url": "asmigala-t-c-b---vrvd-dl---mp-g.bf2.kafka.rhcloud.com:443"
26+
},
27+
"service_account": {
28+
"client_id": "srvc-acct-8d53b9f0-4d6e-43f0-bbf5-b0eb27ea7110",
29+
"client_secret": ""
30+
},
31+
"schema_registry": { "id": "", "url": "" },
32+
"connector": {
33+
"data_shape": { "consumes": { "format": "application/json" } },
34+
"error_handler": { "dead_letter_queue": { "topic": "dlq" } },
35+
"kafka_topic": "test new",
36+
"mongodb_collection": "rhocqe",
37+
"mongodb_create_collection": true,
38+
"mongodb_database": "sampledb",
39+
"mongodb_hosts": "mongodb.asmigala.svc.cluster.local",
40+
"mongodb_password": {},
41+
"mongodb_username": "root"
42+
},
43+
"status": { "state": "updating" }
44+
},
45+
{
46+
"id": "c837al3ihpm73aludtug",
47+
"kind": "Connector",
48+
"href": "/api/connector_mgmt/v1/kafka_connectors/c837al3ihpm73aludtug",
49+
"owner": "mock-user",
50+
"created_at": "2022-02-11T14:40:20.761778Z",
51+
"modified_at": "2022-03-08T10:20:24.103294Z",
52+
"name": "AWS Kinesis Source",
53+
"connector_type_id": "aws_kinesis_sink_0.1",
54+
"channel": "stable",
55+
"deployment_location": {
56+
"kind": "addon",
57+
"cluster_id": "c818ca4alharh4tcb7m0"
58+
},
59+
"desired_state": "deleted",
60+
"resource_version": 272,
61+
"kafka": {
62+
"id": "c81vl3slvnauoahslu90",
63+
"url": "shivamgu-k-c--vl-slvnauoahslu-a.bf2.kafka.rhcloud.com:443"
64+
},
65+
"service_account": {
66+
"client_id": "srvc-acct-5bb611b1-837c-4fe6-820a-af3bc4c0aa09",
67+
"client_secret": ""
68+
},
69+
"schema_registry": { "id": "", "url": "" },
70+
"connector": {
71+
"aws_access_key": {},
72+
"aws_region": "AWS",
73+
"aws_secret_key": {},
74+
"aws_stream": "Stream",
75+
"error_handling": {
76+
"dead_letter_queue": { "topic": "Dead Letter Topic Name" }
77+
},
78+
"kafka_registry_url": "Topic Service Registry URL",
79+
"kafka_topic": "Topic Names "
80+
},
81+
"status": { "state": "updating" }
82+
},
83+
{
84+
"id": "c8bo9dftfa9sdsrfgppg",
85+
"kind": "Connector",
86+
"href": "/api/connector_mgmt/v1/kafka_connectors/c8bo9dftfa9sdsrfgppg",
87+
"owner": "mock-user",
88+
"created_at": "2022-02-24T13:14:29.93717Z",
89+
"modified_at": "2022-02-25T09:48:47.09852Z",
90+
"name": "AWS Cloudwatch Sink",
91+
"connector_type_id": "aws_cloudwatch_sink_0.1",
92+
"channel": "stable",
93+
"deployment_location": { "kind": "addon" },
94+
"desired_state": "ready",
95+
"resource_version": 51,
96+
"kafka": {
97+
"id": "c8b308vrvd7dl597mp4g",
98+
"url": "asmigala-t-c-b---vrvd-dl---mp-g.bf2.kafka.rhcloud.com:443"
99+
},
100+
"service_account": {
101+
"client_id": "srvc-acct-96e27a0e-6306-48ca-ab5e-240ccd459218",
102+
"client_secret": ""
103+
},
104+
"schema_registry": { "id": "", "url": "" },
105+
"connector": {
106+
"aws_access_key": {},
107+
"aws_cw_namespace": "Cloud Watch Namespace",
108+
"aws_region": "AWS Region",
109+
"aws_secret_key": {},
110+
"error_handler": { "log": {} },
111+
"kafka_registry_url": "Topic Service Registry URL",
112+
"kafka_topic": "Topic Names "
113+
},
114+
"status": { "state": "assigning" }
115+
},
116+
{
117+
"id": "c8au7rqk5s1jujjq7rmg",
118+
"kind": "Connector",
119+
"href": "/api/connector_mgmt/v1/kafka_connectors/c8au7rqk5s1jujjq7rmg",
120+
"owner": "mock-user",
121+
"created_at": "2022-02-23T07:36:15.533105Z",
122+
"modified_at": "2022-02-23T16:59:02.515842Z",
123+
"name": "AWS SQS Sink",
124+
"connector_type_id": "aws_sqs_sink_0.1",
125+
"channel": "stable",
126+
"deployment_location": {
127+
"kind": "addon",
128+
"cluster_id": "c818ca4alharh4tcb7m0"
129+
},
130+
"desired_state": "deleted",
131+
"resource_version": 45,
132+
"kafka": {
133+
"id": "c89lvbn1j0qnbnktuko0",
134+
"url": "asmigala-k-c--lvbn-j-qnbnktukoa.bf2.kafka.rhcloud.com:443"
135+
},
136+
"service_account": {
137+
"client_id": "srvc-acct-623f3b7e-0f9d-4e56-8d1a-e3514e5a4b16",
138+
"client_secret": ""
139+
},
140+
"schema_registry": { "id": "", "url": "" },
141+
"connector": {
142+
"aws_access_key": {},
143+
"aws_amazon_a_w_s_host": "localhost",
144+
"aws_auto_create_queue": true,
145+
"aws_queue_name_or_arn": "Queue Name",
146+
"aws_region": "US East",
147+
"aws_secret_key": {},
148+
"aws_use_default_credentials_provider": true,
149+
"error_handling": { "log": {} },
150+
"kafka_registry_url": "example.avro",
151+
"kafka_topic": "MyTopic"
152+
},
153+
"status": { "state": "failed" }
154+
},
155+
{
156+
"id": "c8f5j1vtfa9sdsrj3vdg",
157+
"kind": "Connector",
158+
"href": "/api/connector_mgmt/v1/kafka_connectors/c8f5j1vtfa9sdsrj3vdg",
159+
"owner": "mock-user",
160+
"created_at": "2022-03-01T17:36:07.988059Z",
161+
"modified_at": "2022-03-04T16:11:29.740203Z",
162+
"name": "debezium mongodb",
163+
"connector_type_id": "debezium-mongodb-1.9.0.Alpha2",
164+
"channel": "stable",
165+
"deployment_location": {
166+
"kind": "addon",
167+
"cluster_id": "c818ca4alharh4tcb7m0"
168+
},
169+
"desired_state": "ready",
170+
"resource_version": 170,
171+
"kafka": {
172+
"id": "c8eag87rvd7dl59afs1g",
173+
"url": "lb-cos-c-eag--rvd-dl--afs-g.bf2.kafka.rhcloud.com:443"
174+
},
175+
"service_account": {
176+
"client_id": "srvc-acct-aa843e82-3d0d-4b01-a468-d3a19c2220e9",
177+
"client_secret": ""
178+
},
179+
"schema_registry": { "id": "", "url": "" },
180+
"connector": {
181+
"mongodb.hosts": "cluster0.m54xo.mongodb.net",
182+
"mongodb.name": "test",
183+
"mongodb.password": {},
184+
"mongodb.user": "test"
185+
},
186+
"status": { "state": "provisioning" }
187+
},
188+
{
189+
"id": "c8jmecftfa9sdsrqdiqg",
190+
"kind": "Connector",
191+
"href": "/api/connector_mgmt/v1/kafka_connectors/c8jmecftfa9sdsrqdiqg",
192+
"owner": "mock-user",
193+
"created_at": "2022-03-08T14:24:49.212312Z",
194+
"modified_at": "2022-03-11T08:53:38.480885Z",
195+
"name": "log sink",
196+
"connector_type_id": "log_sink_0.1",
197+
"channel": "stable",
198+
"deployment_location": {
199+
"kind": "addon",
200+
"cluster_id": "c818ca4alharh4tcb7m0"
201+
},
202+
"desired_state": "ready",
203+
"resource_version": 373,
204+
"kafka": {
205+
"id": "c8is1ts45rpbkjl4k4dg",
206+
"url": "btison-con-c-is-ts--rpbkjl-k-dg.bf2.kafka.rhcloud.com:443"
207+
},
208+
"service_account": {
209+
"client_id": "srvc-acct-2f9eab78-3160-4f30-ae43-0d01c77255fd",
210+
"client_secret": ""
211+
},
212+
"schema_registry": { "id": "", "url": "" },
213+
"connector": {
214+
"data_shape": { "consumes": { "format": "application/octet-stream" } },
215+
"error_handler": { "stop": {} },
216+
"kafka_topic": "some_topics2",
217+
"log_multi_line": true,
218+
"log_show_all": true
219+
},
220+
"status": { "state": "updating" }
221+
},
222+
{
223+
"id": "c8fkegvtfa9sdsrjjsk0",
224+
"kind": "Connector",
225+
"href": "/api/connector_mgmt/v1/kafka_connectors/c8fkegvtfa9sdsrjjsk0",
226+
"owner": "mock-user",
227+
"created_at": "2022-03-02T10:30:27.726074Z",
228+
"modified_at": "2022-03-09T07:00:37.257358Z",
229+
"name": "slack sink",
230+
"connector_type_id": "slack_sink_0.1",
231+
"channel": "stable",
232+
"deployment_location": {
233+
"kind": "addon",
234+
"cluster_id": "c818ca4alharh4tcb7m0"
235+
},
236+
"desired_state": "ready",
237+
"resource_version": 310,
238+
"kafka": {
239+
"id": "kafkaId-ignored",
240+
"url": "https://openbridge-c--ajhf-ek--ri--ifea.bf2.kafka.rhcloud.com:443"
241+
},
242+
"service_account": {
243+
"client_id": "srvc-acct-35219453-7a88-485c-8b9a-bcdeb3de694e",
244+
"client_secret": ""
245+
},
246+
"schema_registry": { "id": "", "url": "" },
247+
"connector": {
248+
"kafka_topic": "ob-1caabd74-cad7-4fd7-8f38-f26874edde90",
249+
"slack_channel": "mc",
250+
"slack_webhook_url": {}
251+
},
252+
"status": { "state": "ready" }
253+
}
254+
]
255+
}
Lines changed: 44 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,44 @@
1+
{
2+
"kind": "ConnectorNamespaceList",
3+
"page": 1,
4+
"size": 2,
5+
"total": 2,
6+
"items": [
7+
{
8+
"id": "c8katnf91m180djjmjvg",
9+
"kind": "ConnectorNamespace",
10+
"href": "/api/connector_mgmt/v1/kafka_connector_namespaces/c8katnf91m180djjmjvg",
11+
"owner": "mock-user",
12+
"created_at": "2022-03-09T19:12:53.821698+05:30",
13+
"modified_at": "2022-03-09T19:12:53.821698+05:30",
14+
"name": "default-connector-namespace",
15+
"annotations": [
16+
{
17+
"name": "connector_mgmt.api.openshift.com/profile",
18+
"value": "default-profile"
19+
}
20+
],
21+
"version": 9,
22+
"cluster_id": "c8katnf91m180djjmjv0",
23+
"tenant": { "kind": "organisation", "id": "13888347" }
24+
},
25+
{
26+
"id": "c8kc2gn91m1dvupd4i8g",
27+
"kind": "ConnectorNamespace",
28+
"href": "/api/connector_mgmt/v1/kafka_connector_namespaces/c8kc2gn91m1dvupd4i8g",
29+
"owner": "mock-user",
30+
"created_at": "2022-03-09T20:31:22.244551+05:30",
31+
"modified_at": "2022-03-09T20:31:22.244551+05:30",
32+
"name": "default-connector-namespace",
33+
"annotations": [
34+
{
35+
"name": "connector_mgmt.api.openshift.com/profile",
36+
"value": "default-profile"
37+
}
38+
],
39+
"version": 10,
40+
"cluster_id": "c8kc2gn91m1dvupd4i80",
41+
"tenant": { "kind": "organisation", "id": "13888347" }
42+
}
43+
]
44+
}

0 commit comments

Comments
 (0)