Documentation
¶
Index ¶
- Variables
- type Executor
- func (e *Executor) Do(jobType string, data interface{}, ctx *vk.Ctx) (interface{}, error)
- func (e *Executor) Load(runnables []directive.Runnable) error
- func (e *Executor) Metrics() (*rt.ScalerMetrics, error)
- func (e *Executor) Register(jobType string, runner rt.Runnable, opts ...rt.Option) error
- func (e *Executor) SetSchedule(sched rt.Schedule) error
- func (e *Executor) UseCapabilityConfig(config rcap.CapabilityConfig) error
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrExecutorNotConfigured = errors.New("executor not fully configured") ErrCannotHandle = errors.New("cannot handle job") )
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 (*Executor) Load ¶
Load loads Runnables into the executor's Reactr instance And connects them to the Grav instance (currently unused)
func (*Executor) Metrics ¶
func (e *Executor) Metrics() (*rt.ScalerMetrics, error)
Metrics returns the executor's Reactr isntance's internal metrics
func (*Executor) SetSchedule ¶
SetSchedule adds a Schedule to the executor's Reactr instance
func (*Executor) UseCapabilityConfig ¶
func (e *Executor) UseCapabilityConfig(config rcap.CapabilityConfig) error
UseCapabilityConfig sets up the executor's Reactr instance using the provided capability configuration
Source Files
Click to show internal directories.
Click to hide internal directories.