Versions in this module Expand all Collapse all v0 v0.3.3 Nov 4, 2026 Changes in this version + const MaxPluginListItems + func AttachDebrid(mgr *plugins.Manager, svc *debrid.Service) + func AttachMetadata(mgr *plugins.Manager, registry metadataRegistry) + func AttachSubtitles(mgr *plugins.Manager, svc *subtitles.Service) + func ExpandAddonIndexers(ctx context.Context, mgr *plugins.Manager, rows []config.Indexer) []config.Indexer + func IsLocalPayload(b []byte) bool + type Bridge struct + func Attach(mgr *plugins.Manager, cols *collections.Service, pers *personalize.Engine, ...) *Bridge + func (b *Bridge) Sync(_ context.Context, r plugins.Record) + type Engine struct + func (e *Engine) Check(ctx context.Context, payload []byte) (bool, error) + func (e *Engine) CheckRelease(ctx context.Context, releaseID string, payload []byte) (bool, error) + func (e *Engine) Open(ctx context.Context, releaseID string, payload []byte) (core.MediaSource, error) + func (e *Engine) Prefetch(ctx context.Context, releaseID string, payload []byte, offset, length int64) error + type LocalPayload struct + FilePath string + Name string + Origin string + PluginID string + ReleaseID string + Remote bool + Size int64 + func DecodeLocalPayload(b []byte) (LocalPayload, error) + func (p LocalPayload) Encode() []byte + type MarkerBridge struct + func AttachMarkers(ctx context.Context, mgr *plugins.Manager, svc *markers.Service, ...) *MarkerBridge + func (b *MarkerBridge) Schedule(key core.RatingKey, d time.Duration) <-chan struct{} + func (b *MarkerBridge) Wait() + type Ranking struct + Manager RankingManager + Registry *extend.Registry + func (a Ranking) NewResolve(ctx context.Context, caps core.ClientCaps) resolver.RankingSession + type RankingManager interface + HotReady func(string) (plugins.HotRuntime, bool) + RecordRanking func(context.Context, string, plugins.RankingReport) + type SourceStats struct + Class string + Failures int64 + Grabs int64 + Name string + PluginID string + Searches int64 + type StreamSources struct + func NewStreamSources(inner core.Indexer) *StreamSources + func (s *StreamSources) Backend(ix config.Indexer) (newznab.Backend, error) + func (s *StreamSources) Bind(mgr *plugins.Manager, deb *debrid.Service) + func (s *StreamSources) FetchNZB(ctx context.Context, r core.Release) ([]byte, error) + func (s *StreamSources) HasEnabledPlugins(ctx context.Context) bool + func (s *StreamSources) HasTorrentIndexer() bool + func (s *StreamSources) MissingSources() error + func (s *StreamSources) Name() string + func (s *StreamSources) Order() []string + func (s *StreamSources) ResolveTorrent(ctx context.Context, r core.Release) (core.Release, error) + func (s *StreamSources) Search(ctx context.Context, req core.SearchRequest) ([]core.Release, error) + func (s *StreamSources) SearchRescue(ctx context.Context, req core.SearchRequest) ([]core.Release, error) + func (s *StreamSources) SearchRescueWith(ctx context.Context, req core.SearchRequest, arrived func([]core.Release)) ([]core.Release, error) + func (s *StreamSources) SearchWith(ctx context.Context, req core.SearchRequest, arrived func([]core.Release)) ([]core.Release, error) + func (s *StreamSources) SetAnimeIDs(a stremio.AnimeIDs) + func (s *StreamSources) SetClock(now func() time.Time) + func (s *StreamSources) SetNZBClient(c *http.Client) + func (s *StreamSources) SetOrder(ids []string) + func (s *StreamSources) SetUsenetReady(fn func() bool) + func (s *StreamSources) Stats(ctx context.Context) []SourceStats + func (s *StreamSources) WrapEngine(inner core.Engine) *Engine + type SubtitleProbe struct + func NewSubtitleProbe(mgr *plugins.Manager, catalog probeCatalog) *SubtitleProbe + func (p *SubtitleProbe) Close() + func (p *SubtitleProbe) Handler() http.Handler
Go to main page