Skip to content

Commit 428ab12

Browse files
wangkaibo34wangkaibo34
committed
Follow the naming convention
1 parent f9bef26 commit 428ab12

File tree

2 files changed

+118
-8
lines changed

2 files changed

+118
-8
lines changed

‎client_event_store.go

+116-6
Original file line numberDiff line numberDiff line change
@@ -1,21 +1,131 @@
11
package sls
22

33
const (
4-
EVENT_STORE_TELEMETRY_TYPE = "Event"
5-
EVENT_STORE_INDEX = "{\"max_text_len\":16384,\"ttl\":7,\"log_reduce\":false,\"line\":{\"caseSensitive\":false,\"chn\":true,\"token\":[\",\",\" \",\"'\",\"\\\"\",\";\",\"=\",\"(\",\")\",\"[\",\"]\",\"{\",\"}\",\"?\",\"@\",\"&\",\"<\",\">\",\"/\",\":\",\"\\n\",\"\\t\",\"\\r\"]},\"keys\":{\"specversion\":{\"type\":\"text\",\"doc_value\":true,\"alias\":\"\",\"caseSensitive\":false,\"chn\":false,\"token\":[\",\",\" \",\"'\",\"\\\"\",\";\",\"=\",\"(\",\")\",\"[\",\"]\",\"{\",\"}\",\"?\",\"@\",\"&\",\"<\",\">\",\"/\",\":\",\"\\n\",\"\\t\",\"\\r\"]},\"id\":{\"type\":\"text\",\"doc_value\":true,\"alias\":\"\",\"caseSensitive\":false,\"chn\":false,\"token\":[\",\",\" \",\"'\",\"\\\"\",\";\",\"=\",\"(\",\")\",\"[\",\"]\",\"{\",\"}\",\"?\",\"@\",\"&\",\"<\",\">\",\"/\",\":\",\"\\n\",\"\\t\",\"\\r\"]},\"source\":{\"type\":\"text\",\"doc_value\":true,\"alias\":\"\",\"caseSensitive\":false,\"chn\":false,\"token\":[\",\",\" \",\"'\",\"\\\"\",\";\",\"=\",\"(\",\")\",\"[\",\"]\",\"{\",\"}\",\"?\",\"@\",\"&\",\"<\",\">\",\"/\",\"\\n\",\"\\t\",\"\\r\"]},\"type\":{\"type\":\"text\",\"doc_value\":true,\"alias\":\"\",\"caseSensitive\":false,\"chn\":false,\"token\":[\",\",\" \",\"'\",\"\\\"\",\";\",\"=\",\"(\",\")\",\"[\",\"]\",\"{\",\"}\",\"?\",\"@\",\"&\",\"<\",\">\",\"/\",\":\",\"\\n\",\"\\t\",\"\\r\"]},\"subject\":{\"type\":\"text\",\"doc_value\":true,\"alias\":\"\",\"caseSensitive\":false,\"chn\":false,\"token\":[\",\",\" \",\"'\",\"\\\"\",\";\",\"=\",\"(\",\")\",\"[\",\"]\",\"{\",\"}\",\"?\",\"@\",\"&\",\"<\",\">\",\"/\",\":\",\"\\n\",\"\\t\",\"\\r\"]},\"datacontenttype\":{\"type\":\"text\",\"doc_value\":true,\"alias\":\"\",\"caseSensitive\":false,\"chn\":false,\"token\":[\",\",\" \",\"'\",\"\\\"\",\";\",\"=\",\"(\",\")\",\"[\",\"]\",\"{\",\"}\",\"?\",\"@\",\"&\",\"<\",\">\",\"/\",\":\",\"\\n\",\"\\t\",\"\\r\"]},\"dataschema\":{\"type\":\"text\",\"doc_value\":true,\"alias\":\"\",\"caseSensitive\":false,\"chn\":false,\"token\":[\",\",\" \",\"'\",\"\\\"\",\";\",\"=\",\"(\",\")\",\"[\",\"]\",\"{\",\"}\",\"?\",\"@\",\"&\",\"<\",\">\",\"/\",\":\",\"\\n\",\"\\t\",\"\\r\"]},\"data\":{\"type\":\"json\",\"doc_value\":true,\"alias\":\"\",\"caseSensitive\":false,\"chn\":false,\"token\":[\",\",\" \",\"'\",\"\\\"\",\";\",\"=\",\"(\",\")\",\"[\",\"]\",\"{\",\"}\",\"?\",\"@\",\"&\",\"<\",\">\",\"/\",\":\",\"\\n\",\"\\t\",\"\\r\"],\"index_all\":true,\"max_depth\":-1,\"json_keys\":{}},\"time\":{\"type\":\"text\",\"doc_value\":true,\"alias\":\"\",\"caseSensitive\":false,\"chn\":false,\"token\":[\",\",\" \",\"'\",\"\\\"\",\";\",\"=\",\"(\",\")\",\"[\",\"]\",\"{\",\"}\",\"?\",\"@\",\"&\",\"<\",\">\",\"/\",\":\",\"\\n\",\"\\t\",\"\\r\"]},\"title\":{\"type\":\"text\",\"doc_value\":true,\"alias\":\"\",\"caseSensitive\":false,\"chn\":false,\"token\":[\",\",\" \",\"'\",\"\\\"\",\";\",\"=\",\"(\",\")\",\"[\",\"]\",\"{\",\"}\",\"?\",\"@\",\"&\",\"<\",\">\",\"/\",\":\",\"\\n\",\"\\t\",\"\\r\"]},\"message\":{\"type\":\"text\",\"doc_value\":true,\"alias\":\"\",\"caseSensitive\":false,\"chn\":false,\"token\":[\",\",\" \",\"'\",\"\\\"\",\";\",\"=\",\"(\",\")\",\"[\",\"]\",\"{\",\"}\",\"?\",\"@\",\"&\",\"<\",\">\",\"/\",\":\",\"\\n\",\"\\t\",\"\\r\"]},\"status\":{\"type\":\"text\",\"doc_value\":true,\"alias\":\"\",\"caseSensitive\":false,\"chn\":false,\"token\":[\",\",\" \",\"'\",\"\\\"\",\";\",\"=\",\"(\",\")\",\"[\",\"]\",\"{\",\"}\",\"?\",\"@\",\"&\",\"<\",\">\",\"/\",\":\",\"\\n\",\"\\t\",\"\\r\"]}}}"
4+
EventStoreTelemetryType = "Event"
5+
EventStoreIndex = `{
6+
"max_text_len": 16384,
7+
"ttl": 7,
8+
"log_reduce": false,
9+
"line": {
10+
"caseSensitive": false,
11+
"chn": true,
12+
"token": [",", " ", "'", "\"", ";", "=", "(", ")", "[", "]", "{", "}", "?", "@", "&", "<", ">", "/", ":", "\n", "\t", "\r"]
13+
},
14+
"keys": {
15+
"specversion": {
16+
"type": "text",
17+
"doc_value": true,
18+
"alias": "",
19+
"caseSensitive": false,
20+
"chn": false,
21+
"token": [",", " ", "'", "\"", ";", "=", "(", ")", "[", "]", "{", "}", "?", "@", "&", "<", ">", "/", ":", "\n", "\t", "\r"]
22+
},
23+
"id": {
24+
"type": "text",
25+
"doc_value": true,
26+
"alias": "",
27+
"caseSensitive": false,
28+
"chn": false,
29+
"token": [",", " ", "'", "\"", ";", "=", "(", ")", "[", "]", "{", "}", "?", "@", "&", "<", ">", "/", ":", "\n", "\t", "\r"]
30+
},
31+
"source": {
32+
"type": "text",
33+
"doc_value": true,
34+
"alias": "",
35+
"caseSensitive": false,
36+
"chn": false,
37+
"token": [",", " ", "'", "\"", ";", "=", "(", ")", "[", "]", "{", "}", "?", "@", "&", "<", ">", "/", "\n", "\t", "\r"]
38+
},
39+
"type": {
40+
"type": "text",
41+
"doc_value": true,
42+
"alias": "",
43+
"caseSensitive": false,
44+
"chn": false,
45+
"token": [",", " ", "'", "\"", ";", "=", "(", ")", "[", "]", "{", "}", "?", "@", "&", "<", ">", "/", ":", "\n", "\t", "\r"]
46+
},
47+
"subject": {
48+
"type": "text",
49+
"doc_value": true,
50+
"alias": "",
51+
"caseSensitive": false,
52+
"chn": false,
53+
"token": [",", " ", "'", "\"", ";", "=", "(", ")", "[", "]", "{", "}", "?", "@", "&", "<", ">", "/", ":", "\n", "\t", "\r"]
54+
},
55+
"datacontenttype": {
56+
"type": "text",
57+
"doc_value": true,
58+
"alias": "",
59+
"caseSensitive": false,
60+
"chn": false,
61+
"token": [",", " ", "'", "\"", ";", "=", "(", ")", "[", "]", "{", "}", "?", "@", "&", "<", ">", "/", ":", "\n", "\t", "\r"]
62+
},
63+
"dataschema": {
64+
"type": "text",
65+
"doc_value": true,
66+
"alias": "",
67+
"caseSensitive": false,
68+
"chn": false,
69+
"token": [",", " ", "'", "\"", ";", "=", "(", ")", "[", "]", "{", "}", "?", "@", "&", "<", ">", "/", ":", "\n", "\t", "\r"]
70+
},
71+
"data": {
72+
"type": "json",
73+
"doc_value": true,
74+
"alias": "",
75+
"caseSensitive": false,
76+
"chn": false,
77+
"token": [",", " ", "'", "\"", ";", "=", "(", ")", "[", "]", "{", "}", "?", "@", "&", "<", ">", "/", ":", "\n", "\t", "\r"],
78+
"index_all": true,
79+
"max_depth": -1,
80+
"json_keys": {}
81+
},
82+
"time": {
83+
"type": "text",
84+
"doc_value": true,
85+
"alias": "",
86+
"caseSensitive": false,
87+
"chn": false,
88+
"token": [",", " ", "'", "\"", ";", "=", "(", ")", "[", "]", "{", "}", "?", "@", "&", "<", ">", "/", ":", "\n", "\t", "\r"]
89+
},
90+
"title": {
91+
"type": "text",
92+
"doc_value": true,
93+
"alias": "",
94+
"caseSensitive": false,
95+
"chn": false,
96+
"token": [",", " ", "'", "\"", ";", "=", "(", ")", "[", "]", "{", "}", "?", "@", "&", "<", ">", "/", ":", "\n", "\t", "\r"]
97+
},
98+
"message": {
99+
"type": "text",
100+
"doc_value": true,
101+
"alias": "",
102+
"caseSensitive": false,
103+
"chn": false,
104+
"token": [",", " ", "'", "\"", ";", "=", "(", ")", "[", "]", "{", "}", "?", "@", "&", "<", ">", "/", ":", "\n", "\t", "\r"]
105+
},
106+
"status": {
107+
"type": "text",
108+
"doc_value": true,
109+
"alias": "",
110+
"caseSensitive": false,
111+
"chn": false,
112+
"token": [",", " ", "'", "\"", ";", "=", "(", ")", "[", "]", "{", "}", "?", "@", "&", "<", ">", "/", ":", "\n", "\t", "\r"]
113+
}
114+
}
115+
}`
6116
)
7117

