app

package

Go to main page

Versions in this module

v0

v0.5.2

Nov 4, 2024

Changes in this version

type Application

+ Scry *scry.Client

type Config

+ ScryURL string

type Connector

+ Torrent *grimoire.Store[*Torrent]

+ func (c *Connector) TorrentGet(id string) (*Torrent, error)

+ func (c *Connector) TorrentList(page, limit int) ([]*Torrent, error)

type Indexer

+ Count int64

+ type IndexerCounts struct

+ func (j *IndexerCounts) Kind() string

+ func (j *IndexerCounts) Work(ctx context.Context, job *minion.Job[*IndexerCounts]) error

+ type MigrateTorrents struct

+ func (j *MigrateTorrents) Kind() string

+ func (j *MigrateTorrents) Work(ctx context.Context, job *minion.Job[*MigrateTorrents]) error

+ type ResetIndexes struct

+ func (j *ResetIndexes) Kind() string

+ func (j *ResetIndexes) Work(ctx context.Context, job *minion.Job[*ResetIndexes]) error

+ type Torrent struct

+ Author string

+ Bluray bool

+ Checksum string

+ Description string

+ Download string

+ Encoding string

+ Episode int

+ Group string

+ Infohash string

+ Name string

+ Nzb bool

+ PublishedAt time.Time

+ Quality string

+ Raw string

+ Resolution string

+ Season int

+ Size string

+ Source string

+ Title string

+ Type string

+ Uncensored bool

+ Verified bool

+ View string

+ Volume int

+ Widescreen bool

+ Year int

v0.5.1

Jun 23, 2024

Changes in this version

type Config

+ GroupsPreferred []string

+ GroupsVerified []string

+ Production bool

+ RedisDatabase int

+ func (c *Config) IsVerifiedGroup(group string) bool

type Popular

+ Verified int

v0.5.0

May 27, 2024

Changes in this version

+ func ContextSet(ctx context.Context, key string, value interface{}) context.Context

type Application

+ Cache *Cache

+ func ContextApp(ctx context.Context) *Application

+ type Cache struct

+ func NewCache(log *zap.SugaredLogger, options kv.Options) (*Cache, error)

+ func (c *Cache) Close() error

+ func (c *Cache) Delete(k string) error

+ func (c *Cache) Fetch(k string, v interface{}, f func() (interface{}, error)) (bool, error)

+ func (c *Cache) Get(k string, v interface{}) (bool, error)

+ func (c *Cache) Set(k string, v interface{}) error

type Config

+ RedisAddress string

type Events

+ RiftVideo chan *rift.Video

+ type ReleasesPopular struct

+ func (j *ReleasesPopular) Kind() string

+ func (j *ReleasesPopular) Work(ctx context.Context, job *minion.Job[*ReleasesPopular]) error

v0.4.3

May 6, 2024

Changes in this version

type Application

+ func (a *Application) ParserBatch(c echo.Context, batch *Batch) error

+ func (a *Application) ParserBatchHandler(c echo.Context) error

+ func (a *Application) PopularMovies(c echo.Context) error

+ func (a *Application) PopularMoviesHandler(c echo.Context) error

+ type Batch struct

+ Titles []string

+ Type string

+ type BatchResult struct

+ Info *parser.TorrentInfo

+ Title string

v0.4.2

Apr 15, 2024

v0.4.1

Apr 15, 2024

Changes in this version

+ func TickTock(tag string) func()

type Application

+ func (a *Application) IndexersRefresh(c echo.Context, id string) error

+ func (a *Application) IndexersRefreshHandler(c echo.Context) error

+ func (a *Application) ParserParse(c echo.Context, title string, type_ string) error

+ func (a *Application) ParserParseHandler(c echo.Context) error

+ func (a *Application) ParserTitle(c echo.Context, title string, type_ string) error

+ func (a *Application) ParserTitleHandler(c echo.Context) error

+ func (a *Application) ReleasesMovies(c echo.Context) error

+ func (a *Application) ReleasesMoviesHandler(c echo.Context) error

type Config

+ JackettKey string

+ JackettURL string

+ NZBGeekKey string

+ NZBGeekURL string

type Connector

+ func (c *Connector) IndexerByName(name string) (*Indexer, error)

+ func (c *Connector) ReleasesPopularMovies() ([]*PopularMovie, error)

+ type PopularMovie struct

+ Count int

+ ID *PopularMovieId

+ Verified int

+ type PopularMovieId struct

+ Title string

+ Year int

v0.4.0

Apr 11, 2024

Changes in this version

+ func QueryBool(c echo.Context, name string) bool

+ func QueryDefaultInteger(c echo.Context, name string, def int) (int, error)

