server

Jan 30, 2025

Changes in this version

type LivepeerServer

+ func (ls *LivepeerServer) SmokeTestLiveVideo() http.Handler

Jan 22, 2025

Changes in this version

+ var StreamStatusStore = streamStatusStore

+ func LiveErrorEventSender(ctx context.Context, event map[string]string) func(err error)

type AIAuthRequest

+ GatewayHost string

type AIAuthResponse

+ PipelineID string

+ StreamID string

+ type LivePaymentProcessor struct

+ func NewLivePaymentProcessor(ctx context.Context, processInterval time.Duration, ...) *LivePaymentProcessor

type LivepeerServer

+ func (ls *LivepeerServer) GetLiveVideoToVideoStatus() http.Handler

+ type SlowOrchChecker struct

+ func (s *SlowOrchChecker) BeginSegment() (int, bool)

+ func (s *SlowOrchChecker) EndSegment()

+ func (s *SlowOrchChecker) GetCount() int

Dec 5, 2024

Changes in this version

+ var LiveAIAuthWebhookURL *url.URL

+ type AIAuthRequest struct

+ QueryParams string

+ Stream string

+ StreamKey string

+ Type string

+ type AIAuthResponse struct

+ Pipeline string

+ PipelineParams json.RawMessage

+ RTMPOutputURL string

type LivepeerServer

+ func (ls *LivepeerServer) UpdateLiveVideo() http.Handler

type Orchestrator

+ LiveVideoToVideo func(ctx context.Context, requestID string, ...) (interface{}, error)

Nov 7, 2024

Changes in this version

+ const AISessionManagerTTL

+ var MaxAIRequestSize = 3000000000

+ var TrickleHTTPPath = "/ai/trickle/"

+ func CalculateAudioToTextLatencyScore(took time.Duration, durationSeconds int64) float64

+ func CalculateImageToImageLatencyScore(took time.Duration, req worker.GenImageToImageMultipartRequestBody, ...) float64

+ func CalculateImageToTextLatencyScore(took time.Duration, outPixels int64) float64

+ func CalculateImageToVideoLatencyScore(took time.Duration, req worker.GenImageToVideoMultipartRequestBody, ...) float64

+ func CalculateLLMLatencyScore(took time.Duration, tokensUsed int) float64

+ func CalculateSegmentAnything2LatencyScore(took time.Duration, outPixels int64) float64

+ func CalculateTextToImageLatencyScore(took time.Duration, req worker.GenTextToImageJSONRequestBody, outPixels int64) float64

+ func CalculateTextToSpeechLatencyScore(took time.Duration, inCharacters int64) float64

+ func CalculateUpscaleLatencyScore(took time.Duration, req worker.GenUpscaleMultipartRequestBody, outPixels int64) float64

+ func RunAIWorker(n *core.LivepeerNode, orchAddr string, caps *net.Capabilities)

+ type AIJobRequestData struct

+ InputUrl string

+ Request json.RawMessage

+ type AISession struct

+ Cap core.Capability

+ ModelID string

+ Warm bool

+ type AISessionManager struct

+ func NewAISessionManager(node *core.LivepeerNode, ttl time.Duration) *AISessionManager

+ func (c *AISessionManager) Complete(ctx context.Context, sess *AISession) error

+ func (c *AISessionManager) Remove(ctx context.Context, sess *AISession) error

+ func (c *AISessionManager) Select(ctx context.Context, cap core.Capability, modelID string) (*AISession, error)

+ type AISessionPool struct

+ func NewAISessionPool(selector BroadcastSessionsSelector, suspender *suspender) *AISessionPool

+ func (pool *AISessionPool) Add(sessions []*BroadcastSession)

+ func (pool *AISessionPool) Complete(sess *BroadcastSession)

+ func (pool *AISessionPool) Remove(sess *BroadcastSession)

+ func (pool *AISessionPool) Select(ctx context.Context) *BroadcastSession

+ func (pool *AISessionPool) Size() int

+ type AISessionSelector struct

+ func NewAISessionSelector(cap core.Capability, modelID string, node *core.LivepeerNode, ...) (*AISessionSelector, error)

+ func (sel *AISessionSelector) Complete(sess *AISession)

+ func (sel *AISessionSelector) Refresh(ctx context.Context) error

+ func (sel *AISessionSelector) Remove(sess *AISession)

+ func (sel *AISessionSelector) Select(ctx context.Context) *AISession

+ type APIError struct

+ Message string

+ func (err *APIError) Error() string

+ type APIErrorResponse struct

+ Error error

+ type BadRequestError struct

+ func (e *BadRequestError) Error() string

