services

package
v0.0.0-...-6669290 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 29, 2023 License: MIT Imports: 45 Imported by: 4

Documentation

Index

Constants

View Source 
const (
	HashSize int = 20
)
View Source 
const ServiceSeparator = "~"

Variables

View Source 
var ExportTypes = []ExportType{
	ExportTypeDownload,
	ExportTypeStream,
	ExportTypeTorrentStat,
	ExportTypeSubtitles,
	ExportTypeMediaProbe,
}

Functions

func RegisterExportFlags 

func RegisterExportFlags(f []cli.Flag) []cli.Flag

func RegisterMagnet2TorrentFlags 

func RegisterMagnet2TorrentFlags(f []cli.Flag) []cli.Flag

func RegisterNodesStatFlags 

func RegisterNodesStatFlags(f []cli.Flag) []cli.Flag

func RegisterPromClientFlags 

func RegisterPromClientFlags(f []cli.Flag) []cli.Flag

func RegisterTorrentStoreFlags 

func RegisterTorrentStoreFlags(f []cli.Flag) []cli.Flag

func RegisterTorrentWebCacheFlags 

func RegisterTorrentWebCacheFlags(f []cli.Flag) []cli.Flag

func RegisterTranscodeWebCacheFlags 

func RegisterTranscodeWebCacheFlags(f []cli.Flag) []cli.Flag

func RegisterUrlBuilderFlags 

func RegisterUrlBuilderFlags(f []cli.Flag) []cli.Flag

func RegisterWebFlags 

func RegisterWebFlags(f []cli.Flag) []cli.Flag

Types

type AudioTagBuider 

type AudioTagBuider struct {
	BaseTagBulder
}

func (*AudioTagBuider) Build 

func (s *AudioTagBuider) Build() (*ExportTag, error)

type BaseExporter 

type BaseExporter struct {
	// contains filtered or unexported fields
}

func (*BaseExporter) BuildURL 

func (s *BaseExporter) BuildURL(r *Resource, i *ListItem, g ParamGetter) (*MyURL, error)

func (*BaseExporter) Type 

func (s *BaseExporter) Type() ExportType

type BaseTagBulder 

type BaseTagBulder struct {
	// contains filtered or unexported fields
}

func (*BaseTagBulder) BuildAVTag 

func (s *BaseTagBulder) BuildAVTag(n ExportTagName) (*ExportTag, error)

func (*BaseTagBulder) BuildSource 

func (s *BaseTagBulder) BuildSource(u *MyURL) *ExportSource

func (*BaseTagBulder) BuildURL 

func (s *BaseTagBulder) BuildURL(i *ListItem) (*MyURL, error)

type BaseURLBuilder 

type BaseURLBuilder struct {
	// contains filtered or unexported fields
}

func (*BaseURLBuilder) BuildBaseURL 

func (s *BaseURLBuilder) BuildBaseURL(i *MyURL) (u *MyURL, err error)

func (*BaseURLBuilder) BuildDomain 

func (s *BaseURLBuilder) BuildDomain(i *MyURL) (u *MyURL, err error)

func (*BaseURLBuilder) BuildScheme 

func (s *BaseURLBuilder) BuildScheme(i *MyURL) (u *MyURL)

func (*BaseURLBuilder) GetLastName 

func (s *BaseURLBuilder) GetLastName() string

type CompletedPieces 

type CompletedPieces map[[20]byte]bool

func NewCompletedPiecesFromReader 

func NewCompletedPiecesFromReader(r io.Reader) (CompletedPieces, error)

func (CompletedPieces) Has 

func (cp CompletedPieces) Has(h Hash) bool

func (CompletedPieces) HasAny 

func (cp CompletedPieces) HasAny(hs []Hash) bool

type CompletedPiecesMap 

type CompletedPiecesMap struct {
	lazymap.LazyMap
	// contains filtered or unexported fields
}

func NewCompletedPiecesMap 

