Documentation
¶
Index ¶
- Variables
- type Executor
- func (e *Executor) DesiredStepState(step executable.Executable, req *request.CoordinatedRequest) (map[string][]byte, error)
- func (e *Executor) Do(jobType string, req *request.CoordinatedRequest, ctx *vk.Ctx, cb grav.MsgFunc) (interface{}, error)
- func (e *Executor) ListenAndRun(msgType string, run func(grav.Message, interface{}, error)) error
- func (e *Executor) Load(source appsource.AppSource) error
- func (e *Executor) Metrics() (*rt.ScalerMetrics, error)
- func (e *Executor) Register(jobType string, runner rt.Runnable, capConfig *rcap.CapabilityConfig, ...) error
- func (e *Executor) Send(msg grav.Message)
- func (e *Executor) SetSchedule(sched rt.Schedule) error
- func (e *Executor) UseGrav(g *grav.Grav)
Constants ¶
This section is empty.
Variables ¶
Functions ¶
This section is empty.
Types ¶
type Executor ¶
type Executor struct {
// contains filtered or unexported fields
}
Executor is a facade over Grav and Reactr that allows executing local OR remote functions with a single call, ensuring there is no difference between them to the caller.
func NewWithGrav ¶ added in v0.4.3
NewWithGrav creates an Executor with a custom Grav instance.
func (*Executor) DesiredStepState ¶ added in v0.4.3
func (e *Executor) DesiredStepState(step executable.Executable, req *request.CoordinatedRequest) (map[string][]byte, error)
DesiredStepState calculates the state as it should be for a particular step's 'with' clause.
func (*Executor) Do ¶
func (e *Executor) Do(jobType string, req *request.CoordinatedRequest, ctx *vk.Ctx, cb grav.MsgFunc) (interface{}, error)
Do executes a local or remote job.
func (*Executor) ListenAndRun ¶ added in v0.4.3
ListenAndRun sets up the executor's Reactr instance to listen for messages and execute the associated job.
func (*Executor) Load ¶
Load loads Runnables into the executor's Reactr instance And connects them to the Grav instance.
func (*Executor) Metrics ¶
func (e *Executor) Metrics() (*rt.ScalerMetrics, error)
Metrics returns the executor's Reactr isntance's internal metrics.
func (*Executor) Register ¶
func (e *Executor) Register(jobType string, runner rt.Runnable, capConfig *rcap.CapabilityConfig, opts ...rt.Option) error
Register registers a Runnable.
func (*Executor) SetSchedule ¶
SetSchedule adds a Schedule to the executor's Reactr instance.
Source Files