libdballe 9.6
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
10namespace dballe {
11namespace db {
12namespace summary {
13
17struct 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
43template<typename Station>
45{
46public:
47 typedef Station station_type;
48
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
139extern template class BaseSummary<dballe::Station>;
140extern template class BaseSummary<dballe::DBStation>;
141
142}
143}
144
145#endif
Cursor iterating over summary entries.
Definition: cursor.h:98
A bulletin that has been decoded and physically interpreted.
Definition: message.h:29
Query used to filter DB-All.e data.
Definition: query.h:15
JSON serializer.
Definition: json.h:30
High level objects for working with DB-All.e DB summaries.
Definition: summary.h:45
virtual std::shared_ptr< dballe::CursorSummary > query_summary(const Query &query) const
Query the contents of the summary.
virtual Datetime datetime_min() const =0
Recompute reports, levels, tranges, and varcodes.
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.
virtual void to_json(core::JSONWriter &writer) const =0
Serialize to JSON.
virtual void add_cursor(const dballe::CursorSummary &cur)
Add an entry to the summary taken from the current status of cur.
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_summary(const BaseSummary< dballe::DBStation > &summary)
Merge the copy of another summary into this one.
virtual void add_message(const dballe::Message &message, bool station_data=true, bool data=true)
Add the contents of a Message.
virtual void load_json(core::json::Stream &in)
Load contents from JSON, merging with the current contents.
virtual void add_summary(const BaseSummary< dballe::Station > &summary)
Merge the copy of another summary into this one.
virtual void clear()=0
Completely empty the summary.
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(const Station &station, const summary::VarDesc &vd, const dballe::DatetimeRange &dtrange, size_t count)=0
Add an entry to the summary.
virtual void add_filtered(const BaseSummary< Station > &summary, const dballe::Query &query)
Merge the copy of another summary into this one.
virtual void commit()=0
Write changes to disk.
Common definitions.
uint16_t Varcode
Range of datetimes.
Definition: types.h:295
Date and time.
Definition: types.h:165
Vertical level or layer.
Definition: types.h:625
Station information.
Definition: types.h:794
Information on how a value has been sampled or computed with regards to time.
Definition: types.h:687
Definition: json.h:166
Description of a variable, independent of where and when it was measured.
Definition: summary.h:18
Common base types used by most of DB-All.e code.