conversion

Dec 9, 2019

Changes in this version

+ func InitFFTool()

+ type Config = fftool.Config

+ type Queue struct

+ func NewQueue(c cacher.Cacher) *Queue

+ func (q *Queue) Add(s string)

+ func (q *Queue) Delete(s string)

+ func (q *Queue) Finish(s string)

+ func (q *Queue) Get() (v string, b bool)

+ func (q *Queue) Has(s string) bool

+ func (q *Queue) IsRunning(s string) (b bool)

+ func (q *Queue) List() []string

+ func (q *Queue) Restore() ([]string, error)

+ func (q *Queue) Running(work IWork) (b bool)

+ func (q *Queue) Stop(id string)

type Task

+ ClearTemp bool

type WorkImpl

+ ClearTemp bool

type WorkOptions

+ func ClearTempOption(b bool) WorkOptions

Nov 12, 2019

Changes in this version

type Video

+ No string

Nov 12, 2019

Changes in this version

type Video

+ func (v Video) JSONVersion() string

Nov 12, 2019

Changes in this version

+ func MakeDatabaseInstance(options ...ConfigOptions) (*xorm.Engine, error)

type ConfigOptions

+ func CreateDatabaseOption() ConfigOptions

+ func DBType(p string) ConfigOptions

type Video

+ func (v Video) MarshalJSONVersion() (string, string, error)

+ func (v Video) Version() string

Nov 1, 2019

Changes in this version

type Running

+ func (r *Running) IsRunning(s string) (b bool)

Nov 1, 2019

Changes in this version

type Task

+ Interval int

Nov 1, 2019

Changes in this version

+ type Running struct

+ func (r *Running) Add(s string)

+ func (r *Running) Delete(s string)

+ func (r *Running) Finish(s string)

+ func (r *Running) Has(s string) (b bool)

+ func (r *Running) List() []string

+ func (r *Running) Restore() ([]string, error)

+ func (r *Running) Running(work IWork) (b bool)

+ func (r *Running) Stop(id string)

Oct 31, 2019

Changes in this version

+ const NodeTypeCluster

+ const NodeTypeDummy

+ const NodeTypeSingle

+ func CidHash(path path.Resolved) string

+ func RegisterNode(node Node)

+ type Node interface

+ AddDir func(ctx context.Context, dir string) (string, error)

+ AddFile func(ctx context.Context, filename string) (string, error)

+ ID func() *PeerID

+ PinCheck func(ctx context.Context, hash ...string) (int, error)

+ PinHash func(ctx context.Context, hash string) error

+ Type func() string

+ UnpinHash func(ctx context.Context, hash string) error

+ func NewClusterNode(cfg *api.Config) Node

+ func NewSingleNode(addr string) Node

Oct 28, 2019

Changes in this version

type IWork

+ Stop func() error

type Task

+ func (t *Task) AllRun() (works []IWork, e error)

+ func (t *Task) StartWork(id string) error

+ func (t *Task) StopWork(id string)

Oct 28, 2019

Changes in this version

type IWork

+ Video func() *Video

+ Work func() *Work

type Work

+ func (w *Work) Video() *Video

+ func (w *Work) Work() *Work

Oct 28, 2019

Changes in this version

+ var CachePath = cache.DefaultPath

+ var ErrWorkID = errors.New("video id must input")

+ func RegisterCache()

+ func SetCachePath(path string)

type IWork

+ Info func() string

type Task

+ func (t *Task) GetWork(id string) (IWork, error)

+ func (t *Task) GetWorkStatus(id string) (WorkStatus, error)

type Work

+ func (w *Work) Info() []byte

type WorkStatus

+ const WorkAbnormal

Oct 25, 2019

Changes in this version

+ var DefaultLimit = 3

+ var DefaultNode = "/ip4/127.0.0.1/tcp/5001"

+ var ErrWorkFinish = errors.New("Work was finished")

+ var ErrWrongCastType = errors.New("something wrong when cast to type")

+ var WorkRunProcessFunction = map[string]VideoProcessFunc

+ func AddDir(ctx context.Context, dir string) (string, error)

+ func AddFile(ctx context.Context, filename string) (string, error)

+ func AddTaskMessage(s string) error

