Versions in this module Expand all Collapse all v1 v1.0.2 Sep 22, 2023 Changes in this version + type ActionFactory struct + func (f *ActionFactory) Initialize(ctx action.InitContext) error + func (f *ActionFactory) New(config *action.Config) (action.Action, error) + type Settings struct + GroupBy string + OutputChannel string + PipelineURI string + StreamURI string + type StreamAction struct + func (s *StreamAction) IOMetadata() *metadata.IOMetadata + func (s *StreamAction) Info() *action.Info + func (s *StreamAction) Metadata() *action.Metadata + func (s *StreamAction) Run(context context.Context, inputs map[string]interface{}, ...) error
Go to main page