Documentation ¶
Overview ¶
Package server is the place we integrate the Livepeer node with the LPMS media server.
Index ¶
- Constants
- Variables
- func StartBroadcastClient(bcast Broadcaster, orchestratorServer string) error
- func StartTranscodeServer(orch Orchestrator, bind string, mux *http.ServeMux, workDir string)
- func SubmitSegment(bcast Broadcaster, seg *stream.HLSSegment, nonce uint64) (*net.TranscodeData, error)
- type Broadcaster
- type LivepeerServer
- type Orchestrator
Constants ¶
View Source
const AuthType_LPE = "Livepeer-Eth-1"
View Source
const HLSBufferCap = uint(43200) //12 hrs assuming 1s segment
View Source
const HLSBufferWindow = uint(5)
Variables ¶
View Source
var BroadcastJobVideoProfiles = []ffmpeg.VideoProfile{ffmpeg.P240p30fps4x3, ffmpeg.P360p30fps16x9}
View Source
var LastManifestID core.ManifestID
View Source
var MinDepositSegmentCount = int64(75) // 5 mins assuming 4s segments
Functions ¶
func StartBroadcastClient ¶ added in v0.3.3
func StartBroadcastClient(bcast Broadcaster, orchestratorServer string) error
func StartTranscodeServer ¶ added in v0.3.3
func StartTranscodeServer(orch Orchestrator, bind string, mux *http.ServeMux, workDir string)
XXX do something about the implicit start of the http mux? this smells
func SubmitSegment ¶ added in v0.3.3
func SubmitSegment(bcast Broadcaster, seg *stream.HLSSegment, nonce uint64) (*net.TranscodeData, error)
Types ¶
type Broadcaster ¶ added in v0.3.3
type LivepeerServer ¶
type LivepeerServer struct { RTMPSegmenter lpmscore.RTMPSegmenter LPMS *lpmscore.LPMS LivepeerNode *core.LivepeerNode VideoNonce map[string]uint64 VideoNonceLock *sync.Mutex HttpMux *http.ServeMux // contains filtered or unexported fields }
func NewLivepeerServer ¶
func NewLivepeerServer(rtmpAddr string, httpAddr string, lpNode *core.LivepeerNode) *LivepeerServer
func (*LivepeerServer) StartMediaServer ¶
func (s *LivepeerServer) StartMediaServer(ctx context.Context, maxPricePerSegment *big.Int, transcodingOptions string) error
StartServer starts the LPMS server
func (*LivepeerServer) StartWebserver ¶
func (s *LivepeerServer) StartWebserver(bindAddr string)
type Orchestrator ¶ added in v0.3.3
Click to show internal directories.
Click to hide internal directories.