pkg/statedb · streamplace · Tangled

streamplace pkg statedb

45 files

at commit d1dfd2ca

Eli Mallon · statedb: waiting for a named lock honours cancellation · 1mo ago

branding_test.go

branding: one query per broadcaster, not one per key

branding: a bundle import is one transaction

broadcast_origin.go

syndication: origins come from the shared broadcast_origins table

cdn_log_part_test.go

cdn: provider seam for VOD CDNs, bunny.net signing + access-log ingest

cdn_log_part.go

cdn: provider seam for VOD CDNs, bunny.net signing + access-log ingest

acme: automatic TLS certificates via certmagic, stored in statedb

statedb: migrate server jwks

migrate-statedb: a later pass carries rows that changed

migrate-statedb: a later pass carries rows that changed

draft_video_test.go

fix CI test failures: restore pointer semantics lost in lex migration

fix CI test failures: restore pointer semantics lost in lex migration

finalize_task_test.go

live-to-VOD: an operator's finalize on the internal API

statedb: migrate server jwks

statedb: surface postgres startup failures instead of failing silently

statedb: non-blockin' lockin'

media_origin_test.go

vod: index media.origin locally, and add a reindex from the server repo

media_origin.go

vod: index media.origin locally, and add a reindex from the server repo

statedb: much better postgres distributed locking

moderation_audit_log.go

move audit log to statedb

multistream_event.go

multistreaming: implement multistream status

multistream_target.go

migrate to glex sealed Record types; fix every silent decode bug the compiler surfaced

notification_test.go

feat: add Web Push notifications alongside Firebase

notification.go

feat: add Web Push notifications alongside Firebase

oauth_session_test.go

auth: let users decline Bluesky permissions at login

oauth_session.go

auth: let users decline Bluesky permissions at login

playback_session_key.go

statedb: waiting for a named lock honours cancellation

statedb: bound the Postgres pool per node

queue_processor_draft_test.go

fix CI test failures: restore pointer semantics lost in lex migration

queue_processor_finalize_test.go

didn't i do this already?

queue_processor.go

live-to-VOD: the operator's finalize enqueues again

statedb: add `repo` for keeping track of accounts we care about

s3_segment_test.go

live-to-VOD: one VOD from a recording split across livestream records

live-to-VOD: one VOD from a recording split across livestream records

service_auth.go

spxrpc: add service auth capability

statedb_test.go

atproto: check the firehose for holes, and ask the hosts about the rest

statedb: serialize the index rebuild; refuse an undersized pool

Fix hand-written call sites for glex-generated types

stream_views_test.go

views: a replay inherits its livestream's views, totals per record

stream_views.go

views: count sessions with one atomic upsert

mobile-golive: handle case where you already have an active livestream

live-to-VOD: an upload forgets track records that were deleted

style: gofmt files flagged by CI

webhook_test.go

Fix hand-written call sites for glex-generated types

ListWebhooks active filter fix, and better o11y into webhooks

xrpc_stream_event.go

migrate to glex sealed Record types; fix every silent decode bug the compiler surfaced