+ func QueryDefaultString(c echo.Context, name, def string) string

+ func QueryInt(c echo.Context, name string) int

+ func QueryParamBool(c echo.Context, name string) bool

+ func QueryParamBoolDefault(c echo.Context, name string, def string) bool

+ func QueryParamFloatDefault(c echo.Context, name string, def string) float64

+ func QueryParamInt(c echo.Context, name string) int

+ func QueryParamIntDefault(c echo.Context, name string, def string) int

+ func QueryParamString(c echo.Context, name string) string

+ func QueryParamStringDefault(c echo.Context, name string, def string) string

+ func QueryString(c echo.Context, name string) string

+ func Setup() error

+ func Start() error

+ func WithTimeout(delegate func() interface{}, timeout time.Duration) (ret interface{}, ok bool)

+ type Application struct

+ Config *Config

+ DB *Connector

+ Default *echo.Group

+ Engine *echo.Echo

+ Events *Events

+ Log *zap.SugaredLogger

+ Processor *Processor

+ Reader *reader.Reader

+ Rift *rift.Client

+ Router *echo.Group

+ Workers *minion.Minion

+ func (a *Application) Health() (map[string]bool, error)

+ func (a *Application) IndexersCreate(c echo.Context, subject *Indexer) error

+ func (a *Application) IndexersCreateHandler(c echo.Context) error

+ func (a *Application) IndexersDelete(c echo.Context, id string) error

+ func (a *Application) IndexersDeleteHandler(c echo.Context) error

+ func (a *Application) IndexersIndex(c echo.Context, page int, limit int) error

+ func (a *Application) IndexersIndexHandler(c echo.Context) error

+ func (a *Application) IndexersSettings(c echo.Context, id string, setting *Setting) error

+ func (a *Application) IndexersSettingsHandler(c echo.Context) error

+ func (a *Application) IndexersShow(c echo.Context, id string) error

+ func (a *Application) IndexersShowHandler(c echo.Context) error

+ func (a *Application) IndexersUpdate(c echo.Context, id string, subject *Indexer) error

+ func (a *Application) IndexersUpdateHandler(c echo.Context) error

+ func (a *Application) PopularIndex(c echo.Context, interval string) error

+ func (a *Application) PopularIndexHandler(c echo.Context) error

+ func (a *Application) ReleasesCreate(c echo.Context, subject *Release) error

+ func (a *Application) ReleasesCreateHandler(c echo.Context) error

+ func (a *Application) ReleasesDelete(c echo.Context, id string) error

+ func (a *Application) ReleasesDeleteHandler(c echo.Context) error

+ func (a *Application) ReleasesIndex(c echo.Context, page int, limit int) error

+ func (a *Application) ReleasesIndexHandler(c echo.Context) error

+ func (a *Application) ReleasesSearch(c echo.Context, page int, limit int, ...) error

+ func (a *Application) ReleasesSearchHandler(c echo.Context) error

+ func (a *Application) ReleasesSettings(c echo.Context, id string, setting *Setting) error

+ func (a *Application) ReleasesSettingsHandler(c echo.Context) error

+ func (a *Application) ReleasesShow(c echo.Context, id string) error

+ func (a *Application) ReleasesShowHandler(c echo.Context) error

+ func (a *Application) ReleasesUpdate(c echo.Context, id string, subject *Release) error

+ func (a *Application) ReleasesUpdateHandler(c echo.Context) error

+ func (a *Application) Routes()

+ func (a *Application) SourcesCreate(c echo.Context) error

+ func (a *Application) SourcesIndex(c echo.Context, page int, limit int) error

+ func (a *Application) SourcesIndexHandler(c echo.Context) error

+ func (a *Application) SourcesParse(c echo.Context, id string, categories string) error

+ func (a *Application) SourcesParseHandler(c echo.Context) error

+ func (a *Application) SourcesRead(c echo.Context, id string, categories string) error

+ func (a *Application) SourcesReadHandler(c echo.Context) error

+ func (a *Application) SourcesSearch(c echo.Context, id string, query string, searchType string) error

+ func (a *Application) SourcesSearchHandler(c echo.Context) error

+ func (a *Application) SourcesShow(c echo.Context, id string) error

+ func (a *Application) SourcesShowHandler(c echo.Context) error

+ type Config struct

+ Auth bool

+ ClerkSecretKey string

+ ClerkToken string

+ Connections ConnectionSet

+ Logger string

+ MinionBufferSize int

+ MinionCollection string

+ MinionConcurrency int

+ MinionDatabase string

+ MinionDebug bool

+ MinionURI string

+ Mode string

