server

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
  • func NewLivepeerServer(rtmpAddr string, httpAddr string, lpNode *core.LivepeerNode) *LivepeerServer
  • func (s *LivepeerServer) StartMediaServer(ctx context.Context, maxPricePerSegment *big.Int, transcodingOptions string) error
  • func (s *LivepeerServer) StartWebserver(bindAddr string)
• type Orchestrator

Constants

const AuthType_LPE = "Livepeer-Eth-1"

const BroadcastRetry = 15 * time.Second

const GRPCConnectTimeout = 3 * time.Second

const GRPCTimeout = 8 * time.Second

const HLSBufferCap = uint(43200) //12 hrs assuming 1s segment

const HLSBufferWindow = uint(5)

const HLSUnsubWorkerFreq = time.Second * 5

const HLSWaitInterval = time.Second

const HTTPTimeout = 8 * time.Second

const SegLen = 4 * time.Second

Variables

var BroadcastJobVideoProfiles = []ffmpeg.VideoProfile{ffmpeg.P240p30fps4x3, ffmpeg.P360p30fps16x9}

var BroadcastPrice = big.NewInt(1)

var ErrAlreadyExists = errors.New("StreamAlreadyExists")

var ErrBroadcast = errors.New("ErrBroadcast")

var ErrHLSPlay = errors.New("ErrHLSPlay")

var ErrRTMPPlay = errors.New("ErrRTMPPlay")

var ErrRTMPPublish = errors.New("ErrRTMPPublish")

var ErrRoundInit = errors.New("ErrRoundInit")

var HLSWaitTime = time.Second * 45

var LastHLSStreamID core.StreamID

var LastManifestID core.ManifestID

var MinDepositSegmentCount = int64(75) // 5 mins assuming 4s segments

var MinJobBlocksRemaining = big.NewInt(40) // 10 mins assuming 15s blocks

Functions

func StartBroadcastClient

func StartBroadcastClient(bcast Broadcaster, orchestratorServer string) error

func StartTranscodeServer

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

func SubmitSegment(bcast Broadcaster, seg *stream.HLSSegment, nonce uint64) (*net.TranscodeData, error)

Types

type Broadcaster

type Broadcaster interface {
	Sign([]byte) ([]byte, error)
	Job() *lpTypes.Job
	SetHTTPClient(*http.Client)
	GetHTTPClient() *http.Client
	SetTranscoderInfo(*net.TranscoderInfo)
	GetTranscoderInfo() *net.TranscoderInfo
}

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

type Orchestrator interface {
	ServiceURI() *url.URL
	Address() ethcommon.Address
	Sign([]byte) ([]byte, error)
	CurrentBlock() *big.Int
	GetJob(int64) (*lpTypes.Job, error)
	TranscodeSeg(*lpTypes.Job, *core.SignedSegment) (*core.TranscodeResult, error)
	StreamIDs(*lpTypes.Job) ([]core.StreamID, error)
}