+ func AllHash(session *xorm.Session, limit int, start ...int) (unfins *[]*Hash, e error)

+ func ByteIndex(idx byte) int

+ func CheckDatabase() bool

+ func CheckNode() bool

+ func Checksum(filepath string) string

+ func ConnectToNode() (e error)

+ func DeleteTaskMessage(s string) error

+ func ExistVerifyFunc(tp string, f func(interface{}) string, v ...interface{}) bool

+ func ExistVerifyString(tp string, v ...string) bool

+ func FileAbsName(filename string) string

+ func FileName(filename string) string

+ func FindAll(model IModel, f FindResult, limit int, start ...int) (e error)

+ func GetFileIndex(filename string) int

+ func GetFiles(name string, regex string) (files []string)

+ func GetNameIndex(name string) int

+ func IndexByte(index int) byte

+ func InitMySQL(ops ...ConfigOptions) (*xorm.Engine, error)

+ func InitSQLite3(name string) (eng *xorm.Engine, e error)

+ func InsertOrUpdate(m IModel) (i int64, e error)

+ func IsExist(m IModel) bool

+ func IsMedia(format *split.StreamFormat) bool

+ func IsPicture(name string) bool

+ func IsVideo(filename string) bool

+ func LastSplit(s, sep string) string

+ func MustDatabase(engine *xorm.Engine, err error) *xorm.Engine

+ func MustSession(session *xorm.Session) *xorm.Session

+ func MustString(val, src string) string

+ func PinCheck(ctx context.Context, hash ...string) (int, error)

+ func PinHash(ctx context.Context, hash string) error

+ func RegisterDatabase(engine *xorm.Engine)

+ func ResolvedHash(path path.Resolved) (string, error)

+ func SetNodeAddress(addr string)

+ func SetNodePath(path string)

+ func SyncTable() (e error)

+ func UUID() uuid.UUID

+ func UnpinHash(ctx context.Context, hash string) error

+ func Wrap(err error) error

+ type Actor struct

+ Alias []string

+ Image string

+ Name string

+ StarLink string

+ type BeforeInsert interface

+ BeforeInsert func()

+ type ConfigOptions func(config *dbConfig)

+ func LoginOption(addr, user, pass string) ConfigOptions

+ func SchemaOption(s string) ConfigOptions

+ func ShowSQLOptions(b bool) ConfigOptions

+ func UseCacheOptions(b bool) ConfigOptions

+ type Extend struct

+ Message string

+ Path string

+ type FindResult func(rows *xorm.Rows) error

+ type Fragment struct

+ func (s Fragment) Output() string

+ func (s Fragment) Scale() int64

+ func (s Fragment) Sharpness() string

+ type FragmentOption func(f *Fragment)

+ type Genre struct

+ Content string

+ URL string

+ type Hash struct

+ Caption string

+ Checksum string

+ Encrypt bool

+ Episode string

+ Hash string

+ HashType HashType

+ Key string

+ M3U8 string

+ Name string

+ Resource string

+ SegmentFile string

+ Sharpness string

+ func FindHash(session *xorm.Session, checksum string) (unfin *Hash, e error)

+ func (h *Hash) Clone() (n *Hash)

+ func (h *Hash) Sync() error

+ func (h *Hash) Table() interface{}

+ type HashType string

+ const HashTypeCaption

+ const HashTypeOther

+ const HashTypePoster

+ const HashTypeSlice

+ const HashTypeThumb

+ const HashTypeVideo

+ type IModel interface

+ ID func() string

+ SetID func(string)

+ SetVersion func(int)

+ Table func() interface{}

+ Version func() int

+ type ISync interface

+ Sync func() error

+ type IVideo interface

+ Video func() *Video

+ func VideoFromInfo(ctx context.Context, Work *Work) (IVideo, error)

+ func VideoFromSource(Work *Work) (IVideo, error)

+ type IWork interface

+ ID func() string

+ Reset func() error

+ Run func(ctx context.Context) (e error)

+ Status func() WorkStatus

+ Store func() error

+ Update func() error

+ func LoadWork(id string) (IWork, error)

+ func NewInfoWork(info *VideoPornInfo, options ...WorkOptions) (IWork, error)

+ func NewSourceWork(source *VideoPornSource, options ...WorkOptions) (IWork, error)

