pkg/statedb · streamplace · Tangled

streamplace pkg statedb

51 files

at fable51/moq-push

Eli Mallon · Push streams to --peers over MoQ; lease the stream's jobs · 2d ago

auto_publish_vod_test.go

live: place.stream.live.getClip, clip a livestream to a flat MP4

auto_publish_vod.go

auto-vod: withdraw deleted consent and serialize privacy saves

branding_test.go

branding: one query per broadcaster, not one per key

branding: a bundle import is one transaction

broadcast_origin.go

Transfer streams between nodes over Media over QUIC

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

Push streams to --peers over MoQ; lease the stream's jobs

Push streams to --peers over MoQ; lease the stream's jobs

livestream_vod_test.go

Publish livestreams as VODs automatically when opted in

livestream_vod.go

auto-vod: make the handoff idempotent and recoverable

statedb: bound postgres connect attempts by the retry budget

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

go: update direct dependencies

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

Simplify URLs for supported AT Protocol DID identifiers

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

auto-vod: make the handoff idempotent and recoverable

queue_processor_finalize_test.go

didn't i do this already?

queue_processor.go

Simplify URLs for supported AT Protocol DID identifiers

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

s3_segment_test.go

live: place.stream.live.getClip, clip a livestream to a flat MP4

clips: bound recordings by their earliest segment; best-effort moderation clips

service_auth.go

spxrpc: add service auth capability

statedb_test.go

statedb: bound postgres connect attempts by the retry budget

Push streams to --peers over MoQ; lease the stream's jobs

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