func NewCompletedPiecesMap(c *cli.Context, cl *http.Client) *CompletedPiecesMap

func (*CompletedPiecesMap) Get 

func (s *CompletedPiecesMap) Get(hash string) (CompletedPieces, error)

type DownloadExporter 

type DownloadExporter struct {
	BaseExporter
}

func NewDownloadExporter 

func NewDownloadExporter(ub *URLBuilder) *DownloadExporter

func (*DownloadExporter) Export 

func (s *DownloadExporter) Export(r *Resource, i *ListItem, g ParamGetter) (*ExportItem, error)

type DownloadURLBuilder 

type DownloadURLBuilder struct {
	BaseURLBuilder
}

func (*DownloadURLBuilder) Build 

func (s *DownloadURLBuilder) Build() (u *MyURL, err error)

func (*DownloadURLBuilder) BuildDownloadURL 

func (s *DownloadURLBuilder) BuildDownloadURL(i *MyURL) (u *MyURL, err error)

type ErrorResponse 

type ErrorResponse struct {
	Error string `json:"error"`
}

type Export 

type Export struct {
	// contains filtered or unexported fields
}

func NewExport 

func NewExport(e ...Exporter) *Export

func (*Export) Get 

func (s *Export) Get(r *Resource, i *ListItem, args *ExportGetArgs, g ParamGetter) (*ExportResponse, error)

type ExportGetArgs 

type ExportGetArgs struct {
	Types []ExportType
}

func ExportGetArgsFromParams 

func ExportGetArgsFromParams(g ParamGetter) (*ExportGetArgs, error)

type ExportItem 

type ExportItem struct {
	ExportStreamItem
	ExportMetaItem
	Type string `json:"-"`
	URL  string `json:"url,omitempty"`
}

type ExportKindType 

type ExportKindType string
const (
	ExportKindTypeSubtitles ExportKindType = "subtitles"
)

type ExportMeta 

type ExportMeta struct {
	Transcode    bool `json:"transcode,omitempty"`
	Multibitrate bool `json:"multibitrate,omitempty"`
	Cache        bool `json:"cache,omitempty"`
}

type ExportMetaItem 

type ExportMetaItem struct {
	Meta *ExportMeta `json:"meta,omitempty"`
}

type ExportPreloadType 

type ExportPreloadType string
const (
	ExportPreloadTypeAuto ExportPreloadType = "auto"
	ExportPreloadTypeNone ExportPreloadType = "none"
)

type ExportResponse 

type ExportResponse struct {
	Source      ListItem              `json:"source"`
	ExportItems map[string]ExportItem `json:"exports"`
}

type ExportSource 

type ExportSource struct {
	Src  string `json:"src"`
	Type string `json:"type"`
}

type ExportStreamItem 

type ExportStreamItem struct {
	Tag *ExportTag `json:"html_tag,omitempty"`
}

type ExportTag 

type ExportTag struct {
	Name    ExportTagName     `json:"tag,omitempty"`
	Preload ExportPreloadType `json:"preload,omitempty"`
	Sources []ExportSource    `json:"sources,omitempty"`
	Tracks  []ExportTrack     `json:"tracks,omitempty"`
	Src     string            `json:"src,omitempty"`
	Alt     string            `json:"alt,omitempty"`
	Poster  string            `json:"poster,omitempty"`
}

type ExportTagName 

type ExportTagName string
const (
	ExportTagNameVideo ExportTagName = "video"
	ExportTagNameAudio ExportTagName = "audio"
	ExportTagNameImage ExportTagName = "img"
)

type ExportTrack 

type ExportTrack struct {
	Src     string         `json:"src"`
	Kind    ExportKindType `json:"kind"`
	SrcLang string         `json:"srclang,omitempty"`
	Label   string         `json:"label,omitempty"`
}

type ExportType 

type ExportType string
const (
	ExportTypeDownload    ExportType = "download"
	ExportTypeStream      ExportType = "stream"
	ExportTypeTorrentStat ExportType = "torrent_client_stat"
	ExportTypeSubtitles   ExportType = "subtitles"
	ExportTypeMediaProbe  ExportType = "media_probe"
)

type Exporter 

type Exporter interface {
	Type() ExportType
	Export(r *Resource, i *ListItem, g ParamGetter) (*ExportItem, error)
}

type File 

type File struct {
	Path   []string
	Size   int64
	Pieces []Hash
}

type Hash 

type Hash [HashSize]byte

type ImageTagBuider 

type ImageTagBuider struct {
	BaseTagBulder
}

func (*ImageTagBuider) Build 

func (s *ImageTagBuider) Build() (et *ExportTag, err error)

type K8SClient 

type K8SClient struct {
	// contains filtered or unexported fields
}

func NewK8SClient 

func NewK8SClient() *K8SClient

func (*K8SClient) Get 

func (s *K8SClient) Get() (*kubernetes.Clientset, error)

type List 

type List struct{}

func NewList 

func NewList() *List

func (*List) Get 

func (s *List) Get(r *Resource, args *ListGetArgs) (ListResponse, error)

type ListGetArgs 

type ListGetArgs struct {
	Limit  int
	Offset int
	Output ListOutputType
	Path   []string
}

func ListGetArgsFromParams 

func ListGetArgsFromParams(g ParamGetter) (*ListGetArgs, error)

func NewListGetArgs 

func NewListGetArgs() *ListGetArgs

type ListItem 

type ListItem struct {
	ID          string      `json:"id"`
	Name        string      `json:"name,omitempty"`
	PathStr     string      `json:"path"`
	Path        []string    `json:"-"`
	Type        ListType    `json:"type"`
	Size        int64       `json:"size"`
	MediaFormat MediaFormat `json:"media_format,omitempty"`
	MimeType    string      `json:"mime_type,omitempty"`
	Ext         string      `json:"ext,omitempty"`
}

func (*ListItem) SameDirectory 

func (s *ListItem) SameDirectory(li *ListItem) bool

type ListOutputType 

type ListOutputType string
const (
	ListOutputTypeList ListOutputType = "list"
	ListOutputTypeTree ListOutputType = "tree"
)

type ListResponse 

type ListResponse struct {
	ListItem
	Items []ListItem `json:"items"`
	Count int        `json:"items_count"`
}

type ListType 

type ListType string
const (
	ListTypeFile      ListType = "file"
	ListTypeDirectory ListType = "directory"
)

type Magnet2Torrent 

type Magnet2Torrent struct {
	// contains filtered or unexported fields
}

func NewMagnet2Torrent 

func NewMagnet2Torrent(c *cli.Context) *Magnet2Torrent

func (*Magnet2Torrent) Close 

func (s *Magnet2Torrent) Close()

func (*Magnet2Torrent) Get 

func (s *Magnet2Torrent) Get() (m2t.Magnet2TorrentClient, error)

type Magnet2TorrentClientMock 

type Magnet2TorrentClientMock struct {
	mock.Mock
	// contains filtered or unexported fields
}

func (*Magnet2TorrentClientMock) Magnet2Torrent 

func (s *Magnet2TorrentClientMock) Magnet2Torrent(ctx context.Context, in *m2tp.Magnet2TorrentRequest, opts ...grpc.CallOption) (*m2tp.Magnet2TorrentReply, error)

type Magnet2TorrentGetter 

type Magnet2TorrentGetter interface {
	Get() (m2tp.Magnet2TorrentClient, error)
}

type Magnet2TorrentMock 

type Magnet2TorrentMock struct {
	// contains filtered or unexported fields
}

func NewMagnet2TorrentMock 

func NewMagnet2TorrentMock() *Magnet2TorrentMock

func (*Magnet2TorrentMock) Get 

func (s *Magnet2TorrentMock) Get() (m2tp.Magnet2TorrentClient, error)

type MediaFormat 