8118
func (c *Client) CreateEventStore(project string, eventStore *LogStore) error {
9-
eventStore.TelemetryType = EVENT_STORE_TELEMETRY_TYPE
119+
eventStore.TelemetryType = EventStoreTelemetryType
10120
err := c.CreateLogStoreV2(project, eventStore)
11121
if err != nil {
12122
return err
13123
}
14-
return c.CreateIndexString(project, eventStore.Name, EVENT_STORE_INDEX)
124+
return c.CreateIndexString(project, eventStore.Name, EventStoreIndex)
15125
}
16126

17127
func (c *Client) UpdateEventStore(project string, eventStore *LogStore) error {
18-
eventStore.TelemetryType = EVENT_STORE_TELEMETRY_TYPE
128+
eventStore.TelemetryType = EventStoreTelemetryType
19129
return c.UpdateLogStoreV2(project, eventStore)
20130
}
21131

@@ -28,5 +138,5 @@ func (c *Client) GetEventStore(project, name string) (*LogStore, error) {
28138
}
29139

30140
func (c *Client) ListEventStore(project string, offset, size int) ([]string, error) {
31-
return c.ListLogStoreV2(project, offset, size, EVENT_STORE_TELEMETRY_TYPE)
141+
return c.ListLogStoreV2(project, offset, size, EventStoreTelemetryType)
32142
}

