|
|
@ -112,8 +112,7 @@ type Flow struct {
|
|
|
|
Stream bool
|
|
|
|
Stream bool
|
|
|
|
done chan struct{}
|
|
|
|
done chan struct{}
|
|
|
|
|
|
|
|
|
|
|
|
Id uuid.UUID
|
|
|
|
Id uuid.UUID
|
|
|
|
State map[string]interface{} // Can add value by addon
|
|
|
|
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
func (f *Flow) MarshalJSON() ([]byte, error) {
|
|
|
|
func (f *Flow) MarshalJSON() ([]byte, error) {
|
|
|
@ -126,9 +125,8 @@ func (f *Flow) MarshalJSON() ([]byte, error) {
|
|
|
|
|
|
|
|
|
|
|
|
func NewFlow() *Flow {
|
|
|
|
func NewFlow() *Flow {
|
|
|
|
return &Flow{
|
|
|
|
return &Flow{
|
|
|
|
done: make(chan struct{}),
|
|
|
|
done: make(chan struct{}),
|
|
|
|
Id: uuid.NewV4(),
|
|
|
|
Id: uuid.NewV4(),
|
|
|
|
State: make(map[string]interface{}),
|
|
|
|
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|