type MediaFormat string
const (
	Audio    MediaFormat = "audio"
	Video    MediaFormat = "video"
	Image    MediaFormat = "image"
	Subtitle MediaFormat = "subtitle"
	Unknown  MediaFormat = "unknown"
)

type MediaProbeExporter 

type MediaProbeExporter struct {
	BaseExporter
}

func NewMediaProbeExporter 

func NewMediaProbeExporter(ub *URLBuilder) *MediaProbeExporter

func (*MediaProbeExporter) Export 

func (s *MediaProbeExporter) Export(r *Resource, i *ListItem, g ParamGetter) (*ExportItem, error)

type MediaProbeURLBuilder 

type MediaProbeURLBuilder struct {
	StreamURLBuilder
}

func (*MediaProbeURLBuilder) Build 

func (s *MediaProbeURLBuilder) Build() (u *MyURL, err error)

type MyURL 

type MyURL struct {
	url.URL
	// contains filtered or unexported fields
}

func (*MyURL) BuildExportMeta 

func (s *MyURL) BuildExportMeta() *ExportMeta

type NodeBandwidth 

type NodeBandwidth struct {
	High    uint64
	Low     uint64
	Current uint64
}

type NodeStat 

type NodeStat struct {
	Name string
	NodeBandwidth
	// NodeCPU
	Pools     []string
	Subdomain string
}

type NodeStatWithScore 

type NodeStatWithScore struct {
	NodeStat
	Score    float64
	Distance int
}

type NodesStat 

type NodesStat struct {
	lazymap.LazyMap
	// contains filtered or unexported fields
}

func NewNodesStat 

func NewNodesStat(c *cli.Context, pcl *PromClient, kcl *K8SClient) *NodesStat

func (*NodesStat) Get 

func (s *NodesStat) Get() ([]NodeStat, error)

type ParamGetter 

type ParamGetter interface {
	Param(s string) string
	Query(s string) string
	GetHeader(s string) string
}

type PromClient 

type PromClient struct {
	// contains filtered or unexported fields
}

func NewPromClient 

func NewPromClient(c *cli.Context) *PromClient

func (*PromClient) Get 

func (s *PromClient) Get() (v1.API, error)

type Resource 

type Resource struct {
	ID        string
	Name      string
	Size      int64
	Files     []*File
	Type      ResourceType
	MagnetURI string
	Torrent   []byte
}

type ResourceMap 

type ResourceMap struct {
	lazymap.LazyMap
	// contains filtered or unexported fields
}

func NewResourceMap 

func NewResourceMap(ts TorrentStoreGetter, m2t Magnet2TorrentGetter) *ResourceMap

func (*ResourceMap) Get 

func (s *ResourceMap) Get(b []byte) (*Resource, error)

type ResourceResponse 

type ResourceResponse struct {
	ID        string `json:"id"`
	Name      string `json:"name,omitempty"`
	MagnetURI string `json:"magnet_uri,omitempty"`
}

type ResourceType 

type ResourceType int
const (
	ResourceTypeHash ResourceType = iota
	ResourceTypeMagnet
	ResourceTypeTorrent
	ResourceTypeSha1
)

type ServiceType 

type ServiceType string
const (
	ServiceTypeArchive                    ServiceType = "arch"
	ServiceTypeDownloadProgress           ServiceType = "dp"
	ServiceTypeTorrentCache               ServiceType = "tc"
	ServiceTypeMultibitrateTranscodeCache ServiceType = "mtrc"
	ServiceTypeTranscodeCache             ServiceType = "trc"
	ServiceTypeTranscode                  ServiceType = "hls"
	ServiceTypeVOD                        ServiceType = "vod"
	ServiceTypeSRT2VTT                    ServiceType = "vtt"
	ServiceTypeVideoInfo                  ServiceType = "vi"
)

type StreamExporter 

type StreamExporter struct {
	BaseExporter
	// contains filtered or unexported fields
}

func NewStreamExporter 

