level2co.proto 5.19 KB
Newer Older
Wei Shoulin's avatar
Wei Shoulin committed
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
syntax = "proto3";

package dfs.msc.level2co;
option go_package = "cnlab.net/csst/proto/msc/level2co";
import "common/error.proto";

service Level2CoSrv {
	rpc Find(FindLevel2CoReq) returns (FindLevel2CoResp) {}
	rpc FindCatalog(FindLevel2CoCatalogReq) returns (FindLevel2CoCatalogResp) {}
	rpc Get(GetLevel2CoReq) returns (GetLevel2CoResp) {}
	rpc Write(stream WriteLevel2CoReq) returns (WriteLevel2CoResp) {}
	rpc UpdateQc2Status(UpdateQc2StatusReq) returns (UpdateQc2StatusResp) {}
	rpc UpdateProcStatus(UpdateProcStatusReq) returns (UpdateProcStatusResp) {}	
	rpc DeleteCatalogByLevel2CoId(DeleteCatalogByLevel2CoIdReq) returns (DeleteCatalogByLevel2CoIdResp) {}
}
message Level2CoRecord {
	int64 id = 1;
	string data_type = 2;
	string filename = 3;
	string file_path = 4;
	int32 qc2_status = 5;
	string qc2_time = 6;
	int32 prc_status = 7;
	string prc_time = 8;
	string create_time = 9;
	string pipeline_id = 10; 
	int32 import_status = 11;
}

message FindLevel2CoReq {
	string data_type = 1;
	string create_time_start = 2;
	string create_time_end = 3;
	int32 qc2_status = 4;
	int32 prc_status = 5;
	string filename = 6;
	int32 limit = 7;
	map<string,string> other_conditions = 8;
}

message FindLevel2CoResp {
	bool success = 1;
	int32 totalCount = 2;
	common.Error error = 3;
	repeated Level2CoRecord records = 4;
}

message GetLevel2CoReq {
	int64 id = 1;	
}

message GetLevel2CoResp {
	Level2CoRecord record = 1;
}

message WriteLevel2CoReq {
	Level2CoRecord record = 1;
	bytes data = 2;
}

message WriteLevel2CoResp {
	bool success = 1;
	common.Error error = 2;
	Level2CoRecord record = 3;
}
message UpdateQc2StatusReq {
	int64 id = 1;
	int32 status = 2;
}

message UpdateQc2StatusResp {
	bool success = 1;
	common.Error error = 2;
}
message UpdateProcStatusReq {
	int64 id = 1;
	int32 status = 2;
}

