LPMS

git clone https://github.com/livepeer/lpms.git
cd lpms
bash install_ffmpeg.sh
export PKG_CONFIG_PATH=~/compiled/lib/pkgconfig:$PKG_CONFIG_PATH
go build ./...

go build cmd/main.go
./main

ffmpeg -f avfoundation -framerate 30 -i "0:0" \
  -c:v libx264 -tune zerolatency -b:v 900k \
  -x264-params keyint=60:min-keyint=60 \
  -c:a aac -ac 2 -ar 44100 \
  -f flv rtmp://localhost:1935/stream/test

ffplay http://localhost:7935/stream/test.m3u8

package main

import (
    "github.com/livepeer/lpms/lpms"
    "net/url"
)

func main() {
    opts := lpms.LPMSOpts{
        RtmpAddr: "127.0.0.1:1935",
        HttpAddr: "127.0.0.1:7935",
        WorkDir:  "/tmp/lpms",
    }

    server := lpms.New(&opts)

    server.HandleRTMPPublish(
        // getStreamID: extract stream ID from the ingest URL
        func(url *url.URL) (string, error) {
            return getStreamIDFromPath(url.Path), nil
        },
        // onPublish: called when RTMP stream begins
        func(url *url.URL, rtmpStrm interface{}) error {
            return nil
        },
        // onFinish: called when RTMP stream ends
        func(url *url.URL, rtmpStrm interface{}) error {
            return nil
        },
    )

    server.HandleRTMPPlay(
        func(ctx context.Context, reqPath string, dst interface{}) error {
            streamID := getStreamIDFromPath(reqPath)
            return server.GetRTMPStream(streamID, dst)
        },
    )

    server.Start(context.Background())
}

// Software transcoding
err := transcoder.Transcode(
    &TranscodeOptionsIn{Fname: "input.ts"},
    []TranscodeOptions{{Oname: "output_720p.ts", Profile: P720p30fps16x9}},
)

// NVIDIA GPU device 0
err := transcoder.Transcode(
    &TranscodeOptionsIn{Fname: "input.ts", Accel: Nvidia, Device: "0"},
    []TranscodeOptions{{Oname: "output_720p.ts", Profile: P720p30fps16x9}},
)