Versions in this module Expand all Collapse all v4 v4.22.0 Oct 23, 2023 Changes in this version + type EventType string + var EventConsume EventType = "CONSUME" + var EventDelete EventType = "DELETE" + var EventError EventType = "ERROR" + var EventProduce EventType = "PRODUCE" + type NodeEvent struct + Content string + Meta map[string]any + Type EventType + func EventConsumeOf(part *message.Part) NodeEvent + func EventDeleteOf() NodeEvent + func EventErrorOf(err error) NodeEvent + func EventProduceOf(part *message.Part) NodeEvent + type Summary struct + Input uint64 + Output uint64 + ProcessorErrors uint64 + func NewSummary() *Summary + func TracedBundle(b *bundle.Environment) (*bundle.Environment, *Summary) + func (s *Summary) InputEvents(flush bool) map[string][]NodeEvent + func (s *Summary) OutputEvents(flush bool) map[string][]NodeEvent + func (s *Summary) ProcessorEvents(flush bool) map[string][]NodeEvent + func (s *Summary) SetEnabled(e bool) + func (s *Summary) SetEventLimit(n int64)
Go to main page