type BroadcastConfig

+ func (cfg *BroadcastConfig) GetCapabilitiesMaxPrice(caps common.CapabilityComparator) *big.Rat

+ func (cfg *BroadcastConfig) SetCapabilityMaxPrice(cap core.Capability, modelID string, newPrice *core.AutoConvertedPrice)

+ type ImageToVideoResponseAsync struct

+ RequestID string

+ type ImageToVideoResult struct

+ Error *APIError

+ type ImageToVideoResultRequest struct

+ RequestID string

+ type ImageToVideoResultResponse struct

+ Result *ImageToVideoResult

+ Status ImageToVideoStatus

+ type ImageToVideoStatus string

+ const Complete

+ const Processing

+ type LivePaymentReceiver interface

+ AccountSegment func(ctx context.Context, segmentInfo *SegmentInfoReceiver) error

+ type LivePaymentSender interface

+ SendPayment func(ctx context.Context, segmentInfo *SegmentInfoSender) error

type LivepeerServer

+ AISessionManager *AISessionManager

+ func (ls *LivepeerServer) ImageToVideo() http.Handler

+ func (ls *LivepeerServer) ImageToVideoResult() http.Handler

+ func (ls *LivepeerServer) LLM() http.Handler

+ func (ls *LivepeerServer) StartLiveVideo() http.Handler

type Orchestrator

+ AIResults func(job int64, res *core.RemoteAIWorkerResult)

+ AudioToText func(ctx context.Context, requestID string, ...) (interface{}, error)

+ Balance func(addr ethcommon.Address, manifestID core.ManifestID) *big.Rat

+ CheckAICapacity func(pipeline, modelID string) bool

+ CreateStorageForRequest func(requestID string) error

+ GetStorageForRequest func(requestID string) (drivers.OSSession, bool)

+ ImageToImage func(ctx context.Context, requestID string, ...) (interface{}, error)

+ ImageToText func(ctx context.Context, requestID string, ...) (interface{}, error)

+ ImageToVideo func(ctx context.Context, requestID string, ...) (interface{}, error)

+ LLM func(ctx context.Context, requestID string, req worker.GenLLMFormdataRequestBody) (interface{}, error)

+ PriceInfoForCaps func(sender ethcommon.Address, manifestID core.ManifestID, caps *net.Capabilities) (*net.PriceInfo, error)

+ SegmentAnything2 func(ctx context.Context, requestID string, ...) (interface{}, error)

+ ServeAIWorker func(stream net.AIWorker_RegisterAIWorkerServer, capabilities *net.Capabilities)

+ TextToImage func(ctx context.Context, requestID string, ...) (interface{}, error)

+ TextToSpeech func(ctx context.Context, requestID string, ...) (interface{}, error)

+ Upscale func(ctx context.Context, requestID string, ...) (interface{}, error)

+ type SegmentInfoReceiver struct

+ type SegmentInfoSender struct

+ type ServiceUnavailableError struct

+ func (e *ServiceUnavailableError) Error() string

+ type StubCapabilityComparator struct

+ IsLegacy bool

+ NetCaps *net.Capabilities

+ func (s *StubCapabilityComparator) CompatibleWith(other *net.Capabilities) bool

+ func (s *StubCapabilityComparator) LegacyOnly() bool

+ func (s *StubCapabilityComparator) ToNetCapabilities() *net.Capabilities

Sep 10, 2024

Changes in this version

type BroadcastSession

+ CleanupSession sessionsCleanup

Aug 21, 2024

Changes in this version

type ProbabilitySelectionAlgorithm

+ IgnoreMaxPriceIfNeeded bool

Jan 29, 2024

Changes in this version

type BroadcastSession

+ InitialPrice *net.PriceInfo

Oct 4, 2023

Changes in this version

+ type ProbabilitySelectionAlgorithm struct

+ MinPerfScore float64

+ PriceExpFactor float64

+ PriceWeight float64

+ RandWeight float64

+ StakeWeight float64

+ func (sa ProbabilitySelectionAlgorithm) Select(addrs []ethcommon.Address, stakes map[ethcommon.Address]int64, ...) ethcommon.Address

Dec 21, 2022

Changes in this version

+ const HTTPIdleTimeout

+ const SELECTOR_LATENCY_SCORE_THRESHOLD

Oct 21, 2022

Changes in this version

+ func EndTranscodingSession(ctx context.Context, sess *BroadcastSession) error

type Router

+ func (r *Router) EndTranscodingSession(ctx context.Context, request *net.EndTranscodingSessionRequest) (*net.EndTranscodingSessionResponse, error)

May 11, 2022

