Versions in this module Expand all Collapse all v0 v0.1.0 Sep 5, 2018 Changes in this version + type ActionFactory struct + func (f *ActionFactory) Init() error + func (f *ActionFactory) New(config *action.Config) (action.Action, error) + type Settings struct + GroupBy string + OutputChannel string + PipelineURI string + type StreamAction struct + func (s *StreamAction) IOMetadata() *data.IOMetadata + func (s *StreamAction) Metadata() *action.Metadata + func (s *StreamAction) Run(context context.Context, inputs map[string]*data.Attribute, ...) error
Go to main page