rtspadapter

package

v1.4.21 Latest Latest Go to latest Published: Aug 10, 2026 License: GPL-3.0 Imports: 4 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

Adapter RTSP 协议适配器处理 RTSP 拉流的状态管理

func NewAdapter(ipcCore ipc.Core, smsCore sms.Core) *Adapter

func (a *Adapter) DeleteDevice(ctx context.Context, device *ipc.Device) error

DeleteDevice implements ipc.Protocoler.

func (a *Adapter) InitDevice(ctx context.Context, device *ipc.Device) error

InitDevice implements ipc.Protocoler.

func (a *Adapter) OnStreamChanged(ctx context.Context, app, stream string) error

OnStreamChanged implements ipc.Protocoler. RTSP 拉流断开时更新通道状态（IsOnline=false, IsPlaying=false）

func (a *Adapter) OnStreamNotFound(ctx context.Context, app string, stream string) error

OnStreamNotFound implements ipc.Protocoler. 当流不存在时，从 Channel 获取配置并启动拉流代理

func (a *Adapter) PTZControl(ctx context.Context, device *ipc.Device, channel *ipc.Channel, cmd ipc.PTZCommand) error

PTZControl implements ipc.Protocoler. RTSP 协议不支持云台控制

func (a *Adapter) QueryCatalog(ctx context.Context, device *ipc.Device) error

QueryCatalog implements ipc.Protocoler.

func (a *Adapter) StartPlay(ctx context.Context, device *ipc.Device, channel *ipc.Channel) (*ipc.PlayResponse, error)

StartPlay implements ipc.Protocoler.

func (a *Adapter) StopPlay(ctx context.Context, device *ipc.Device, channel *ipc.Channel) error

StopPlay implements ipc.Protocoler.

func (a *Adapter) ValidateDevice(ctx context.Context, device *ipc.Device) error

ValidateDevice implements ipc.Protocoler.