Versions in this module Expand all Collapse all v1 v1.1.0 Feb 25, 2026 Changes in this version type Hub + func (r *Hub) IsReceivingFrames() bool + func (r *Hub) Reset() + type Logger interface + Print func(v ...interface{}) + Printf func(format string, v ...interface{}) v1.0.0 Feb 24, 2026 Changes in this version + func AnnexbToAvcc(au [][]byte) []byte + func BuildFragment(seqNr uint32, dts uint64, dur uint32, isIDR bool, avcc []byte) ([]byte, error) + func BuildInitH264(sps, pps []byte) ([]byte, error) + func BuildInitH265(vps, sps, pps []byte) ([]byte, error) + type Config struct + Logger *log.Logger + ReadBufferSize int + Rtsp string + WriteBufferSize int + WriteTimeout time.Duration + type Hub struct + func NewHub() *Hub + func (r *Hub) Broadcast(data []byte) + func (r *Hub) GetInit() []byte + func (r *Hub) GetStats(name string) StreamStats + func (r *Hub) GetStatus() Status + func (r *Hub) SetFramerate(framerate float64) + func (r *Hub) SetInfo(codec string, width, height int, frameRate float64) + func (r *Hub) SetInit(data []byte) + func (r *Hub) Subscribe() chan []byte + func (r *Hub) Unsubscribe(ch chan []byte) + type Instance struct + func Init(cfg *Config) *Instance + func (r *Instance) Connect() error + func (r *Instance) GetHub() *Hub + func (r *Instance) HandleWebsocket(conn *websocket.Conn) + func (r *Instance) Handler() fiber.Handler + func (r *Instance) InstanceReady() bool + func (r *Instance) Start(addr string) error + func (r *Instance) Stop() error + type Status struct + Streams []*StreamStats + type StreamStats struct + Bitrate float64 + BytesRecv uint64 + ClientCount int32 + Codec string + FrameNo uint64 + Framerate float64 + Height int + Name string + Ready bool + Uptime time.Duration + Width int
Go to main page