MCPcopy Create free account
hub / github.com/rabbitstack/fibratus / Consumer

Struct Consumer

internal/etw/consumer.go:36–44  ·  view source on GitHub ↗

Consumer is the core component in the event processing pipeline. The raw event is offloaded from the session buffer, then parsed and converted to typed representation with process state attached to it. The event consumer is responsible for enriching the event with additional attributes. The event is

Source from the content-addressed store, hash-verified

34// with additional attributes. The event is sent to the queue where
35// all registered listeners are executed.
36type Consumer struct {
37 q *event.Queue
38 sequencer *event.Sequencer
39 processors processors.Chain
40 psnap ps.Snapshotter
41 config *config.Config
42 filter filter.Filter
43 isClosing bool
44}
45
46// NewConsumer builds a new event consumer.
47func NewConsumer(

Callers

nothing calls this directly

Calls

no outgoing calls

Tested by

no test coverage detected