substreams_database_change/pb/
mod.rs

1use crate::pb::sf::substreams::sink::database::v1::field::UpdateOp;
2
3/// The module database exists for backward compatibility reason, it should NOT be used anymore.
4///
5/// Replace `substreams_database_change::pb::database::<...>` by `substreams_database_change::pb::sf::substreams::sink::database::v1::<...>`,
6/// this module will be removed in future versions.
7///
8/// A simple search/replace is usually sufficient to update your code.
9#[deprecated(
10    since = "4.0.0",
11    note = "The module database exists for backward compatibility reason, it should NOT be used anymore. Replace substreams_database_change::pb::database::<...> by substreams_database_change::pb::sf::substreams::sink::database::v1::<...>, this module will be removed in future versions."
12)]
13pub mod database {
14    macro_rules! deprecated_reexport {
15        ($($item:ident),* $(,)?) => {
16            $(
17                #[deprecated(
18                    since = "4.0.0",
19                    note = "Use substreams_database_change::pb::sf::substreams::sink::database::v1 instead, this module will be removed in future versions."
20                )]
21                pub type $item = super::sf::substreams::sink::database::v1::$item;
22            )*
23        };
24    }
25
26    deprecated_reexport!(DatabaseChanges, TableChange, CompositePrimaryKey, Field);
27
28    pub mod table_change {
29        macro_rules! deprecated_reexport {
30            ($($item:ident),* $(,)?) => {
31                $(
32                    #[deprecated(
33                        since = "4.0.0",
34                        note = "Use substreams_database_change::pb::sf::substreams::sink::database::v1::table_change instead, this module will be removed in future versions."
35                    )]
36                    pub type $item = super::super::sf::substreams::sink::database::v1::table_change::$item;
37                )*
38            };
39        }
40
41        deprecated_reexport!(Operation, PrimaryKey);
42    }
43
44    pub mod field {
45        macro_rules! deprecated_reexport {
46            ($($item:ident),* $(,)?) => {
47                $(
48                    #[deprecated(
49                        since = "4.0.0",
50                        note = "Use substreams_database_change::pb::sf::substreams::sink::database::v1::field instead, this module will be removed in future versions."
51                    )]
52                    pub type $item = super::super::sf::substreams::sink::database::v1::field::$item;
53                )*
54            };
55        }
56
57        deprecated_reexport!(UpdateOp);
58    }
59}
60
61include!("pb.rs");
62
63impl UpdateOp {
64    pub fn as_display_name(&self) -> &'static str {
65        match self {
66            UpdateOp::Unspecified => "unspecified",
67            UpdateOp::Add => "add/sub",
68            UpdateOp::Max => "max",
69            UpdateOp::Min => "min",
70            UpdateOp::SetIfNull => "set_if_null",
71            UpdateOp::Set => "set",
72        }
73    }
74}
substreams_database_change/pb/mod.rs

substreams_database_change/pb/
mod.rs