+ NatsURL string

+ Port int

+ RiftURL string

+ Words []string

+ func (c *Config) ConnectionFor(name string) (*Connection, error)

+ func (c *Config) Validate() error

+ type Connection struct

+ Collection string

+ Database string

+ URI string

+ func (c *Connection) UnmarshalText(text []byte) error

+ type ConnectionSet map[string]*Connection

+ func (c *ConnectionSet) UnmarshalText(text []byte) error

+ type Connector struct

+ Indexer *grimoire.Store[*Indexer]

+ Log *zap.SugaredLogger

+ Release *grimoire.Store[*Release]

+ func NewConnector(app *Application) (*Connector, error)

+ func (c *Connector) IndexerActive() ([]*Indexer, error)

+ func (c *Connector) IndexerGet(id string) (*Indexer, error)

+ func (c *Connector) IndexerList(page, limit int) ([]*Indexer, int64, error)

+ func (c *Connector) ReleaseGet(id string) (*Release, error)

+ func (c *Connector) ReleaseList(page, limit int) ([]*Release, int64, error)

+ func (c *Connector) ReleaseSetting(id, setting string, value bool) error

+ func (c *Connector) ReleasesAll() ([]*Release, error)

+ func (c *Connector) ReleasesPopular(interval string) (map[string][]*Popular, error)

+ func (c *Connector) ReleasesPopularType(ctx context.Context, t string, date time.Time, limit int) ([]*Popular, error)

+ type Count struct

+ func (c *Count) Inc()

+ type Events struct

+ App *Application

+ Log *zap.SugaredLogger

+ Merc *mercury.Mercury

+ Releases chan *Release

+ func NewEvents(app *Application) (*Events, error)

+ func (e *Events) Send(topic EventsTopic, data any) error

+ func (e *Events) Start() error

+ type EventsChannel string

+ type EventsTopic string

+ type H map[string]any

+ func (h H) MarshalXML(e *xml.Encoder, start xml.StartElement) error

+ type Indexer struct

+ Active bool

+ Categories []int

+ Name string

+ ProcessedAt time.Time

+ URL string

+ type ParseActive struct

+ func (j *ParseActive) Kind() string

+ func (j *ParseActive) Work(ctx context.Context, job *minion.Job[*ParseActive]) error

+ type ParseIndexer struct

+ ID string

+ Title string

+ func (j *ParseIndexer) Kind() string

+ func (j *ParseIndexer) Work(ctx context.Context, job *minion.Job[*ParseIndexer]) error

+ type ParseRift struct

+ func (j *ParseRift) Kind() string

+ func (j *ParseRift) Work(ctx context.Context, job *minion.Job[*ParseRift]) error

+ type ParseRiftAll struct

+ func (j *ParseRiftAll) Kind() string

+ func (j *ParseRiftAll) Work(ctx context.Context, job *minion.Job[*ParseRiftAll]) error

+ type Popular struct

+ Count int

+ Title string

+ Type string

+ Year int

+ type PopularResponse struct

+ Anime []*Popular

+ Movies []*Popular

+ Tv []*Popular

+ type Processor struct

+ func (p *Processor) Parse(source string, categories []int) ([]*Release, error)

+ func (p *Processor) Process(source string, list []*newznab.NZB) ([]*Release, error)

+ type Release struct

+ Bluray bool

+ Checksum string

+ Description string

+ Download string

+ Downloader string

+ Encodings []string

+ Episode int

+ Group string

+ Info *parser.TorrentInfo

+ Infohash string

+ PublishedAt time.Time

+ Quality string

+ Raw *newznab.NZB

+ Resolution string

+ Season int

+ Size int64

+ Source string

+ ThreeD bool

+ Title string

+ Type string

+ Uncensored bool

+ Unrated bool

+ Verified bool

+ View string

+ Volume int

+ Website string

+ Widescreen bool

+ Year int

+ func (r *Release) Created(ctx context.Context) error

+ func (r *Release) Updated(ctx context.Context, result *mongo.UpdateResult) error

+ type Response struct

+ Error bool

+ Message string

+ Result interface{}

+ Total int64

+ type RunicSourceSimple struct

+ Name string

+ Type string

+ URL string

+ type Setting struct

+ Name string

+ Value bool

+ type SettingsBatch struct

+ IDs []string

+ Name string

+ Value bool

+ type UpdateIndexes struct

+ func (j *UpdateIndexes) Kind() string

+ func (j *UpdateIndexes) Timeout(job *minion.Job[*UpdateIndexes]) time.Duration

+ func (j *UpdateIndexes) Work(ctx context.Context, job *minion.Job[*UpdateIndexes]) error

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL