oversync_queries/
lib.rs

1pub mod config {
2	pub const LOAD_PIPES: &str = include_str!("../surql/queries/config/load_pipes.surql");
3	pub const LOAD_QUERIES: &str = include_str!("../surql/queries/config/load_queries.surql");
4	pub const LOAD_SINKS: &str = include_str!("../surql/queries/config/load_sinks.surql");
5	pub const LOAD_SOURCES: &str = include_str!("../surql/queries/config/load_sources.surql");
6	pub const READ_PIPES_CACHE: &str =
7		include_str!("../surql/queries/config/read_pipes_cache.surql");
8	pub const READ_SINKS_CACHE: &str =
9		include_str!("../surql/queries/config/read_sinks_cache.surql");
10	pub const READ_SOURCES_CACHE: &str =
11		include_str!("../surql/queries/config/read_sources_cache.surql");
12}
13
14pub mod config_version {
15	pub const CREATE_VERSION: &str =
16		include_str!("../surql/queries/config_version/create_version.surql");
17	pub const GET_VERSION: &str = include_str!("../surql/queries/config_version/get_version.surql");
18	pub const LIST_VERSIONS: &str =
19		include_str!("../surql/queries/config_version/list_versions.surql");
20	pub const NEXT_VERSION: &str =
21		include_str!("../surql/queries/config_version/next_version.surql");
22}
23
24pub mod credential {
25	pub const CREATE_CREDENTIAL: &str =
26		include_str!("../surql/queries/credential/create_credential.surql");
27	pub const DELETE_CREDENTIAL: &str =
28		include_str!("../surql/queries/credential/delete_credential.surql");
29	pub const LIST_CREDENTIALS: &str =
30		include_str!("../surql/queries/credential/list_credentials.surql");
31	pub const LOOKUP_CREDENTIAL: &str =
32		include_str!("../surql/queries/credential/lookup_credential.surql");
33}
34
35pub mod delta {
36	pub const BATCH_UPSERT: &str = include_str!("../surql/queries/delta/batch_upsert.surql");
37	pub const DELETE_PENDING: &str = include_str!("../surql/queries/delta/delete_pending.surql");
38	pub const DELETE_STALE: &str = include_str!("../surql/queries/delta/delete_stale.surql");
39	pub const FIND_CREATED: &str = include_str!("../surql/queries/delta/find_created.surql");
40	pub const FIND_DELETED: &str = include_str!("../surql/queries/delta/find_deleted.surql");
41	pub const FIND_UPDATED: &str = include_str!("../surql/queries/delta/find_updated.surql");
42	pub const LIST_CYCLE_HISTORY: &str =
43		include_str!("../surql/queries/delta/list_cycle_history.surql");
44	pub const LOG_CYCLE_FINISH: &str =
45		include_str!("../surql/queries/delta/log_cycle_finish.surql");
46	pub const LOG_CYCLE_START: &str = include_str!("../surql/queries/delta/log_cycle_start.surql");
47	pub const NEXT_CYCLE_ID: &str = include_str!("../surql/queries/delta/next_cycle_id.surql");
48	pub const PREP_PREV_HASH: &str = include_str!("../surql/queries/delta/prep_prev_hash.surql");
49	pub const READ_PENDING: &str = include_str!("../surql/queries/delta/read_pending.surql");
50	pub const READ_SNAPSHOT_KEYS: &str =
51		include_str!("../surql/queries/delta/read_snapshot_keys.surql");
52	pub const READ_SNAPSHOT_KEYS_PAGED: &str =
53		include_str!("../surql/queries/delta/read_snapshot_keys_paged.surql");
54	pub const SAVE_PENDING: &str = include_str!("../surql/queries/delta/save_pending.surql");
55}
56
57pub mod mutations {
58	pub const CREATE_DLQ_ENTRY: &str =
59		include_str!("../surql/queries/mutations/create_dlq_entry.surql");
60	pub const CREATE_PIPE: &str = include_str!("../surql/queries/mutations/create_pipe.surql");
61	pub const CREATE_SINK: &str = include_str!("../surql/queries/mutations/create_sink.surql");
62	pub const CREATE_SOURCE: &str = include_str!("../surql/queries/mutations/create_source.surql");
63	pub const DELETE_DLQ_ENTRY: &str =
64		include_str!("../surql/queries/mutations/delete_dlq_entry.surql");
65	pub const DELETE_PIPE: &str = include_str!("../surql/queries/mutations/delete_pipe.surql");
66	pub const DELETE_PIPE_QUERIES: &str =
67		include_str!("../surql/queries/mutations/delete_pipe_queries.surql");
68	pub const DELETE_SINK: &str = include_str!("../surql/queries/mutations/delete_sink.surql");
69	pub const DELETE_SOURCE: &str = include_str!("../surql/queries/mutations/delete_source.surql");
70	pub const DELETE_SOURCE_QUERIES: &str =
71		include_str!("../surql/queries/mutations/delete_source_queries.surql");
72	pub const LIST_DLQ: &str = include_str!("../surql/queries/mutations/list_dlq.surql");
73	pub const LOCK_RELEASE: &str = include_str!("../surql/queries/mutations/lock_release.surql");
74	pub const LOCK_TRY_ACQUIRE: &str =
75		include_str!("../surql/queries/mutations/lock_try_acquire.surql");
76	pub const UPDATE_PIPE_DELTA: &str =
77		include_str!("../surql/queries/mutations/update_pipe_delta.surql");
78	pub const UPDATE_PIPE_ENABLED: &str =
79		include_str!("../surql/queries/mutations/update_pipe_enabled.surql");
80	pub const UPDATE_PIPE_ORIGIN_CONFIG: &str =
81		include_str!("../surql/queries/mutations/update_pipe_origin_config.surql");
82	pub const UPDATE_PIPE_ORIGIN_CONNECTOR: &str =
83		include_str!("../surql/queries/mutations/update_pipe_origin_connector.surql");
84	pub const UPDATE_PIPE_ORIGIN_DSN: &str =
85		include_str!("../surql/queries/mutations/update_pipe_origin_dsn.surql");
86	pub const UPDATE_PIPE_RETRY: &str =
87		include_str!("../surql/queries/mutations/update_pipe_retry.surql");
88	pub const UPDATE_PIPE_SCHEDULE: &str =
89		include_str!("../surql/queries/mutations/update_pipe_schedule.surql");
90	pub const UPDATE_PIPE_TARGETS: &str =
91		include_str!("../surql/queries/mutations/update_pipe_targets.surql");
92	pub const UPDATE_SINK_CONFIG: &str =
93		include_str!("../surql/queries/mutations/update_sink_config.surql");
94	pub const UPDATE_SINK_ENABLED: &str =
95		include_str!("../surql/queries/mutations/update_sink_enabled.surql");
96	pub const UPDATE_SINK_TYPE: &str =
97		include_str!("../surql/queries/mutations/update_sink_type.surql");
98	pub const UPDATE_SOURCE_CONFIG: &str =
99		include_str!("../surql/queries/mutations/update_source_config.surql");
100	pub const UPDATE_SOURCE_CONNECTOR: &str =
101		include_str!("../surql/queries/mutations/update_source_connector.surql");
102	pub const UPDATE_SOURCE_ENABLED: &str =
103		include_str!("../surql/queries/mutations/update_source_enabled.surql");
104}
105
106pub mod query_config {
107	pub const DELETE_ONE: &str = include_str!("../surql/queries/query_config/delete_one.surql");
108	pub const LIST_BY_SOURCE: &str =
109		include_str!("../surql/queries/query_config/list_by_source.surql");
110	pub const UPDATE_ENABLED: &str =
111		include_str!("../surql/queries/query_config/update_enabled.surql");
112	pub const UPDATE_KEY_COLUMN: &str =
113		include_str!("../surql/queries/query_config/update_key_column.surql");
114	pub const UPDATE_QUERY: &str = include_str!("../surql/queries/query_config/update_query.surql");
115	pub const UPDATE_SINKS: &str = include_str!("../surql/queries/query_config/update_sinks.surql");
116}
117
118pub mod sink {
119	pub const BATCH_UPSERT_EVENTS: &str =
120		include_str!("../surql/queries/sink/batch_upsert_events.surql");
121	pub const UPSERT_EVENT: &str = include_str!("../surql/queries/sink/upsert_event.surql");
122}
oversync_queries/lib.rs

oversync_queries/
lib.rs
