diff --git a/config/options.go b/config/options.go index 9dd7443b..667d3262 100644 --- a/config/options.go +++ b/config/options.go @@ -197,7 +197,7 @@ func NewWatchOptions(opts ...options.Option) WatchOptions { } // Coalesce controls watch event combining -func Coalesce(b bool) options.Option { +func WatchCoalesce(b bool) options.Option { return func(src interface{}) error { return options.Set(src, b, ".Coalesce") } diff --git a/flow/options.go b/flow/options.go index 723ca21e..344c0b75 100644 --- a/flow/options.go +++ b/flow/options.go @@ -134,3 +134,10 @@ func Fallback(step string) options.Option { return options.Set(src, step, ".Fallback") } } + +// ID sets the step ID +func StepID(id string) options.Option { + return func(src interface{}) error { + return options.Set(src, id, ".ID") + } +} diff --git a/options/options.go b/options/options.go index 43f035ec..cda572a6 100644 --- a/options/options.go +++ b/options/options.go @@ -187,10 +187,3 @@ func Timeout(td time.Duration) Option { return Set(src, td, ".Timeout") } } - -// ID sets the step ID -func StepID(id string) Option { - return func(src interface{}) error { - return Set(src, id, ".ID") - } -}