Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Transformer ¶
type Transformer struct{}
Transformer implements the pipeline.Transformer interface for MCP, A2A, and Agent Skill sources.
func NewTransformer ¶
func NewTransformer() *Transformer
NewTransformer creates a transformer for MCP, A2A, and Agent Skill pipeline items.
func (*Transformer) Transform ¶
func (t *Transformer) Transform(ctx context.Context, inputCh <-chan types.SourceItem, result *types.Result) (<-chan *corev1.Record, <-chan error)
runTransformStage runs the transformation stage with concurrent workers. This is a shared function used by both Pipeline and DryRunPipeline. It always tracks the total records it processes (non-duplicates after filtering).
func (*Transformer) TransformRecord ¶
func (t *Transformer) TransformRecord(item types.SourceItem) (*corev1.Record, error)
TransformRecord converts a pipeline source item (MCP, A2A, or Agent Skill) to OASF format.
Source Files
Click to show internal directories.
Click to hide internal directories.