Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func New ¶
func New(s services.SettingsService, container *dig.Container, log zerolog.Logger, dirService services.DirectoryService, signalR services.SignalRService, notify services.NotificationService, preferences models.Preferences, transLoco services.TranslocoService, fs afero.Afero, ) (core.Client, error)
Types ¶
type ProviderQueue ¶
type ProviderQueue struct {
// contains filtered or unexported fields
}
ProviderQueue represents the queue for each separate provider. The queue has just one internal worker This worker will always empty out the loadingQueue, then the downloadQueue. Each queue has a max capacity of 100. The worker is started automatically after creation
func NewProviderQueue ¶
func (*ProviderQueue) AddToDownloadQueue ¶
func (pq *ProviderQueue) AddToDownloadQueue(content core.Downloadable) error
AddToDownloadQueue adds content to the download queue (for ready content)
func (*ProviderQueue) AddToLoadingQueue ¶
func (pq *ProviderQueue) AddToLoadingQueue(content core.Downloadable) error
AddToLoadingQueue adds content to the loading queue
func (*ProviderQueue) Shutdown ¶
func (pq *ProviderQueue) Shutdown()
Shutdown gracefully shuts down the provider queue, has a hard limit of 30s
type Registry ¶
type Registry interface {
Create(c core.Client, req payload.DownloadRequest) (core.Downloadable, error)
}
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.