dendrite/appservice
S7evinK 9de7efa0b0
Remove sarama/saramajetstream dependencies (#2138)
* Remove dependency on saramajetstream & sarama

Signed-off-by: Till Faelligen <tfaelligen@gmail.com>

* Remove internal.ContinualConsumer from federationapi

* Remove internal.ContinualConsumer from syncapi

* Remove internal.ContinualConsumer from keyserver

* Move to new Prepare function

* Remove saramajetstream & sarama dependency

* Delete unneeded file

* Remove duplicate import

* Log error instead of silently irgnoring it

* Move `OffsetNewest` and `OffsetOldest` into keyserver types, change them to be more sane values

* Fix comments

Co-authored-by: Neil Alexander <neilalexander@users.noreply.github.com>
2022-02-04 13:08:13 +00:00
..
api Fix #1655 by re-adding the appservice alias query (#1660) 2020-12-18 13:33:28 +00:00
consumers Use pull consumers (#2140) 2022-02-02 13:32:48 +00:00
inthttp
query Fix ineffectual error assignment (#1976) 2021-08-16 14:19:35 +01:00
storage Add NATS JetStream support (#1866) 2022-01-05 17:44:49 +00:00
types
workers Use default transport for AS traffic (#1789) 2021-03-05 16:40:32 +00:00
appservice.go Remove sarama/saramajetstream dependencies (#2138) 2022-02-04 13:08:13 +00:00
README.md

Application Service

This component interfaces with external Application Services. This includes any HTTP endpoints that application services call, as well as talking to any HTTP endpoints that application services provide themselves.

Consumers

This component consumes and filters events from the Roomserver Kafka stream, passing on any necessary events to subscribing application services.