Versions in this module Expand all Collapse all v0 v0.1.1 Nov 13, 2025 Changes in this version + type AfterProcessHook func(ctx *ProcessContext) error + type AfterRouteHook func(ctx *RouteContext) error + type AfterSendHook func(ctx *MessageContext) error + type BeforeProcessHook func(ctx *ProcessContext) error + type BeforeRouteHook func(ctx *RouteContext) error + type BeforeSendHook func(ctx *MessageContext) error + type GlobalPluginFactory func(broker *PluginBroker) error + type HookBundle struct + AfterProcess []AfterProcessHook + AfterRoute []AfterRouteHook + AfterSend []AfterSendHook + BeforeProcess []BeforeProcessHook + BeforeRoute []BeforeRouteHook + BeforeSend []BeforeSendHook + TxCreated []TxCreatedHook + type MessageContext struct + Cycle int + NodeID int + Packet *core.Packet + TargetID int + type NodePluginFactory func(nodeID int, broker *PluginBroker) error + type PluginBroker struct + func NewPluginBroker() *PluginBroker + func (p *PluginBroker) EmitAfterProcess(ctx *ProcessContext) error + func (p *PluginBroker) EmitAfterRoute(ctx *RouteContext) error + func (p *PluginBroker) EmitAfterSend(ctx *MessageContext) error + func (p *PluginBroker) EmitBeforeProcess(ctx *ProcessContext) error + func (p *PluginBroker) EmitBeforeRoute(ctx *RouteContext) error + func (p *PluginBroker) EmitBeforeSend(ctx *MessageContext) error + func (p *PluginBroker) EmitTxCreated(ctx *TxCreatedContext) error + func (p *PluginBroker) ListAllPlugins() []PluginDescriptor + func (p *PluginBroker) ListPlugins(category PluginCategory) []PluginDescriptor + func (p *PluginBroker) RegisterAfterProcess(h AfterProcessHook) + func (p *PluginBroker) RegisterAfterRoute(h AfterRouteHook) + func (p *PluginBroker) RegisterAfterSend(h AfterSendHook) + func (p *PluginBroker) RegisterBeforeProcess(h BeforeProcessHook) + func (p *PluginBroker) RegisterBeforeRoute(h BeforeRouteHook) + func (p *PluginBroker) RegisterBeforeSend(h BeforeSendHook) + func (p *PluginBroker) RegisterBundle(desc PluginDescriptor, bundle HookBundle) + func (p *PluginBroker) RegisterPluginMetadata(desc PluginDescriptor) + func (p *PluginBroker) RegisterTxCreated(h TxCreatedHook) + type PluginCategory string + const PluginCategoryCapability + const PluginCategoryInstrumentation + const PluginCategoryPolicy + const PluginCategoryVisualization + type PluginDescriptor struct + Category PluginCategory + Description string + Name string + type ProcessContext struct + Cycle int + Node interface{} + NodeID int + Packet *core.Packet + Transaction *core.Transaction + type Registry struct + func NewRegistry(broker *PluginBroker) *Registry + func (r *Registry) Broker() *PluginBroker + func (r *Registry) Descriptor(name string) (PluginDescriptor, bool) + func (r *Registry) LoadForNode(nodeID int, names []string) error + func (r *Registry) LoadGlobal(names []string) error + func (r *Registry) RegisterGlobal(name string, desc PluginDescriptor, factory GlobalPluginFactory) error + func (r *Registry) RegisterNode(name string, desc PluginDescriptor, factory NodePluginFactory) error + type RouteContext struct + DefaultTarget int + Packet *core.Packet + SourceNodeID int + TargetID int + type TxCreatedContext struct + Packet *core.Packet + Transaction *core.Transaction + type TxCreatedHook func(ctx *TxCreatedContext) error v0.1.0 Nov 12, 2025
Go to main page