app

Documentation

Index

• func ProcessJob(job ProcessingJob)
• func ScanMediaFiles(id int) error
• type DownloaderManager
  • func (dm *DownloaderManager) AutoDownload(mediaID int, releases []integration.Release)
  • func (dm *DownloaderManager) DeleteDownloader(id int)
  • func (dm *DownloaderManager) DoTask()
  • func (dm *DownloaderManager) Download(mediaID int, release integration.Release, ...) error
  • func (dm *DownloaderManager) GetDownloads() []ManagedDownload
  • func (dm *DownloaderManager) GetFrequency() time.Duration
  • func (dm *DownloaderManager) GetTaskName() string
  • func (dm *DownloaderManager) RegisterDownload(id int, mediaID int, friendlyName, status, identifier string, ...)
  • func (dm *DownloaderManager) RegisterDownloader(id int, downloaderType, name string, configuration map[string]interface{}) error
• type IndexerManager
  • func (im *IndexerManager) DeleteIndexer(id int)
  • func (im *IndexerManager) DoTask()
  • func (im *IndexerManager) GetFrequency() time.Duration
  • func (*IndexerManager) GetTaskName() string
  • func (im *IndexerManager) RegisterIndexer(id int, downloadType string, userID int, name, apiKey, baseUrl string, ...)
  • func (im *IndexerManager) SearchEpisode(seasonNum, episodeNum int, showTitle string, tvdbID *int, imdbID *string) ([]integration.Release, error)
  • func (im *IndexerManager) SearchMovie(movieTitle string, year int, imdbID *string) ([]integration.Release, error)
  • func (im *IndexerManager) SearchSeason(seasonNum int, showTitle string, tvdbID *int, imdbID *string) ([]integration.Release, error)
• type LibraryManager
  • func NewLibraryManager() LibraryManager
  • func (lm *LibraryManager) CheckMediaPath(mediaID int, path string) bool
  • func (lm *LibraryManager) DoTask()
  • func (lm *LibraryManager) GetAllMediaPathStatuses() map[int]bool
  • func (lm *LibraryManager) GetFrequency() time.Duration
  • func (lm *LibraryManager) GetMediaPathStatus(id int) bool
  • func (*LibraryManager) GetTaskName() string
  • func (lm *LibraryManager) SetMediaPathStatus(id int, status bool)
• type ManagedDownload
• type ManagedDownloader
  • func (md ManagedDownloader) GetName() string
• type ManagedIndexer
  • func (mi ManagedIndexer) GetName() string
• type ManagedMediaServer
  • func (m ManagedMediaServer) GetName() string
• type MediaServerManager
  • func (msm *MediaServerManager) DoTask()
  • func (msm *MediaServerManager) GetFrequency() time.Duration
  • func (*MediaServerManager) GetTaskName() string
  • func (msm *MediaServerManager) ImportMedia(path string) error
  • func (msm *MediaServerManager) RegisterMediaServer(id int, mediaServerType, name string, configuration map[string]interface{}) error
• type ProcessingDistributor
  • func NewProcessor(numWorkers int) *ProcessingDistributor
  • func (pd *ProcessingDistributor) AddJob(job ProcessingJob)
• type ProcessingJob
• type Service
• type SystemMonitor
  • func (m *SystemMonitor) DoTask()
  • func (m *SystemMonitor) GetFrequency() time.Duration
  • func (m *SystemMonitor) GetStatus() map[string]SystemTypeStatus
  • func (*SystemMonitor) GetTaskName() string
• type SystemStatus
• type SystemTypeStatus

Functions

func ProcessJob

func ProcessJob(job ProcessingJob)

func ScanMediaFiles

func ScanMediaFiles(id int) error

Types

type DownloaderManager

type DownloaderManager struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

var DM DownloaderManager

func (*DownloaderManager) AutoDownload

func (dm *DownloaderManager) AutoDownload(mediaID int, releases []integration.Release)

func (*DownloaderManager) DeleteDownloader

func (dm *DownloaderManager) DeleteDownloader(id int)

func (*DownloaderManager) DoTask

func (dm *DownloaderManager) DoTask()

func (*DownloaderManager) Download

func (dm *DownloaderManager) Download(mediaID int, release integration.Release, highPriority, tryAgainOnFail, haveLock bool) error

func (*DownloaderManager) GetDownloads

func (dm *DownloaderManager) GetDownloads() []ManagedDownload

func (*DownloaderManager) GetFrequency

func (dm *DownloaderManager) GetFrequency() time.Duration

func (*DownloaderManager) GetTaskName

func (dm *DownloaderManager) GetTaskName() string

func (*DownloaderManager) RegisterDownload

func (dm *DownloaderManager) RegisterDownload(id int, mediaID int, friendlyName, status, identifier string, releaseID *string)

func (*DownloaderManager) RegisterDownloader

func (dm *DownloaderManager) RegisterDownloader(id int, downloaderType, name string, configuration map[string]interface{}) error

type IndexerManager

type IndexerManager struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

var IM IndexerManager

func (*IndexerManager) DeleteIndexer