+ type Model struct

+ func (m *Model) BeforeInsert()

+ func (m *Model) SetID(id string)

+ func (m *Model) SetVersion(v int)

+ func (m Model) ID() string

+ func (m Model) Version() int

+ type PeerID struct

+ Addresses []string

+ AgentVersion string

+ ID string

+ ProtocolVersion string

+ PublicKey string

+ func MyID() *PeerID

+ type PoolMessage map[string][]byte

+ func LoadTaskMessage() (PoolMessage, error)

+ type RunType string

+ const RunTypeJSON

+ const RunTypePath

+ type Sample struct

+ Image string

+ Index int64

+ Thumb string

+ Title string

+ type Scale int64

+ const HighScale

+ const LowScale

+ const MiddleScale

+ type Task struct

+ Limit int

+ func NewTask() *Task

+ func (t *Task) AddWorker(Work IWork) error

+ func (t *Task) AutoStop() bool

+ func (t *Task) Finish(id string)

+ func (t *Task) Restore() error

+ func (t *Task) Running(id string) (b bool)

+ func (t *Task) SetAutoStop(autoStop bool)

+ func (t *Task) Start() error

+ func (t *Task) Stop()

+ type Video struct

+ Alias []string

+ BanNo string

+ Caption string

+ Date string

+ Director string

+ Episode string

+ Format string

+ Group string

+ Index string

+ Intro string

+ Key string

+ Language string

+ Length string

+ M3U8 string

+ M3U8Hash string

+ PosterHash string

+ Producer string

+ Publisher string

+ Role []string

+ Sample []string

+ Season string

+ Series string

+ Sharpness string

+ SourceHash string

+ Systematics string

+ Tags []string

+ ThumbHash string

+ TotalEpisode string

+ Type string

+ Uncensored bool

+ func (v *Video) BeforeInsert()

+ func (v *Video) Sync() error

+ func (v *Video) Table() interface{}

+ type VideoPornInfo struct

+ Actors []*Actor

+ From string

+ Genres []*Genre

+ ID string

+ Image string

+ MovieSet string

+ OriginalTitle string

+ Plot string

+ ReleaseDate string

+ Sample []*Sample

+ Studio string

+ Thumb string

+ Title string

+ Uncensored bool

+ Year string

+ func (v VideoPornInfo) Video() *Video

+ type VideoPornSource struct

+ Alias []string

+ Bangumi string

+ Caption string

+ Date string

+ Director string

+ ExtendList []*Extend

+ Format string

+ Intro string

+ Language string

+ Length string

+ Poster string

+ PosterPath string

+ Producer string

+ Publisher string

+ Role []string

+ Series string

+ SourceHash string

+ Tags []string

+ Thumb string

+ ThumbPath string

+ Uncensored bool

+ VideoPath []string

+ func (v VideoPornSource) Video() *Video

+ type VideoProcessFunc func(src []byte) (IVideo, error)

+ type Work struct

+ Value []byte

+ WorkType string

+ func (w *Work) Reset() error

+ func (w *Work) Run(ctx context.Context) (e error)

+ func (w *Work) Status() WorkStatus

+ func (w *Work) Stop() error

+ func (w *Work) Store() error

+ func (w *Work) Update() error

+ func (w Work) CheckStop(f func() error) error

+ func (w Work) ID() string

+ func (w Work) Output() string

+ type WorkImpl struct

+ ID string

+ Output string

+ PosterPath string

+ SamplePath []string

+ Scale Scale

+ Skip []string

+ Status WorkStatus

+ ThumbPath string

+ VideoPaths []string

+ type WorkOptions func(impl *WorkImpl)

+ func IDOption(id string) WorkOptions

+ func OutputPathOption(path string) WorkOptions

+ func PosterPathOption(path string) WorkOptions

+ func SamplePathOption(path []string) WorkOptions

+ func ScaleOption(scale Scale) WorkOptions

+ func SkipOption(skip ...string) WorkOptions

+ func ThumbPathOption(path string) WorkOptions

+ func VideoPathOption(path []string) WorkOptions

+ type WorkStatus int

+ const WorkFinish

+ const WorkRunning

+ const WorkStopped

+ const WorkWaiting