Changes in this version

+ const LIVERPEER_TRANSCODE_CONFIG_HEADER

+ func PixelFormatNone() ffmpeg.PixelFormat

+ type BreakOperation bool

+ type ChainIdGetter interface

+ ChainID func() (*big.Int, error)

type LivepeerServer

+ func (s *LivepeerServer) SetContextFromUnitTest(c context.Context)

Jan 25, 2022

Changes in this version

+ const MainnetChainId

+ const RinkebyChainId

Dec 21, 2021

Changes in this version

+ var SelectRandFreq float64

type BroadcastSession

+ OrchestratorScore float32

+ VerifiedByPerceptualHash bool

+ func (bs *BroadcastSession) Address() string

+ func (bs *BroadcastSession) Clone() *BroadcastSession

+ func (bs *BroadcastSession) IsTrusted() bool

+ func (bs *BroadcastSession) Transcoder() string

type BroadcastSessionsManager

+ VerificationFreq uint

+ type BroadcastSessionsSelectorFactory func() BroadcastSessionsSelector

type MinLSSelector

+ func NewMinLSSelectorWithRandFreq(stakeRdr stakeReader, minLS float64, randFreq float64) *MinLSSelector

+ type SessionPool struct

+ func NewSessionPool(mid core.ManifestID, poolSize, numOrchs int, sus *suspender, ...) *SessionPool

+ type SubmitResult struct

+ Err error

+ Session *BroadcastSession

+ TranscodeResult *ReceivedTranscodeResult

Sep 13, 2021

Changes in this version

+ var MetadataPublishTimeout = 1 * time.Second

+ var MetadataQueue event.Producer

Aug 10, 2021

Changes in this version

+ var DetectionWebhookURL *url.URL

+ var DetectionWhClient = &http.Client

Apr 13, 2021

Changes in this version

+ var NonRetryableErrMap = nonRetryableErrMapInit()

Mar 15, 2021

Changes in this version

+ type Router struct

+ func NewRouter(uris []*url.URL) *Router

+ func (r *Router) GetOrchestrator(ctx context.Context, req *net.OrchestratorRequest) (*net.OrchestratorInfo, error)

+ func (r *Router) Ping(ctx context.Context, req *net.PingPong) (*net.PingPong, error)

+ func (r *Router) Start(uri *url.URL, serviceURI *url.URL, workDir string) error

+ func (r *Router) Stop()

Feb 3, 2021

Changes in this version

type BroadcastSession

+ SegsInFlight []SegFlightMetadata

+ type SegFlightMetadata struct

Dec 14, 2020

Changes in this version

type LivepeerServer

+ func (s *LivepeerServer) HandleRecordings(w http.ResponseWriter, r *http.Request)

Oct 22, 2020

Changes in this version

type BroadcastSession

+ Balances *core.AddressBalances

type Orchestrator

+ AuthToken func(sessionID string, expiration int64) *net.AuthToken

Aug 6, 2020

Changes in this version

type BroadcastSession

+ Params *core.StreamParameters

type Orchestrator

+ Capabilities func() *net.Capabilities

Jul 6, 2020

Changes in this version

+ type Redeemer struct

+ func NewRedeemer(recipient ethcommon.Address, eth eth.LivepeerEthClient, ...) (*Redeemer, error)

+ func (r *Redeemer) MaxFloat(ctx context.Context, req *net.MaxFloatReq) (*net.MaxFloatUpdate, error)

+ func (r *Redeemer) MonitorMaxFloat(req *net.MaxFloatReq, stream net.TicketRedeemer_MonitorMaxFloatServer) error

+ func (r *Redeemer) QueueTicket(ctx context.Context, ticket *net.Ticket) (*net.QueueTicketRes, error)

+ func (r *Redeemer) Start(url *url.URL, workDir string) error

+ func (r *Redeemer) Stop()

+ type RedeemerClient struct

+ func NewRedeemerClient(uri string, sm pm.SenderManager, tm pm.TimeManager) (*RedeemerClient, error)

+ func (r *RedeemerClient) MaxFloat(sender ethcommon.Address) (*big.Int, error)

+ func (r *RedeemerClient) QueueTicket(ticket *pm.SignedTicket) error

+ func (r *RedeemerClient) Start()

+ func (r *RedeemerClient) Stop()

+ func (r *RedeemerClient) ValidateSender(sender ethcommon.Address) error

Mar 12, 2020

Changes in this version

+ var MaxAttempts = 3

Jan 11, 2020

Changes in this version

+ var Policy *verification.Policy

type BroadcastSession

+ LatencyScore float64

+ type BroadcastSessionsSelector interface

