Versions in this module Expand all Collapse all v4 v4.27.1 May 31, 2024 v4.27.0 May 31, 2024 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