processor

May 31, 2026

Changes in this version

+ type AnnotationPart struct

+ Reports []Report

+ type BuiltinProcessor struct

+ func NewBuiltinProcessor(c *config.ProcessorConfig) (*BuiltinProcessor, error)

+ func (b *BuiltinProcessor) GetConfig() *config.ProcessorConfig

+ func (b *BuiltinProcessor) Process(input *DataContext) (*DataContext, error)

type DataContext

+ Annotations *AnnotationPart

+ type Finding = common.EventAnnotationFinding

+ type Report = common.EventAnnotation

Mar 20, 2026

Changes in this version

+ const CurrentDataContextVersion

Mar 18, 2026

Changes in this version

+ type WebhookProcessor struct

+ HTTPClient *http.Client

+ func NewWebhookProcessor(c *config.ProcessorConfig) (*WebhookProcessor, error)

+ func (w *WebhookProcessor) GetConfig() *config.ProcessorConfig

+ func (w *WebhookProcessor) Process(input *DataContext) (*DataContext, error)

Mar 16, 2026

Changes in this version

type DataContext

+ Auth *common.AuthContext

Mar 12, 2026

Changes in this version

+ var ErrProcessorDisabled = errors.New("processor is disabled")

Feb 10, 2026

Changes in this version

+ type CLIProcessor struct

+ WorkingDir string

+ func NewCLIProcessor(c *config.ProcessorConfig) (*CLIProcessor, error)

+ func (e *CLIProcessor) GetConfig() *config.ProcessorConfig

+ func (e *CLIProcessor) Process(input *DataContext) (*DataContext, error)

+ type DataContext struct

+ Event *common.MCPEvent

+ Payload *PayloadPart

+ Routing *RoutingPart

+ Version string

+ type PayloadPart struct

+ OriginalRequest *mcp.CallToolRequest

+ OriginalResult *mcp.CallToolResult

+ Request *mcp.CallToolRequest

+ Result *mcp.CallToolResult

+ type ProcessorInterface interface

+ GetConfig func() *config.ProcessorConfig

+ Process func(input *DataContext) (*DataContext, error)

+ func NewProcessor(processorConfig *config.ProcessorConfig) (ProcessorInterface, error)

+ type RoutingPart struct

+ OriginalServerName string

+ OriginalToolname string

+ ServerName string

+ ToolName string

Jan 31, 2026

Changes in this version

+ func FormatMCPError(result *ChainResult, requestID interface{}) (string, error)

+ func RunScaffoldInteractive(in io.Reader, out io.Writer) error

+ type Chain struct

+ func NewChain(processors []*config.ProcessorConfig, serverName, sessionID string) (*Chain, error)

+ func (c *Chain) Execute(event common.McpEventInterface) (*ChainResult, error)

+ func (c *Chain) HasProcessors() bool

+ type ChainResult struct

+ Error *string

+ Metadata map[string]interface{}

+ ModifiedPayload map[string]interface{}

+ ProcessorChain []string

+ Status int

+ type Executor struct

+ WorkingDir string

+ func NewExecutor() (*Executor, error)

+ func (e *Executor) Execute(processorConfig *config.ProcessorConfig, input *config.ProcessorInput) (*config.ProcessorOutput, error)