NewAvroEncoder creates an encoder which will be used to avro encode all events prior to sending to kafka Its only used by the kafka sink.

NewOpsCenterSink returns a new OpsCenterSink.

KafkaConfig is the Kafka producer configuration.

KafkaSink is a sink that sends events to a Kafka topic.

OpsCenterConfig is the configuration of the Sink.

OpsCenterSink is an AWS OpsCenter notifcation path.

Receiver allows receiving.

BatchSink is an extension Sink that can handle batch events.

KafkaEncoder is an interface type for adding an encoder to the kafka data pipeline.

Sink is the interface that the third-party providers should implement.