manager

Feb 19, 2024

Changes in this version

+ const AuthTokenPrefix

Jun 29, 2022

Changes in this version

+ type HttpServerConfig struct

+ Bind string

+ ManagerToken string

type VideoManager

+ func (m *VideoManager) StartHttpServer(config HttpServerConfig) (chan struct{}, error)

May 8, 2022

Changes in this version

+ const AdminChannelField

+ const AuthHeader

+ const TokenCtxField

+ func CreateRoutes(r *router.Router, manager *VideoManager, log logging.KVLogger, cb AuthCallback)

+ type AuthCallback func(*fasthttp.RequestCtx) bool

Mar 24, 2022

Changes in this version

+ func AttachVideoHandler(r *router.Router, prefix string, manager *VideoManager, log logging.KVLogger)

+ func CORSMiddleware(h fasthttp.RequestHandler) fasthttp.RequestHandler

+ func MetricsMiddleware(h fasthttp.RequestHandler) fasthttp.RequestHandler

+ type VideoLibrary interface

+ GetAllChannels func() ([]db.Channel, error)

+ GetURL func(sdHash string) (string, error)

type VideoManager

+ func (m *VideoManager) ResolveStream(uri string) (*TranscodingRequest, error)

Jul 30, 2021

Changes in this version

+ var ErrTranscodingDisabled = errors.New("transcoding is disabled for this stream")

Jul 22, 2021

Changes in this version

+ func LoadConfiguredChannels(priority, enabled []string)

+ func SetBlobServer(s string)

Jun 22, 2021

Changes in this version

+ var ErrChannelNotEnabled = errors.New("transcoding is not enabled for this channel")

+ var ErrNoSigningChannel = errors.New("no signing channel for stream")

+ var ErrStreamNotFound = errors.New("could not resolve stream URI")

+ var ErrTranscodingForbidden = errors.New("transcoding this stream is not possible at this time")

+ var ErrTranscodingQueued = errors.New("transcoding queued")

+ var ErrTranscodingUnderway = errors.New("transcoding is in progress")

+ var QueueHits = prometheus.NewGaugeVec(prometheus.GaugeOpts{ ... }, []string{ ... })

+ var QueueItemAge = prometheus.NewSummaryVec(prometheus.SummaryOpts{ ... }, []string{ ... })

+ var QueueLength = prometheus.NewGaugeVec(prometheus.GaugeOpts{ ... }, []string{ ... })

+ func LoadEnabledChannels(channels []string)

+ func RegisterMetrics()

+ func Resolve(uri string) (*ljsonrpc.Claim, error)

+ func SetCDNServer(s string)

+ func SetLogger(l *zap.SugaredLogger)

+ type Gatekeeper func(key string, value interface{}, queue *mfr.Queue) bool

+ type HttpAPI struct

+ func NewHttpAPI(cfg *HttpAPIConfiguration) *HttpAPI

+ func (s HttpAPI) Addr() string

+ func (s HttpAPI) Shutdown() error

+ func (s HttpAPI) Start() error

+ func (s HttpAPI) URL() string

+ type HttpAPIConfiguration struct

+ func ConfigureHttpAPI() *HttpAPIConfiguration

+ func (c *HttpAPIConfiguration) Addr(addr string) *HttpAPIConfiguration

+ func (c *HttpAPIConfiguration) Debug(debug bool) *HttpAPIConfiguration

+ func (c *HttpAPIConfiguration) VideoManager(mgr *VideoManager) *HttpAPIConfiguration

+ func (c *HttpAPIConfiguration) VideoPath(videoPath string) *HttpAPIConfiguration

+ type Pool struct

+ func NewPool() *Pool

+ func (p *Pool) AddQueue(name string, minHits uint, k Gatekeeper)

+ func (p *Pool) Admit(key string, value interface{}) error

+ func (p *Pool) Next() *mfr.Item

+ func (p *Pool) Out() <-chan *mfr.Item

+ func (p *Pool) Start()

+ func (p *Pool) Stop()

+ type TranscodingRequest struct

+ ChannelSupportAmount int64

+ ChannelURI string

+ ClaimID string

+ Name string

+ NormalizedName string

+ SDHash string

+ URI string

+ func ResolveRequest(uri string) (*TranscodingRequest, error)

+ func (c *TranscodingRequest) Download(dest string) (*os.File, int64, error)

+ func (r *TranscodingRequest) Complete()

+ func (r *TranscodingRequest) Reject()

+ func (r *TranscodingRequest) Release()

+ type VideoManager struct

+ func NewManager(l video.VideoLibrary, minHits int) *VideoManager

+ func (m *VideoManager) Library() video.VideoLibrary

+ func (m *VideoManager) Pool() *Pool

+ func (m *VideoManager) RequestStatus(uri string) int

+ func (m *VideoManager) Requests() <-chan *TranscodingRequest

+ func (m *VideoManager) Video(uri string) (*video.Video, error)

+ type WriteCounter struct

+ Loaded uint64

+ Size uint64

+ Started time.Time

+ URL string

+ func (wc *WriteCounter) Write(p []byte) (int, error)