store

Documentation

Index

• func GetMsgChan() chan *message.CardMessageFuture
• func GetRouter() *mux.Router
• type FS
  • func GetInstance() *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

Functions

func GetMsgChan

func GetMsgChan() chan *message.CardMessageFuture

func GetRouter

func GetRouter() *mux.Router

Types

type FS

type FS struct {
	Funcs map[string]func(source *task.Collection,
		result *task.Collection,
		context *task.TaskContext) bool

	SharedJobs map[string]*JobFunc
	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) GetExecutor

func (fs *FS) GetExecutor(name string) (iexecutor.IExecutor, error)

func (*FS) GetJob

func (fs *FS) GetJob(id string) (*task.Job, error)

func (*FS) GetLimiter

func (fs *FS) GetLimiter(name string) (*rate.Limiter, error)

func (*FS) GetLocal

func (fs *FS) GetLocal(key string) (*JobFunc, error)

func (*FS) GetShared

func (fs *FS) GetShared(key string) (*JobFunc, error)

func (*FS) HAdd

func (fs *FS) HAdd(f func(source *task.Collection,
	result *task.Collection,
	context *task.TaskContext) bool) (hash string)

func (*FS) SetExecutor

func (fs *FS) SetExecutor(exe iexecutor.IExecutor, name string)

func (*FS) SetJob

func (fs *FS) SetJob(j *task.Job)

func (*FS) SetLimiter

func (fs *FS) SetLimiter(name string, r rate.Limit, b int)

func (*FS) SetLocal

func (fs *FS) SetLocal(key string, val *JobFunc)

func (*FS) SetMapper

func (fs *FS) SetMapper(mp imapper.IMapper, name string)

func (*FS) SetReducer

func (fs *FS) SetReducer(rd ireducer.IReducer, name string)

func (*FS) SetShared

func (fs *FS) SetShared(key string, val *JobFunc)

type JobFunc

type JobFunc struct {
	F         func(w http.ResponseWriter, r *http.Request, bg *task.Background)
	Methods   []string
	Signature string
}