"git@baltig.infn.it:infn-cloud/paas-ci.git" did not exist on "c4fc2b8f4a6638e803d23f2576d46496c1245648"
Newer
Older
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
/*
* Copyright 2021 INFN
*
* Licensed under the EUPL, Version 1.2 or – as soon they
* will be approved by the European Commission - subsequent
* versions of the EUPL (the "Licence");
* You may not use this work except in compliance with the
* Licence.
* You may obtain a copy of the Licence at:
*
* https://joinup.ec.europa.eu/software/page/eupl
*
* Unless required by applicable law or agreed to in
* writing, software distributed under the Licence is
* distributed on an "AS IS" basis,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either
* express or implied.
* See the Licence for the specific language governing
* permissions and limitations under the Licence.
*/
#ifndef __CHAOSFramework__CE8768D_5BB0_4EF2_A186_7685A0C31B3F_QueryCursorRPC_h
#define __CHAOSFramework__CE8768D_5BB0_4EF2_A186_7685A0C31B3F_QueryCursorRPC_h
#include <chaos/common/chaos_types.h>
#include <chaos/common/exception/CException.h>
#include "QueryCursor.h"
#include <stdint.h>
namespace chaos {
namespace common {
namespace io {
class IODirectIOPSMsgDriver;
#define DEFAULT_PAGE_LEN 1000
class QueryCursorRPC :public QueryCursor{
friend class IODirectIOPSMsgDriver;
protected:
QueryCursorRPC(const std::string& _query_id,
const std::string& _node_id,
uint64_t _start_ts,
uint64_t _end_ts,
uint32_t page_len=DEFAULT_PAGE_LEN);
QueryCursorRPC(const std::string& _query_id,
const std::string& _node_id,
uint64_t _start_ts,
uint64_t _end_ts,
const ChaosStringSet& _meta_tags,
const ChaosStringSet& _projection_keys,
uint32_t page_len = DEFAULT_PAGE_LEN);
QueryCursorRPC(const std::string& _query_id,
const std::string& _node_id,
uint64_t _start_ts,
uint64_t _end_ts,
uint64_t _sequid,
uint64_t _runid,
uint32_t page_len = DEFAULT_PAGE_LEN);
QueryCursorRPC(const std::string& _query_id,
const std::string& _node_id,
uint64_t _start_ts,
uint64_t _end_ts,
uint64_t _sequid,
uint64_t _runid,
const ChaosStringSet& _meta_tags,
const ChaosStringSet& _projection_keys,
uint32_t page_len=DEFAULT_PAGE_LEN);
~QueryCursorRPC();
virtual int fetchData();
};
}
}
}
#endif /* __CHAOSFramework__CE8768D_5BB0_4EF2_A186_7685A0C31B3F_QueryCursorRPC_h */