gqlmodel

Documentation

Index

• type Episodes
• type QueueJobsQueryInput
• type QueueJobsQueryResult
• type QueueMutation
  • func (m *QueueMutation) EnqueueReprocessTorrentsBatch(ctx context.Context, input manager.EnqueueReprocessTorrentsBatchRequest) (*string, error)
  • func (m *QueueMutation) PurgeJobs(ctx context.Context, input manager.PurgeJobsRequest) (*string, error)
• type QueueQuery
  • func (r QueueQuery) Jobs(ctx context.Context, query QueueJobsQueryInput) (QueueJobsQueryResult, error)
  • func (q QueueQuery) Metrics(ctx context.Context, input gen.QueueMetricsQueryInput) (*gen.QueueMetricsQueryResult, error)
• type TorrentContent
  • func NewTorrentContentFromResultItem(item search.TorrentContentResultItem) TorrentContent
• type TorrentContentQuery
  • func (t TorrentContentQuery) Search(ctx context.Context, input TorrentContentSearchQueryInput) (TorrentContentSearchResult, error)
• type TorrentContentSearchQueryInput
• type TorrentContentSearchResult
• type TorrentFilesQueryInput
• type TorrentMutation
• type TorrentQuery
  • func (t TorrentQuery) Files(ctx context.Context, query TorrentFilesQueryInput) (search.TorrentFilesResult, error)
  • func (t TorrentQuery) ListSources(ctx context.Context) (gen.TorrentListSourcesResult, error)
  • func (t TorrentQuery) Metrics(ctx context.Context, input gen.TorrentMetricsQueryInput) (*gen.TorrentMetricsQueryResult, error)
  • func (t TorrentQuery) SuggestTags(ctx context.Context, input *gen.SuggestTagsQueryInput) (search.TorrentSuggestTagsResult, error)
• type TorrentSourceInfo
  • func TorrentSourceInfosFromTorrent(t model.Torrent) []TorrentSourceInfo

Types

type Episodes

type Episodes struct {
	Label   string
	Seasons []model.Season `json:"omitempty"`
}

type QueueJobsQueryInput

type QueueJobsQueryInput struct {
	Queues      []string
	Statuses    []model.QueueJobStatus
	Limit       model.NullUint
	Page        model.NullUint
	Offset      model.NullUint
	TotalCount  model.NullBool
	HasNextPage model.NullBool
	Facets      *gen.QueueJobsFacetsInput
	OrderBy     []gen.QueueJobsOrderByInput
}

type QueueJobsQueryResult

type QueueJobsQueryResult struct {
	TotalCount   uint
	HasNextPage  bool
	Items        []model.QueueJob
	Aggregations gen.QueueJobsAggregations
}

type QueueMutation

type QueueMutation struct {
	QueueManager manager.Manager
}

func (*QueueMutation) EnqueueReprocessTorrentsBatch

func (m *QueueMutation) EnqueueReprocessTorrentsBatch(ctx context.Context, input manager.EnqueueReprocessTorrentsBatchRequest) (*string, error)

func (*QueueMutation) PurgeJobs

func (m *QueueMutation) PurgeJobs(ctx context.Context, input manager.PurgeJobsRequest) (*string, error)

type QueueQuery

type QueueQuery struct {
	QueueJobSearch     search.QueueJobSearch
	QueueMetricsClient queuemetrics.Client
}

func (QueueQuery) Jobs

func (r QueueQuery) Jobs(
	ctx context.Context,
	query QueueJobsQueryInput,
) (QueueJobsQueryResult, error)

func (QueueQuery) Metrics

func (q QueueQuery) Metrics(ctx context.Context, input gen.QueueMetricsQueryInput) (*gen.QueueMetricsQueryResult, error)

type TorrentContent

type TorrentContent struct {
	ID              string
	InfoHash        protocol.ID
	ContentType     model.NullContentType
	ContentSource   model.NullString
	ContentID       model.NullString
	Title           string
	Languages       []model.Language `json:"omitempty"`
	Episodes        *Episodes
	VideoResolution model.NullVideoResolution
	VideoSource     model.NullVideoSource
	VideoCodec      model.NullVideoCodec
	Video3D         model.NullVideo3D
	VideoModifier   model.NullVideoModifier
	ReleaseGroup    model.NullString
	SearchString    string
	Seeders         model.NullUint
	Leechers        model.NullUint
	PublishedAt     time.Time
	CreatedAt       time.Time
	UpdatedAt       time.Time
	Torrent         model.Torrent
	Content         *model.Content
}

func NewTorrentContentFromResultItem

func NewTorrentContentFromResultItem(item search.TorrentContentResultItem) TorrentContent

type TorrentContentQuery

type TorrentContentQuery struct {
	TorrentContentSearch search.TorrentContentSearch
}

func (TorrentContentQuery) Search

func (t TorrentContentQuery) Search(
	ctx context.Context,
	input TorrentContentSearchQueryInput,
) (TorrentContentSearchResult, error)

type TorrentContentSearchQueryInput

type TorrentContentSearchQueryInput struct {
	q.SearchParams
	Facets     *gen.TorrentContentFacetsInput
	OrderBy    []gen.TorrentContentOrderByInput
	InfoHashes graphql.Omittable[[]protocol.ID]
}

type TorrentContentSearchResult

type TorrentContentSearchResult struct {
	TotalCount           uint
	TotalCountIsEstimate bool
	HasNextPage          bool
	Items                []TorrentContent
	Aggregations         gen.TorrentContentAggregations
}

type TorrentFilesQueryInput

type TorrentFilesQueryInput struct {
	InfoHashes  []protocol.ID
	Limit       model.NullUint
	Page        model.NullUint
	Offset      model.NullUint
	TotalCount  model.NullBool
	HasNextPage model.NullBool
	Cached      model.NullBool
	OrderBy     []gen.TorrentFilesOrderByInput
}

type TorrentMutation

type TorrentMutation struct{}

type TorrentQuery

type TorrentQuery struct {
	Dao                  *dao.Query
	Search               search.Search
	TorrentMetricsClient torrentmetrics.Client
}

func (TorrentQuery) Files

func (t TorrentQuery) Files(ctx context.Context, query TorrentFilesQueryInput) (search.TorrentFilesResult, error)

func (TorrentQuery) ListSources

func (t TorrentQuery) ListSources(ctx context.Context) (gen.TorrentListSourcesResult, error)

func (TorrentQuery) Metrics

func (t TorrentQuery) Metrics(ctx context.Context, input gen.TorrentMetricsQueryInput) (*gen.TorrentMetricsQueryResult, error)

func (TorrentQuery) SuggestTags

func (t TorrentQuery) SuggestTags(ctx context.Context, input *gen.SuggestTagsQueryInput) (search.TorrentSuggestTagsResult, error)

type TorrentSourceInfo

type TorrentSourceInfo struct {
	Key      string
	Name     string
	ImportID model.NullString
	Seeders  model.NullUint
	Leechers model.NullUint
}

func TorrentSourceInfosFromTorrent

func TorrentSourceInfosFromTorrent(t model.Torrent) []TorrentSourceInfo