libdballe  9.11
summary.h
1 #ifndef DBALLE_DB_SUMMARY_H
2 #define DBALLE_DB_SUMMARY_H
3 
4 #include <dballe/core/fwd.h>
5 #include <dballe/core/defs.h>
6 #include <dballe/types.h>
7 #include <vector>
8 #include <functional>
9 
10 namespace dballe {
11 namespace db {
12 namespace summary {
13 
17 struct VarDesc
18 {
19  dballe::Level level;
20  dballe::Trange trange;
21  wreport::Varcode varcode;
22 
23  VarDesc() = default;
24 
25  VarDesc(const dballe::Level& level, const dballe::Trange& trange, wreport::Varcode varcode)
26  : level(level), trange(trange), varcode(varcode) {}
27 
28  VarDesc(const VarDesc&) = default;
29 
30  bool operator==(const VarDesc& o) const { return std::tie(level, trange, varcode) == std::tie(o.level, o.trange, o.varcode); }
31  bool operator!=(const VarDesc& o) const { return std::tie(level, trange, varcode) != std::tie(o.level, o.trange, o.varcode); }
32  bool operator< (const VarDesc& o) const { return std::tie(level, trange, varcode) < std::tie(o.level, o.trange, o.varcode); }
33  bool operator<=(const VarDesc& o) const { return std::tie(level, trange, varcode) <= std::tie(o.level, o.trange, o.varcode); }
34  bool operator> (const VarDesc& o) const { return std::tie(level, trange, varcode) > std::tie(o.level, o.trange, o.varcode); }
35  bool operator>=(const VarDesc& o) const { return std::tie(level, trange, varcode) >= std::tie(o.level, o.trange, o.varcode); }
36 };
37 
38 }
39 
43 template<typename Station>
45 {
46 public:
47  typedef Station station_type;
48 
49  BaseSummary();
50  BaseSummary(const BaseSummary&) = delete;
51  BaseSummary(BaseSummary&&) = delete;
52  BaseSummary& operator=(const BaseSummary&) = delete;
53  BaseSummary& operator=(BaseSummary&&) = delete;
54  virtual ~BaseSummary();
55 
56  // virtual bool operator==(const BaseSummary<Station>& o) const = 0;
57 
58  virtual bool stations(std::function<bool(const Station&)>) const = 0;
59  virtual bool reports(std::function<bool(const std::string&)>) const = 0;
60  virtual bool levels(std::function<bool(const Level&)>) const = 0;
61  virtual bool tranges(std::function<bool(const Trange&)>) const = 0;
62  virtual bool varcodes(std::function<bool(const wreport::Varcode&)>) const = 0;
63 
70  virtual Datetime datetime_min() const = 0;
71  virtual Datetime datetime_max() const = 0;
72  virtual unsigned data_count() const = 0;
73 
84  virtual std::shared_ptr<dballe::CursorSummary> query_summary(const Query& query) const;
85 
87  virtual void clear() = 0;
88 
90  virtual void add(const Station& station, const summary::VarDesc& vd, const dballe::DatetimeRange& dtrange, size_t count) = 0;
91 
93  virtual void add_cursor(const dballe::CursorSummary& cur);
94 
96  virtual void add_message(const dballe::Message& message, bool station_data=true, bool data=true);
97 
99  virtual void add_messages(const std::vector<std::shared_ptr<dballe::Message>>& messages, bool station_data=true, bool data=true);
100 
102  virtual void add_summary(const BaseSummary<dballe::Station>& summary);
103 
105  virtual void add_summary(const BaseSummary<dballe::DBStation>& summary);
106 
108  virtual void add_filtered(const BaseSummary<Station>& summary, const dballe::Query& query);
109 
111  virtual void commit() = 0;
112 
114  virtual bool iter(std::function<bool(const Station&, const summary::VarDesc&, const DatetimeRange&, size_t)>) const = 0;
115 
117  virtual bool iter_filtered(const dballe::Query& query, std::function<bool(const Station&, const summary::VarDesc&, const DatetimeRange&, size_t)>) const = 0;
118 
120  virtual void to_json(core::JSONWriter& writer) const = 0;
121 
123  virtual void load_json(core::json::Stream& in);
124 
125  DBALLE_TEST_ONLY virtual void dump(FILE* out) const = 0;
126 };
127 
128 
133 
138 
139 extern template class BaseSummary<dballe::Station>;
140 extern template class BaseSummary<dballe::DBStation>;
141 
142 }
143 }
144 
145 #endif
Common base types used by most of DB-All.e code.
virtual void add_cursor(const dballe::CursorSummary &cur)
Add an entry to the summary taken from the current status of cur.
Definition: json.h:165
Station information.
Definition: types.h:793
Description of a variable, independent of where and when it was measured.
Definition: summary.h:17
virtual void clear()=0
Completely empty the summary.
Information on how a value has been sampled or computed with regards to time.
Definition: types.h:686
Cursor iterating over summary entries.
Definition: cursor.h:97
virtual Datetime datetime_min() const =0
Recompute reports, levels, tranges, and varcodes.
Definition: cmdline.h:18
virtual void add_message(const dballe::Message &message, bool station_data=true, bool data=true)
Add the contents of a Message.
virtual void to_json(core::JSONWriter &writer) const =0
Serialize to JSON.
Vertical level or layer.
Definition: types.h:624
virtual bool iter(std::function< bool(const Station &, const summary::VarDesc &, const DatetimeRange &, size_t)>) const =0
Iterate the contents of this summary. There is no guarantee on sorting order.
virtual void add_summary(const BaseSummary< dballe::Station > &summary)
Merge the copy of another summary into this one.
A bulletin that has been decoded and physically interpreted.
Definition: message.h:28
uint16_t Varcode
Range of datetimes.
Definition: types.h:294
virtual void add_messages(const std::vector< std::shared_ptr< dballe::Message >> &messages, bool station_data=true, bool data=true)
Add the contents of a Messages.
virtual void add(const Station &station, const summary::VarDesc &vd, const dballe::DatetimeRange &dtrange, size_t count)=0
Add an entry to the summary.
High level objects for working with DB-All.e DB summaries.
Definition: summary.h:44
Date and time.
Definition: types.h:164
virtual void commit()=0
Write changes to disk.
JSON serializer.
Definition: json.h:29
virtual void load_json(core::json::Stream &in)
Load contents from JSON, merging with the current contents.
virtual void add_filtered(const BaseSummary< Station > &summary, const dballe::Query &query)
Merge the copy of another summary into this one.
Common definitions.
Query used to filter DB-All.e data.
Definition: query.h:14
virtual std::shared_ptr< dballe::CursorSummary > query_summary(const Query &query) const
Query the contents of the summary.
virtual bool iter_filtered(const dballe::Query &query, std::function< bool(const Station &, const summary::VarDesc &, const DatetimeRange &, size_t)>) const =0
Iterate the contents of this summary. There is no guarantee on sorting order.