‎client_event_store_test.go

+2-2
Original file line numberDiff line numberDiff line change
@@ -74,7 +74,7 @@ func (m *EventStoreTestSuite) TestClient_UpdateAndGetEventStore() {
7474
m.Require().Equal(m.eventStoreName, eventStore.Name)
7575
m.Require().Equal(m.ttl, eventStore.TTL)
7676
m.Require().Equal(m.shardCnt, eventStore.ShardCount)
77-
m.Require().Equal(EVENT_STORE_TELEMETRY_TYPE, eventStore.TelemetryType)
77+
m.Require().Equal(EventStoreTelemetryType, eventStore.TelemetryType)
7878

7979
eventStore.TTL = 15
8080
ue := m.client.UpdateEventStore(m.projectName, eventStore)
@@ -83,7 +83,7 @@ func (m *EventStoreTestSuite) TestClient_UpdateAndGetEventStore() {
8383
m.Require().Nil(ge1)
8484
m.Require().Equal(m.eventStoreName, eventStore1.Name)
8585
m.Require().Equal(15, eventStore1.TTL)
86-
m.Require().Equal(EVENT_STORE_TELEMETRY_TYPE, eventStore1.TelemetryType)
86+
m.Require().Equal(EventStoreTelemetryType, eventStore1.TelemetryType)
8787
de := m.client.DeleteEventStore(m.projectName, m.eventStoreName)
8888
m.Require().Nil(de)
8989
}

0 commit comments

Comments
 (0)