Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewAggregatorResolver ¶
func NewAggregatorResolver(aggregator aggregatorSource) *aggregatorResolver
func NewManualResolver ¶
func NewManualResolver(store manualPayloadStore) *manualResolver
func NewUsenetIndexResolver ¶
func NewUsenetIndexResolver(catalog usenetIndexCatalog, archive archiveNZBStore) *usenetIndexResolver
Types ¶
type DefaultReleaseResolver ¶
type DefaultReleaseResolver struct {
// contains filtered or unexported fields
}
func NewDefaultReleaseResolver ¶
func NewDefaultReleaseResolver( manual sourceResolver, aggregator sourceResolver, usenetIndex sourceResolver, ) *DefaultReleaseResolver
func (*DefaultReleaseResolver) GetNZB ¶
func (r *DefaultReleaseResolver) GetNZB(ctx context.Context, sourceKind string, rel *domain.Release) (io.ReadCloser, error)
route payload fetch using source kind, not release.Source heuristics.
func (*DefaultReleaseResolver) GetRelease ¶
func (r *DefaultReleaseResolver) GetRelease(ctx context.Context, sourceKind, sourceReleaseID string) (*domain.Release, error)
route release lookup using persisted queue provenance.
Source Files
Click to show internal directories.
Click to hide internal directories.