athena_rs 3.26.2

Hyper performant polyglot Database driver
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127

//! Operational worker/runtime expected logging-schema table contracts.

use super::logging_expectation_contracts::ExpectedLoggingTable;

pub(super) const EXPECTED_BACKUP_JOBS: ExpectedLoggingTable = ExpectedLoggingTable {
    table_schema: "public",
    table_name: "backup_jobs",
    relation_type: "BASE TABLE",
    required: true,
    purpose: "Queue and execution history for durable backup and restore jobs",
    required_columns: &[
        "job_type",
        "client_name",
        "status",
        "s3_bucket",
        "s3_key",
        "execution_daemon_id",
        "lease_expires_at",
        "completed_at",
    ],
};

pub(super) const EXPECTED_BACKUP_JOB_LOGS: ExpectedLoggingTable = ExpectedLoggingTable {
    table_schema: "public",
    table_name: "backup_job_logs",
    relation_type: "BASE TABLE",
    required: true,
    purpose: "Execution log lines for backup and restore jobs",
    required_columns: &["job_id", "level", "message", "created_at"],
};

pub(super) const EXPECTED_BACKUP_SCHEDULES: ExpectedLoggingTable = ExpectedLoggingTable {
    table_schema: "public",
    table_name: "backup_schedules",
    relation_type: "BASE TABLE",
    required: true,
    purpose: "Persisted backup schedules and daemon pinning",
    required_columns: &[
        "client_name",
        "frequency",
        "cron_expression",
        "execution_daemon_id",
        "enabled",
        "next_run_at",
    ],
};

pub(super) const EXPECTED_DATABASE_CLONE_JOBS: ExpectedLoggingTable = ExpectedLoggingTable {
    table_schema: "public",
    table_name: "database_clone_jobs",
    relation_type: "BASE TABLE",
    required: true,
    purpose: "Clone control-plane queue and daemon lease ownership",
    required_columns: &[
        "job_id",
        "status",
        "phase",
        "execution_daemon_id",
        "lease_expires_at",
        "created_at",
    ],
};

pub(super) const EXPECTED_DATABASE_CLONE_JOB_EVENTS: ExpectedLoggingTable = ExpectedLoggingTable {
    table_schema: "public",
    table_name: "database_clone_job_events",
    relation_type: "BASE TABLE",
    required: true,
    purpose: "Clone control-plane event log for daemon execution tracing",
    required_columns: &[
        "event_id",
        "job_id",
        "daemon_id",
        "kind",
        "message",
        "created_at",
    ],
};

pub(super) const EXPECTED_DAEMON_RUNTIME_REGISTRY: ExpectedLoggingTable = ExpectedLoggingTable {
    table_schema: "public",
    table_name: "daemon_runtime_registry",
    relation_type: "BASE TABLE",
    required: true,
    purpose: "Durable daemon presence registry for Studio operations",
    required_columns: &[
        "daemon_id",
        "runtime_kind",
        "host",
        "version",
        "workers_json",
        "metadata_json",
        "started_at",
        "last_seen_at",
    ],
};

pub(super) const EXPECTED_TYPESENSE_SYNC_JOBS: ExpectedLoggingTable = ExpectedLoggingTable {
    table_schema: "public",
    table_name: "typesense_sync_jobs",
    relation_type: "BASE TABLE",
    required: true,
    purpose: "Typesense sync job definitions and daemon affinity",
    required_columns: &[
        "name",
        "enabled",
        "auto_sync_enabled",
        "execution_daemon_id",
        "next_sync_at",
        "last_sync_status",
    ],
};

pub(super) const EXPECTED_TYPESENSE_SYNC_RUNS: ExpectedLoggingTable = ExpectedLoggingTable {
    table_schema: "public",
    table_name: "typesense_sync_runs",
    relation_type: "BASE TABLE",
    required: true,
    purpose: "Typesense sync runtime history and active runs",
    required_columns: &[
        "job_id",
        "status",
        "started_at",
        "progress_pct",
        "progress_stage",
    ],
};