Documentation
¶
Overview ¶
Package pipelinesteps provides a plugin that registers generic pipeline step types: validate, transform, conditional, set, log, delegate, jq, publish, http_call, request_parse, db_query, db_exec, json_response. It also provides the PipelineWorkflowHandler for composable pipelines.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Plugin ¶
type Plugin struct {
plugin.BaseEnginePlugin
// contains filtered or unexported fields
}
Plugin registers generic pipeline step factories and the pipeline workflow handler.
func (*Plugin) Capabilities ¶
func (p *Plugin) Capabilities() []capability.Contract
Capabilities returns the capability contracts defined by this plugin.
func (*Plugin) PipelineHandler ¶
func (p *Plugin) PipelineHandler() *handlers.PipelineWorkflowHandler
PipelineHandler returns the plugin's pipeline handler instance, if created. This is used by the engine's wiring hook to inject StepRegistry and Logger.
func (*Plugin) StepFactories ¶
func (p *Plugin) StepFactories() map[string]plugin.StepFactory
StepFactories returns the step factories provided by this plugin.
func (*Plugin) WorkflowHandlers ¶
func (p *Plugin) WorkflowHandlers() map[string]plugin.WorkflowHandlerFactory
WorkflowHandlers returns the pipeline workflow handler factory.
Source Files