Documentation
¶
Index ¶
- func GetMsgChan() chan *message.CardMessageFuture
- func GetRouter() *mux.Router
- type FS
- func (fs *FS) Add(...)
- func (fs *FS) AddLocal(methods []string, ...)
- func (fs *FS) AddShared(methods []string, ...)
- func (fs *FS) Call(id string, source *task.Collection, result *task.Collection, ...) bool
- func (fs *FS) GetExecutor(name string) (iexecutor.IExecutor, error)
- func (fs *FS) GetJob(id string) (*task.Job, error)
- func (fs *FS) GetLimiter(name string) (*rate.Limiter, error)
- func (fs *FS) GetLocal(key string) (*JobFunc, error)
- func (fs *FS) GetShared(key string) (*JobFunc, error)
- func (fs *FS) HAdd(...) (hash string)
- func (fs *FS) SetExecutor(exe iexecutor.IExecutor, name string)
- func (fs *FS) SetJob(j *task.Job)
- func (fs *FS) SetLimiter(name string, r rate.Limit, b int)
- func (fs *FS) SetLocal(key string, val *JobFunc)
- func (fs *FS) SetMapper(mp imapper.IMapper, name string)
- func (fs *FS) SetReducer(rd ireducer.IReducer, name string)
- func (fs *FS) SetShared(key string, val *JobFunc)
- type JobFunc
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GetMsgChan ¶
func GetMsgChan() chan *message.CardMessageFuture
Types ¶
type FS ¶
type FS struct {
Funcs map[string]func(source *task.Collection,
result *task.Collection,
context *task.TaskContext) bool
LocalJobs map[string]*JobFunc
// contains filtered or unexported fields
}
func GetInstance ¶
func GetInstance() *FS
func (*FS) Add ¶
func (fs *FS) Add(f func(source *task.Collection, result *task.Collection, context *task.TaskContext) bool, id ...string)
func (*FS) AddLocal ¶
func (fs *FS) AddLocal(methods []string, jobs ...func(w http.ResponseWriter, r *http.Request, bg *task.Background))
func (*FS) AddShared ¶
func (fs *FS) AddShared(methods []string, jobs ...func(w http.ResponseWriter, r *http.Request, bg *task.Background))
func (*FS) Call ¶
func (fs *FS) Call(id string, source *task.Collection, result *task.Collection, context *task.TaskContext) bool
func (*FS) HAdd ¶
func (fs *FS) HAdd(f func(source *task.Collection, result *task.Collection, context *task.TaskContext) bool) (hash string)
type JobFunc ¶
type JobFunc struct {
F func(w http.ResponseWriter, r *http.Request, bg *task.Background)
Methods []string
Signature string
}
Source Files
Click to show internal directories.
Click to hide internal directories.