Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

server

package

Go to main page

Versions in this module

v0

v0.3.3

Mar 26, 2019

Changes in this version

+ const AuthType_LPE

+ const BroadcastRetry

+ const GRPCConnectTimeout

+ const GRPCTimeout

+ const HTTPTimeout

+ const SegLen

+ var ErrRoundInit = errors.New("ErrRoundInit")

+ var MinDepositSegmentCount = int64(75)

+ var MinJobBlocksRemaining = big.NewInt(40)

+ 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 interface

+ GetHTTPClient func() *http.Client

+ GetTranscoderInfo func() *net.TranscoderInfo

+ Job func() *lpTypes.Job

+ SetHTTPClient func(*http.Client)

+ SetTranscoderInfo func(*net.TranscoderInfo)

+ Sign func([]byte) ([]byte, error)

type LivepeerServer

+ HttpMux *http.ServeMux

+ VideoNonce map[string]uint64

+ VideoNonceLock *sync.Mutex

+ type Orchestrator interface

+ Address func() ethcommon.Address

+ CurrentBlock func() *big.Int

+ GetJob func(int64) (*lpTypes.Job, error)

+ ServiceURI func() *url.URL

+ Sign func([]byte) ([]byte, error)

+ StreamIDs func(*lpTypes.Job) ([]core.StreamID, error)

+ TranscodeSeg func(*lpTypes.Job, *core.SignedSegment) (*core.TranscodeResult, error)

v0.1.7

Dec 18, 2017

Changes in this version

+ const EthEventTimeout

+ const EthMinedTxTimeout

+ const EthRpcTimeout

+ const HLSBufferCap

+ const HLSBufferWindow

+ const HLSUnsubWorkerFreq

+ const HLSWaitInterval

+ var BroadcastJobVideoProfiles = []lpmscore.VideoProfile

+ 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

+ var TranscoderFeeCut = uint8(10)

+ var TranscoderRewardCut = uint8(10)

+ var TranscoderSegmentPrice = big.NewInt(150)

+ type LivepeerServer struct

+ FfmpegPath string

+ HttpPort string

+ LPMS *lpmscore.LPMS

+ LivepeerNode *core.LivepeerNode

+ RTMPSegmenter lpmscore.RTMPSegmenter

+ RtmpPort string

+ 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()