1pub mod config {
2 pub const LOAD_PIPES: &str = include_str!("../surql/queries/config/load_pipes.surql");
3 pub const LOAD_PIPE_PRESETS: &str =
4 include_str!("../surql/queries/config/load_pipe_presets.surql");
5 pub const LOAD_QUERIES: &str = include_str!("../surql/queries/config/load_queries.surql");
6 pub const LOAD_SINKS: &str = include_str!("../surql/queries/config/load_sinks.surql");
7 pub const READ_PIPES_CACHE: &str =
8 include_str!("../surql/queries/config/read_pipes_cache.surql");
9 pub const READ_PIPE_PRESETS_CACHE: &str =
10 include_str!("../surql/queries/config/read_pipe_presets_cache.surql");
11 pub const READ_SINKS_CACHE: &str =
12 include_str!("../surql/queries/config/read_sinks_cache.surql");
13}
14
15pub mod config_version {
16 pub const CREATE_VERSION: &str =
17 include_str!("../surql/queries/config_version/create_version.surql");
18 pub const GET_VERSION: &str = include_str!("../surql/queries/config_version/get_version.surql");
19 pub const LIST_VERSIONS: &str =
20 include_str!("../surql/queries/config_version/list_versions.surql");
21 pub const NEXT_VERSION: &str =
22 include_str!("../surql/queries/config_version/next_version.surql");
23}
24
25pub mod credential {
26 pub const CREATE_CREDENTIAL: &str =
27 include_str!("../surql/queries/credential/create_credential.surql");
28 pub const DELETE_CREDENTIAL: &str =
29 include_str!("../surql/queries/credential/delete_credential.surql");
30 pub const LIST_CREDENTIALS: &str =
31 include_str!("../surql/queries/credential/list_credentials.surql");
32 pub const LOOKUP_CREDENTIAL: &str =
33 include_str!("../surql/queries/credential/lookup_credential.surql");
34}
35
36pub mod delta {
37 pub const BATCH_UPSERT: &str = include_str!("../surql/queries/delta/batch_upsert.surql");
38 pub const DELETE_PENDING: &str = include_str!("../surql/queries/delta/delete_pending.surql");
39 pub const DELETE_STALE: &str = include_str!("../surql/queries/delta/delete_stale.surql");
40 pub const FIND_CREATED: &str = include_str!("../surql/queries/delta/find_created.surql");
41 pub const FIND_DELETED: &str = include_str!("../surql/queries/delta/find_deleted.surql");
42 pub const FIND_UPDATED: &str = include_str!("../surql/queries/delta/find_updated.surql");
43 pub const LIST_CYCLE_HISTORY: &str =
44 include_str!("../surql/queries/delta/list_cycle_history.surql");
45 pub const LOG_CYCLE_FINISH: &str =
46 include_str!("../surql/queries/delta/log_cycle_finish.surql");
47 pub const LOG_CYCLE_START: &str = include_str!("../surql/queries/delta/log_cycle_start.surql");
48 pub const NEXT_CYCLE_ID: &str = include_str!("../surql/queries/delta/next_cycle_id.surql");
49 pub const PREP_PREV_HASH: &str = include_str!("../surql/queries/delta/prep_prev_hash.surql");
50 pub const READ_PENDING: &str = include_str!("../surql/queries/delta/read_pending.surql");
51 pub const READ_SNAPSHOT_KEYS: &str =
52 include_str!("../surql/queries/delta/read_snapshot_keys.surql");
53 pub const READ_SNAPSHOT_KEYS_PAGED: &str =
54 include_str!("../surql/queries/delta/read_snapshot_keys_paged.surql");
55 pub const SAVE_PENDING: &str = include_str!("../surql/queries/delta/save_pending.surql");
56}
57
58pub mod mutations {
59 pub const CREATE_DLQ_ENTRY: &str =
60 include_str!("../surql/queries/mutations/create_dlq_entry.surql");
61 pub const CREATE_PIPE: &str = include_str!("../surql/queries/mutations/create_pipe.surql");
62 pub const CREATE_PIPE_PRESET: &str =
63 include_str!("../surql/queries/mutations/create_pipe_preset.surql");
64 pub const CREATE_QUERY: &str = include_str!("../surql/queries/mutations/create_query.surql");
65 pub const CREATE_QUERY_WITH_SINKS: &str =
66 include_str!("../surql/queries/mutations/create_query_with_sinks.surql");
67 pub const CREATE_SINK: &str = include_str!("../surql/queries/mutations/create_sink.surql");
68 pub const DELETE_DLQ_ENTRY: &str =
69 include_str!("../surql/queries/mutations/delete_dlq_entry.surql");
70 pub const DELETE_PIPE: &str = include_str!("../surql/queries/mutations/delete_pipe.surql");
71 pub const DELETE_PIPE_PRESET: &str =
72 include_str!("../surql/queries/mutations/delete_pipe_preset.surql");
73 pub const DELETE_PIPE_QUERIES: &str =
74 include_str!("../surql/queries/mutations/delete_pipe_queries.surql");
75 pub const DELETE_SINK: &str = include_str!("../surql/queries/mutations/delete_sink.surql");
76 pub const LIST_DLQ: &str = include_str!("../surql/queries/mutations/list_dlq.surql");
77 pub const LOCK_RELEASE: &str = include_str!("../surql/queries/mutations/lock_release.surql");
78 pub const LOCK_RENEW: &str = include_str!("../surql/queries/mutations/lock_renew.surql");
79 pub const LOCK_TRY_ACQUIRE: &str =
80 include_str!("../surql/queries/mutations/lock_try_acquire.surql");
81 pub const UPDATE_PIPE_DELTA: &str =
82 include_str!("../surql/queries/mutations/update_pipe_delta.surql");
83 pub const UPDATE_PIPE_ENABLED: &str =
84 include_str!("../surql/queries/mutations/update_pipe_enabled.surql");
85 pub const UPDATE_PIPE_FILTERS: &str =
86 include_str!("../surql/queries/mutations/update_pipe_filters.surql");
87 pub const UPDATE_PIPE_LINKS: &str =
88 include_str!("../surql/queries/mutations/update_pipe_links.surql");
89 pub const UPDATE_PIPE_ORIGIN_CREDENTIAL: &str =
90 include_str!("../surql/queries/mutations/update_pipe_origin_credential.surql");
91 pub const UPDATE_PIPE_ORIGIN_CONFIG: &str =
92 include_str!("../surql/queries/mutations/update_pipe_origin_config.surql");
93 pub const UPDATE_PIPE_ORIGIN_CONNECTOR: &str =
94 include_str!("../surql/queries/mutations/update_pipe_origin_connector.surql");
95 pub const UPDATE_PIPE_ORIGIN_DSN: &str =
96 include_str!("../surql/queries/mutations/update_pipe_origin_dsn.surql");
97 pub const UPDATE_PIPE_TRINO_URL: &str =
98 include_str!("../surql/queries/mutations/update_pipe_trino_url.surql");
99 pub const UPDATE_PIPE_RETRY: &str =
100 include_str!("../surql/queries/mutations/update_pipe_retry.surql");
101 pub const UPDATE_PIPE_RECIPE: &str =
102 include_str!("../surql/queries/mutations/update_pipe_recipe.surql");
103 pub const UPDATE_PIPE_RECIPE_NONE: &str =
104 include_str!("../surql/queries/mutations/update_pipe_recipe_none.surql");
105 pub const UPDATE_PIPE_PRESET: &str =
106 include_str!("../surql/queries/mutations/update_pipe_preset.surql");
107 pub const UPDATE_PIPE_SCHEDULE: &str =
108 include_str!("../surql/queries/mutations/update_pipe_schedule.surql");
109 pub const UPDATE_PIPE_TARGETS: &str =
110 include_str!("../surql/queries/mutations/update_pipe_targets.surql");
111 pub const UPDATE_PIPE_TRANSFORMS: &str =
112 include_str!("../surql/queries/mutations/update_pipe_transforms.surql");
113 pub const UPDATE_SINK_CONFIG: &str =
114 include_str!("../surql/queries/mutations/update_sink_config.surql");
115 pub const UPDATE_SINK_ENABLED: &str =
116 include_str!("../surql/queries/mutations/update_sink_enabled.surql");
117 pub const UPDATE_SINK_TYPE: &str =
118 include_str!("../surql/queries/mutations/update_sink_type.surql");
119}
120
121pub mod query_config {
122 pub const DELETE_ONE: &str = include_str!("../surql/queries/query_config/delete_one.surql");
123 pub const LIST_BY_SOURCE: &str =
124 include_str!("../surql/queries/query_config/list_by_source.surql");
125 pub const UPDATE_ENABLED: &str =
126 include_str!("../surql/queries/query_config/update_enabled.surql");
127 pub const UPDATE_KEY_COLUMN: &str =
128 include_str!("../surql/queries/query_config/update_key_column.surql");
129 pub const UPDATE_QUERY: &str = include_str!("../surql/queries/query_config/update_query.surql");
130 pub const UPDATE_SINKS: &str = include_str!("../surql/queries/query_config/update_sinks.surql");
131 pub const UPDATE_TRANSFORM: &str =
132 include_str!("../surql/queries/query_config/update_transform.surql");
133}
134
135pub mod links {
136 pub const CREATE_RULE: &str = include_str!("../surql/queries/links/create_rule.surql");
137 pub const LIST_RULES: &str = include_str!("../surql/queries/links/list_rules.surql");
138 pub const DELETE_RULE: &str = include_str!("../surql/queries/links/delete_rule.surql");
139 pub const UPSERT_LINK: &str = include_str!("../surql/queries/links/upsert_link.surql");
140 pub const READ_LINKS: &str = include_str!("../surql/queries/links/read_links.surql");
141 pub const DELETE_LINK: &str = include_str!("../surql/queries/links/delete_link.surql");
142 pub const READ_SNAPSHOT_ROWS: &str =
143 include_str!("../surql/queries/links/read_snapshot_rows.surql");
144 pub const BATCH_UPSERT_LINKS: &str =
145 include_str!("../surql/queries/links/batch_upsert_links.surql");
146}
147
148pub mod sink {
149 pub const BATCH_UPSERT_EVENTS: &str =
150 include_str!("../surql/queries/sink/batch_upsert_events.surql");
151 pub const UPSERT_EVENT: &str = include_str!("../surql/queries/sink/upsert_event.surql");
152 pub const UPSERT_DOCUMENT: &str = include_str!("../surql/queries/sink/upsert_document.surql");
153 pub const BATCH_UPSERT_DOCUMENTS: &str =
154 include_str!("../surql/queries/sink/batch_upsert_documents.surql");
155}