func NewStreamExporter(ub *URLBuilder, tb *TagBuilder) *StreamExporter

func (*StreamExporter) Export 

func (s *StreamExporter) Export(r *Resource, i *ListItem, g ParamGetter) (*ExportItem, error)

func (*StreamExporter) MakeExportStreamItem 

func (s *StreamExporter) MakeExportStreamItem(r *Resource, i *ListItem, g ParamGetter) (*ExportStreamItem, error)

func (*StreamExporter) Type 

func (s *StreamExporter) Type() ExportType

type StreamURLBuilder 

type StreamURLBuilder struct {
	BaseURLBuilder
	// contains filtered or unexported fields
}

func (*StreamURLBuilder) Build 

func (s *StreamURLBuilder) Build() (u *MyURL, err error)

func (*StreamURLBuilder) BuildAudioStreamURL 

func (s *StreamURLBuilder) BuildAudioStreamURL(i *MyURL, suffix string) (u *MyURL, err error)

func (*StreamURLBuilder) BuildSRT2VTTURL 

func (s *StreamURLBuilder) BuildSRT2VTTURL(i *MyURL) (u *MyURL)

func (*StreamURLBuilder) BuildStreamURL 

func (s *StreamURLBuilder) BuildStreamURL(i *MyURL, suffix string) (u *MyURL, err error)

func (*StreamURLBuilder) BuildSubtitleStreamURL 

func (s *StreamURLBuilder) BuildSubtitleStreamURL(i *MyURL) (u *MyURL, err error)

func (*StreamURLBuilder) BuildTranscodeCacheURL 

func (s *StreamURLBuilder) BuildTranscodeCacheURL(i *MyURL, multi bool, suffix string) (u *MyURL, ok bool, err error)

func (*StreamURLBuilder) BuildTranscodeURL 

func (s *StreamURLBuilder) BuildTranscodeURL(i *MyURL, suffix string) (u *MyURL)

func (*StreamURLBuilder) BuildVODURL 

func (s *StreamURLBuilder) BuildVODURL(i *MyURL, suffix string) (u *MyURL)

func (*StreamURLBuilder) BuildVideoStreamURL 

func (s *StreamURLBuilder) BuildVideoStreamURL(i *MyURL, suffix string) (u *MyURL, err error)

type Subdomains 

type Subdomains struct {
	// contains filtered or unexported fields
}

func NewSubdomains 

func NewSubdomains(c *cli.Context, nsp *NodesStat) *Subdomains

func (*Subdomains) Get 

func (s *Subdomains) Get(infohash string, pool string) ([]string, error)

type Subtitles 

type Subtitles struct {
	URL string `json:"url"`
}

type SubtitlesExporter 

type SubtitlesExporter struct {
	BaseExporter
}

func NewSubtitlesExporter 

func NewSubtitlesExporter(ub *URLBuilder) *SubtitlesExporter

func (*SubtitlesExporter) Export 

func (s *SubtitlesExporter) Export(r *Resource, i *ListItem, g ParamGetter) (*ExportItem, error)

type SubtitlesURLBuilder 

type SubtitlesURLBuilder struct {
	BaseURLBuilder
}

func (*SubtitlesURLBuilder) Build 

func (s *SubtitlesURLBuilder) Build() (u *MyURL, err error)

func (*SubtitlesURLBuilder) BuildSubtitlesURL 

func (s *SubtitlesURLBuilder) BuildSubtitlesURL(i *MyURL) (u *MyURL)

type TagBuilder 

type TagBuilder struct {
	// contains filtered or unexported fields
}

func NewTagBuilder 

func NewTagBuilder(ub *URLBuilder, l *List) *TagBuilder

func (*TagBuilder) Build 

func (s *TagBuilder) Build(r *Resource, i *ListItem, g ParamGetter) (*ExportTag, error)

type TorrentStatExporter 

type TorrentStatExporter struct {
	BaseExporter
}

func NewTorrentStatExporter 

