poll

Documentation

Overview

Package poll implements a tick-based JPEG polling worker.

Instead of managing RTSP sessions directly, it polls go2rtc's HTTP API for pre-decoded JPEG frames. This eliminates H264 NAL assembly, GOP buffering, and the ffmpeg subprocess used by the previous approach.

Index

• type JPEGFetcher
• type Publisher
• type Worker
  • func NewWorker(cam config.CameraConfig, fetcher JPEGFetcher, gate *motion.Gate, pub Publisher, ...) *Worker
  • func (w *Worker) Run(ctx context.Context)

Types

type JPEGFetcher

type JPEGFetcher interface {
	FetchJPEG(ctx context.Context, name string) ([]byte, error)
}

JPEGFetcher retrieves raw JPEG bytes for a named stream. The go2rtc Client satisfies this interface.

type Publisher

type Publisher interface {
	Publish(ctx context.Context, meta *pb.FrameReady, jpegIn []byte) error
}

Publisher uploads frames and publishes stream metadata. media.Publisher satisfies this interface.

type Worker

type Worker struct {
	// contains filtered or unexported fields
}

Worker polls go2rtc at a fixed interval, gates on motion, and publishes motion-bearing frames to MinIO + Redis Streams.

func NewWorker

func NewWorker(
	cam config.CameraConfig,
	fetcher JPEGFetcher,
	gate *motion.Gate,
	pub Publisher,
	log *zap.Logger,
) *Worker

NewWorker creates a Worker for the given camera.

func (*Worker) Run

func (w *Worker) Run(ctx context.Context)

Run polls go2rtc until ctx is cancelled.