Versions in this module Expand all Collapse all v0 v0.2.0 May 14, 2019 Changes in this version + func New(ctx activity.InitContext) (activity.Activity, error) + func NewSlidingTimeWindow(function string, settings *window.Settings) (window.TimeWindow, error) + func NewSlidingWindow(function string, settings *window.Settings) (window.Window, error) + func NewTumblingTimeWindow(function string, settings *window.Settings) (window.TimeWindow, error) + func NewTumblingWindow(function string, settings *window.Settings) (window.Window, error) + type Activity struct + func (a *Activity) Eval(ctx activity.Context) (done bool, err error) + func (a *Activity) Metadata() *activity.Metadata + func (a *Activity) PostEval(ctx activity.Context, userData interface{}) (done bool, err error) + type Input struct + Value interface{} + type Output struct + Report bool + Result interface{} + type Settings struct + AdditionalSettings string + Function string + ProceedOnlyOnEmit bool + Resolution int + WindowSize int + WindowType string Other modules containing this package github.com/project-flogo/stream
Go to main page