package
0.0.0-20240307193727-a3dabfac5042
Repository: https://github.com/openshift/eventrouter.git
Documentation: pkg.go.dev
# Packages
No description provided by the author
# Functions
ManufactureSink will manufacture a sink according to viper configs TODO: Determine if it should return an array of sinks.
NewEventData constructs an EventData struct from an old and new event, setting the verb accordingly.
NewGlogSink will create a new.
NewHTTPSink constructs a new HTTPSink given a sink URL and buffer size.
NewKafkaSinkSink will create a new KafkaSink with default options, returned as an EventSinkInterface.
NewStdoutSink will create a new StdoutSink with default options, returned as an EventSinkInterface.
# Structs
EventData encodes an eventrouter event and previous event, with a verb for whether the event is created or updated.
GlogSink is the most basic sink Useful when you already have ELK/EFK Stack.
HTTPSink wraps an HTTP endpoint that messages should be sent to.
KafkaSink implements the EventSinkInterface.
StdoutSink is the other basic sink By default, Fluentd/ElasticSearch won't index glog formatted lines By logging raw JSON to stdout, we will get automated indexing which can be queried in Kibana.
# Interfaces
EventSinkInterface is the interface used to shunt events.