A diet Tap option for handling atproto sync
fixed env renames
Bailey Townsend
(Jun 30, 2026, 12:39 PM -0500)
18266504
8d1658f2
+26
-26
+26
-26
cmd/tab/main.go
+26
-26
cmd/tab/main.go
···
44
44
Name: "env",
45
45
Usage: "environment name for observability",
46
46
Value: "dev",
47
-
Sources: cli.EnvVars("tab_ENV"),
47
+
Sources: cli.EnvVars("TAB_ENV"),
48
48
},
49
49
&cli.StringFlag{
50
50
Name: "db-url",
51
51
Usage: "database connection string (sqlite://path or postgres://...)",
52
52
Value: "sqlite://./tab.db",
53
-
Sources: cli.EnvVars("tab_DATABASE_URL"),
53
+
Sources: cli.EnvVars("TAB_DATABASE_URL"),
54
54
},
55
55
&cli.IntFlag{
56
56
Name: "max-db-conn",
57
57
Usage: "maximum number of database connections",
58
58
Value: 32,
59
-
Sources: cli.EnvVars("tab_MAX_DB_CONNS"),
59
+
Sources: cli.EnvVars("TAB_MAX_DB_CONNS"),
60
60
},
61
61
&cli.StringFlag{
62
62
Name: "bind",
63
63
Usage: "address and port to listen on for HTTP APIs",
64
64
Value: ":2480",
65
-
Sources: cli.EnvVars("tab_BIND"),
65
+
Sources: cli.EnvVars("TAB_BIND"),
66
66
},
67
67
&cli.StringFlag{
68
68
Name: "plc-url",
69
69
Usage: "PLC registry HTTP/HTTPS url",
70
70
Value: "https://plc.directory",
71
-
Sources: cli.EnvVars("tab_PLC_URL", "ATP_PLC_HOST"),
71
+
Sources: cli.EnvVars("TAB_PLC_URL", "ATP_PLC_HOST"),
72
72
},
73
73
&cli.StringFlag{
74
74
Name: "relay-url",
75
75
Usage: "AT Protocol relay HTTP/HTTPS url",
76
76
Value: "https://relay1.us-east.bsky.network",
77
-
Sources: cli.EnvVars("tab_RELAY_URL"),
77
+
Sources: cli.EnvVars("TAB_RELAY_URL"),
78
78
},
79
79
&cli.StringFlag{
80
80
Name: "light-rail-url",
81
81
Usage: "Microcosm Lightrail HTTP/HTTPS url",
82
82
Value: "",
83
-
Sources: cli.EnvVars("tab_LIGHT_RAIL_URL"),
83
+
Sources: cli.EnvVars("TAB_LIGHT_RAIL_URL"),
84
84
},
85
85
&cli.StringFlag{
86
86
Name: "jetstream-url",
87
87
Usage: "JetStream HTTP/HTTPS url",
88
-
Sources: cli.EnvVars("tab_JETSTREAM_URL"),
88
+
Sources: cli.EnvVars("TAB_JETSTREAM_URL"),
89
89
},
90
90
&cli.IntFlag{
91
91
Name: "firehose-parallelism",
92
92
Usage: "number of parallel firehose event processors",
93
93
Value: 10,
94
-
Sources: cli.EnvVars("tab_FIREHOSE_PARALLELISM"),
94
+
Sources: cli.EnvVars("TAB_FIREHOSE_PARALLELISM"),
95
95
},
96
96
&cli.IntFlag{
97
97
Name: "resync-parallelism",
98
98
Usage: "number of parallel resync workers",
99
99
Value: 5,
100
-
Sources: cli.EnvVars("tab_RESYNC_PARALLELISM"),
100
+
Sources: cli.EnvVars("TAB_RESYNC_PARALLELISM"),
101
101
},
102
102
&cli.IntFlag{
103
103
Name: "outbox-parallelism",
104
104
Usage: "number of parallel outbox workers",
105
105
Value: 1,
106
-
Sources: cli.EnvVars("tab_OUTBOX_PARALLELISM"),
106
+
Sources: cli.EnvVars("TAB_OUTBOX_PARALLELISM"),
107
107
},
108
108
&cli.DurationFlag{
109
109
Name: "cursor-save-interval",
110
110
Usage: "how often to save firehose cursor",
111
111
Value: 1 * time.Second,
112
-
Sources: cli.EnvVars("tab_CURSOR_SAVE_INTERVAL"),
112
+
Sources: cli.EnvVars("TAB_CURSOR_SAVE_INTERVAL"),
113
113
},
114
114
&cli.BoolFlag{
115
115
Name: "no-replay",
116
116
Usage: "skip saved cursor and connect to firehose head on startup (incompatible with --full-network, not recommended for production)",
117
-
Sources: cli.EnvVars("tab_NO_REPLAY"),
117
+
Sources: cli.EnvVars("TAB_NO_REPLAY"),
118
118
},
119
119
&cli.DurationFlag{
120
120
Name: "repo-fetch-timeout",
121
121
Usage: "timeout when fetching repo CARs from PDS (e.g. 180s)",
122
122
Value: 300 * time.Second,
123
-
Sources: cli.EnvVars("tab_REPO_FETCH_TIMEOUT"),
123
+
Sources: cli.EnvVars("TAB_REPO_FETCH_TIMEOUT"),
124
124
},
125
125
&cli.IntFlag{
126
126
Name: "ident-cache-size",
···
132
132
Name: "outbox-capacity",
133
133
Usage: "rough size of outbox before back pressure is applied",
134
134
Value: 100_000,
135
-
Sources: cli.EnvVars("tab_OUTBOX_CAPACITY"),
135
+
Sources: cli.EnvVars("TAB_OUTBOX_CAPACITY"),
136
136
},
137
137
&cli.BoolFlag{
138
138
Name: "full-network",
139
139
Usage: "enumerate and sync all repos on the network",
140
-
Sources: cli.EnvVars("tab_FULL_NETWORK"),
140
+
Sources: cli.EnvVars("TAB_FULL_NETWORK"),
141
141
},
142
142
&cli.StringFlag{
143
143
Name: "signal-collection",
144
144
Usage: "enumerate repos by collection (exact NSID)",
145
-
Sources: cli.EnvVars("tab_SIGNAL_COLLECTION"),
145
+
Sources: cli.EnvVars("TAB_SIGNAL_COLLECTION"),
146
146
},
147
147
&cli.StringSliceFlag{
148
148
Name: "light-rail-signal-collections",
149
149
Usage: "enumerate repos by collections (exact NSIDs)",
150
-
Sources: cli.EnvVars("tab_LIGHT_RAIL_SIGNAL_COLLECTIONS"),
150
+
Sources: cli.EnvVars("TAB_LIGHT_RAIL_SIGNAL_COLLECTIONS"),
151
151
},
152
152
&cli.BoolFlag{
153
153
Name: "disable-acks",
154
154
Usage: "disable client acknowledgments (fire-and-forget mode)",
155
-
Sources: cli.EnvVars("tab_DISABLE_ACKS"),
155
+
Sources: cli.EnvVars("TAB_DISABLE_ACKS"),
156
156
},
157
157
&cli.StringFlag{
158
158
Name: "webhook-url",
159
159
Usage: "webhook URL for event delivery (instead of WebSocket)",
160
-
Sources: cli.EnvVars("tab_WEBHOOK_URL"),
160
+
Sources: cli.EnvVars("TAB_WEBHOOK_URL"),
161
161
},
162
162
&cli.StringSliceFlag{
163
163
Name: "collection-filters",
164
164
Usage: "filter output records by collection (supports wildcards)",
165
-
Sources: cli.EnvVars("tab_COLLECTION_FILTERS"),
165
+
Sources: cli.EnvVars("TAB_COLLECTION_FILTERS"),
166
166
},
167
167
&cli.BoolFlag{
168
168
Name: "outbox-only",
169
169
Usage: "run in outbox-only mode (no firehose, resync, or enumeration)",
170
-
Sources: cli.EnvVars("tab_OUTBOX_ONLY"),
170
+
Sources: cli.EnvVars("TAB_OUTBOX_ONLY"),
171
171
},
172
172
&cli.StringFlag{
173
173
Name: "admin-password",
174
174
Usage: "Basic auth admin password required for all requests (if set)",
175
-
Sources: cli.EnvVars("tab_ADMIN_PASSWORD"),
175
+
Sources: cli.EnvVars("TAB_ADMIN_PASSWORD"),
176
176
},
177
177
&cli.DurationFlag{
178
178
Name: "retry-timeout",
179
179
Usage: "timeout before retrying unacked events",
180
180
Value: 60 * time.Second,
181
-
Sources: cli.EnvVars("tab_RETRY_TIMEOUT"),
181
+
Sources: cli.EnvVars("TAB_RETRY_TIMEOUT"),
182
182
},
183
183
&cli.StringFlag{
184
184
Name: "log-level",
185
185
Usage: "log verbosity level (debug, info, warn, error)",
186
186
Value: "info",
187
-
Sources: cli.EnvVars("tab_LOG_LEVEL", "LOG_LEVEL"),
187
+
Sources: cli.EnvVars("TAB_LOG_LEVEL", "LOG_LEVEL"),
188
188
},
189
189
&cli.StringFlag{
190
190
Name: "metrics-listen",
191
191
Usage: "address for metrics/pprof server (disabled if empty)",
192
-
Sources: cli.EnvVars("tab_METRICS_LISTEN"),
192
+
Sources: cli.EnvVars("TAB_METRICS_LISTEN"),
193
193
},
194
194
},
195
195
Action: runtab,