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 =
18		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 =
48		include_str!("../surql/queries/delta/log_cycle_start.surql");
49	pub const NEXT_CYCLE_ID: &str = include_str!("../surql/queries/delta/next_cycle_id.surql");
50	pub const PREP_PREV_HASH: &str = include_str!("../surql/queries/delta/prep_prev_hash.surql");
51	pub const READ_PENDING: &str = include_str!("../surql/queries/delta/read_pending.surql");
52	pub const READ_SNAPSHOT_KEYS: &str =
53		include_str!("../surql/queries/delta/read_snapshot_keys.surql");
54	pub const READ_SNAPSHOT_KEYS_PAGED: &str =
55		include_str!("../surql/queries/delta/read_snapshot_keys_paged.surql");
56	pub const SAVE_PENDING: &str = include_str!("../surql/queries/delta/save_pending.surql");
57}
58
59pub mod mutations {
60	pub const CREATE_DLQ_ENTRY: &str =
61		include_str!("../surql/queries/mutations/create_dlq_entry.surql");
62	pub const CREATE_PIPE: &str = include_str!("../surql/queries/mutations/create_pipe.surql");
63	pub const CREATE_SINK: &str = include_str!("../surql/queries/mutations/create_sink.surql");
64	pub const CREATE_SOURCE: &str =
65		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 =
73		include_str!("../surql/queries/mutations/delete_source.surql");
74	pub const DELETE_SOURCE_QUERIES: &str =
75		include_str!("../surql/queries/mutations/delete_source_queries.surql");
76	pub const LIST_DLQ: &str = include_str!("../surql/queries/mutations/list_dlq.surql");
77	pub const LOCK_RELEASE: &str =
78		include_str!("../surql/queries/mutations/lock_release.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_ORIGIN_CONFIG: &str =
86		include_str!("../surql/queries/mutations/update_pipe_origin_config.surql");
87	pub const UPDATE_PIPE_ORIGIN_CONNECTOR: &str =
88		include_str!("../surql/queries/mutations/update_pipe_origin_connector.surql");
89	pub const UPDATE_PIPE_ORIGIN_DSN: &str =
90		include_str!("../surql/queries/mutations/update_pipe_origin_dsn.surql");
91	pub const UPDATE_PIPE_RETRY: &str =
92		include_str!("../surql/queries/mutations/update_pipe_retry.surql");
93	pub const UPDATE_PIPE_SCHEDULE: &str =
94		include_str!("../surql/queries/mutations/update_pipe_schedule.surql");
95	pub const UPDATE_PIPE_TARGETS: &str =
96		include_str!("../surql/queries/mutations/update_pipe_targets.surql");
97	pub const UPDATE_SINK_CONFIG: &str =
98		include_str!("../surql/queries/mutations/update_sink_config.surql");
99	pub const UPDATE_SINK_ENABLED: &str =
100		include_str!("../surql/queries/mutations/update_sink_enabled.surql");
101	pub const UPDATE_SINK_TYPE: &str =
102		include_str!("../surql/queries/mutations/update_sink_type.surql");
103	pub const UPDATE_SOURCE_CONFIG: &str =
104		include_str!("../surql/queries/mutations/update_source_config.surql");
105	pub const UPDATE_SOURCE_CONNECTOR: &str =
106		include_str!("../surql/queries/mutations/update_source_connector.surql");
107	pub const UPDATE_SOURCE_ENABLED: &str =
108		include_str!("../surql/queries/mutations/update_source_enabled.surql");
109}
110
111pub mod query_config {
112	pub const DELETE_ONE: &str = include_str!("../surql/queries/query_config/delete_one.surql");
113	pub const LIST_BY_SOURCE: &str =
114		include_str!("../surql/queries/query_config/list_by_source.surql");
115	pub const UPDATE_ENABLED: &str =
116		include_str!("../surql/queries/query_config/update_enabled.surql");
117	pub const UPDATE_KEY_COLUMN: &str =
118		include_str!("../surql/queries/query_config/update_key_column.surql");
119	pub const UPDATE_QUERY: &str =
120		include_str!("../surql/queries/query_config/update_query.surql");
121	pub const UPDATE_SINKS: &str =
122		include_str!("../surql/queries/query_config/update_sinks.surql");
123}
124
125pub mod sink {
126	pub const BATCH_UPSERT_EVENTS: &str =
127		include_str!("../surql/queries/sink/batch_upsert_events.surql");
128	pub const UPSERT_EVENT: &str = include_str!("../surql/queries/sink/upsert_event.surql");
129}
oversync_queries/lib.rs

oversync_queries/
lib.rs
