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_QUERY: &str = include_str!("../surql/queries/mutations/create_query.surql");
62 pub const CREATE_QUERY_WITH_SINKS: &str =
63 include_str!("../surql/queries/mutations/create_query_with_sinks.surql");
64 pub const CREATE_SINK: &str = include_str!("../surql/queries/mutations/create_sink.surql");
65 pub const CREATE_SOURCE: &str = include_str!("../surql/queries/mutations/create_source.surql");
66 pub const DELETE_DLQ_ENTRY: &str =
67 include_str!("../surql/queries/mutations/delete_dlq_entry.surql");
68 pub const DELETE_PIPE: &str = include_str!("../surql/queries/mutations/delete_pipe.surql");
69 pub const DELETE_PIPE_QUERIES: &str =
70 include_str!("../surql/queries/mutations/delete_pipe_queries.surql");
71 pub const DELETE_SINK: &str = include_str!("../surql/queries/mutations/delete_sink.surql");
72 pub const DELETE_SOURCE: &str = include_str!("../surql/queries/mutations/delete_source.surql");
73 pub const DELETE_SOURCE_QUERIES: &str =
74 include_str!("../surql/queries/mutations/delete_source_queries.surql");
75 pub const LIST_DLQ: &str = include_str!("../surql/queries/mutations/list_dlq.surql");
76 pub const LOCK_RELEASE: &str = include_str!("../surql/queries/mutations/lock_release.surql");
77 pub const LOCK_TRY_ACQUIRE: &str =
78 include_str!("../surql/queries/mutations/lock_try_acquire.surql");
79 pub const UPDATE_PIPE_DELTA: &str =
80 include_str!("../surql/queries/mutations/update_pipe_delta.surql");
81 pub const UPDATE_PIPE_ENABLED: &str =
82 include_str!("../surql/queries/mutations/update_pipe_enabled.surql");
83 pub const UPDATE_PIPE_ORIGIN_CONFIG: &str =
84 include_str!("../surql/queries/mutations/update_pipe_origin_config.surql");
85 pub const UPDATE_PIPE_ORIGIN_CONNECTOR: &str =
86 include_str!("../surql/queries/mutations/update_pipe_origin_connector.surql");
87 pub const UPDATE_PIPE_ORIGIN_DSN: &str =
88 include_str!("../surql/queries/mutations/update_pipe_origin_dsn.surql");
89 pub const UPDATE_PIPE_RETRY: &str =
90 include_str!("../surql/queries/mutations/update_pipe_retry.surql");
91 pub const UPDATE_PIPE_SCHEDULE: &str =
92 include_str!("../surql/queries/mutations/update_pipe_schedule.surql");
93 pub const UPDATE_PIPE_TARGETS: &str =
94 include_str!("../surql/queries/mutations/update_pipe_targets.surql");
95 pub const UPDATE_SINK_CONFIG: &str =
96 include_str!("../surql/queries/mutations/update_sink_config.surql");
97 pub const UPDATE_SINK_ENABLED: &str =
98 include_str!("../surql/queries/mutations/update_sink_enabled.surql");
99 pub const UPDATE_SINK_TYPE: &str =
100 include_str!("../surql/queries/mutations/update_sink_type.surql");
101 pub const UPDATE_SOURCE_CONFIG: &str =
102 include_str!("../surql/queries/mutations/update_source_config.surql");
103 pub const UPDATE_SOURCE_CONNECTOR: &str =
104 include_str!("../surql/queries/mutations/update_source_connector.surql");
105 pub const UPDATE_SOURCE_ENABLED: &str =
106 include_str!("../surql/queries/mutations/update_source_enabled.surql");
107}
108
109pub mod query_config {
110 pub const DELETE_ONE: &str = include_str!("../surql/queries/query_config/delete_one.surql");
111 pub const LIST_BY_SOURCE: &str =
112 include_str!("../surql/queries/query_config/list_by_source.surql");
113 pub const UPDATE_ENABLED: &str =
114 include_str!("../surql/queries/query_config/update_enabled.surql");
115 pub const UPDATE_KEY_COLUMN: &str =
116 include_str!("../surql/queries/query_config/update_key_column.surql");
117 pub const UPDATE_QUERY: &str = include_str!("../surql/queries/query_config/update_query.surql");
118 pub const UPDATE_SINKS: &str = include_str!("../surql/queries/query_config/update_sinks.surql");
119}
120
121pub mod links {
122 pub const CREATE_RULE: &str = include_str!("../surql/queries/links/create_rule.surql");
123 pub const LIST_RULES: &str = include_str!("../surql/queries/links/list_rules.surql");
124 pub const DELETE_RULE: &str = include_str!("../surql/queries/links/delete_rule.surql");
125 pub const UPSERT_LINK: &str = include_str!("../surql/queries/links/upsert_link.surql");
126 pub const READ_LINKS: &str = include_str!("../surql/queries/links/read_links.surql");
127 pub const DELETE_LINK: &str = include_str!("../surql/queries/links/delete_link.surql");
128 pub const READ_SNAPSHOT_ROWS: &str =
129 include_str!("../surql/queries/links/read_snapshot_rows.surql");
130 pub const BATCH_UPSERT_LINKS: &str =
131 include_str!("../surql/queries/links/batch_upsert_links.surql");
132}
133
134pub mod sink {
135 pub const BATCH_UPSERT_EVENTS: &str =
136 include_str!("../surql/queries/sink/batch_upsert_events.surql");
137 pub const UPSERT_EVENT: &str = include_str!("../surql/queries/sink/upsert_event.surql");
138 pub const UPSERT_DOCUMENT: &str = include_str!("../surql/queries/sink/upsert_document.surql");
139 pub const BATCH_UPSERT_DOCUMENTS: &str =
140 include_str!("../surql/queries/sink/batch_upsert_documents.surql");
141}