tracing

Documentation

Index

• type EventType
• type NodeEvent
• type Summary
  • func NewSummary() *Summary
  • func TracedBundle(b *bundle.Environment) (*bundle.Environment, *Summary)
  • func (s *Summary) InputEvents() map[string][]NodeEvent
  • func (s *Summary) OutputEvents() map[string][]NodeEvent
  • func (s *Summary) ProcessorEvents() map[string][]NodeEvent

Types

type EventType

type EventType string

EventType describes the type of event a component might experience during a config run.

var (
	EventProduce EventType = "PRODUCE"
	EventConsume EventType = "CONSUME"
	EventDelete  EventType = "DELETE"
	EventError   EventType = "ERROR"
)

Various event types.

type NodeEvent

type NodeEvent struct {
	Type    EventType
	Content string
}

NodeEvent represents a single event that occured within the stream.

type Summary

type Summary struct {
	Input           uint64
	Output          uint64
	ProcessorErrors uint64
	// contains filtered or unexported fields
}

Summary is a high level description of all traced events.

func NewSummary

func NewSummary() *Summary

NewSummary creates a new tracing summary that can be passed to component constructors for adding traces.

func TracedBundle

func TracedBundle(b *bundle.Environment) (*bundle.Environment, *Summary)

TracedBundle modifies a provided bundle environment so that traceable components are wrapped by components that add trace events to the returned summary.

func (*Summary) InputEvents

func (s *Summary) InputEvents() map[string][]NodeEvent

InputEvents returns a map of input labels to events traced during the execution of a stream pipeline.

func (*Summary) OutputEvents

func (s *Summary) OutputEvents() map[string][]NodeEvent

OutputEvents returns a map of output labels to events traced during the execution of a stream pipeline.

func (*Summary) ProcessorEvents

func (s *Summary) ProcessorEvents() map[string][]NodeEvent

ProcessorEvents returns a map of processor labels to events traced during the execution of a stream pipeline.