Documentation
¶
Index ¶
- Constants
- func APICallback(v interface{}, cb APICallbackFunc) (Stepper, APICaller)
- func AddDir(api *API, dir string) (path.Resolved, error)
- func AddFile(api *API, filename string) (path.Resolved, error)
- func DatabaseCallback(v interface{}, cb DatabaseCallbackFunc) (Stepper, DatabaseCaller)
- func DatabasePinCall(p chan<- *model.Pin, fn func(session *xorm.Session) *xorm.Session) (Stepper, DatabaseCaller)
- func DatabaseUnfinishedCall(u chan<- *model.Unfinished, fn func(session *xorm.Session) *xorm.Session) (Stepper, DatabaseCaller)
- func DatabaseVideoCall(v chan<- *model.Video, fn func(session *xorm.Session) *xorm.Session) (Stepper, DatabaseCaller)
- func GetFiles(p string) (files []string)
- func Hash(v interface{}) string
- func IndexNumber(index int) byte
- func IsPicture(name string) bool
- func IsVideo(filename string) bool
- func JSONRead(path string, v interface{}) error
- func JSONWrite(path string, v interface{}) error
- func LastSlice(s, sep string) string
- func MoveCall(from, to string) (Stepper, MoveCaller)
- func MustString(val, src string) string
- func NumberIndex(name string) int
- func OnlyName(name string) string
- func OnlyNo(name string) string
- func PathMD5(s ...string) string
- func ReadJSON(path string, v interface{}) (e error)
- func SkipTypeVerify(tp model.Type, v ...interface{}) bool
- func SkipVerify(tp string, v ...interface{}) bool
- func SliceCall(file string, u *model.Unfinished, cb SliceCallbackFunc) (Stepper, SliceCaller)
- func WriteJSON(path string, v interface{}) (e error)
- type API
- type APICallbackFunc
- type APICaller
- type AfterInitOptions
- type BeforeUpdate
- type Database
- type DatabaseArgs
- type DatabaseCallbackFunc
- type DatabaseCaller
- type Extend
- type Initer
- type Move
- type MoveCallbackFunc
- type MoveCaller
- type Optioner
- type Options
- type PeerID
- type Process
- type ProcessCallbackFunc
- type ProcessCaller
- type PushFunc
- type Pusher
- type Runnable
- type Scale
- type Seeder
- type Slice
- type SliceCallbackFunc
- type SliceCaller
- type State
- type Stepper
- type Task
- type TaskAble
- type TaskStep
- type Tasker
- type Thread
- type ThreadBase
- type ThreadRun
- type Threader
Constants ¶
View Source
const TimeOutLimit = 5 * time.Second
Variables ¶
This section is empty.
Functions ¶
func APICallback ¶
func APICallback(v interface{}, cb APICallbackFunc) (Stepper, APICaller)
APICallback ...
func DatabaseCallback ¶
func DatabaseCallback(v interface{}, cb DatabaseCallbackFunc) (Stepper, DatabaseCaller)
DatabaseCallback ...
func DatabasePinCall ¶
func DatabasePinCall(p chan<- *model.Pin, fn func(session *xorm.Session) *xorm.Session) (Stepper, DatabaseCaller)
DatabasePinCall ...
func DatabaseUnfinishedCall ¶
func DatabaseUnfinishedCall(u chan<- *model.Unfinished, fn func(session *xorm.Session) *xorm.Session) (Stepper, DatabaseCaller)
DatabaseUnfinishedCall ...
func DatabaseVideoCall ¶
func DatabaseVideoCall(v chan<- *model.Video, fn func(session *xorm.Session) *xorm.Session) (Stepper, DatabaseCaller)
DatabaseVideoCall ...
func SliceCall ¶
func SliceCall(file string, u *model.Unfinished, cb SliceCallbackFunc) (Stepper, SliceCaller)
SliceCall ...
Types ¶
type APICallbackFunc ¶
APICallbackFunc ...
type BeforeUpdate ¶
BeforeUpdate ...
type Database ¶
type Database struct {
*Thread
// contains filtered or unexported fields
}
Database ...
func NewDatabase ¶
func NewDatabase(eng *xorm.Engine, args ...DatabaseArgs) *Database
NewDatabase ...
type DatabaseArgs ¶
type DatabaseArgs func(*Database)
DatabaseArgs ...
func DatabaseShowExecTimeArg ¶
func DatabaseShowExecTimeArg() DatabaseArgs
DatabaseShowExecTimeArg ...
type DatabaseCallbackFunc ¶
DatabaseCallbackFunc ...
type DatabaseCaller ¶
DatabaseCaller ...
type PeerID ¶
type PeerID struct {
Addresses []string `json:"Addresses"`
AgentVersion string `json:"AgentVersion"`
ID string `json:"ID"`
ProtocolVersion string `json:"ProtocolVersion"`
PublicKey string `json:"PublicKey"`
}
PeerID ...
type Process ¶
type Process struct {
*Thread
// contains filtered or unexported fields
}
Process ...
type ProcessCallbackFunc ¶
ProcessCallbackFunc ...
type ProcessCaller ¶
ProcessCaller ...
type Scale ¶
type Scale int64
Scale ...
const HighScale Scale = 1080
HighScale ...
const LowScale Scale = 480
LowScale ...
const MiddleScale Scale = 720
MiddleScale ...
type Seeder ¶
type Seeder interface {
Start()
Wait()
Stop()
Context() context.Context
PushTo(stepper Stepper, v interface{}) error
GetThread(stepper Stepper) ThreadRun
SetThread(stepper Stepper, threader ThreadRun)
HasThread(stepper Stepper) bool
SetBaseThread(stepper Stepper, threader Threader)
IsBase(stepper Stepper) bool
SetNormalThread(stepper Stepper, threader ThreadRun)
IsNormal(stepper Stepper) bool
Register(ops ...Optioner)
RunTask(task *Task)
AddTasker(tasker Tasker)
}
Seeder ...
type Slice ¶
type Slice struct {
*Thread
Scale Scale
SliceOutput string
SkipType []interface{}
SkipExist bool
SkipSlice bool
// contains filtered or unexported fields
}
Slice ...
type SliceCallbackFunc ¶
SliceCallbackFunc ...
type Stepper ¶
type Stepper int
Stepper ...
const ( // StepperNone ... StepperNone Stepper = iota //StepperRDatabase ... //StepperRDatabase //StepperDatabase ... StepperDatabase //StepperAPI ... StepperAPI //StepperSlice ... StepperSlice // StepperProcess ... StepperProcess // StepperMoveInfo ... StepperMoveInfo // StepperMove ... StepperMove // StepperTransfer ... StepperTransfer // StepperPin ... StepperPin // StepperCheck ... StepperCheck // StepperUpdate ... StepperUpdate // StepperTask ... StepperTask // StepperMax ... StepperMax )
StepperNone ...
type ThreadBase ¶
ThreadBase ...
Source Files
¶
Click to show internal directories.
Click to hide internal directories.