Skip to content
GitLab
Commit 9b992884 authored by Wei Shoulin's avatar Wei Shoulin
Browse files

C9

parent 462fb961
Hide whitespace changes
Inline Side-by-side
csst_dfs_proto/common/account/account.proto deleted 100644 → 0
View file @ 462fb961
syntax = "proto3";
package dfs.common.account;
option go_package = "cnlab.net/csst/proto/common/account";
service Account {
rpc Read(ReadRequest) returns (ReadResponse) {}
rpc Create(CreateRequest) returns (CreateResponse) {}
rpc Update(UpdateRequest) returns (UpdateResponse) {}
rpc Delete(DeleteRequest) returns (DeleteResponse) {}
rpc Search(SearchRequest) returns (SearchResponse) {}
}
message Record {
// uuid
string id = 1;
// service or user
string type = 2;
// service name, username, etc
string client_id = 3;
// we leave this blank in responses
// used for update and create
string client_secret = 4;
map<string,string> metadata = 5;
// unix timestamp
int64 created = 6;
// unix timestamp
int64 updated = 7;
}
message ReadRequest {
string id = 1;
}
message ReadResponse {
Record account = 1;
}
message CreateRequest {
// If id is blank, one will be generated
Record account = 1;
}
message CreateResponse {
}
message UpdateRequest {
// Id and client_id cannot be changed
Record account = 1;
}
message UpdateResponse {
}
message DeleteRequest {
string id = 1;
}
message DeleteResponse {
}
message SearchRequest {
string client_id = 1;
string type = 2;
int64 limit = 3;
int64 offset = 4;
}
message SearchResponse {
repeated Record accounts = 1;
}
csst_dfs_proto/common/ephem/ephem.proto
View file @ 9b992884
......@@ -6,181 +6,14 @@ option go_package = "cnlab.net/csst/proto/common/ephem";
import "common/error.proto";
service EphemSearchSrv {
rpc Gaia3Search(EphemSearchRequest) returns (stream Gaia3SearchResponse) {}
rpc Search(SearchRequest) returns (stream SearchResponse) {}
}
message Gaia3Record {
int64 SolutionId = 1;
string Designation = 2;
int64 SourceId = 3;
int64 RandomIndex = 4;
double RefEpoch = 5;
double Ra = 6;
double RaError = 7;
double Dec = 8;
double DecError = 9;
double Parallax = 10;
double ParallaxError = 11;
double ParallaxOverError = 12;
double Pm = 13;
double Pmra = 14;
double PmraError = 15;
double Pmdec = 16;
double PmdecError = 17;
double RaDecCorr = 18;
double RaParallaxCorr = 19;
double RaPmraCorr = 20;
double RaPmdecCorr = 21;
double DecParallaxCorr = 22;
double DecPmraCorr = 23;
double DecPmdecCorr = 24;
double ParallaxPmraCorr = 25;
double ParallaxPmdecCorr = 26;
double PmraPmdecCorr = 27;
int64 AstrometricNObsAl = 28;
int64 AstrometricNObsAc = 29;
int64 AstrometricNGoodObsAl = 30;
int64 AstrometricNBadObsAl = 31;
double AstrometricGofAl = 32;
double AstrometricChi2Al = 33;
double AstrometricExcessNoise = 34;
double AstrometricExcessNoiseSig = 35;
int64 AstrometricParamsSolved = 36;
int32 AstrometricPrimaryFlag = 37;
double NuEffUsedInAstrometry = 38;
double Pseudocolour = 39;
double PseudocolourError = 40;
double RaPseudocolourCorr = 41;
double DecPseudocolourCorr = 42;
double ParallaxPseudocolourCorr = 43;
double PmraPseudocolourCorr = 44;
double PmdecPseudocolourCorr = 45;
int64 AstrometricMatchedTransits = 46;
int64 VisibilityPeriodsUsed = 47;
double AstrometricSigma5dMax = 48;
int64 MatchedTransits = 49;
int64 NewMatchedTransits = 50;
int64 MatchedTransitsRemoved = 51;
double IpdGofHarmonicAmplitude = 52;
double IpdGofHarmonicPhase = 53;
int64 IpdFracMultiPeak = 54;
int64 IpdFracOddWin = 55;
double Ruwe = 56;
double ScanDirectionStrengthK1 = 57;
double ScanDirectionStrengthK2 = 58;
double ScanDirectionStrengthK3 = 59;
double ScanDirectionStrengthK4 = 60;
double ScanDirectionMeanK1 = 61;
double ScanDirectionMeanK2 = 62;
double ScanDirectionMeanK3 = 63;
double ScanDirectionMeanK4 = 64;
int32 DuplicatedSource = 65;
int64 PhotGNObs = 66;
double PhotGMeanFlux = 67;
double PhotGMeanFluxError = 68;
double PhotGMeanFluxOverError = 69;
double PhotGMeanMag = 70;
int64 PhotBpNObs = 71;
double PhotBpMeanFlux = 72;
double PhotBpMeanFluxError = 73;
double PhotBpMeanFluxOverError = 74;
double PhotBpMeanMag = 75;
int64 PhotRpNObs = 76;
double PhotRpMeanFlux = 77;
double PhotRpMeanFluxError = 78;
double PhotRpMeanFluxOverError = 79;
double PhotRpMeanMag = 80;
double PhotBpRpExcessFactor = 81;
double PhotBpNContaminatedTransits = 82;
double PhotBpNBlendedTransits = 83;
double PhotRpNContaminatedTransits = 84;
double PhotRpNBlendedTransits = 85;
double PhotProcMode = 86;
double BpRp = 87;
double BpG = 88;
double GRp = 89;
double RadialVelocity = 90;
double RadialVelocityError = 91;
double RvMethodUsed = 92;
double RvNbTransits = 93;
double RvNbDeblendedTransits = 94;
double RvVisibilityPeriodsUsed = 95;
double RvExpectedSigToNoise = 96;
double RvRenormalisedGof = 97;
double RvChisqPvalue = 98;
double RvTimeDuration = 99;
double RvAmplitudeRobust = 100;
double RvTemplateTeff = 101;
double RvTemplateLogg = 102;
double RvTemplateFeH = 103;
double RvAtmParamOrigin = 104;
double Vbroad = 105;
double VbroadError = 106;
double VbroadNbTransits = 107;
double GrvsMag = 108;
double GrvsMagError = 109;
double GrvsMagNbTransits = 110;
double RvsSpecSigToNoise = 111;
string PhotVariableFlag = 112;
double L = 113;
double B = 114;
double EclLon = 115;
double EclLat = 116;
int32 InQsoCandidates = 117;
int32 InGalaxyCandidates = 118;
int64 NonSingleStar = 119;
int32 HasXpContinuous = 120;
int32 HasXpSampled = 121;
int32 HasRvs = 122;
int32 HasEpochPhotometry = 123;
int32 HasEpochRv = 124;
int32 HasMcmcGspphot = 125;
int32 HasMcmcMsc = 126;
int32 InAndromedaSurvey = 127;
double ClassprobDscCombmodQuasar = 128;
double ClassprobDscCombmodGalaxy = 129;
double ClassprobDscCombmodStar = 130;
double TeffGspphot = 131;
double TeffGspphotLower = 132;
double TeffGspphotUpper = 133;
double LoggGspphot = 134;
double LoggGspphotLower = 135;
double LoggGspphotUpper = 136;
double MhGspphot = 137;
double MhGspphotLower = 138;
double MhGspphotUpper = 139;
double DistanceGspphot = 140;
double DistanceGspphotLower = 141;
double DistanceGspphotUpper = 142;
double AzeroGspphot = 143;
double AzeroGspphotLower = 144;
double AzeroGspphotUpper = 145;
double AgGspphot = 146;
double AgGspphotLower = 147;
double AgGspphotUpper = 148;
double EbpminrpGspphot = 149;
double EbpminrpGspphotLower = 150;
double EbpminrpGspphotUpper = 151;
string LibnameGspphot = 152;
int32 NS8HIdx = 153;
int32 NS16HIdx = 154;
int32 NS32HIdx = 155;
int32 NS64HIdx = 156;
int32 FileIdx = 157;
message SearchRequest {
map<string,string> conditions = 1;
}
message EphemSearchRequest {
double ra = 1;
double dec = 2;
double radius = 3;
string columns = 4;
double minMag = 5;
double maxMag = 6;
int64 obstime = 7;
int64 limit = 8;
}
message Gaia3SearchResponse {
message SearchResponse {
bool success = 1;
int32 totalCount = 2;
common.Error error = 3;
......
csst_dfs_proto/common/ephem/ephem_pb2.py
View file @ 9b992884
......@@ -14,7 +14,7 @@ _sym_db = _symbol_database.Default()
from ...common import error_pb2 as common_dot_error__pb2
DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\x18\x63ommon/ephem/ephem.proto\x12\tdfs.ephem\x1a\x12\x63ommon/error.proto\"\xd7\x1e\n\x0bGaia3Record\x12\x12\n\nSolutionId\x18\x01 \x01(\x03\x12\x13\n\x0b\x44\x65signation\x18\x02 \x01(\t\x12\x10\n\x08SourceId\x18\x03 \x01(\x03\x12\x13\n\x0bRandomIndex\x18\x04 \x01(\x03\x12\x10\n\x08RefEpoch\x18\x05 \x01(\x01\x12\n\n\x02Ra\x18\x06 \x01(\x01\x12\x0f\n\x07RaError\x18\x07 \x01(\x01\x12\x0b\n\x03\x44\x65\x63\x18\x08 \x01(\x01\x12\x10\n\x08\x44\x65\x63\x45rror\x18\t \x01(\x01\x12\x10\n\x08Parallax\x18\n \x01(\x01\x12\x15\n\rParallaxError\x18\x0b \x01(\x01\x12\x19\n\x11ParallaxOverError\x18\x0c \x01(\x01\x12\n\n\x02Pm\x18\r \x01(\x01\x12\x0c\n\x04Pmra\x18\x0e \x01(\x01\x12\x11\n\tPmraError\x18\x0f \x01(\x01\x12\r\n\x05Pmdec\x18\x10 \x01(\x01\x12\x12\n\nPmdecError\x18\x11 \x01(\x01\x12\x11\n\tRaDecCorr\x18\x12 \x01(\x01\x12\x16\n\x0eRaParallaxCorr\x18\x13 \x01(\x01\x12\x12\n\nRaPmraCorr\x18\x14 \x01(\x01\x12\x13\n\x0bRaPmdecCorr\x18\x15 \x01(\x01\x12\x17\n\x0f\x44\x65\x63ParallaxCorr\x18\x16 \x01(\x01\x12\x13\n\x0b\x44\x65\x63PmraCorr\x18\x17 \x01(\x01\x12\x14\n\x0c\x44\x65\x63PmdecCorr\x18\x18 \x01(\x01\x12\x18\n\x10ParallaxPmraCorr\x18\x19 \x01(\x01\x12\x19\n\x11ParallaxPmdecCorr\x18\x1a \x01(\x01\x12\x15\n\rPmraPmdecCorr\x18\x1b \x01(\x01\x12\x19\n\x11\x41strometricNObsAl\x18\x1c \x01(\x03\x12\x19\n\x11\x41strometricNObsAc\x18\x1d \x01(\x03\x12\x1d\n\x15\x41strometricNGoodObsAl\x18\x1e \x01(\x03\x12\x1c\n\x14\x41strometricNBadObsAl\x18\x1f \x01(\x03\x12\x18\n\x10\x41strometricGofAl\x18 \x01(\x01\x12\x19\n\x11\x41strometricChi2Al\x18! \x01(\x01\x12\x1e\n\x16\x41strometricExcessNoise\x18\" \x01(\x01\x12!\n\x19\x41strometricExcessNoiseSig\x18# \x01(\x01\x12\x1f\n\x17\x41strometricParamsSolved\x18$ \x01(\x03\x12\x1e\n\x16\x41strometricPrimaryFlag\x18% \x01(\x05\x12\x1d\n\x15NuEffUsedInAstrometry\x18& \x01(\x01\x12\x14\n\x0cPseudocolour\x18\' \x01(\x01\x12\x19\n\x11PseudocolourError\x18( \x01(\x01\x12\x1a\n\x12RaPseudocolourCorr\x18) \x01(\x01\x12\x1b\n\x13\x44\x65\x63PseudocolourCorr\x18* \x01(\x01\x12 \n\x18ParallaxPseudocolourCorr\x18+ \x01(\x01\x12\x1c\n\x14PmraPseudocolourCorr\x18, \x01(\x01\x12\x1d\n\x15PmdecPseudocolourCorr\x18- \x01(\x01\x12\"\n\x1a\x41strometricMatchedTransits\x18. \x01(\x03\x12\x1d\n\x15VisibilityPeriodsUsed\x18/ \x01(\x03\x12\x1d\n\x15\x41strometricSigma5dMax\x18\x30 \x01(\x01\x12\x17\n\x0fMatchedTransits\x18\x31 \x01(\x03\x12\x1a\n\x12NewMatchedTransits\x18\x32 \x01(\x03\x12\x1e\n\x16MatchedTransitsRemoved\x18\x33 \x01(\x03\x12\x1f\n\x17IpdGofHarmonicAmplitude\x18\x34 \x01(\x01\x12\x1b\n\x13IpdGofHarmonicPhase\x18\x35 \x01(\x01\x12\x18\n\x10IpdFracMultiPeak\x18\x36 \x01(\x03\x12\x15\n\rIpdFracOddWin\x18\x37 \x01(\x03\x12\x0c\n\x04Ruwe\x18\x38 \x01(\x01\x12\x1f\n\x17ScanDirectionStrengthK1\x18\x39 \x01(\x01\x12\x1f\n\x17ScanDirectionStrengthK2\x18: \x01(\x01\x12\x1f\n\x17ScanDirectionStrengthK3\x18; \x01(\x01\x12\x1f\n\x17ScanDirectionStrengthK4\x18< \x01(\x01\x12\x1b\n\x13ScanDirectionMeanK1\x18= \x01(\x01\x12\x1b\n\x13ScanDirectionMeanK2\x18> \x01(\x01\x12\x1b\n\x13ScanDirectionMeanK3\x18? \x01(\x01\x12\x1b\n\x13ScanDirectionMeanK4\x18@ \x01(\x01\x12\x18\n\x10\x44uplicatedSource\x18\x41 \x01(\x05\x12\x11\n\tPhotGNObs\x18\x42 \x01(\x03\x12\x15\n\rPhotGMeanFlux\x18\x43 \x01(\x01\x12\x1a\n\x12PhotGMeanFluxError\x18\x44 \x01(\x01\x12\x1e\n\x16PhotGMeanFluxOverError\x18\x45 \x01(\x01\x12\x14\n\x0cPhotGMeanMag\x18\x46 \x01(\x01\x12\x12\n\nPhotBpNObs\x18G \x01(\x03\x12\x16\n\x0ePhotBpMeanFlux\x18H \x01(\x01\x12\x1b\n\x13PhotBpMeanFluxError\x18I \x01(\x01\x12\x1f\n\x17PhotBpMeanFluxOverError\x18J \x01(\x01\x12\x15\n\rPhotBpMeanMag\x18K \x01(\x01\x12\x12\n\nPhotRpNObs\x18L \x01(\x03\x12\x16\n\x0ePhotRpMeanFlux\x18M \x01(\x01\x12\x1b\n\x13PhotRpMeanFluxError\x18N \x01(\x01\x12\x1f\n\x17PhotRpMeanFluxOverError\x18O \x01(\x01\x12\x15\n\rPhotRpMeanMag\x18P \x01(\x01\x12\x1c\n\x14PhotBpRpExcessFactor\x18Q \x01(\x01\x12#\n\x1bPhotBpNContaminatedTransits\x18R \x01(\x01\x12\x1e\n\x16PhotBpNBlendedTransits\x18S \x01(\x01\x12#\n\x1bPhotRpNContaminatedTransits\x18T \x01(\x01\x12\x1e\n\x16PhotRpNBlendedTransits\x18U \x01(\x01\x12\x14\n\x0cPhotProcMode\x18V \x01(\x01\x12\x0c\n\x04\x42pRp\x18W \x01(\x01\x12\x0b\n\x03\x42pG\x18X \x01(\x01\x12\x0b\n\x03GRp\x18Y \x01(\x01\x12\x16\n\x0eRadialVelocity\x18Z \x01(\x01\x12\x1b\n\x13RadialVelocityError\x18[ \x01(\x01\x12\x14\n\x0cRvMethodUsed\x18\\ \x01(\x01\x12\x14\n\x0cRvNbTransits\x18] \x01(\x01\x12\x1d\n\x15RvNbDeblendedTransits\x18^ \x01(\x01\x12\x1f\n\x17RvVisibilityPeriodsUsed\x18_ \x01(\x01\x12\x1c\n\x14RvExpectedSigToNoise\x18` \x01(\x01\x12\x19\n\x11RvRenormalisedGof\x18\x61 \x01(\x01\x12\x15\n\rRvChisqPvalue\x18\x62 \x01(\x01\x12\x16\n\x0eRvTimeDuration\x18\x63 \x01(\x01\x12\x19\n\x11RvAmplitudeRobust\x18\x64 \x01(\x01\x12\x16\n\x0eRvTemplateTeff\x18\x65 \x01(\x01\x12\x16\n\x0eRvTemplateLogg\x18\x66 \x01(\x01\x12\x15\n\rRvTemplateFeH\x18g \x01(\x01\x12\x18\n\x10RvAtmParamOrigin\x18h \x01(\x01\x12\x0e\n\x06Vbroad\x18i \x01(\x01\x12\x13\n\x0bVbroadError\x18j \x01(\x01\x12\x18\n\x10VbroadNbTransits\x18k \x01(\x01\x12\x0f\n\x07GrvsMag\x18l \x01(\x01\x12\x14\n\x0cGrvsMagError\x18m \x01(\x01\x12\x19\n\x11GrvsMagNbTransits\x18n \x01(\x01\x12\x19\n\x11RvsSpecSigToNoise\x18o \x01(\x01\x12\x18\n\x10PhotVariableFlag\x18p \x01(\t\x12\t\n\x01L\x18q \x01(\x01\x12\t\n\x01\x42\x18r \x01(\x01\x12\x0e\n\x06\x45\x63lLon\x18s \x01(\x01\x12\x0e\n\x06\x45\x63lLat\x18t \x01(\x01\x12\x17\n\x0fInQsoCandidates\x18u \x01(\x05\x12\x1a\n\x12InGalaxyCandidates\x18v \x01(\x05\x12\x15\n\rNonSingleStar\x18w \x01(\x03\x12\x17\n\x0fHasXpContinuous\x18x \x01(\x05\x12\x14\n\x0cHasXpSampled\x18y \x01(\x05\x12\x0e\n\x06HasRvs\x18z \x01(\x05\x12\x1a\n\x12HasEpochPhotometry\x18{ \x01(\x05\x12\x12\n\nHasEpochRv\x18| \x01(\x05\x12\x16\n\x0eHasMcmcGspphot\x18} \x01(\x05\x12\x12\n\nHasMcmcMsc\x18~ \x01(\x05\x12\x19\n\x11InAndromedaSurvey\x18\x7f \x01(\x05\x12\"\n\x19\x43lassprobDscCombmodQuasar\x18\x80\x01 \x01(\x01\x12\"\n\x19\x43lassprobDscCombmodGalaxy\x18\x81\x01 \x01(\x01\x12 \n\x17\x43lassprobDscCombmodStar\x18\x82\x01 \x01(\x01\x12\x14\n\x0bTeffGspphot\x18\x83\x01 \x01(\x01\x12\x19\n\x10TeffGspphotLower\x18\x84\x01 \x01(\x01\x12\x19\n\x10TeffGspphotUpper\x18\x85\x01 \x01(\x01\x12\x14\n\x0bLoggGspphot\x18\x86\x01 \x01(\x01\x12\x19\n\x10LoggGspphotLower\x18\x87\x01 \x01(\x01\x12\x19\n\x10LoggGspphotUpper\x18\x88\x01 \x01(\x01\x12\x12\n\tMhGspphot\x18\x89\x01 \x01(\x01\x12\x17\n\x0eMhGspphotLower\x18\x8a\x01 \x01(\x01\x12\x17\n\x0eMhGspphotUpper\x18\x8b\x01 \x01(\x01\x12\x18\n\x0f\x44istanceGspphot\x18\x8c\x01 \x01(\x01\x12\x1d\n\x14\x44istanceGspphotLower\x18\x8d\x01 \x01(\x01\x12\x1d\n\x14\x44istanceGspphotUpper\x18\x8e\x01 \x01(\x01\x12\x15\n\x0c\x41zeroGspphot\x18\x8f\x01 \x01(\x01\x12\x1a\n\x11\x41zeroGspphotLower\x18\x90\x01 \x01(\x01\x12\x1a\n\x11\x41zeroGspphotUpper\x18\x91\x01 \x01(\x01\x12\x12\n\tAgGspphot\x18\x92\x01 \x01(\x01\x12\x17\n\x0e\x41gGspphotLower\x18\x93\x01 \x01(\x01\x12\x17\n\x0e\x41gGspphotUpper\x18\x94\x01 \x01(\x01\x12\x18\n\x0f\x45\x62pminrpGspphot\x18\x95\x01 \x01(\x01\x12\x1d\n\x14\x45\x62pminrpGspphotLower\x18\x96\x01 \x01(\x01\x12\x1d\n\x14\x45\x62pminrpGspphotUpper\x18\x97\x01 \x01(\x01\x12\x17\n\x0eLibnameGspphot\x18\x98\x01 \x01(\t\x12\x10\n\x07NS8HIdx\x18\x99\x01 \x01(\x05\x12\x11\n\x08NS16HIdx\x18\x9a\x01 \x01(\x05\x12\x11\n\x08NS32HIdx\x18\x9b\x01 \x01(\x05\x12\x11\n\x08NS64HIdx\x18\x9c\x01 \x01(\x05\x12\x10\n\x07\x46ileIdx\x18\x9d\x01 \x01(\x05\"\x8e\x01\n\x12\x45phemSearchRequest\x12\n\n\x02ra\x18\x01 \x01(\x01\x12\x0b\n\x03\x64\x65\x63\x18\x02 \x01(\x01\x12\x0e\n\x06radius\x18\x03 \x01(\x01\x12\x0f\n\x07\x63olumns\x18\x04 \x01(\t\x12\x0e\n\x06minMag\x18\x05 \x01(\x01\x12\x0e\n\x06maxMag\x18\x06 \x01(\x01\x12\x0f\n\x07obstime\x18\x07 \x01(\x03\x12\r\n\x05limit\x18\x08 \x01(\x03\"i\n\x13Gaia3SearchResponse\x12\x0f\n\x07success\x18\x01 \x01(\x08\x12\x12\n\ntotalCount\x18\x02 \x01(\x05\x12\x1c\n\x05\x65rror\x18\x03 \x01(\x0b\x32\r.common.Error\x12\x0f\n\x07records\x18\x04 \x01(\x0c\x32\x62\n\x0e\x45phemSearchSrv\x12P\n\x0bGaia3Search\x12\x1d.dfs.ephem.EphemSearchRequest\x1a\x1e.dfs.ephem.Gaia3SearchResponse\"\x00\x30\x01\x42#Z!cnlab.net/csst/proto/common/ephemb\x06proto3')
DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\x18\x63ommon/ephem/ephem.proto\x12\tdfs.ephem\x1a\x12\x63ommon/error.proto\"\x80\x01\n\rSearchRequest\x12<\n\nconditions\x18\x01 \x03(\x0b\x32(.dfs.ephem.SearchRequest.ConditionsEntry\x1a\x31\n\x0f\x43onditionsEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\r\n\x05value\x18\x02 \x01(\t:\x02\x38\x01\"d\n\x0eSearchResponse\x12\x0f\n\x07success\x18\x01 \x01(\x08\x12\x12\n\ntotalCount\x18\x02 \x01(\x05\x12\x1c\n\x05\x65rror\x18\x03 \x01(\x0b\x32\r.common.Error\x12\x0f\n\x07records\x18\x04 \x01(\x0c\x32S\n\x0e\x45phemSearchSrv\x12\x41\n\x06Search\x12\x18.dfs.ephem.SearchRequest\x1a\x19.dfs.ephem.SearchResponse\"\x00\x30\x01\x42#Z!cnlab.net/csst/proto/common/ephemb\x06proto3')
_builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, globals())
_builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'common.ephem.ephem_pb2', globals())
......@@ -22,12 +22,14 @@ if _descriptor._USE_C_DESCRIPTORS == False:
DESCRIPTOR._options = None
DESCRIPTOR._serialized_options = b'Z!cnlab.net/csst/proto/common/ephem'
_GAIA3RECORD._serialized_start=60
_GAIA3RECORD._serialized_end=3987
_EPHEMSEARCHREQUEST._serialized_start=3990
_EPHEMSEARCHREQUEST._serialized_end=4132
_GAIA3SEARCHRESPONSE._serialized_start=4134
_GAIA3SEARCHRESPONSE._serialized_end=4239
_EPHEMSEARCHSRV._serialized_start=4241
_EPHEMSEARCHSRV._serialized_end=4339
_SEARCHREQUEST_CONDITIONSENTRY._options = None
_SEARCHREQUEST_CONDITIONSENTRY._serialized_options = b'8\001'
_SEARCHREQUEST._serialized_start=60
_SEARCHREQUEST._serialized_end=188
_SEARCHREQUEST_CONDITIONSENTRY._serialized_start=139
_SEARCHREQUEST_CONDITIONSENTRY._serialized_end=188
_SEARCHRESPONSE._serialized_start=190
_SEARCHRESPONSE._serialized_end=290
_EPHEMSEARCHSRV._serialized_start=292
_EPHEMSEARCHSRV._serialized_end=375
# @@protoc_insertion_point(module_scope)
csst_dfs_proto/common/ephem/ephem_pb2_grpc.py
View file @ 9b992884
......@@ -14,17 +14,17 @@ class EphemSearchSrvStub(object):
Args:
channel: A grpc.Channel.
"""
self.Gaia3Search = channel.unary_stream(
'/dfs.ephem.EphemSearchSrv/Gaia3Search',
request_serializer=common_dot_ephem_dot_ephem__pb2.EphemSearchRequest.SerializeToString,
response_deserializer=common_dot_ephem_dot_ephem__pb2.Gaia3SearchResponse.FromString,
self.Search = channel.unary_stream(
'/dfs.ephem.EphemSearchSrv/Search',
request_serializer=common_dot_ephem_dot_ephem__pb2.SearchRequest.SerializeToString,
response_deserializer=common_dot_ephem_dot_ephem__pb2.SearchResponse.FromString,
)
class EphemSearchSrvServicer(object):
"""Missing associated documentation comment in .proto file."""
def Gaia3Search(self, request, context):
def Search(self, request, context):
"""Missing associated documentation comment in .proto file."""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
......@@ -33,10 +33,10 @@ class EphemSearchSrvServicer(object):
def add_EphemSearchSrvServicer_to_server(servicer, server):
rpc_method_handlers = {
'Gaia3Search': grpc.unary_stream_rpc_method_handler(
servicer.Gaia3Search,
request_deserializer=common_dot_ephem_dot_ephem__pb2.EphemSearchRequest.FromString,
response_serializer=common_dot_ephem_dot_ephem__pb2.Gaia3SearchResponse.SerializeToString,
'Search': grpc.unary_stream_rpc_method_handler(
servicer.Search,
request_deserializer=common_dot_ephem_dot_ephem__pb2.SearchRequest.FromString,
response_serializer=common_dot_ephem_dot_ephem__pb2.SearchResponse.SerializeToString,
),
}
generic_handler = grpc.method_handlers_generic_handler(
......@@ -49,7 +49,7 @@ class EphemSearchSrv(object):
"""Missing associated documentation comment in .proto file."""
@staticmethod
def Gaia3Search(request,
def Search(request,
target,
options=(),
channel_credentials=None,
......@@ -59,8 +59,8 @@ class EphemSearchSrv(object):
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_stream(request, target, '/dfs.ephem.EphemSearchSrv/Gaia3Search',
common_dot_ephem_dot_ephem__pb2.EphemSearchRequest.SerializeToString,
common_dot_ephem_dot_ephem__pb2.Gaia3SearchResponse.FromString,
return grpc.experimental.unary_stream(request, target, '/dfs.ephem.EphemSearchSrv/Search',
common_dot_ephem_dot_ephem__pb2.SearchRequest.SerializeToString,
common_dot_ephem_dot_ephem__pb2.SearchResponse.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
csst_dfs_proto/common/jwt/jwt.proto deleted 100644 → 0
View file @ 462fb961
syntax = "proto3";
package dfs.jwt;
option go_package = "cnlab.net/csst/proto/common/auth";
import "common/error.proto";
service AuthSrv {
rpc MakeAccessToken (Request) returns (Response) {
}
rpc DelUserAccessToken (Request) returns (Response) {
}
rpc GetCachedAccessToken (Request) returns (Response) {
}
}
message Request {
int64 userId = 1;
string userName = 2;
string token = 3;
}
message Response {
bool success = 1;
common.Error error = 2;
string token = 3;
}
\ No newline at end of file
csst_dfs_proto/common/oauth2/oauth2.proto deleted 100644 → 0
View file @ 462fb961
syntax = "proto3";
package dfs.common.oauth2;
option go_package = "cnlab.net/csst/proto/common/oauth2";
service Oauth2 {
rpc Authorize(AuthorizeRequest) returns (AuthorizeResponse) {}
rpc Token(TokenRequest) returns (TokenResponse) {}
rpc Revoke(RevokeRequest) returns (RevokeResponse) {}
rpc Introspect(IntrospectRequest) returns (IntrospectResponse) {}
}
message Token {
string access_token = 1;
string token_type = 2;
string refresh_token = 3;
int64 expires_at = 4;
repeated string scopes = 5;
// metadata associated with the token
map<string,string> metadata = 6;
}
message AuthorizeRequest {
// code, token (not supported)
string response_type = 1;
string client_id = 2;
repeated string scopes = 3;
string state = 4;
string redirect_uri = 5;
}
message AuthorizeResponse {
string code = 1;
string state = 2;
// implicit response
Token token = 3;
}
message TokenRequest {
string client_id = 1;
string client_secret = 2;
string code = 3;
// password (not supported), client_credentials, authorization_code, refresh_token
string grant_type = 4;
string redirect_uri = 5;
string refresh_token = 6;
// scopes can be added for client_credentials request
repeated string scopes = 7;
// metadata to be stored with a token that's generated
map<string, string> metadata = 8;
}
message TokenResponse {
Token token = 1;
}
message RevokeRequest {
// revoke access token
string access_token = 1;
// revoke via refresh token
string refresh_token = 2;
}
message RevokeResponse {
}
message IntrospectRequest {
string access_token = 1;
}
message IntrospectResponse {
Token token = 1;
bool active = 2;
}
csst_dfs_proto/db/db.proto 0 → 100644
View file @ 9b992884
syntax = "proto3";
package dfs.db;
option go_package = "cnlab.net/csst/proto/db";
import "common/error.proto";
service DBSrv {
rpc Find(FindReq) returns (stream FindResp) {}
rpc Get(GetReq) returns (GetResp) {}
rpc Write(WriteReq) returns (WriteResp) {}
rpc WriteStream(stream WriteStreamReq) returns (WriteResp) {}
rpc Update(UpdateReq) returns (UpdateResp) {}
}
message FindReq {
map<string,string> conditions = 1;
}
message FindResp {
bool success = 1;
int32 totalCount = 2;
common.Error error = 3;
bytes records = 4;
}
message GetReq {
map<string,string> conditions = 1;
}
message GetResp {
repeated string columns = 1;
bytes record = 2;
}
message WriteReq {
map<string,string> conditions = 1;
}
message WriteStreamReq {
map<string,string> conditions = 1;
bytes data = 2;
}
message WriteResp {
bool success = 1;
common.Error error = 2;
repeated string columns = 3;
bytes record = 4;
}
message UpdateReq {
map<string,string> conditions = 1;
}
message UpdateResp {
bool success = 1;
common.Error error = 2;
}
\ No newline at end of file
csst_dfs_proto/db/db_pb2.py 0 → 100644
View file @ 9b992884
# -*- coding: utf-8 -*-
# Generated by the protocol buffer compiler. DO NOT EDIT!
# source: db/db.proto
"""Generated protocol buffer code."""
from google.protobuf.internal import builder as _builder
from google.protobuf import descriptor as _descriptor
from google.protobuf import descriptor_pool as _descriptor_pool
from google.protobuf import symbol_database as _symbol_database
# @@protoc_insertion_point(imports)
_sym_db = _symbol_database.Default()
from ..common import error_pb2 as common_dot_error__pb2
DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\x0b\x64\x62/db.proto\x12\x06\x64\x66s.db\x1a\x12\x63ommon/error.proto\"q\n\x07\x46indReq\x12\x33\n\nconditions\x18\x01 \x03(\x0b\x32\x1f.dfs.db.FindReq.ConditionsEntry\x1a\x31\n\x0f\x43onditionsEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\r\n\x05value\x18\x02 \x01(\t:\x02\x38\x01\"^\n\x08\x46indResp\x12\x0f\n\x07success\x18\x01 \x01(\x08\x12\x12\n\ntotalCount\x18\x02 \x01(\x05\x12\x1c\n\x05\x65rror\x18\x03 \x01(\x0b\x32\r.common.Error\x12\x0f\n\x07records\x18\x04 \x01(\x0c\"o\n\x06GetReq\x12\x32\n\nconditions\x18\x01 \x03(\x0b\x32\x1e.dfs.db.GetReq.ConditionsEntry\x1a\x31\n\x0f\x43onditionsEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\r\n\x05value\x18\x02 \x01(\t:\x02\x38\x01\"*\n\x07GetResp\x12\x0f\n\x07\x63olumns\x18\x01 \x03(\t\x12\x0e\n\x06record\x18\x02 \x01(\x0c\"s\n\x08WriteReq\x12\x34\n\nconditions\x18\x01 \x03(\x0b\x32 .dfs.db.WriteReq.ConditionsEntry\x1a\x31\n\x0f\x43onditionsEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\r\n\x05value\x18\x02 \x01(\t:\x02\x38\x01\"\x8d\x01\n\x0eWriteStreamReq\x12:\n\nconditions\x18\x01 \x03(\x0b\x32&.dfs.db.WriteStreamReq.ConditionsEntry\x12\x0c\n\x04\x64\x61ta\x18\x02 \x01(\x0c\x1a\x31\n\x0f\x43onditionsEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\r\n\x05value\x18\x02 \x01(\t:\x02\x38\x01\"[\n\tWriteResp\x12\x0f\n\x07success\x18\x01 \x01(\x08\x12\x1c\n\x05\x65rror\x18\x02 \x01(\x0b\x32\r.common.Error\x12\x0f\n\x07\x63olumns\x18\x03 \x03(\t\x12\x0e\n\x06record\x18\x04 \x01(\x0c\"u\n\tUpdateReq\x12\x35\n\nconditions\x18\x01 \x03(\x0b\x32!.dfs.db.UpdateReq.ConditionsEntry\x1a\x31\n\x0f\x43onditionsEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\r\n\x05value\x18\x02 \x01(\t:\x02\x38\x01\";\n\nUpdateResp\x12\x0f\n\x07success\x18\x01 \x01(\x08\x12\x1c\n\x05\x65rror\x18\x02 \x01(\x0b\x32\r.common.Error2\x81\x02\n\x05\x44\x42Srv\x12-\n\x04\x46ind\x12\x0f.dfs.db.FindReq\x1a\x10.dfs.db.FindResp\"\x00\x30\x01\x12(\n\x03Get\x12\x0e.dfs.db.GetReq\x1a\x0f.dfs.db.GetResp\"\x00\x12.\n\x05Write\x12\x10.dfs.db.WriteReq\x1a\x11.dfs.db.WriteResp\"\x00\x12<\n\x0bWriteStream\x12\x16.dfs.db.WriteStreamReq\x1a\x11.dfs.db.WriteResp\"\x00(\x01\x12\x31\n\x06Update\x12\x11.dfs.db.UpdateReq\x1a\x12.dfs.db.UpdateResp\"\x00\x42\x19Z\x17\x63nlab.net/csst/proto/dbb\x06proto3')
_builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, globals())
_builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'db.db_pb2', globals())
if _descriptor._USE_C_DESCRIPTORS == False:
DESCRIPTOR._options = None
DESCRIPTOR._serialized_options = b'Z\027cnlab.net/csst/proto/db'
_FINDREQ_CONDITIONSENTRY._options = None
_FINDREQ_CONDITIONSENTRY._serialized_options = b'8\001'
_GETREQ_CONDITIONSENTRY._options = None
_GETREQ_CONDITIONSENTRY._serialized_options = b'8\001'
_WRITEREQ_CONDITIONSENTRY._options = None
_WRITEREQ_CONDITIONSENTRY._serialized_options = b'8\001'
_WRITESTREAMREQ_CONDITIONSENTRY._options = None
_WRITESTREAMREQ_CONDITIONSENTRY._serialized_options = b'8\001'
_UPDATEREQ_CONDITIONSENTRY._options = None
_UPDATEREQ_CONDITIONSENTRY._serialized_options = b'8\001'
_FINDREQ._serialized_start=43
_FINDREQ._serialized_end=156
_FINDREQ_CONDITIONSENTRY._serialized_start=107
_FINDREQ_CONDITIONSENTRY._serialized_end=156
_FINDRESP._serialized_start=158
_FINDRESP._serialized_end=252
_GETREQ._serialized_start=254
_GETREQ._serialized_end=365
_GETREQ_CONDITIONSENTRY._serialized_start=107
_GETREQ_CONDITIONSENTRY._serialized_end=156
_GETRESP._serialized_start=367
_GETRESP._serialized_end=409
_WRITEREQ._serialized_start=411
_WRITEREQ._serialized_end=526
_WRITEREQ_CONDITIONSENTRY._serialized_start=107
_WRITEREQ_CONDITIONSENTRY._serialized_end=156
_WRITESTREAMREQ._serialized_start=529
_WRITESTREAMREQ._serialized_end=670
_WRITESTREAMREQ_CONDITIONSENTRY._serialized_start=107
_WRITESTREAMREQ_CONDITIONSENTRY._serialized_end=156
_WRITERESP._serialized_start=672
_WRITERESP._serialized_end=763
_UPDATEREQ._serialized_start=765
_UPDATEREQ._serialized_end=882
_UPDATEREQ_CONDITIONSENTRY._serialized_start=107
_UPDATEREQ_CONDITIONSENTRY._serialized_end=156
_UPDATERESP._serialized_start=884
_UPDATERESP._serialized_end=943
_DBSRV._serialized_start=946
_DBSRV._serialized_end=1203
# @@protoc_insertion_point(module_scope)
csst_dfs_proto/db/db_pb2_grpc.py 0 → 100644
View file @ 9b992884
# Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT!
"""Client and server classes corresponding to protobuf-defined services."""
import grpc
from . import db_pb2 as db_dot_db__pb2
class DBSrvStub(object):
"""Missing associated documentation comment in .proto file."""
def __init__(self, channel):
"""Constructor.
Args:
channel: A grpc.Channel.
"""
self.Find = channel.unary_stream(
'/dfs.db.DBSrv/Find',
request_serializer=db_dot_db__pb2.FindReq.SerializeToString,
response_deserializer=db_dot_db__pb2.FindResp.FromString,
)
self.Get = channel.unary_unary(
'/dfs.db.DBSrv/Get',
request_serializer=db_dot_db__pb2.GetReq.SerializeToString,
response_deserializer=db_dot_db__pb2.GetResp.FromString,
)
self.Write = channel.unary_unary(
'/dfs.db.DBSrv/Write',
request_serializer=db_dot_db__pb2.WriteReq.SerializeToString,
response_deserializer=db_dot_db__pb2.WriteResp.FromString,
)
self.WriteStream = channel.stream_unary(
'/dfs.db.DBSrv/WriteStream',
request_serializer=db_dot_db__pb2.WriteStreamReq.SerializeToString,
response_deserializer=db_dot_db__pb2.WriteResp.FromString,
)
self.Update = channel.unary_unary(
'/dfs.db.DBSrv/Update',
request_serializer=db_dot_db__pb2.UpdateReq.SerializeToString,
response_deserializer=db_dot_db__pb2.UpdateResp.FromString,
)
class DBSrvServicer(object):
"""Missing associated documentation comment in .proto file."""
def Find(self, request, context):
"""Missing associated documentation comment in .proto file."""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
def Get(self, request, context):
"""Missing associated documentation comment in .proto file."""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
def Write(self, request, context):
"""Missing associated documentation comment in .proto file."""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
def WriteStream(self, request_iterator, context):
"""Missing associated documentation comment in .proto file."""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
def Update(self, request, context):
"""Missing associated documentation comment in .proto file."""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
def add_DBSrvServicer_to_server(servicer, server):
rpc_method_handlers = {
'Find': grpc.unary_stream_rpc_method_handler(
servicer.Find,
request_deserializer=db_dot_db__pb2.FindReq.FromString,
response_serializer=db_dot_db__pb2.FindResp.SerializeToString,
),
'Get': grpc.unary_unary_rpc_method_handler(
servicer.Get,
request_deserializer=db_dot_db__pb2.GetReq.FromString,
response_serializer=db_dot_db__pb2.GetResp.SerializeToString,
),
'Write': grpc.unary_unary_rpc_method_handler(
servicer.Write,
request_deserializer=db_dot_db__pb2.WriteReq.FromString,
response_serializer=db_dot_db__pb2.WriteResp.SerializeToString,
),
'WriteStream': grpc.stream_unary_rpc_method_handler(
servicer.WriteStream,
request_deserializer=db_dot_db__pb2.WriteStreamReq.FromString,
response_serializer=db_dot_db__pb2.WriteResp.SerializeToString,
),
'Update': grpc.unary_unary_rpc_method_handler(
servicer.Update,
request_deserializer=db_dot_db__pb2.UpdateReq.FromString,
response_serializer=db_dot_db__pb2.UpdateResp.SerializeToString,
),
}
generic_handler = grpc.method_handlers_generic_handler(
'dfs.db.DBSrv', rpc_method_handlers)
server.add_generic_rpc_handlers((generic_handler,))
# This class is part of an EXPERIMENTAL API.
class DBSrv(object):
"""Missing associated documentation comment in .proto file."""
@staticmethod
def Find(request,
target,
options=(),
channel_credentials=None,
call_credentials=None,
insecure=False,
compression=None,
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_stream(request, target, '/dfs.db.DBSrv/Find',
db_dot_db__pb2.FindReq.SerializeToString,
db_dot_db__pb2.FindResp.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
@staticmethod
def Get(request,
target,
options=(),
channel_credentials=None,
call_credentials=None,
insecure=False,
compression=None,
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(request, target, '/dfs.db.DBSrv/Get',
db_dot_db__pb2.GetReq.SerializeToString,
db_dot_db__pb2.GetResp.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
@staticmethod
def Write(request,
target,
options=(),
channel_credentials=None,
call_credentials=None,
insecure=False,
compression=None,
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(request, target, '/dfs.db.DBSrv/Write',
db_dot_db__pb2.WriteReq.SerializeToString,
db_dot_db__pb2.WriteResp.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
@staticmethod
def WriteStream(request_iterator,
target,
options=(),
channel_credentials=None,
call_credentials=None,
insecure=False,
compression=None,
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.stream_unary(request_iterator, target, '/dfs.db.DBSrv/WriteStream',
db_dot_db__pb2.WriteStreamReq.SerializeToString,
db_dot_db__pb2.WriteResp.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
@staticmethod
def Update(request,
target,
options=(),
channel_credentials=None,
call_credentials=None,
insecure=False,
compression=None,
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(request, target, '/dfs.db.DBSrv/Update',
db_dot_db__pb2.UpdateReq.SerializeToString,
db_dot_db__pb2.UpdateResp.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
csst_dfs_proto/facility/level0prc/level0prc.proto
View file @ 9b992884
......@@ -11,13 +11,13 @@ service Level0PrcSrv {
}
message Level0PrcRecord {
int64 id = 1;
string level0_id = 2;
int64 level0_id = 2;
string pipeline_id = 3;
string prc_module = 4;
string params_file_path = 5;
string run_id = 5;
int32 prc_status = 6;
string prc_time = 7;
string result_file_path = 8;
string message = 8;
}
message FindLevel0PrcReq {
......
csst_dfs_proto/facility/level0prc/level0prc_pb2.py
View file @ 9b992884
......@@ -14,7 +14,7 @@ _sym_db = _symbol_database.Default()
from ...common import error_pb2 as common_dot_error__pb2
DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\"facility/level0prc/level0prc.proto\x12\x16\x64\x66s.facility.level0prc\x1a\x12\x63ommon/error.proto\"\xb3\x01\n\x0fLevel0PrcRecord\x12\n\n\x02id\x18\x01 \x01(\x03\x12\x11\n\tlevel0_id\x18\x02 \x01(\t\x12\x13\n\x0bpipeline_id\x18\x03 \x01(\t\x12\x12\n\nprc_module\x18\x04 \x01(\t\x12\x18\n\x10params_file_path\x18\x05 \x01(\t\x12\x12\n\nprc_status\x18\x06 \x01(\x05\x12\x10\n\x08prc_time\x18\x07 \x01(\t\x12\x18\n\x10result_file_path\x18\x08 \x01(\t\"\xf3\x01\n\x10\x46indLevel0PrcReq\x12\x11\n\tlevel0_id\x18\x01 \x01(\t\x12\x13\n\x0bpipeline_id\x18\x02 \x01(\t\x12\x12\n\nprc_module\x18\x03 \x01(\t\x12\x12\n\nprc_status\x18\x04 \x01(\x05\x12W\n\x10other_conditions\x18\x05 \x03(\x0b\x32=.dfs.facility.level0prc.FindLevel0PrcReq.OtherConditionsEntry\x1a\x36\n\x14OtherConditionsEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\r\n\x05value\x18\x02 \x01(\t:\x02\x38\x01\"\x90\x01\n\x11\x46indLevel0PrcResp\x12\x0f\n\x07success\x18\x01 \x01(\x08\x12\x12\n\ntotalCount\x18\x02 \x01(\x05\x12\x1c\n\x05\x65rror\x18\x03 \x01(\x0b\x32\r.common.Error\x12\x38\n\x07records\x18\x04 \x03(\x0b\x32\'.dfs.facility.level0prc.Level0PrcRecord\"L\n\x11WriteLevel0PrcReq\x12\x37\n\x06record\x18\x01 \x01(\x0b\x32\'.dfs.facility.level0prc.Level0PrcRecord\"|\n\x12WriteLevel0PrcResp\x12\x0f\n\x07success\x18\x01 \x01(\x08\x12\x1c\n\x05\x65rror\x18\x02 \x01(\x0b\x32\r.common.Error\x12\x37\n\x06record\x18\x03 \x01(\x0b\x32\'.dfs.facility.level0prc.Level0PrcRecord\"1\n\x13UpdateProcStatusReq\x12\n\n\x02id\x18\x01 \x01(\x03\x12\x0e\n\x06status\x18\x02 \x01(\x05\"E\n\x14UpdateProcStatusResp\x12\x0f\n\x07success\x18\x01 \x01(\x08\x12\x1c\n\x05\x65rror\x18\x02 \x01(\x0b\x32\r.common.Error2\xc0\x02\n\x0cLevel0PrcSrv\x12]\n\x04\x46ind\x12(.dfs.facility.level0prc.FindLevel0PrcReq\x1a).dfs.facility.level0prc.FindLevel0PrcResp\"\x00\x12`\n\x05Write\x12).dfs.facility.level0prc.WriteLevel0PrcReq\x1a*.dfs.facility.level0prc.WriteLevel0PrcResp\"\x00\x12o\n\x10UpdateProcStatus\x12+.dfs.facility.level0prc.UpdateProcStatusReq\x1a,.dfs.facility.level0prc.UpdateProcStatusResp\"\x00\x42)Z\'cnlab.net/csst/proto/facility/level0prcb\x06proto3')
DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\"facility/level0prc/level0prc.proto\x12\x16\x64\x66s.facility.level0prc\x1a\x12\x63ommon/error.proto\"\xa0\x01\n\x0fLevel0PrcRecord\x12\n\n\x02id\x18\x01 \x01(\x03\x12\x11\n\tlevel0_id\x18\x02 \x01(\x03\x12\x13\n\x0bpipeline_id\x18\x03 \x01(\t\x12\x12\n\nprc_module\x18\x04 \x01(\t\x12\x0e\n\x06run_id\x18\x05 \x01(\t\x12\x12\n\nprc_status\x18\x06 \x01(\x05\x12\x10\n\x08prc_time\x18\x07 \x01(\t\x12\x0f\n\x07message\x18\x08 \x01(\t\"\xf3\x01\n\x10\x46indLevel0PrcReq\x12\x11\n\tlevel0_id\x18\x01 \x01(\t\x12\x13\n\x0bpipeline_id\x18\x02 \x01(\t\x12\x12\n\nprc_module\x18\x03 \x01(\t\x12\x12\n\nprc_status\x18\x04 \x01(\x05\x12W\n\x10other_conditions\x18\x05 \x03(\x0b\x32=.dfs.facility.level0prc.FindLevel0PrcReq.OtherConditionsEntry\x1a\x36\n\x14OtherConditionsEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\r\n\x05value\x18\x02 \x01(\t:\x02\x38\x01\"\x90\x01\n\x11\x46indLevel0PrcResp\x12\x0f\n\x07success\x18\x01 \x01(\x08\x12\x12\n\ntotalCount\x18\x02 \x01(\x05\x12\x1c\n\x05\x65rror\x18\x03 \x01(\x0b\x32\r.common.Error\x12\x38\n\x07records\x18\x04 \x03(\x0b\x32\'.dfs.facility.level0prc.Level0PrcRecord\"L\n\x11WriteLevel0PrcReq\x12\x37\n\x06record\x18\x01 \x01(\x0b\x32\'.dfs.facility.level0prc.Level0PrcRecord\"|\n\x12WriteLevel0PrcResp\x12\x0f\n\x07success\x18\x01 \x01(\x08\x12\x1c\n\x05\x65rror\x18\x02 \x01(\x0b\x32\r.common.Error\x12\x37\n\x06record\x18\x03 \x01(\x0b\x32\'.dfs.facility.level0prc.Level0PrcRecord\"1\n\x13UpdateProcStatusReq\x12\n\n\x02id\x18\x01 \x01(\x03\x12\x0e\n\x06status\x18\x02 \x01(\x05\"E\n\x14UpdateProcStatusResp\x12\x0f\n\x07success\x18\x01 \x01(\x08\x12\x1c\n\x05\x65rror\x18\x02 \x01(\x0b\x32\r.common.Error2\xc0\x02\n\x0cLevel0PrcSrv\x12]\n\x04\x46ind\x12(.dfs.facility.level0prc.FindLevel0PrcReq\x1a).dfs.facility.level0prc.FindLevel0PrcResp\"\x00\x12`\n\x05Write\x12).dfs.facility.level0prc.WriteLevel0PrcReq\x1a*.dfs.facility.level0prc.WriteLevel0PrcResp\"\x00\x12o\n\x10UpdateProcStatus\x12+.dfs.facility.level0prc.UpdateProcStatusReq\x1a,.dfs.facility.level0prc.UpdateProcStatusResp\"\x00\x42)Z\'cnlab.net/csst/proto/facility/level0prcb\x06proto3')
_builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, globals())
_builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'facility.level0prc.level0prc_pb2', globals())
......@@ -25,21 +25,21 @@ if _descriptor._USE_C_DESCRIPTORS == False:
_FINDLEVEL0PRCREQ_OTHERCONDITIONSENTRY._options = None
_FINDLEVEL0PRCREQ_OTHERCONDITIONSENTRY._serialized_options = b'8\001'
_LEVEL0PRCRECORD._serialized_start=83
_LEVEL0PRCRECORD._serialized_end=262
_FINDLEVEL0PRCREQ._serialized_start=265
_FINDLEVEL0PRCREQ._serialized_end=508
_FINDLEVEL0PRCREQ_OTHERCONDITIONSENTRY._serialized_start=454
_FINDLEVEL0PRCREQ_OTHERCONDITIONSENTRY._serialized_end=508
_FINDLEVEL0PRCRESP._serialized_start=511
_FINDLEVEL0PRCRESP._serialized_end=655
_WRITELEVEL0PRCREQ._serialized_start=657
_WRITELEVEL0PRCREQ._serialized_end=733
_WRITELEVEL0PRCRESP._serialized_start=735
_WRITELEVEL0PRCRESP._serialized_end=859
_UPDATEPROCSTATUSREQ._serialized_start=861
_UPDATEPROCSTATUSREQ._serialized_end=910
_UPDATEPROCSTATUSRESP._serialized_start=912
_UPDATEPROCSTATUSRESP._serialized_end=981
_LEVEL0PRCSRV._serialized_start=984
_LEVEL0PRCSRV._serialized_end=1304
_LEVEL0PRCRECORD._serialized_end=243
_FINDLEVEL0PRCREQ._serialized_start=246
_FINDLEVEL0PRCREQ._serialized_end=489
_FINDLEVEL0PRCREQ_OTHERCONDITIONSENTRY._serialized_start=435
_FINDLEVEL0PRCREQ_OTHERCONDITIONSENTRY._serialized_end=489
_FINDLEVEL0PRCRESP._serialized_start=492
_FINDLEVEL0PRCRESP._serialized_end=636
_WRITELEVEL0PRCREQ._serialized_start=638
_WRITELEVEL0PRCREQ._serialized_end=714
_WRITELEVEL0PRCRESP._serialized_start=716
_WRITELEVEL0PRCRESP._serialized_end=840
_UPDATEPROCSTATUSREQ._serialized_start=842
_UPDATEPROCSTATUSREQ._serialized_end=891
_UPDATEPROCSTATUSRESP._serialized_start=893
_UPDATEPROCSTATUSRESP._serialized_end=962
_LEVEL0PRCSRV._serialized_start=965
_LEVEL0PRCSRV._serialized_end=1285
# @@protoc_insertion_point(module_scope)
csst_dfs_proto/facility/level1prc/level1prc.proto
View file @ 9b992884
......@@ -14,10 +14,10 @@ message Level1PrcRecord {
int64 level1_id = 2;
string pipeline_id = 3;
string prc_module = 4;
string params_file_path = 5;
string run_id = 5;
int32 prc_status = 6;
string prc_time = 7;
string result_file_path = 8;
string message = 8;
}
message FindLevel1PrcReq {
......
csst_dfs_proto/facility/level1prc/level1prc_pb2.py
View file @ 9b992884
......@@ -14,7 +14,7 @@ _sym_db = _symbol_database.Default()
from ...common import error_pb2 as common_dot_error__pb2
DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\"facility/level1prc/level1prc.proto\x12\x16\x64\x66s.facility.level1prc\x1a\x12\x63ommon/error.proto\"\xb3\x01\n\x0fLevel1PrcRecord\x12\n\n\x02id\x18\x01 \x01(\x03\x12\x11\n\tlevel1_id\x18\x02 \x01(\x03\x12\x13\n\x0bpipeline_id\x18\x03 \x01(\t\x12\x12\n\nprc_module\x18\x04 \x01(\t\x12\x18\n\x10params_file_path\x18\x05 \x01(\t\x12\x12\n\nprc_status\x18\x06 \x01(\x05\x12\x10\n\x08prc_time\x18\x07 \x01(\t\x12\x18\n\x10result_file_path\x18\x08 \x01(\t\"\xf3\x01\n\x10\x46indLevel1PrcReq\x12\x11\n\tlevel1_id\x18\x01 \x01(\x03\x12\x13\n\x0bpipeline_id\x18\x02 \x01(\t\x12\x12\n\nprc_module\x18\x03 \x01(\t\x12\x12\n\nprc_status\x18\x04 \x01(\x05\x12W\n\x10other_conditions\x18\x05 \x03(\x0b\x32=.dfs.facility.level1prc.FindLevel1PrcReq.OtherConditionsEntry\x1a\x36\n\x14OtherConditionsEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\r\n\x05value\x18\x02 \x01(\t:\x02\x38\x01\"\x90\x01\n\x11\x46indLevel1PrcResp\x12\x0f\n\x07success\x18\x01 \x01(\x08\x12\x12\n\ntotalCount\x18\x02 \x01(\x05\x12\x1c\n\x05\x65rror\x18\x03 \x01(\x0b\x32\r.common.Error\x12\x38\n\x07records\x18\x04 \x03(\x0b\x32\'.dfs.facility.level1prc.Level1PrcRecord\"L\n\x11WriteLevel1PrcReq\x12\x37\n\x06record\x18\x01 \x01(\x0b\x32\'.dfs.facility.level1prc.Level1PrcRecord\"|\n\x12WriteLevel1PrcResp\x12\x0f\n\x07success\x18\x01 \x01(\x08\x12\x1c\n\x05\x65rror\x18\x02 \x01(\x0b\x32\r.common.Error\x12\x37\n\x06record\x18\x03 \x01(\x0b\x32\'.dfs.facility.level1prc.Level1PrcRecord\"1\n\x13UpdateProcStatusReq\x12\n\n\x02id\x18\x01 \x01(\x03\x12\x0e\n\x06status\x18\x02 \x01(\x05\"E\n\x14UpdateProcStatusResp\x12\x0f\n\x07success\x18\x01 \x01(\x08\x12\x1c\n\x05\x65rror\x18\x02 \x01(\x0b\x32\r.common.Error2\xc0\x02\n\x0cLevel1PrcSrv\x12]\n\x04\x46ind\x12(.dfs.facility.level1prc.FindLevel1PrcReq\x1a).dfs.facility.level1prc.FindLevel1PrcResp\"\x00\x12`\n\x05Write\x12).dfs.facility.level1prc.WriteLevel1PrcReq\x1a*.dfs.facility.level1prc.WriteLevel1PrcResp\"\x00\x12o\n\x10UpdateProcStatus\x12+.dfs.facility.level1prc.UpdateProcStatusReq\x1a,.dfs.facility.level1prc.UpdateProcStatusResp\"\x00\x42)Z\'cnlab.net/csst/proto/facility/level1prcb\x06proto3')
DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\"facility/level1prc/level1prc.proto\x12\x16\x64\x66s.facility.level1prc\x1a\x12\x63ommon/error.proto\"\xa0\x01\n\x0fLevel1PrcRecord\x12\n\n\x02id\x18\x01 \x01(\x03\x12\x11\n\tlevel1_id\x18\x02 \x01(\x03\x12\x13\n\x0bpipeline_id\x18\x03 \x01(\t\x12\x12\n\nprc_module\x18\x04 \x01(\t\x12\x0e\n\x06run_id\x18\x05 \x01(\t\x12\x12\n\nprc_status\x18\x06 \x01(\x05\x12\x10\n\x08prc_time\x18\x07 \x01(\t\x12\x0f\n\x07message\x18\x08 \x01(\t\"\xf3\x01\n\x10\x46indLevel1PrcReq\x12\x11\n\tlevel1_id\x18\x01 \x01(\x03\x12\x13\n\x0bpipeline_id\x18\x02 \x01(\t\x12\x12\n\nprc_module\x18\x03 \x01(\t\x12\x12\n\nprc_status\x18\x04 \x01(\x05\x12W\n\x10other_conditions\x18\x05 \x03(\x0b\x32=.dfs.facility.level1prc.FindLevel1PrcReq.OtherConditionsEntry\x1a\x36\n\x14OtherConditionsEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\r\n\x05value\x18\x02 \x01(\t:\x02\x38\x01\"\x90\x01\n\x11\x46indLevel1PrcResp\x12\x0f\n\x07success\x18\x01 \x01(\x08\x12\x12\n\ntotalCount\x18\x02 \x01(\x05\x12\x1c\n\x05\x65rror\x18\x03 \x01(\x0b\x32\r.common.Error\x12\x38\n\x07records\x18\x04 \x03(\x0b\x32\'.dfs.facility.level1prc.Level1PrcRecord\"L\n\x11WriteLevel1PrcReq\x12\x37\n\x06record\x18\x01 \x01(\x0b\x32\'.dfs.facility.level1prc.Level1PrcRecord\"|\n\x12WriteLevel1PrcResp\x12\x0f\n\x07success\x18\x01 \x01(\x08\x12\x1c\n\x05\x65rror\x18\x02 \x01(\x0b\x32\r.common.Error\x12\x37\n\x06record\x18\x03 \x01(\x0b\x32\'.dfs.facility.level1prc.Level1PrcRecord\"1\n\x13UpdateProcStatusReq\x12\n\n\x02id\x18\x01 \x01(\x03\x12\x0e\n\x06status\x18\x02 \x01(\x05\"E\n\x14UpdateProcStatusResp\x12\x0f\n\x07success\x18\x01 \x01(\x08\x12\x1c\n\x05\x65rror\x18\x02 \x01(\x0b\x32\r.common.Error2\xc0\x02\n\x0cLevel1PrcSrv\x12]\n\x04\x46ind\x12(.dfs.facility.level1prc.FindLevel1PrcReq\x1a).dfs.facility.level1prc.FindLevel1PrcResp\"\x00\x12`\n\x05Write\x12).dfs.facility.level1prc.WriteLevel1PrcReq\x1a*.dfs.facility.level1prc.WriteLevel1PrcResp\"\x00\x12o\n\x10UpdateProcStatus\x12+.dfs.facility.level1prc.UpdateProcStatusReq\x1a,.dfs.facility.level1prc.UpdateProcStatusResp\"\x00\x42)Z\'cnlab.net/csst/proto/facility/level1prcb\x06proto3')
_builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, globals())
_builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'facility.level1prc.level1prc_pb2', globals())
......@@ -25,21 +25,21 @@ if _descriptor._USE_C_DESCRIPTORS == False:
_FINDLEVEL1PRCREQ_OTHERCONDITIONSENTRY._options = None
_FINDLEVEL1PRCREQ_OTHERCONDITIONSENTRY._serialized_options = b'8\001'
_LEVEL1PRCRECORD._serialized_start=83
_LEVEL1PRCRECORD._serialized_end=262
_FINDLEVEL1PRCREQ._serialized_start=265
_FINDLEVEL1PRCREQ._serialized_end=508
_FINDLEVEL1PRCREQ_OTHERCONDITIONSENTRY._serialized_start=454
_FINDLEVEL1PRCREQ_OTHERCONDITIONSENTRY._serialized_end=508
_FINDLEVEL1PRCRESP._serialized_start=511
_FINDLEVEL1PRCRESP._serialized_end=655
_WRITELEVEL1PRCREQ._serialized_start=657
_WRITELEVEL1PRCREQ._serialized_end=733
_WRITELEVEL1PRCRESP._serialized_start=735
_WRITELEVEL1PRCRESP._serialized_end=859
_UPDATEPROCSTATUSREQ._serialized_start=861
_UPDATEPROCSTATUSREQ._serialized_end=910
_UPDATEPROCSTATUSRESP._serialized_start=912
_UPDATEPROCSTATUSRESP._serialized_end=981
_LEVEL1PRCSRV._serialized_start=984
_LEVEL1PRCSRV._serialized_end=1304
_LEVEL1PRCRECORD._serialized_end=243
_FINDLEVEL1PRCREQ._serialized_start=246
_FINDLEVEL1PRCREQ._serialized_end=489
_FINDLEVEL1PRCREQ_OTHERCONDITIONSENTRY._serialized_start=435
_FINDLEVEL1PRCREQ_OTHERCONDITIONSENTRY._serialized_end=489
_FINDLEVEL1PRCRESP._serialized_start=492
_FINDLEVEL1PRCRESP._serialized_end=636
_WRITELEVEL1PRCREQ._serialized_start=638
_WRITELEVEL1PRCREQ._serialized_end=714
_WRITELEVEL1PRCRESP._serialized_start=716
_WRITELEVEL1PRCRESP._serialized_end=840
_UPDATEPROCSTATUSREQ._serialized_start=842
_UPDATEPROCSTATUSREQ._serialized_end=891
_UPDATEPROCSTATUSRESP._serialized_start=893
_UPDATEPROCSTATUSRESP._serialized_end=962
_LEVEL1PRCSRV._serialized_start=965
_LEVEL1PRCSRV._serialized_end=1285
# @@protoc_insertion_point(module_scope)
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment