Documentation
¶
Index ¶
- Variables
- func InitWorkers() func()
- type DMMHashlistItem
- type Error
- type IdQueue
- type Job
- type JobTracker
- type Worker
- func InitCrawlStoreWorker(conf *WorkerConfig) *Worker
- func InitLinkedUserdataAddonReloaderWorker(conf *WorkerConfig) *Worker
- func InitMagnetCachePullerWorker(conf *WorkerConfig) *Worker
- func InitMapAniDBTorrentWorker(conf *WorkerConfig) *Worker
- func InitMapAnimeIdWorker(conf *WorkerConfig) *Worker
- func InitMapIMDBTorrentWorker(conf *WorkerConfig) *Worker
- func InitParseTorrentWorker(conf *WorkerConfig) *Worker
- func InitPushTorrentsWorker(conf *WorkerConfig) *Worker
- func InitSyncAniDBTVDBEpisodeMapWorker(conf *WorkerConfig) *Worker
- func InitSyncAniDBTitlesWorker(conf *WorkerConfig) *Worker
- func InitSyncAnimeAPIWorker(conf *WorkerConfig) *Worker
- func InitSyncAnimeToshoWorker(conf *WorkerConfig) *Worker
- func InitSyncBitmagnetWorker(conf *WorkerConfig) *Worker
- func InitSyncDMMHashlistWorker(conf *WorkerConfig) *Worker
- func InitSyncIMDBWorker(conf *WorkerConfig) *Worker
- func InitSyncLetterboxdList(conf *WorkerConfig) *Worker
- func InitSyncManamiAnimeDatabaseWorker(conf *WorkerConfig) *Worker
- func InitSyncStremioStremioWorker(conf *WorkerConfig) *Worker
- func InitSyncStremioTraktWorker(conf *WorkerConfig) *Worker
- func NewWorker(conf *WorkerConfig) *Worker
- type WorkerConfig
- type WorkerDetail
Constants ¶
This section is empty.
Variables ¶
View Source
var Peer = peer.NewAPIClient(&peer.APIClientConfig{ BaseURL: config.PeerURL, APIKey: config.PeerAuthToken, })
View Source
var TorrentPusherQueue = IdQueue{ // contains filtered or unexported fields }
View Source
var WorkerDetailsById = map[string]*WorkerDetail{
"parse-torrent": {
Title: "Parse Torrent",
},
"push-torrent": {
Title: "Push Torrent",
},
"crawl-store": {
Title: "Crawl Store",
},
"sync-imdb": {
Title: "Sync IMDB",
},
"sync-dmm-hashlist": {
Title: "Sync DMM Hashlist",
},
"map-imdb-torrent": {
Title: "Map IMDB Torrent",
},
"pull-magnet-cache": {
Title: "Pull Magnet Cache",
},
"map-anime-id": {
Title: "Map Anime ID",
},
"sync-animeapi": {
Title: "Sync AnimeAPI",
},
"sync-anidb-titles": {
Title: "Sync AniDB Titles",
},
"sync-anidb-tvdb-episode-map": {
Title: "Sync AniDB-TVDB Episode Map",
},
"manami-anime-database": {
Title: "Sync Manami Anime Database",
},
"map-anidb-torrent": {
Title: "Map AniDB Torrent",
},
"sync-letterboxd-list": {
Title: "Sync Letterboxd List",
},
"sync-bitmagnet": {
Title: "Sync Bitmagnet",
},
"sync-animetosho": {
Title: "Sync AnimeTosho",
},
"reload-linked-userdata-addon": {
Title: "Reload Linked Userdata Addon",
},
"sync-stremio-trakt": {
Title: "Sync Stremio-Trakt",
},
"sync-stremio-stremio": {
Title: "Sync Stremio-Stremio",
},
}
Functions ¶
func InitWorkers ¶
func InitWorkers() func()
Types ¶
type DMMHashlistItem ¶
type JobTracker ¶
type JobTracker[T any] struct { // contains filtered or unexported fields }
func NewJobTracker ¶
func NewJobTracker[T any](name string, expiresIn time.Duration) *JobTracker[T]
func (JobTracker[T]) GetLast ¶
func (t JobTracker[T]) GetLast() (*job_log.ParsedJobLog[T], error)
type Worker ¶
func InitCrawlStoreWorker ¶
func InitCrawlStoreWorker(conf *WorkerConfig) *Worker
func InitLinkedUserdataAddonReloaderWorker ¶
func InitLinkedUserdataAddonReloaderWorker(conf *WorkerConfig) *Worker
func InitMagnetCachePullerWorker ¶
func InitMagnetCachePullerWorker(conf *WorkerConfig) *Worker
func InitMapAniDBTorrentWorker ¶
func InitMapAniDBTorrentWorker(conf *WorkerConfig) *Worker
func InitMapAnimeIdWorker ¶
func InitMapAnimeIdWorker(conf *WorkerConfig) *Worker
func InitMapIMDBTorrentWorker ¶
func InitMapIMDBTorrentWorker(conf *WorkerConfig) *Worker
func InitParseTorrentWorker ¶
func InitParseTorrentWorker(conf *WorkerConfig) *Worker
func InitPushTorrentsWorker ¶
func InitPushTorrentsWorker(conf *WorkerConfig) *Worker
func InitSyncAniDBTVDBEpisodeMapWorker ¶
func InitSyncAniDBTVDBEpisodeMapWorker(conf *WorkerConfig) *Worker
func InitSyncAniDBTitlesWorker ¶
func InitSyncAniDBTitlesWorker(conf *WorkerConfig) *Worker
func InitSyncAnimeAPIWorker ¶
func InitSyncAnimeAPIWorker(conf *WorkerConfig) *Worker
func InitSyncAnimeToshoWorker ¶
func InitSyncAnimeToshoWorker(conf *WorkerConfig) *Worker
func InitSyncBitmagnetWorker ¶
func InitSyncBitmagnetWorker(conf *WorkerConfig) *Worker
func InitSyncDMMHashlistWorker ¶
func InitSyncDMMHashlistWorker(conf *WorkerConfig) *Worker
func InitSyncIMDBWorker ¶
func InitSyncIMDBWorker(conf *WorkerConfig) *Worker
func InitSyncLetterboxdList ¶
func InitSyncLetterboxdList(conf *WorkerConfig) *Worker
func InitSyncManamiAnimeDatabaseWorker ¶
func InitSyncManamiAnimeDatabaseWorker(conf *WorkerConfig) *Worker
func InitSyncStremioStremioWorker ¶
func InitSyncStremioStremioWorker(conf *WorkerConfig) *Worker
func InitSyncStremioTraktWorker ¶
func InitSyncStremioTraktWorker(conf *WorkerConfig) *Worker
func NewWorker ¶
func NewWorker(conf *WorkerConfig) *Worker
type WorkerConfig ¶
Source Files
¶
- common.go
- letterboxd_list_syncer.go
- linked_userdata_addon_reloader.go
- magnet_cache_puller.go
- map_anidb_torrent.go
- map_anime_id.go
- map_imdb_torrent.go
- store_crawler.go
- sync_anidb_titles.go
- sync_anidb_tvdb_episode_map.go
- sync_animeapi.go
- sync_animetosho.go
- sync_bitmagnet.go
- sync_dmm_hashlist.go
- sync_imdb.go
- sync_manami_anime_database.go
- sync_stremio_stremio.go
- sync_stremio_trakt.go
- torrent_parser.go
- torrent_pusher.go
- worker.go
Click to show internal directories.
Click to hide internal directories.