Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

camera

package

Go to main page

Versions in this module

v1

v1.0.4

Jul 16, 2025

v1.0.3

Jun 14, 2025

Changes in this version

type CameraBrands

+ const CameraBrandTPLink

v1.0.2

Jun 10, 2025

v1.0.1

May 14, 2025

Changes in this version

+ const StreamSinkChanDefaultBufferSize

+ var AllCameraBrands []CameraBrands

+ func EstimateFPS(frameIntervals []time.Duration) float64

+ func RunStandardStream(stream *Stream, sink StandardStreamSink, ch StreamSinkChan)

+ type Camera struct

+ Config atomic.Pointer[configdb.Camera]

+ HighDumper *VideoRingBuffer

+ HighStream *Stream

+ Log logs.Log

+ LowDecoder *VideoDecodeReader

+ LowDumper *VideoRingBuffer

+ LowStream *Stream

+ func NewCamera(log logs.Log, cfg configdb.Camera, ringBufferSizeBytes int) (*Camera, error)

+ func (c *Camera) Close(wg *sync.WaitGroup)

+ func (c *Camera) ExtractHighRes(method ExtractMethod, duration time.Duration) (*videox.PacketBuffer, error)

+ func (c *Camera) GetStream(res defs.Resolution) *Stream

+ func (c *Camera) HighResRecordingStreamName() string

+ func (c *Camera) ID() int64

+ func (c *Camera) LastPacketAt() time.Time

+ func (c *Camera) LatestImage(contentType string) []byte

+ func (c *Camera) LongLivedName() string

+ func (c *Camera) LowResRecordingStreamName() string

+ func (c *Camera) Name() string

+ func (c *Camera) RecordingStreamName(resolution defs.Resolution) string

+ func (c *Camera) Start() error

+ type CameraBrands string

+ const CameraBrandGenericONVIF

+ const CameraBrandGenericRTSP

+ const CameraBrandHikVision

+ const CameraBrandReolink

+ const CameraBrandUnknown

+ func IdentifyCameraFromHTTP(headers http.Header, body string) CameraBrands

+ type CameraRTSPInfo struct

+ HighResURL string

+ LowResURL string

+ PacketsAreAnnexBEncoded bool

+ func GetCameraRTSP(brand CameraBrands, host, username, password string, port int, ...) (*CameraRTSPInfo, error)

+ type ExtractMethod int

+ const ExtractMethodDeepClone

+ const ExtractMethodDrain

+ const ExtractMethodShallowClone

+ type FullChannelPolicy int

+ const FullChannelPolicyDrop

+ const FullChannelPolicyStall

+ type OnvifDeviceInfo struct

+ Brand CameraBrands

+ Firmware string

+ MainStreamURL string

+ Model string

+ Serial string

+ SubStreamURL string

+ func OnvifGetDeviceInfo(host, username, password string) (*OnvifDeviceInfo, error)

+ type RingBufferListener struct

+ Chan chan *videox.VideoPacket

+ Name string

+ Policy FullChannelPolicy

+ type StandardStreamSink interface

+ Close func()

+ OnConnect func(stream *Stream) (StreamSinkChan, error)

+ OnPacketRTP func(packet *videox.VideoPacket)

+ type Stream struct

+ CameraName string

+ Client *gortsplib.Client

+ Codec videox.Codec

+ Ident string

+ Log logs.Log

+ StreamName string

+ func NewStream(logger logs.Log, cameraName, streamName string, cameraSendsAnnexBEncoded bool) *Stream

+ func (s *Stream) Close(wg *sync.WaitGroup)

+ func (s *Stream) ConnectSink(name string, sink StreamSinkChan)

+ func (s *Stream) ConnectSinkAndRun(name string, sink StandardStreamSink) error

+ func (s *Stream) Info() *StreamInfo

+ func (s *Stream) LastPacketReceivedAt() time.Time

+ func (s *Stream) Listen(address string) error

+ func (s *Stream) RecentFrameStats() StreamStats

+ func (s *Stream) RecentFrameTimes() []float64

+ func (s *Stream) RemoveSink(sink StreamSinkChan)

+ type StreamInfo struct

+ Height int

+ Width int

+ type StreamMsg struct

+ Packet *videox.VideoPacket

+ Stream *Stream

+ Type StreamMsgType

+ type StreamMsgType int

+ const StreamMsgTypeClose

+ const StreamMsgTypePacket

+ type StreamSinkChan chan StreamMsg

+ type StreamStats struct

+ FPS float64

+ FrameIntervalAvg float64

+ FrameIntervalVar float64

+ FrameSize float64

+ InterframeSize float64

+ KeyframeInterval int

+ KeyframeSize float64

+ func (s *StreamStats) FPSRounded() int

+ func (s *StreamStats) KeyframeIntervalDuration() time.Duration

+ type VideoDecodeReader struct

+ Decoder *videox.VideoDecoder

+ Log logs.Log

+ func NewVideoDecodeReader() *VideoDecodeReader

+ func (r *VideoDecodeReader) Close()

+ func (r *VideoDecodeReader) GetLastImageIfDifferent(ifNotEqualTo int64) (*accel.YUVImage, int64, time.Time)

+ func (r *VideoDecodeReader) LastImageCopy() (*accel.YUVImage, int64)

+ func (r *VideoDecodeReader) LastPacketAt() time.Time

+ func (r *VideoDecodeReader) OnConnect(stream *Stream) (StreamSinkChan, error)

+ func (r *VideoDecodeReader) OnPacketRTP(packet *videox.VideoPacket)

+ type VideoRecorder struct

+ Log logs.Log

+ func StartVideoRecorder(ringBuffer *VideoRingBuffer, streamName string, archive *fsv.Archive, ...) *VideoRecorder

+ func (r *VideoRecorder) Stop()

+ type VideoRingBuffer struct

+ Buffer ringbuffer.WeightedRingT[videox.VideoPacket]

+ BufferLock sync.Mutex

+ Log logs.Log

+ func NewVideoRingBuffer(maxRingBufferBytes int) *VideoRingBuffer

+ func (r *VideoRingBuffer) AddPacketListener(name string, c chan *videox.VideoPacket, policy FullChannelPolicy)

+ func (r *VideoRingBuffer) Close()

+ func (r *VideoRingBuffer) ExtractRawBuffer(method ExtractMethod, duration time.Duration) (*videox.PacketBuffer, error)

+ func (r *VideoRingBuffer) ExtractRawBufferNoLock(method ExtractMethod, duration time.Duration) (*videox.PacketBuffer, error)

+ func (r *VideoRingBuffer) FindLatestIDRPacketNoLock() int

+ func (r *VideoRingBuffer) OnConnect(stream *Stream) (StreamSinkChan, error)

+ func (r *VideoRingBuffer) OnPacketRTP(packet *videox.VideoPacket)

+ func (r *VideoRingBuffer) RemovePacketListener(c chan *videox.VideoPacket)