Documentation ¶
Index ¶
- type Router
- func (r *Router) Fail(node anemos.Node, instance *api.TaskInstance)
- func (r *Router) RegisterSession(session anemos.Session)
- func (r *Router) SignalDownstream(node anemos.Node)
- func (r *Router) StartTask(node anemos.Node, instance *api.TaskInstance)
- func (r *Router) StartVirtual(node anemos.Node, instance *api.TaskInstance)
- func (r *Router) Trigger(event *api.Event)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Router ¶
func (*Router) Fail ¶
func (r *Router) Fail(node anemos.Node, instance *api.TaskInstance)
func (*Router) RegisterSession ¶
func (r *Router) RegisterSession(session anemos.Session)
func (*Router) SignalDownstream ¶
func (r *Router) SignalDownstream(node anemos.Node)
func (*Router) StartTask ¶
func (r *Router) StartTask(node anemos.Node, instance *api.TaskInstance)
func (*Router) StartVirtual ¶
func (r *Router) StartVirtual(node anemos.Node, instance *api.TaskInstance)
Click to show internal directories.
Click to hide internal directories.