Versions in this module Expand all Collapse all v0 v0.0.1 Jul 5, 2020 Changes in this version + func ClusterManager(url string, token string) (res *clusterManager) + func StandaloneManager() (res *standaloneManager) + type Config struct + Name string + type IManager interface + Error func(err error) + type ITaskSetup interface + Run func() + Task func(name string, input func(input stream.IInputStream), ...) *stream.DataStream + func Cluster(url string, token string) ITaskSetup + func New(manager IManager) ITaskSetup + func Standalone() ITaskSetup