Versions in this module Expand all Collapse all v0 v0.3.4 Mar 30, 2024 v0.3.3 Mar 30, 2024 v0.3.2 Mar 27, 2024 v0.3.1 Mar 27, 2024 v0.3.0 Mar 27, 2024 Changes in this version + type Count struct + func (c *Count) Inc() + type ParseRiftAll struct + func (j *ParseRiftAll) Kind() string + func (j *ParseRiftAll) Work(ctx context.Context, job *minion.Job[*ParseRiftAll]) error + 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 v0.2.1 Mar 9, 2024 v0.2.0 Mar 9, 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 QueryInt(c echo.Context, name string) int + 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) 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) 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) error + func (a *Application) IndexersUpdateHandler(c echo.Context) error + func (a *Application) JobsCreate(c echo.Context) error + func (a *Application) JobsCreateHandler(c echo.Context) error + func (a *Application) JobsDelete(c echo.Context, id string) error + func (a *Application) JobsDeleteHandler(c echo.Context) error + func (a *Application) JobsIndex(c echo.Context, page int, limit int) error + func (a *Application) JobsIndexHandler(c echo.Context) error + func (a *Application) JobsSettings(c echo.Context, id string) error + func (a *Application) JobsSettingsHandler(c echo.Context) error + func (a *Application) JobsShow(c echo.Context, id string) error + func (a *Application) JobsShowHandler(c echo.Context) error + func (a *Application) JobsUpdate(c echo.Context, id string) error + func (a *Application) JobsUpdateHandler(c echo.Context) error + func (a *Application) ReleasesCreate(c echo.Context) 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) ReleasesSettings(c echo.Context, id string) 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) error + func (a *Application) ReleasesUpdateHandler(c echo.Context) error + func (a *Application) Routes() + func (a *Application) SourcesCreate(c echo.Context) error + func (a *Application) SourcesCreateHandler(c echo.Context) error + func (a *Application) SourcesDelete(c echo.Context, id string) error + func (a *Application) SourcesDeleteHandler(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) error + func (a *Application) SourcesParseHandler(c echo.Context) error + func (a *Application) SourcesRead(c echo.Context, id 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) SourcesSettings(c echo.Context, id string) error + func (a *Application) SourcesSettingsHandler(c echo.Context) error + func (a *Application) SourcesShow(c echo.Context, id string) error + func (a *Application) SourcesShowHandler(c echo.Context) error + func (a *Application) SourcesUpdate(c echo.Context, id string) error + func (a *Application) SourcesUpdateHandler(c echo.Context) error + type Config struct + Auth bool + ClerkSecretKey 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 + Minion *grimoire.Store[*Minion] + 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) MinionGet(id string) (*Minion, error) + func (c *Connector) MinionList(limit, skip int) ([]*Minion, 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) + 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 Minion struct + Args string + Attempts []*MinionAttempt + Kind string + Queue string + Status string + type MinionAttempt struct + Duration float64 + Error string + Stacktrace []string + StartedAt time.Time + Status 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 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, result *mongo.UpdateResult) error + func (r *Release) Updated(ctx context.Context, result *mongo.UpdateResult) error + type RunicSourceSimple struct + Name string + Type string + URL string + type Setting struct + Key string + Value bool
Go to main page