monibuca/doc/pull.md

sequence

sequenceDiagram
    participant P as Plugin
    participant M as PluginMeta
    participant PJ as PullJob
    participant S as Server
    participant IPuller as IPuller

    P->>P: Pull(streamPath, conf)
    P->>M: Meta.Puller(conf)
    M-->>P: puller (IPuller)
    P->>PJ: GetPullJob()
    PJ-->>P: pullJob
    P->>PJ: Init(puller, p, streamPath, conf)
    PJ->>S: Server.Pulls.Add(p, logger)
    S->>PJ: Start()
    PJ->>IPuller: SetRetry(conf.MaxRetry, conf.RetryInterval)
    PJ->>PJ: Description = {...}
    Note over PJ: Set description with plugin info, streamPath, URL, etc.
    PJ->>IPuller: Start()

simple config

flv plugin

local file

flv:
  pull: 
    live/test: /Users/dexter/Movies/jb-demo.flv

remote file

flv:
  pull: 
    live/test: http://192.168.1.100/live/stream.flv

mp4 plugin

local file

mp4:
  pull:
    live/test: /Users/dexter/Movies/jb-demo.mp4

remote file

mp4:
  pull:
    live/test: http://192.168.1.100/live/stream.mp4

srt plugin

local file

srt:
  pull: 
    live/test: srt://127.0.0.1:6000?streamid=subscribe:/live/stream&passphrase=foobarfoobar

rtmp plugin

rtmp:
  pull: 
    live/test: rtmp://127.0.0.1/live/stream

rtsp plugin

rtsp:
  pull: 
    live/test: rtsp://127.0.0.1/live/stream

hls plugin

hls:
  pull:
    live/test: http://127.0.0.1/live/stream.m3u8

gb28181 plugin

deivceID/channelID

gb28181:
  pull: 
    live/test: 34020000002000000001/34020000002000000001

full config

pull on subscribe

xxx:
  onsub:
    pull:
      .*: $0

config retry

xxx:
  pull:
    live/test: xxxx
    maxRetry: 3
    retryInterval: 5s

config proxy

xxx:
  pull:
    live/test: xxxx
    proxy: http://127.0.0.1:8080

config header

xxx:
  pull:
    live/test: xxxx
    header:
      User-Agent: xxx

config args

xxx:
  pull:
    live/test: xxxx
    args:
      user: xxx
      password: xxx