server

Documentation

Overview

Package server is the place we integrate the Livepeer node with the LPMS media server.

Index

• Constants
• Variables
• type LivepeerServer
  • func NewLivepeerServer(rtmpPort string, httpPort string, ffmpegPath string, lpNode *core.LivepeerNode) *LivepeerServer
  • func (s *LivepeerServer) StartMediaServer(ctx context.Context, maxPricePerSegment int, transcodingOptions string) error
  • func (s *LivepeerServer) StartWebserver()

Constants

const EthEventTimeout = 5 * time.Second

const EthMinedTxTimeout = 60 * time.Second

const EthRpcTimeout = 5 * time.Second

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

const HLSBufferWindow = uint(5)

const HLSUnsubWorkerFreq = time.Second * 5

const HLSWaitInterval = time.Second

Variables

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

var BroadcastPrice = uint64(1)

var ErrAlreadyExists = errors.New("StreamAlreadyExists")

var ErrBroadcast = errors.New("ErrBroadcast")

var ErrHLSPlay = errors.New("ErrHLSPlay")

var ErrNotFound = errors.New("ErrNotFound")

var ErrRTMPPlay = errors.New("ErrRTMPPlay")

var ErrRTMPPublish = errors.New("ErrRTMPPublish")

var HLSWaitTime = time.Second * 45

var LastHLSStreamID core.StreamID

var LastManifestID core.ManifestID

var SegOptions = segmenter.SegmenterOptions{SegLength: 8 * time.Second}

var TranscoderFeeCut = uint8(10)

var TranscoderRewardCut = uint8(10)

var TranscoderSegmentPrice = big.NewInt(150)

Types

type LivepeerServer

type LivepeerServer struct {
	RTMPSegmenter lpmscore.RTMPSegmenter
	LPMS          *lpmscore.LPMS
	HttpPort      string
	RtmpPort      string
	FfmpegPath    string
	LivepeerNode  *core.LivepeerNode
	// contains filtered or unexported fields
}

func NewLivepeerServer

func NewLivepeerServer(rtmpPort string, httpPort string, ffmpegPath string, lpNode *core.LivepeerNode) *LivepeerServer

func (*LivepeerServer) StartMediaServer

func (s *LivepeerServer) StartMediaServer(ctx context.Context, maxPricePerSegment int, transcodingOptions string) error

StartServer starts the LPMS server

func (*LivepeerServer) StartWebserver

func (s *LivepeerServer) StartWebserver()