+ Add func(sessions []*BroadcastSession)

+ Clear func()

+ Complete func(sess *BroadcastSession)

+ Select func() *BroadcastSession

+ Size func() int

+ type LIFOSelector []*BroadcastSession

+ func (s *LIFOSelector) Add(sessions []*BroadcastSession)

+ func (s *LIFOSelector) Clear()

+ func (s *LIFOSelector) Complete(sess *BroadcastSession)

+ func (s *LIFOSelector) Select() *BroadcastSession

+ func (s *LIFOSelector) Size() int

+ type MinLSSelector struct

+ func NewMinLSSelector(stakeRdr stakeReader, minLS float64) *MinLSSelector

+ func (s *MinLSSelector) Add(sessions []*BroadcastSession)

+ func (s *MinLSSelector) Clear()

+ func (s *MinLSSelector) Complete(sess *BroadcastSession)

+ func (s *MinLSSelector) Select() *BroadcastSession

+ func (s *MinLSSelector) Size() int

+ type ReceivedTranscodeResult struct

+ Info *net.OrchestratorInfo

+ LatencyScore float64

Oct 29, 2019

Changes in this version

+ const CreditSpent

+ const ReceivedChange

+ const RefreshIntervalHttpPush

+ const Staged

+ const StreamKeyBytes

+ var AuthWebhookURL string

+ var BroadcastCfg = &BroadcastConfig

+ var StreamPrefix = regexp.MustCompile(`^[ /]*(stream/)?|(live/)?`)

+ func CheckOrchestratorAvailability(orch Orchestrator) bool

+ func GetOrchestratorInfo(ctx context.Context, bcast Broadcaster, orchestratorServer *url.URL) (*net.OrchestratorInfo, error)

+ func RunTranscoder(n *core.LivepeerNode, orchAddr string, capacity int)

+ type Balance interface

+ Credit func(amount *big.Rat)

+ StageUpdate func(minCredit *big.Rat, ev *big.Rat) (int, *big.Rat, *big.Rat)

+ type BalanceUpdate struct

+ Debit *big.Rat

+ ExistingCredit *big.Rat

+ NewCredit *big.Rat

+ NumTickets int

+ Status BalanceUpdateStatus

+ type BalanceUpdateStatus int

+ type BlockGetter interface

+ LastSeenBlock func() (*big.Int, error)

+ type BroadcastConfig struct

+ func (cfg *BroadcastConfig) MaxPrice() *big.Rat

+ func (cfg *BroadcastConfig) SetMaxPrice(price *big.Rat)

+ type BroadcastSession struct

+ Balance Balance

+ Broadcaster Broadcaster

+ BroadcasterOS drivers.OSSession

+ ManifestID core.ManifestID

+ OrchestratorInfo *net.OrchestratorInfo

+ OrchestratorOS drivers.OSSession

+ PMSessionID string

+ Profiles []ffmpeg.VideoProfile

+ Sender pm.Sender

+ type BroadcastSessionsManager struct

+ func NewSessionManager(node *core.LivepeerNode, params *streamParameters, pl core.PlaylistManager) *BroadcastSessionsManager

type Broadcaster

+ Address func() ethcommon.Address

type LivepeerServer

+ ExposeCurrentManifest bool

+ HTTPMux *http.ServeMux

+ func (s *LivepeerServer) GetNodeStatus() *net.NodeStatus

+ func (s *LivepeerServer) HandlePush(w http.ResponseWriter, r *http.Request)

+ func (s *LivepeerServer) LastHLSStreamID() core.StreamID

+ func (s *LivepeerServer) LastManifestID() core.ManifestID

+ func (s *LivepeerServer) LatestPlaylist() core.PlaylistManager

+ func (s *LivepeerServer) StartCliWebserver(bindAddr string)

type Orchestrator

+ CheckCapacity func(core.ManifestID) error

+ DebitFees func(addr ethcommon.Address, manifestID core.ManifestID, price *net.PriceInfo, ...)

+ PriceInfo func(sender ethcommon.Address) (*net.PriceInfo, error)

+ ProcessPayment func(payment net.Payment, manifestID core.ManifestID) error

+ ServeTranscoder func(stream net.Transcoder_RegisterTranscoderServer, capacity int)

+ SufficientBalance func(addr ethcommon.Address, manifestID core.ManifestID) bool

+ TicketParams func(sender ethcommon.Address) (*net.TicketParams, error)

+ TranscoderResults func(job int64, res *core.RemoteTranscoderResult)

+ TranscoderSecret func() string

+ VerifySig func(ethcommon.Address, string, []byte) bool

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)

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