anemos

type Executor interface {
	Execute(*api.TaskInstance)
}

type Group interface {
	Node
	AddNode(node Node)
	Resolve()
}

type Node interface {
	Provider() string
	Operation() string
	Name() string
	Attributes() map[string]string
	//Name() (string)
	AddUpstream(name string, node Node)
	AddDownstream(name string, node Node)
	Upstream() map[string]Node
	Downstream() map[string]Node
	Status() NodeInstanceStatus
	EndStateReached() bool
	AssignSession(session Session)

	OnEvent(event *api.Event)
	OnStart(event *api.Event)
	OnProgress(event *api.Event)
	OnFinish(event *api.Event)
	OnCancel(event *api.Event)
	OnSkip(event *api.Event)
}

type NodeInstanceStatus int

type Observer interface {
}

type Router interface {
	StartTask(node Node, instance *api.TaskInstance)
	StartVirtual(node Node, instance *api.TaskInstance)
	Fail(node Node, instance *api.TaskInstance)

	SignalDownstream(node Node)

	RegisterSession(session Session)
}

type Session interface {
	SetRouter(Router)
	Router() Router
	NewTaskInstance(node Node) *api.TaskInstance
}

type Trigger interface {
	Trigger(event *api.Event)
}

type Uri struct {
	Kind      string
	Provider  string
	Operation string
	Name      string
	Id        string
	Status    string
}