message UpdateProcStatusResp {
	bool success = 1;
	common.Error error = 2;
}
message Level2CoCatalogRecord {
	int64 ID = 1;
	float X = 2;
	double XErr = 3;
	float Y = 4;
	double YErr = 5;
	double RA = 6;
	double RAErr = 7;
	double DEC = 8;
	double DECErr = 9;
	float A = 10;
	float AErr = 11;
	float B = 12;
	float BErr = 13;
	float PA = 14;
	float PAErr = 15;
	int32 Flag = 16;
	int32 Flag_ISO = 17;
	int32 Flag_ISO_Num = 18;
	float FWHM = 19;
	float AB = 20;
	float E = 21;
	double Flux_Kron = 22;
	float FluxErr_Kron = 23;
	double Mag_Kron = 24;
	double MagErr_Kron = 25;
	double Radius_Kron = 26;
	float Sky = 27;
	float Flux_Aper1 = 28;
	float FluxErr_Aper1 = 29;
	float Mag_Aper1 = 30;
	float MagErr_Aper1 = 31;
	float Flux_Aper2 = 32;
	float FluxErr_Aper2 = 33;
	float Mag_Aper2 = 34;
	float MagErr_Aper2 = 35;
	float Flux_Aper3 = 36;
	float FluxErr_Aper3 = 37;
	float Mag_Aper3 = 38;
	float MagErr_Aper3 = 39;
	float Flux_Aper4 = 40;
	float FluxErr_Aper4 = 41;
	float Mag_Aper4 = 42;
	float MagErr_Aper4 = 43;
	float Flux_Aper5 = 44;
	float FluxErr_Aper5 = 45;
	float Mag_Aper5 = 46;
	float MagErr_Aper5 = 47;
	float Flux_Aper6 = 48;
	float FluxErr_Aper6 = 49;
	float Mag_Aper6 = 50;
	float MagErr_Aper6 = 51;
	float Flux_Aper7 = 52;
	float FluxErr_Aper7 = 53;
	float Mag_Aper7 = 54;
	float MagErr_Aper7 = 55;
	float Flux_Aper8 = 56;
	float FluxErr_Aper8 = 57;
	float Mag_Aper8 = 58;
	float MagErr_Aper8 = 59;
	float Flux_Aper9 = 60;
	float FluxErr_Aper9 = 61;
	float Mag_Aper9 = 62;
	float MagErr_Aper9 = 63;
	float Flux_Aper10 = 64;
	float FluxErr_Aper10 = 65;
	float Mag_Aper10 = 66;
	float MagErr_Aper10 = 67;
	float Flux_Aper11 = 68;
	float FluxErr_Aper11 = 69;
	float Mag_Aper11 = 70;
	float MagErr_Aper11 = 71;
	float Flux_Aper12 = 72;
	float FluxErr_Aper12 = 73;
	float Mag_Aper12 = 74;
	float MagErr_Aper12 = 75;
	int32 Type = 76;
	float R20 = 77;
	float R50 = 78;
	float R90 = 79;
	double X_PSF = 80;
	double Y_PSF = 81;
	double RA_PSF = 82;
	double DEC_PSF = 83;
	float Chi2_PSF = 84;
	float Flux_PSF = 85;
	float FluxErr_PSF = 86;
	float Mag_PSF = 87;
	float MagErr_PSF = 88;
	double X_Model = 89;
	double Y_Model = 90;
	double RA_Model = 91;
	double DEC_Model = 92;
	float Chi2_Model = 93;
	int32 Flag_Model = 94;
	float Flux_Model = 95;
	float FluxErr_Model = 96;
	float Mag_Model = 97;
	float MagErr_Model = 98;
	float Flux_Bulge = 99;
	float FluxErr_Bulge = 100;
	float Mag_Bulge = 101;
	float MagErr_Bulge = 102;
	float Re_Bulge = 103;
	float ReErr_Bulge = 104;
	float E_Bulge = 105;
	float EErr_Bulge = 106;
	float PA_Bulge = 107;
	float PAErr_Bulge = 108;
	float Flux_Disk = 109;
	float FluxErr_Disk = 110;
	float Mag_Disk = 111;
	float MagErr_Disk = 112;
	float Re_Disk = 113;
	float ReErr_Disk = 114;
	float E_Disk = 115;
	float EErr_Disk = 116;
	float PA_Disk = 117;
	float PAErr_Disk = 118;
	float Ratio_Disk = 119;
	float RatioErr_Disk = 120;
	float Spread_Model = 121;
	float SpreadErr_Model = 122;
	int32 NS128HIdx = 123;
}

message FindLevel2CoCatalogReq {
	string obs_id = 1;
	string detector_no = 2;
	string ra = 3;
	string dec = 4;
	double radius = 5;
	double minMag = 6;
	double maxMag = 7;
	string obs_time_start = 8;	
	string obs_time_end = 9;	
	int32 limit = 10;
}

message FindLevel2CoCatalogResp {
	bool success = 1;
	int32 totalCount = 2;
	common.Error error = 3;
	repeated Level2CoCatalogRecord records = 4;
}



message DeleteCatalogByLevel2CoIdReq {
	int64 level2_id = 1;
}

message DeleteCatalogByLevel2CoIdResp {
	bool success = 1;
	common.Error error = 2;
}