datasource.pb.go 30 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887
  1. // Code generated by protoc-gen-go. DO NOT EDIT.
  2. // source: datasource.proto
  3. package datasource
  4. import proto "github.com/golang/protobuf/proto"
  5. import fmt "fmt"
  6. import math "math"
  7. import (
  8. context "golang.org/x/net/context"
  9. grpc "google.golang.org/grpc"
  10. )
  11. // Reference imports to suppress errors if they are not otherwise used.
  12. var _ = proto.Marshal
  13. var _ = fmt.Errorf
  14. var _ = math.Inf
  15. // This is a compile-time assertion to ensure that this generated file
  16. // is compatible with the proto package it is being compiled against.
  17. // A compilation error at this line likely means your copy of the
  18. // proto package needs to be updated.
  19. const _ = proto.ProtoPackageIsVersion2 // please upgrade the proto package
  20. type RowValue_Kind int32
  21. const (
  22. // Field type null.
  23. RowValue_TYPE_NULL RowValue_Kind = 0
  24. // Field type double.
  25. RowValue_TYPE_DOUBLE RowValue_Kind = 1
  26. // Field type int64.
  27. RowValue_TYPE_INT64 RowValue_Kind = 2
  28. // Field type bool.
  29. RowValue_TYPE_BOOL RowValue_Kind = 3
  30. // Field type string.
  31. RowValue_TYPE_STRING RowValue_Kind = 4
  32. // Field type bytes.
  33. RowValue_TYPE_BYTES RowValue_Kind = 5
  34. )
  35. var RowValue_Kind_name = map[int32]string{
  36. 0: "TYPE_NULL",
  37. 1: "TYPE_DOUBLE",
  38. 2: "TYPE_INT64",
  39. 3: "TYPE_BOOL",
  40. 4: "TYPE_STRING",
  41. 5: "TYPE_BYTES",
  42. }
  43. var RowValue_Kind_value = map[string]int32{
  44. "TYPE_NULL": 0,
  45. "TYPE_DOUBLE": 1,
  46. "TYPE_INT64": 2,
  47. "TYPE_BOOL": 3,
  48. "TYPE_STRING": 4,
  49. "TYPE_BYTES": 5,
  50. }
  51. func (x RowValue_Kind) String() string {
  52. return proto.EnumName(RowValue_Kind_name, int32(x))
  53. }
  54. func (RowValue_Kind) EnumDescriptor() ([]byte, []int) {
  55. return fileDescriptor_datasource_1e8c5a099546b349, []int{8, 0}
  56. }
  57. type DatasourceRequest struct {
  58. TimeRange *TimeRange `protobuf:"bytes,1,opt,name=timeRange" json:"timeRange,omitempty"`
  59. Datasource *DatasourceInfo `protobuf:"bytes,2,opt,name=datasource" json:"datasource,omitempty"`
  60. Queries []*Query `protobuf:"bytes,3,rep,name=queries" json:"queries,omitempty"`
  61. XXX_NoUnkeyedLiteral struct{} `json:"-"`
  62. XXX_unrecognized []byte `json:"-"`
  63. XXX_sizecache int32 `json:"-"`
  64. }
  65. func (m *DatasourceRequest) Reset() { *m = DatasourceRequest{} }
  66. func (m *DatasourceRequest) String() string { return proto.CompactTextString(m) }
  67. func (*DatasourceRequest) ProtoMessage() {}
  68. func (*DatasourceRequest) Descriptor() ([]byte, []int) {
  69. return fileDescriptor_datasource_1e8c5a099546b349, []int{0}
  70. }
  71. func (m *DatasourceRequest) XXX_Unmarshal(b []byte) error {
  72. return xxx_messageInfo_DatasourceRequest.Unmarshal(m, b)
  73. }
  74. func (m *DatasourceRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
  75. return xxx_messageInfo_DatasourceRequest.Marshal(b, m, deterministic)
  76. }
  77. func (dst *DatasourceRequest) XXX_Merge(src proto.Message) {
  78. xxx_messageInfo_DatasourceRequest.Merge(dst, src)
  79. }
  80. func (m *DatasourceRequest) XXX_Size() int {
  81. return xxx_messageInfo_DatasourceRequest.Size(m)
  82. }
  83. func (m *DatasourceRequest) XXX_DiscardUnknown() {
  84. xxx_messageInfo_DatasourceRequest.DiscardUnknown(m)
  85. }
  86. var xxx_messageInfo_DatasourceRequest proto.InternalMessageInfo
  87. func (m *DatasourceRequest) GetTimeRange() *TimeRange {
  88. if m != nil {
  89. return m.TimeRange
  90. }
  91. return nil
  92. }
  93. func (m *DatasourceRequest) GetDatasource() *DatasourceInfo {
  94. if m != nil {
  95. return m.Datasource
  96. }
  97. return nil
  98. }
  99. func (m *DatasourceRequest) GetQueries() []*Query {
  100. if m != nil {
  101. return m.Queries
  102. }
  103. return nil
  104. }
  105. type Query struct {
  106. RefId string `protobuf:"bytes,1,opt,name=refId" json:"refId,omitempty"`
  107. MaxDataPoints int64 `protobuf:"varint,2,opt,name=maxDataPoints" json:"maxDataPoints,omitempty"`
  108. IntervalMs int64 `protobuf:"varint,3,opt,name=intervalMs" json:"intervalMs,omitempty"`
  109. ModelJson string `protobuf:"bytes,4,opt,name=modelJson" json:"modelJson,omitempty"`
  110. XXX_NoUnkeyedLiteral struct{} `json:"-"`
  111. XXX_unrecognized []byte `json:"-"`
  112. XXX_sizecache int32 `json:"-"`
  113. }
  114. func (m *Query) Reset() { *m = Query{} }
  115. func (m *Query) String() string { return proto.CompactTextString(m) }
  116. func (*Query) ProtoMessage() {}
  117. func (*Query) Descriptor() ([]byte, []int) {
  118. return fileDescriptor_datasource_1e8c5a099546b349, []int{1}
  119. }
  120. func (m *Query) XXX_Unmarshal(b []byte) error {
  121. return xxx_messageInfo_Query.Unmarshal(m, b)
  122. }
  123. func (m *Query) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
  124. return xxx_messageInfo_Query.Marshal(b, m, deterministic)
  125. }
  126. func (dst *Query) XXX_Merge(src proto.Message) {
  127. xxx_messageInfo_Query.Merge(dst, src)
  128. }
  129. func (m *Query) XXX_Size() int {
  130. return xxx_messageInfo_Query.Size(m)
  131. }
  132. func (m *Query) XXX_DiscardUnknown() {
  133. xxx_messageInfo_Query.DiscardUnknown(m)
  134. }
  135. var xxx_messageInfo_Query proto.InternalMessageInfo
  136. func (m *Query) GetRefId() string {
  137. if m != nil {
  138. return m.RefId
  139. }
  140. return ""
  141. }
  142. func (m *Query) GetMaxDataPoints() int64 {
  143. if m != nil {
  144. return m.MaxDataPoints
  145. }
  146. return 0
  147. }
  148. func (m *Query) GetIntervalMs() int64 {
  149. if m != nil {
  150. return m.IntervalMs
  151. }
  152. return 0
  153. }
  154. func (m *Query) GetModelJson() string {
  155. if m != nil {
  156. return m.ModelJson
  157. }
  158. return ""
  159. }
  160. type TimeRange struct {
  161. FromRaw string `protobuf:"bytes,1,opt,name=fromRaw" json:"fromRaw,omitempty"`
  162. ToRaw string `protobuf:"bytes,2,opt,name=toRaw" json:"toRaw,omitempty"`
  163. FromEpochMs int64 `protobuf:"varint,3,opt,name=fromEpochMs" json:"fromEpochMs,omitempty"`
  164. ToEpochMs int64 `protobuf:"varint,4,opt,name=toEpochMs" json:"toEpochMs,omitempty"`
  165. XXX_NoUnkeyedLiteral struct{} `json:"-"`
  166. XXX_unrecognized []byte `json:"-"`
  167. XXX_sizecache int32 `json:"-"`
  168. }
  169. func (m *TimeRange) Reset() { *m = TimeRange{} }
  170. func (m *TimeRange) String() string { return proto.CompactTextString(m) }
  171. func (*TimeRange) ProtoMessage() {}
  172. func (*TimeRange) Descriptor() ([]byte, []int) {
  173. return fileDescriptor_datasource_1e8c5a099546b349, []int{2}
  174. }
  175. func (m *TimeRange) XXX_Unmarshal(b []byte) error {
  176. return xxx_messageInfo_TimeRange.Unmarshal(m, b)
  177. }
  178. func (m *TimeRange) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
  179. return xxx_messageInfo_TimeRange.Marshal(b, m, deterministic)
  180. }
  181. func (dst *TimeRange) XXX_Merge(src proto.Message) {
  182. xxx_messageInfo_TimeRange.Merge(dst, src)
  183. }
  184. func (m *TimeRange) XXX_Size() int {
  185. return xxx_messageInfo_TimeRange.Size(m)
  186. }
  187. func (m *TimeRange) XXX_DiscardUnknown() {
  188. xxx_messageInfo_TimeRange.DiscardUnknown(m)
  189. }
  190. var xxx_messageInfo_TimeRange proto.InternalMessageInfo
  191. func (m *TimeRange) GetFromRaw() string {
  192. if m != nil {
  193. return m.FromRaw
  194. }
  195. return ""
  196. }
  197. func (m *TimeRange) GetToRaw() string {
  198. if m != nil {
  199. return m.ToRaw
  200. }
  201. return ""
  202. }
  203. func (m *TimeRange) GetFromEpochMs() int64 {
  204. if m != nil {
  205. return m.FromEpochMs
  206. }
  207. return 0
  208. }
  209. func (m *TimeRange) GetToEpochMs() int64 {
  210. if m != nil {
  211. return m.ToEpochMs
  212. }
  213. return 0
  214. }
  215. type DatasourceResponse struct {
  216. Results []*QueryResult `protobuf:"bytes,1,rep,name=results" json:"results,omitempty"`
  217. XXX_NoUnkeyedLiteral struct{} `json:"-"`
  218. XXX_unrecognized []byte `json:"-"`
  219. XXX_sizecache int32 `json:"-"`
  220. }
  221. func (m *DatasourceResponse) Reset() { *m = DatasourceResponse{} }
  222. func (m *DatasourceResponse) String() string { return proto.CompactTextString(m) }
  223. func (*DatasourceResponse) ProtoMessage() {}
  224. func (*DatasourceResponse) Descriptor() ([]byte, []int) {
  225. return fileDescriptor_datasource_1e8c5a099546b349, []int{3}
  226. }
  227. func (m *DatasourceResponse) XXX_Unmarshal(b []byte) error {
  228. return xxx_messageInfo_DatasourceResponse.Unmarshal(m, b)
  229. }
  230. func (m *DatasourceResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
  231. return xxx_messageInfo_DatasourceResponse.Marshal(b, m, deterministic)
  232. }
  233. func (dst *DatasourceResponse) XXX_Merge(src proto.Message) {
  234. xxx_messageInfo_DatasourceResponse.Merge(dst, src)
  235. }
  236. func (m *DatasourceResponse) XXX_Size() int {
  237. return xxx_messageInfo_DatasourceResponse.Size(m)
  238. }
  239. func (m *DatasourceResponse) XXX_DiscardUnknown() {
  240. xxx_messageInfo_DatasourceResponse.DiscardUnknown(m)
  241. }
  242. var xxx_messageInfo_DatasourceResponse proto.InternalMessageInfo
  243. func (m *DatasourceResponse) GetResults() []*QueryResult {
  244. if m != nil {
  245. return m.Results
  246. }
  247. return nil
  248. }
  249. type QueryResult struct {
  250. Error string `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
  251. RefId string `protobuf:"bytes,2,opt,name=refId" json:"refId,omitempty"`
  252. MetaJson string `protobuf:"bytes,3,opt,name=metaJson" json:"metaJson,omitempty"`
  253. Series []*TimeSeries `protobuf:"bytes,4,rep,name=series" json:"series,omitempty"`
  254. Tables []*Table `protobuf:"bytes,5,rep,name=tables" json:"tables,omitempty"`
  255. XXX_NoUnkeyedLiteral struct{} `json:"-"`
  256. XXX_unrecognized []byte `json:"-"`
  257. XXX_sizecache int32 `json:"-"`
  258. }
  259. func (m *QueryResult) Reset() { *m = QueryResult{} }
  260. func (m *QueryResult) String() string { return proto.CompactTextString(m) }
  261. func (*QueryResult) ProtoMessage() {}
  262. func (*QueryResult) Descriptor() ([]byte, []int) {
  263. return fileDescriptor_datasource_1e8c5a099546b349, []int{4}
  264. }
  265. func (m *QueryResult) XXX_Unmarshal(b []byte) error {
  266. return xxx_messageInfo_QueryResult.Unmarshal(m, b)
  267. }
  268. func (m *QueryResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
  269. return xxx_messageInfo_QueryResult.Marshal(b, m, deterministic)
  270. }
  271. func (dst *QueryResult) XXX_Merge(src proto.Message) {
  272. xxx_messageInfo_QueryResult.Merge(dst, src)
  273. }
  274. func (m *QueryResult) XXX_Size() int {
  275. return xxx_messageInfo_QueryResult.Size(m)
  276. }
  277. func (m *QueryResult) XXX_DiscardUnknown() {
  278. xxx_messageInfo_QueryResult.DiscardUnknown(m)
  279. }
  280. var xxx_messageInfo_QueryResult proto.InternalMessageInfo
  281. func (m *QueryResult) GetError() string {
  282. if m != nil {
  283. return m.Error
  284. }
  285. return ""
  286. }
  287. func (m *QueryResult) GetRefId() string {
  288. if m != nil {
  289. return m.RefId
  290. }
  291. return ""
  292. }
  293. func (m *QueryResult) GetMetaJson() string {
  294. if m != nil {
  295. return m.MetaJson
  296. }
  297. return ""
  298. }
  299. func (m *QueryResult) GetSeries() []*TimeSeries {
  300. if m != nil {
  301. return m.Series
  302. }
  303. return nil
  304. }
  305. func (m *QueryResult) GetTables() []*Table {
  306. if m != nil {
  307. return m.Tables
  308. }
  309. return nil
  310. }
  311. type Table struct {
  312. Columns []*TableColumn `protobuf:"bytes,1,rep,name=columns" json:"columns,omitempty"`
  313. Rows []*TableRow `protobuf:"bytes,2,rep,name=rows" json:"rows,omitempty"`
  314. XXX_NoUnkeyedLiteral struct{} `json:"-"`
  315. XXX_unrecognized []byte `json:"-"`
  316. XXX_sizecache int32 `json:"-"`
  317. }
  318. func (m *Table) Reset() { *m = Table{} }
  319. func (m *Table) String() string { return proto.CompactTextString(m) }
  320. func (*Table) ProtoMessage() {}
  321. func (*Table) Descriptor() ([]byte, []int) {
  322. return fileDescriptor_datasource_1e8c5a099546b349, []int{5}
  323. }
  324. func (m *Table) XXX_Unmarshal(b []byte) error {
  325. return xxx_messageInfo_Table.Unmarshal(m, b)
  326. }
  327. func (m *Table) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
  328. return xxx_messageInfo_Table.Marshal(b, m, deterministic)
  329. }
  330. func (dst *Table) XXX_Merge(src proto.Message) {
  331. xxx_messageInfo_Table.Merge(dst, src)
  332. }
  333. func (m *Table) XXX_Size() int {
  334. return xxx_messageInfo_Table.Size(m)
  335. }
  336. func (m *Table) XXX_DiscardUnknown() {
  337. xxx_messageInfo_Table.DiscardUnknown(m)
  338. }
  339. var xxx_messageInfo_Table proto.InternalMessageInfo
  340. func (m *Table) GetColumns() []*TableColumn {
  341. if m != nil {
  342. return m.Columns
  343. }
  344. return nil
  345. }
  346. func (m *Table) GetRows() []*TableRow {
  347. if m != nil {
  348. return m.Rows
  349. }
  350. return nil
  351. }
  352. type TableColumn struct {
  353. Name string `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
  354. XXX_NoUnkeyedLiteral struct{} `json:"-"`
  355. XXX_unrecognized []byte `json:"-"`
  356. XXX_sizecache int32 `json:"-"`
  357. }
  358. func (m *TableColumn) Reset() { *m = TableColumn{} }
  359. func (m *TableColumn) String() string { return proto.CompactTextString(m) }
  360. func (*TableColumn) ProtoMessage() {}
  361. func (*TableColumn) Descriptor() ([]byte, []int) {
  362. return fileDescriptor_datasource_1e8c5a099546b349, []int{6}
  363. }
  364. func (m *TableColumn) XXX_Unmarshal(b []byte) error {
  365. return xxx_messageInfo_TableColumn.Unmarshal(m, b)
  366. }
  367. func (m *TableColumn) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
  368. return xxx_messageInfo_TableColumn.Marshal(b, m, deterministic)
  369. }
  370. func (dst *TableColumn) XXX_Merge(src proto.Message) {
  371. xxx_messageInfo_TableColumn.Merge(dst, src)
  372. }
  373. func (m *TableColumn) XXX_Size() int {
  374. return xxx_messageInfo_TableColumn.Size(m)
  375. }
  376. func (m *TableColumn) XXX_DiscardUnknown() {
  377. xxx_messageInfo_TableColumn.DiscardUnknown(m)
  378. }
  379. var xxx_messageInfo_TableColumn proto.InternalMessageInfo
  380. func (m *TableColumn) GetName() string {
  381. if m != nil {
  382. return m.Name
  383. }
  384. return ""
  385. }
  386. type TableRow struct {
  387. Values []*RowValue `protobuf:"bytes,1,rep,name=values" json:"values,omitempty"`
  388. XXX_NoUnkeyedLiteral struct{} `json:"-"`
  389. XXX_unrecognized []byte `json:"-"`
  390. XXX_sizecache int32 `json:"-"`
  391. }
  392. func (m *TableRow) Reset() { *m = TableRow{} }
  393. func (m *TableRow) String() string { return proto.CompactTextString(m) }
  394. func (*TableRow) ProtoMessage() {}
  395. func (*TableRow) Descriptor() ([]byte, []int) {
  396. return fileDescriptor_datasource_1e8c5a099546b349, []int{7}
  397. }
  398. func (m *TableRow) XXX_Unmarshal(b []byte) error {
  399. return xxx_messageInfo_TableRow.Unmarshal(m, b)
  400. }
  401. func (m *TableRow) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
  402. return xxx_messageInfo_TableRow.Marshal(b, m, deterministic)
  403. }
  404. func (dst *TableRow) XXX_Merge(src proto.Message) {
  405. xxx_messageInfo_TableRow.Merge(dst, src)
  406. }
  407. func (m *TableRow) XXX_Size() int {
  408. return xxx_messageInfo_TableRow.Size(m)
  409. }
  410. func (m *TableRow) XXX_DiscardUnknown() {
  411. xxx_messageInfo_TableRow.DiscardUnknown(m)
  412. }
  413. var xxx_messageInfo_TableRow proto.InternalMessageInfo
  414. func (m *TableRow) GetValues() []*RowValue {
  415. if m != nil {
  416. return m.Values
  417. }
  418. return nil
  419. }
  420. type RowValue struct {
  421. Kind RowValue_Kind `protobuf:"varint,1,opt,name=kind,enum=models.RowValue_Kind" json:"kind,omitempty"`
  422. DoubleValue float64 `protobuf:"fixed64,2,opt,name=doubleValue" json:"doubleValue,omitempty"`
  423. Int64Value int64 `protobuf:"varint,3,opt,name=int64Value" json:"int64Value,omitempty"`
  424. BoolValue bool `protobuf:"varint,4,opt,name=boolValue" json:"boolValue,omitempty"`
  425. StringValue string `protobuf:"bytes,5,opt,name=stringValue" json:"stringValue,omitempty"`
  426. BytesValue []byte `protobuf:"bytes,6,opt,name=bytesValue,proto3" json:"bytesValue,omitempty"`
  427. XXX_NoUnkeyedLiteral struct{} `json:"-"`
  428. XXX_unrecognized []byte `json:"-"`
  429. XXX_sizecache int32 `json:"-"`
  430. }
  431. func (m *RowValue) Reset() { *m = RowValue{} }
  432. func (m *RowValue) String() string { return proto.CompactTextString(m) }
  433. func (*RowValue) ProtoMessage() {}
  434. func (*RowValue) Descriptor() ([]byte, []int) {
  435. return fileDescriptor_datasource_1e8c5a099546b349, []int{8}
  436. }
  437. func (m *RowValue) XXX_Unmarshal(b []byte) error {
  438. return xxx_messageInfo_RowValue.Unmarshal(m, b)
  439. }
  440. func (m *RowValue) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
  441. return xxx_messageInfo_RowValue.Marshal(b, m, deterministic)
  442. }
  443. func (dst *RowValue) XXX_Merge(src proto.Message) {
  444. xxx_messageInfo_RowValue.Merge(dst, src)
  445. }
  446. func (m *RowValue) XXX_Size() int {
  447. return xxx_messageInfo_RowValue.Size(m)
  448. }
  449. func (m *RowValue) XXX_DiscardUnknown() {
  450. xxx_messageInfo_RowValue.DiscardUnknown(m)
  451. }
  452. var xxx_messageInfo_RowValue proto.InternalMessageInfo
  453. func (m *RowValue) GetKind() RowValue_Kind {
  454. if m != nil {
  455. return m.Kind
  456. }
  457. return RowValue_TYPE_NULL
  458. }
  459. func (m *RowValue) GetDoubleValue() float64 {
  460. if m != nil {
  461. return m.DoubleValue
  462. }
  463. return 0
  464. }
  465. func (m *RowValue) GetInt64Value() int64 {
  466. if m != nil {
  467. return m.Int64Value
  468. }
  469. return 0
  470. }
  471. func (m *RowValue) GetBoolValue() bool {
  472. if m != nil {
  473. return m.BoolValue
  474. }
  475. return false
  476. }
  477. func (m *RowValue) GetStringValue() string {
  478. if m != nil {
  479. return m.StringValue
  480. }
  481. return ""
  482. }
  483. func (m *RowValue) GetBytesValue() []byte {
  484. if m != nil {
  485. return m.BytesValue
  486. }
  487. return nil
  488. }
  489. type DatasourceInfo struct {
  490. Id int64 `protobuf:"varint,1,opt,name=id" json:"id,omitempty"`
  491. OrgId int64 `protobuf:"varint,2,opt,name=orgId" json:"orgId,omitempty"`
  492. Name string `protobuf:"bytes,3,opt,name=name" json:"name,omitempty"`
  493. Type string `protobuf:"bytes,4,opt,name=type" json:"type,omitempty"`
  494. Url string `protobuf:"bytes,5,opt,name=url" json:"url,omitempty"`
  495. JsonData string `protobuf:"bytes,6,opt,name=jsonData" json:"jsonData,omitempty"`
  496. DecryptedSecureJsonData map[string]string `protobuf:"bytes,7,rep,name=decryptedSecureJsonData" json:"decryptedSecureJsonData,omitempty" protobuf_key:"bytes,1,opt,name=key" protobuf_val:"bytes,2,opt,name=value"`
  497. XXX_NoUnkeyedLiteral struct{} `json:"-"`
  498. XXX_unrecognized []byte `json:"-"`
  499. XXX_sizecache int32 `json:"-"`
  500. }
  501. func (m *DatasourceInfo) Reset() { *m = DatasourceInfo{} }
  502. func (m *DatasourceInfo) String() string { return proto.CompactTextString(m) }
  503. func (*DatasourceInfo) ProtoMessage() {}
  504. func (*DatasourceInfo) Descriptor() ([]byte, []int) {
  505. return fileDescriptor_datasource_1e8c5a099546b349, []int{9}
  506. }
  507. func (m *DatasourceInfo) XXX_Unmarshal(b []byte) error {
  508. return xxx_messageInfo_DatasourceInfo.Unmarshal(m, b)
  509. }
  510. func (m *DatasourceInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
  511. return xxx_messageInfo_DatasourceInfo.Marshal(b, m, deterministic)
  512. }
  513. func (dst *DatasourceInfo) XXX_Merge(src proto.Message) {
  514. xxx_messageInfo_DatasourceInfo.Merge(dst, src)
  515. }
  516. func (m *DatasourceInfo) XXX_Size() int {
  517. return xxx_messageInfo_DatasourceInfo.Size(m)
  518. }
  519. func (m *DatasourceInfo) XXX_DiscardUnknown() {
  520. xxx_messageInfo_DatasourceInfo.DiscardUnknown(m)
  521. }
  522. var xxx_messageInfo_DatasourceInfo proto.InternalMessageInfo
  523. func (m *DatasourceInfo) GetId() int64 {
  524. if m != nil {
  525. return m.Id
  526. }
  527. return 0
  528. }
  529. func (m *DatasourceInfo) GetOrgId() int64 {
  530. if m != nil {
  531. return m.OrgId
  532. }
  533. return 0
  534. }
  535. func (m *DatasourceInfo) GetName() string {
  536. if m != nil {
  537. return m.Name
  538. }
  539. return ""
  540. }
  541. func (m *DatasourceInfo) GetType() string {
  542. if m != nil {
  543. return m.Type
  544. }
  545. return ""
  546. }
  547. func (m *DatasourceInfo) GetUrl() string {
  548. if m != nil {
  549. return m.Url
  550. }
  551. return ""
  552. }
  553. func (m *DatasourceInfo) GetJsonData() string {
  554. if m != nil {
  555. return m.JsonData
  556. }
  557. return ""
  558. }
  559. func (m *DatasourceInfo) GetDecryptedSecureJsonData() map[string]string {
  560. if m != nil {
  561. return m.DecryptedSecureJsonData
  562. }
  563. return nil
  564. }
  565. type TimeSeries struct {
  566. Name string `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
  567. Tags map[string]string `protobuf:"bytes,2,rep,name=tags" json:"tags,omitempty" protobuf_key:"bytes,1,opt,name=key" protobuf_val:"bytes,2,opt,name=value"`
  568. Points []*Point `protobuf:"bytes,3,rep,name=points" json:"points,omitempty"`
  569. XXX_NoUnkeyedLiteral struct{} `json:"-"`
  570. XXX_unrecognized []byte `json:"-"`
  571. XXX_sizecache int32 `json:"-"`
  572. }
  573. func (m *TimeSeries) Reset() { *m = TimeSeries{} }
  574. func (m *TimeSeries) String() string { return proto.CompactTextString(m) }
  575. func (*TimeSeries) ProtoMessage() {}
  576. func (*TimeSeries) Descriptor() ([]byte, []int) {
  577. return fileDescriptor_datasource_1e8c5a099546b349, []int{10}
  578. }
  579. func (m *TimeSeries) XXX_Unmarshal(b []byte) error {
  580. return xxx_messageInfo_TimeSeries.Unmarshal(m, b)
  581. }
  582. func (m *TimeSeries) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
  583. return xxx_messageInfo_TimeSeries.Marshal(b, m, deterministic)
  584. }
  585. func (dst *TimeSeries) XXX_Merge(src proto.Message) {
  586. xxx_messageInfo_TimeSeries.Merge(dst, src)
  587. }
  588. func (m *TimeSeries) XXX_Size() int {
  589. return xxx_messageInfo_TimeSeries.Size(m)
  590. }
  591. func (m *TimeSeries) XXX_DiscardUnknown() {
  592. xxx_messageInfo_TimeSeries.DiscardUnknown(m)
  593. }
  594. var xxx_messageInfo_TimeSeries proto.InternalMessageInfo
  595. func (m *TimeSeries) GetName() string {
  596. if m != nil {
  597. return m.Name
  598. }
  599. return ""
  600. }
  601. func (m *TimeSeries) GetTags() map[string]string {
  602. if m != nil {
  603. return m.Tags
  604. }
  605. return nil
  606. }
  607. func (m *TimeSeries) GetPoints() []*Point {
  608. if m != nil {
  609. return m.Points
  610. }
  611. return nil
  612. }
  613. type Point struct {
  614. Timestamp int64 `protobuf:"varint,1,opt,name=timestamp" json:"timestamp,omitempty"`
  615. Value float64 `protobuf:"fixed64,2,opt,name=value" json:"value,omitempty"`
  616. XXX_NoUnkeyedLiteral struct{} `json:"-"`
  617. XXX_unrecognized []byte `json:"-"`
  618. XXX_sizecache int32 `json:"-"`
  619. }
  620. func (m *Point) Reset() { *m = Point{} }
  621. func (m *Point) String() string { return proto.CompactTextString(m) }
  622. func (*Point) ProtoMessage() {}
  623. func (*Point) Descriptor() ([]byte, []int) {
  624. return fileDescriptor_datasource_1e8c5a099546b349, []int{11}
  625. }
  626. func (m *Point) XXX_Unmarshal(b []byte) error {
  627. return xxx_messageInfo_Point.Unmarshal(m, b)
  628. }
  629. func (m *Point) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
  630. return xxx_messageInfo_Point.Marshal(b, m, deterministic)
  631. }
  632. func (dst *Point) XXX_Merge(src proto.Message) {
  633. xxx_messageInfo_Point.Merge(dst, src)
  634. }
  635. func (m *Point) XXX_Size() int {
  636. return xxx_messageInfo_Point.Size(m)
  637. }
  638. func (m *Point) XXX_DiscardUnknown() {
  639. xxx_messageInfo_Point.DiscardUnknown(m)
  640. }
  641. var xxx_messageInfo_Point proto.InternalMessageInfo
  642. func (m *Point) GetTimestamp() int64 {
  643. if m != nil {
  644. return m.Timestamp
  645. }
  646. return 0
  647. }
  648. func (m *Point) GetValue() float64 {
  649. if m != nil {
  650. return m.Value
  651. }
  652. return 0
  653. }
  654. func init() {
  655. proto.RegisterType((*DatasourceRequest)(nil), "models.DatasourceRequest")
  656. proto.RegisterType((*Query)(nil), "models.Query")
  657. proto.RegisterType((*TimeRange)(nil), "models.TimeRange")
  658. proto.RegisterType((*DatasourceResponse)(nil), "models.DatasourceResponse")
  659. proto.RegisterType((*QueryResult)(nil), "models.QueryResult")
  660. proto.RegisterType((*Table)(nil), "models.Table")
  661. proto.RegisterType((*TableColumn)(nil), "models.TableColumn")
  662. proto.RegisterType((*TableRow)(nil), "models.TableRow")
  663. proto.RegisterType((*RowValue)(nil), "models.RowValue")
  664. proto.RegisterType((*DatasourceInfo)(nil), "models.DatasourceInfo")
  665. proto.RegisterMapType((map[string]string)(nil), "models.DatasourceInfo.DecryptedSecureJsonDataEntry")
  666. proto.RegisterType((*TimeSeries)(nil), "models.TimeSeries")
  667. proto.RegisterMapType((map[string]string)(nil), "models.TimeSeries.TagsEntry")
  668. proto.RegisterType((*Point)(nil), "models.Point")
  669. proto.RegisterEnum("models.RowValue_Kind", RowValue_Kind_name, RowValue_Kind_value)
  670. }
  671. // Reference imports to suppress errors if they are not otherwise used.
  672. var _ context.Context
  673. var _ grpc.ClientConn
  674. // This is a compile-time assertion to ensure that this generated file
  675. // is compatible with the grpc package it is being compiled against.
  676. const _ = grpc.SupportPackageIsVersion4
  677. // DatasourcePluginClient is the client API for DatasourcePlugin service.
  678. //
  679. // For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
  680. type DatasourcePluginClient interface {
  681. Query(ctx context.Context, in *DatasourceRequest, opts ...grpc.CallOption) (*DatasourceResponse, error)
  682. }
  683. type datasourcePluginClient struct {
  684. cc *grpc.ClientConn
  685. }
  686. func NewDatasourcePluginClient(cc *grpc.ClientConn) DatasourcePluginClient {
  687. return &datasourcePluginClient{cc}
  688. }
  689. func (c *datasourcePluginClient) Query(ctx context.Context, in *DatasourceRequest, opts ...grpc.CallOption) (*DatasourceResponse, error) {
  690. out := new(DatasourceResponse)
  691. err := c.cc.Invoke(ctx, "/models.DatasourcePlugin/Query", in, out, opts...)
  692. if err != nil {
  693. return nil, err
  694. }
  695. return out, nil
  696. }
  697. // Server API for DatasourcePlugin service
  698. type DatasourcePluginServer interface {
  699. Query(context.Context, *DatasourceRequest) (*DatasourceResponse, error)
  700. }
  701. func RegisterDatasourcePluginServer(s *grpc.Server, srv DatasourcePluginServer) {
  702. s.RegisterService(&_DatasourcePlugin_serviceDesc, srv)
  703. }
  704. func _DatasourcePlugin_Query_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  705. in := new(DatasourceRequest)
  706. if err := dec(in); err != nil {
  707. return nil, err
  708. }
  709. if interceptor == nil {
  710. return srv.(DatasourcePluginServer).Query(ctx, in)
  711. }
  712. info := &grpc.UnaryServerInfo{
  713. Server: srv,
  714. FullMethod: "/models.DatasourcePlugin/Query",
  715. }
  716. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  717. return srv.(DatasourcePluginServer).Query(ctx, req.(*DatasourceRequest))
  718. }
  719. return interceptor(ctx, in, info, handler)
  720. }
  721. var _DatasourcePlugin_serviceDesc = grpc.ServiceDesc{
  722. ServiceName: "models.DatasourcePlugin",
  723. HandlerType: (*DatasourcePluginServer)(nil),
  724. Methods: []grpc.MethodDesc{
  725. {
  726. MethodName: "Query",
  727. Handler: _DatasourcePlugin_Query_Handler,
  728. },
  729. },
  730. Streams: []grpc.StreamDesc{},
  731. Metadata: "datasource.proto",
  732. }
  733. func init() { proto.RegisterFile("datasource.proto", fileDescriptor_datasource_1e8c5a099546b349) }
  734. var fileDescriptor_datasource_1e8c5a099546b349 = []byte{
  735. // 841 bytes of a gzipped FileDescriptorProto
  736. 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x94, 0x55, 0xdb, 0x8e, 0x23, 0x35,
  737. 0x10, 0xa5, 0x2f, 0xc9, 0xa4, 0x2b, 0x3b, 0xa1, 0xd7, 0xdc, 0x42, 0x34, 0x42, 0xa1, 0xb5, 0x88,
  738. 0x80, 0x44, 0x40, 0xd9, 0xd1, 0x80, 0x40, 0xe2, 0x21, 0x3b, 0x11, 0xca, 0x10, 0x66, 0x06, 0x27,
  739. 0x8b, 0xb4, 0x08, 0x09, 0x75, 0xd2, 0x4e, 0x68, 0xb6, 0xbb, 0x9d, 0xb5, 0xdd, 0x13, 0x22, 0x9e,
  740. 0xf8, 0x18, 0x24, 0x9e, 0xf9, 0x01, 0x1e, 0xf9, 0x2d, 0xe4, 0xea, 0x6b, 0x76, 0x02, 0x12, 0x6f,
  741. 0xae, 0x73, 0x4e, 0x95, 0xcb, 0x55, 0x65, 0x1b, 0xdc, 0xc0, 0x57, 0xbe, 0xe4, 0xa9, 0x58, 0xb1,
  742. 0xe1, 0x56, 0x70, 0xc5, 0x49, 0x33, 0xe6, 0x01, 0x8b, 0xa4, 0xf7, 0xbb, 0x01, 0x0f, 0x2f, 0x4b,
  743. 0x92, 0xb2, 0x17, 0x29, 0x93, 0x8a, 0x7c, 0x0c, 0x8e, 0x0a, 0x63, 0x46, 0xfd, 0x64, 0xc3, 0xba,
  744. 0x46, 0xdf, 0x18, 0xb4, 0x47, 0x0f, 0x87, 0x99, 0xc7, 0x70, 0x51, 0x10, 0xb4, 0xd2, 0x90, 0x0b,
  745. 0x80, 0x6a, 0x8b, 0xae, 0x89, 0x1e, 0x6f, 0x16, 0x1e, 0x55, 0xfc, 0x69, 0xb2, 0xe6, 0xb4, 0xa6,
  746. 0x24, 0xef, 0xc3, 0xc9, 0x8b, 0x94, 0x89, 0x90, 0xc9, 0xae, 0xd5, 0xb7, 0x06, 0xed, 0xd1, 0x69,
  747. 0xe1, 0xf4, 0x6d, 0xca, 0xc4, 0x9e, 0x16, 0xac, 0xf7, 0x9b, 0x01, 0x0d, 0x84, 0xc8, 0xeb, 0xd0,
  748. 0x10, 0x6c, 0x3d, 0x0d, 0x30, 0x2f, 0x87, 0x66, 0x06, 0x79, 0x04, 0xa7, 0xb1, 0xff, 0x8b, 0xde,
  749. 0xe9, 0x96, 0x87, 0x89, 0x92, 0x98, 0x83, 0x45, 0x0f, 0x41, 0xf2, 0x0e, 0x40, 0x98, 0x28, 0x26,
  750. 0xee, 0xfc, 0xe8, 0x1b, 0xbd, 0xa3, 0x96, 0xd4, 0x10, 0x72, 0x06, 0x0e, 0x6e, 0x7f, 0x25, 0x79,
  751. 0xd2, 0xb5, 0x31, 0x7e, 0x05, 0x78, 0xbf, 0x82, 0x53, 0x1e, 0x9e, 0x74, 0xe1, 0x64, 0x2d, 0x78,
  752. 0x4c, 0xfd, 0x5d, 0x9e, 0x48, 0x61, 0xea, 0x04, 0x15, 0xd7, 0xb8, 0x99, 0x25, 0x88, 0x06, 0xe9,
  753. 0x43, 0x5b, 0x0b, 0x26, 0x5b, 0xbe, 0xfa, 0xa9, 0xdc, 0xbb, 0x0e, 0xe9, 0xcd, 0x15, 0x2f, 0x78,
  754. 0x1b, 0xf9, 0x0a, 0xf0, 0x9e, 0x00, 0xa9, 0xf7, 0x49, 0x6e, 0x79, 0x22, 0x19, 0xf9, 0x08, 0x4e,
  755. 0x04, 0x93, 0x69, 0xa4, 0x64, 0xd7, 0xc0, 0xfa, 0xbd, 0x76, 0x58, 0x3f, 0xe4, 0x68, 0xa1, 0xf1,
  756. 0xfe, 0x30, 0xa0, 0x5d, 0x23, 0x74, 0xaa, 0x4c, 0x08, 0x2e, 0x8a, 0x5a, 0xa2, 0x51, 0x55, 0xd8,
  757. 0xac, 0x57, 0xb8, 0x07, 0xad, 0x98, 0x29, 0x1f, 0x4b, 0x63, 0x21, 0x51, 0xda, 0xe4, 0x43, 0x68,
  758. 0xca, 0xac, 0x8b, 0x36, 0x66, 0x41, 0xea, 0xc3, 0x32, 0x47, 0x86, 0xe6, 0x0a, 0xf2, 0x1e, 0x34,
  759. 0x95, 0xbf, 0x8c, 0x98, 0xec, 0x36, 0x0e, 0x3b, 0xbe, 0xd0, 0x28, 0xcd, 0x49, 0xef, 0x07, 0x68,
  760. 0x20, 0xa0, 0x8f, 0xb8, 0xe2, 0x51, 0x1a, 0x27, 0xf7, 0x8e, 0x88, 0xfc, 0x13, 0xe4, 0x68, 0xa1,
  761. 0x21, 0x8f, 0xc0, 0x16, 0x7c, 0xa7, 0xfb, 0xaf, 0xb5, 0xee, 0x61, 0x70, 0xbe, 0xa3, 0xc8, 0x7a,
  762. 0xef, 0x42, 0xbb, 0xe6, 0x4d, 0x08, 0xd8, 0x89, 0x1f, 0xb3, 0xbc, 0x0c, 0xb8, 0xf6, 0xce, 0xa1,
  763. 0x55, 0x38, 0x91, 0x01, 0x34, 0xef, 0xfc, 0x28, 0x65, 0x45, 0x0a, 0x65, 0x58, 0xca, 0x77, 0xdf,
  764. 0x69, 0x82, 0xe6, 0xbc, 0xf7, 0x97, 0x09, 0xad, 0x02, 0x24, 0x1f, 0x80, 0xfd, 0x3c, 0x4c, 0xb2,
  765. 0x49, 0xed, 0x8c, 0xde, 0x78, 0xd9, 0x69, 0xf8, 0x75, 0x98, 0x04, 0x14, 0x25, 0x7a, 0x3c, 0x02,
  766. 0x9e, 0x2e, 0x23, 0x86, 0x0c, 0x56, 0xde, 0xa0, 0x75, 0x28, 0x9f, 0xdd, 0x8b, 0xf3, 0x4c, 0x50,
  767. 0xcd, 0x6e, 0x8e, 0xe8, 0xf1, 0x59, 0x72, 0x1e, 0x65, 0xb4, 0x1e, 0x9f, 0x16, 0xad, 0x00, 0x1d,
  768. 0x5f, 0x2a, 0x11, 0x26, 0x9b, 0x8c, 0x6f, 0xe0, 0x41, 0xeb, 0x90, 0x8e, 0xbf, 0xdc, 0x2b, 0x26,
  769. 0x33, 0x41, 0xb3, 0x6f, 0x0c, 0x1e, 0xd0, 0x1a, 0xe2, 0xad, 0xc1, 0xd6, 0xf9, 0x92, 0x53, 0x70,
  770. 0x16, 0xcf, 0x6e, 0x27, 0x3f, 0x5e, 0x3f, 0x9d, 0xcd, 0xdc, 0x57, 0xc8, 0xab, 0xd0, 0x46, 0xf3,
  771. 0xf2, 0xe6, 0xe9, 0x78, 0x36, 0x71, 0x0d, 0xd2, 0x01, 0x40, 0x60, 0x7a, 0xbd, 0xb8, 0x38, 0x77,
  772. 0xcd, 0x52, 0x3f, 0xbe, 0xb9, 0x99, 0xb9, 0x56, 0xa9, 0x9f, 0x2f, 0xe8, 0xf4, 0xfa, 0x2b, 0xd7,
  773. 0x2e, 0xf5, 0xe3, 0x67, 0x8b, 0xc9, 0xdc, 0x6d, 0x78, 0x7f, 0x9b, 0xd0, 0x39, 0x7c, 0x31, 0x48,
  774. 0x07, 0xcc, 0x30, 0xab, 0xa2, 0x45, 0xcd, 0x30, 0xd0, 0x03, 0xca, 0xc5, 0x26, 0x1f, 0x50, 0x8b,
  775. 0x66, 0x46, 0xd9, 0x44, 0xab, 0x6a, 0xa2, 0xc6, 0xd4, 0x7e, 0xcb, 0xf2, 0xbb, 0x8c, 0x6b, 0xe2,
  776. 0x82, 0x95, 0x8a, 0x28, 0x2f, 0x81, 0x5e, 0xea, 0xd1, 0xfe, 0x59, 0xf2, 0x44, 0xef, 0x8a, 0x07,
  777. 0x77, 0x68, 0x69, 0x93, 0x18, 0xde, 0x0a, 0xd8, 0x4a, 0xec, 0xb7, 0x8a, 0x05, 0x73, 0xb6, 0x4a,
  778. 0x05, 0xbb, 0x2a, 0xa4, 0x27, 0x38, 0x0b, 0x8f, 0x8f, 0x3f, 0x73, 0xc3, 0xcb, 0xe3, 0x5e, 0x93,
  779. 0x44, 0x89, 0x3d, 0xfd, 0xb7, 0x98, 0xbd, 0x2b, 0x38, 0xfb, 0x2f, 0x47, 0x9d, 0xfc, 0x73, 0xb6,
  780. 0xcf, 0x07, 0x55, 0x2f, 0x75, 0x31, 0xee, 0xca, 0x99, 0x71, 0x68, 0x66, 0x7c, 0x6e, 0x7e, 0x66,
  781. 0x78, 0x7f, 0x1a, 0x00, 0xd5, 0x05, 0x3c, 0x36, 0xe4, 0xe4, 0x13, 0xb0, 0x95, 0xbf, 0x29, 0x6e,
  782. 0xcb, 0xd9, 0xfd, 0x6b, 0x3b, 0x5c, 0xf8, 0x1b, 0x99, 0xe5, 0x8c, 0x4a, 0x7d, 0x7d, 0xb7, 0xd9,
  783. 0x0b, 0xfb, 0xd2, 0x83, 0x8d, 0x4f, 0x2c, 0xcd, 0xc9, 0xde, 0xa7, 0xe0, 0x94, 0x9e, 0xff, 0x2b,
  784. 0xe9, 0x2f, 0xa0, 0x81, 0x91, 0xf0, 0x39, 0x0c, 0x63, 0x26, 0x95, 0x1f, 0x6f, 0xf3, 0xde, 0x57,
  785. 0xc0, 0x61, 0x00, 0x23, 0x0f, 0x30, 0xa2, 0xe0, 0x56, 0x5d, 0xb8, 0x8d, 0xd2, 0x4d, 0x98, 0x90,
  786. 0x2f, 0x8b, 0x8f, 0xe3, 0xed, 0xfb, 0x8d, 0xca, 0xff, 0xbb, 0x5e, 0xef, 0x18, 0x95, 0x3d, 0xb1,
  787. 0xe3, 0x07, 0xdf, 0xd7, 0x3e, 0xac, 0x65, 0x13, 0xbf, 0xcf, 0xc7, 0xff, 0x04, 0x00, 0x00, 0xff,
  788. 0xff, 0xab, 0xf8, 0xda, 0x77, 0x52, 0x07, 0x00, 0x00,
  789. }