func (im *IndexerManager) DeleteIndexer(id int)

func (*IndexerManager) DoTask

func (im *IndexerManager) DoTask()

sync rss feeds

func (*IndexerManager) GetFrequency

func (im *IndexerManager) GetFrequency() time.Duration

func (*IndexerManager) GetTaskName

func (*IndexerManager) GetTaskName() string

func (*IndexerManager) RegisterIndexer

func (im *IndexerManager) RegisterIndexer(id int, downloadType string, userID int, name, apiKey, baseUrl string, forMovies, forSeries bool, lastRSSID string)

func (*IndexerManager) SearchEpisode

func (im *IndexerManager) SearchEpisode(seasonNum, episodeNum int, showTitle string, tvdbID *int, imdbID *string) ([]integration.Release, error)

func (*IndexerManager) SearchMovie

func (im *IndexerManager) SearchMovie(movieTitle string, year int, imdbID *string) ([]integration.Release, error)

func (*IndexerManager) SearchSeason

func (im *IndexerManager) SearchSeason(seasonNum int, showTitle string, tvdbID *int, imdbID *string) ([]integration.Release, error)

type LibraryManager

type LibraryManager struct {
	// contains filtered or unexported fields
}

var LM LibraryManager

func NewLibraryManager

func NewLibraryManager() LibraryManager

func (*LibraryManager) CheckMediaPath

func (lm *LibraryManager) CheckMediaPath(mediaID int, path string) bool

func (*LibraryManager) DoTask

func (lm *LibraryManager) DoTask()

func (*LibraryManager) GetAllMediaPathStatuses

func (lm *LibraryManager) GetAllMediaPathStatuses() map[int]bool

func (*LibraryManager) GetFrequency

func (lm *LibraryManager) GetFrequency() time.Duration

func (*LibraryManager) GetMediaPathStatus

func (lm *LibraryManager) GetMediaPathStatus(id int) bool

func (*LibraryManager) GetTaskName

func (*LibraryManager) GetTaskName() string

func (*LibraryManager) SetMediaPathStatus

func (lm *LibraryManager) SetMediaPathStatus(id int, status bool)

type ManagedDownload

type ManagedDownload struct {
	ID             int
	TryAgainOnFail bool
	ReleaseID      *string
	integration.Download
}

type ManagedDownloader

type ManagedDownloader struct {
	ID             int
	Name           string
	DownloaderType string
	integration.Downloader
}

func (ManagedDownloader) GetName

func (md ManagedDownloader) GetName() string

type ManagedIndexer

type ManagedIndexer struct {
	ID        int
	Name      string
	ForMovies bool
	ForSeries bool
	LastRSSID string
	integration.Indexer
}

func (ManagedIndexer) GetName

func (mi ManagedIndexer) GetName() string

type ManagedMediaServer

type ManagedMediaServer struct {
	ID              int
	Name            string
	MediaServerType string
	integration.MediaServer
}

func (ManagedMediaServer) GetName

func (m ManagedMediaServer) GetName() string

type MediaServerManager

type MediaServerManager struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

var MSM MediaServerManager

func (*MediaServerManager) DoTask

func (msm *MediaServerManager) DoTask()

func (*MediaServerManager) GetFrequency

func (msm *MediaServerManager) GetFrequency() time.Duration

func (*MediaServerManager) GetTaskName

func (*MediaServerManager) GetTaskName() string

func (*MediaServerManager) ImportMedia

func (msm *MediaServerManager) ImportMedia(path string) error

func (*MediaServerManager) RegisterMediaServer

func (msm *MediaServerManager) RegisterMediaServer(id int, mediaServerType, name string, configuration map[string]interface{}) error

type ProcessingDistributor

type ProcessingDistributor struct {
	// contains filtered or unexported fields
}

var Processor *ProcessingDistributor

func NewProcessor

func NewProcessor(numWorkers int) *ProcessingDistributor

func (*ProcessingDistributor) AddJob

func (pd *ProcessingDistributor) AddJob(job ProcessingJob)

type ProcessingJob

type ProcessingJob struct {
	// contains filtered or unexported fields
}

type Service

type Service interface {
	TestConnection() error
	GetName() string
}

type SystemMonitor

type SystemMonitor struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

var Monitor SystemMonitor

func (*SystemMonitor) DoTask

func (m *SystemMonitor) DoTask()

func (*SystemMonitor) GetFrequency

func (m *SystemMonitor) GetFrequency() time.Duration

func (*SystemMonitor) GetStatus

func (m *SystemMonitor) GetStatus() map[string]SystemTypeStatus

func (*SystemMonitor) GetTaskName

func (*SystemMonitor) GetTaskName() string

type SystemStatus

type SystemStatus struct {
	Msg        string `json:"msg,omitempty"`
	SystemName string `json:"systemName,omitempty"`
}

type SystemTypeStatus

type SystemTypeStatus struct {
	Healthy  bool           `json:"healthy"`
	Msg      string         `json:"msg,omitempty"`
	Statuses []SystemStatus `json:"statuses,omitempty"`
}