func NewTorrentStatExporter(ub *URLBuilder) *TorrentStatExporter

func (*TorrentStatExporter) Export 

func (s *TorrentStatExporter) Export(r *Resource, i *ListItem, g ParamGetter) (*ExportItem, error)

type TorrentStatURLBuilder 

type TorrentStatURLBuilder struct {
	BaseURLBuilder
}

func (*TorrentStatURLBuilder) Build 

func (s *TorrentStatURLBuilder) Build() (u *MyURL, err error)

func (*TorrentStatURLBuilder) BuildStatURL 

func (s *TorrentStatURLBuilder) BuildStatURL(i *MyURL) *MyURL

type TorrentStore 

type TorrentStore struct {
	// contains filtered or unexported fields
}

func NewTorrentStore 

func NewTorrentStore(c *cli.Context) *TorrentStore

func (*TorrentStore) Close 

func (s *TorrentStore) Close()

func (*TorrentStore) Get 

func (s *TorrentStore) Get() (ts.TorrentStoreClient, error)

type TorrentStoreClientMock 

type TorrentStoreClientMock struct {
	mock.Mock
}

func (*TorrentStoreClientMock) Pull 

func (s *TorrentStoreClientMock) Pull(ctx context.Context, in *tsp.PullRequest, opts ...grpc.CallOption) (*tsp.PullReply, error)

func (*TorrentStoreClientMock) Push 

func (s *TorrentStoreClientMock) Push(ctx context.Context, in *tsp.PushRequest, opts ...grpc.CallOption) (*tsp.PushReply, error)

func (*TorrentStoreClientMock) Touch 

func (s *TorrentStoreClientMock) Touch(ctx context.Context, in *tsp.TouchRequest, opts ...grpc.CallOption) (*tsp.TouchReply, error)

type TorrentStoreGetter 

type TorrentStoreGetter interface {
	Get() (tsp.TorrentStoreClient, error)
}

type TorrentStoreMock 

type TorrentStoreMock struct {
	// contains filtered or unexported fields
}

func NewTorrentStoreMock 

func NewTorrentStoreMock() *TorrentStoreMock

func (*TorrentStoreMock) Get 

func (s *TorrentStoreMock) Get() (tsp.TorrentStoreClient, error)

type TranscodeDoneMap 

type TranscodeDoneMap struct {
	lazymap.LazyMap
	// contains filtered or unexported fields
}

func NewTranscodeDoneMap 

func NewTranscodeDoneMap(c *cli.Context, cl *http.Client) *TranscodeDoneMap

func (*TranscodeDoneMap) Get 

func (s *TranscodeDoneMap) Get(prefix string, hash string, path string) (bool, error)

type URLBuilder 

type URLBuilder struct {
	// contains filtered or unexported fields
}

func NewURLBuilder 

func NewURLBuilder(c *cli.Context, cpm *CompletedPiecesMap, tdm *TranscodeDoneMap, sd *Subdomains) *URLBuilder

func (*URLBuilder) Build 

func (s *URLBuilder) Build(r *Resource, i *ListItem, g ParamGetter, et ExportType) (*MyURL, error)

type VideoTagBuider 

type VideoTagBuider struct {
	BaseTagBulder
	// contains filtered or unexported fields
}

func (*VideoTagBuider) Build 

func (s *VideoTagBuider) Build() (*ExportTag, error)

func (*VideoTagBuider) BuildAttachedResources 

func (s *VideoTagBuider) BuildAttachedResources(et *ExportTag) (*ExportTag, error)

func (*VideoTagBuider) BuildTrack 

func (s *VideoTagBuider) BuildTrack(i *ListItem) (*ExportTrack, error)

type Web 

type Web struct {
	// contains filtered or unexported fields
}

func NewWeb 

func NewWeb(c *cli.Context, rm *ResourceMap, co *List, ex *Export) *Web

func (*Web) Close 

func (s *Web) Close()

func (*Web) Serve 

func (s *Web) Serve() error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.