Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type OutputClientDataConsumer ¶
type OutputClientDataConsumer struct {
// contains filtered or unexported fields
}
OutputClientDataConsumer consumes events that originated in the client API server.
func NewOutputClientDataConsumer ¶
func NewOutputClientDataConsumer( process *process.ProcessContext, cfg *config.SyncAPI, kafkaConsumer sarama.Consumer, store storage.Database, notifier *notifier.Notifier, stream types.StreamProvider, ) *OutputClientDataConsumer
NewOutputClientDataConsumer creates a new OutputClientData consumer. Call Start() to begin consuming from room servers.
func (*OutputClientDataConsumer) Start ¶
func (s *OutputClientDataConsumer) Start() error
Start consuming from room servers
type OutputKeyChangeEventConsumer ¶
type OutputKeyChangeEventConsumer struct {
// contains filtered or unexported fields
}
OutputKeyChangeEventConsumer consumes events that originated in the key server.
func NewOutputKeyChangeEventConsumer ¶
func NewOutputKeyChangeEventConsumer( process *process.ProcessContext, serverName gomatrixserverlib.ServerName, topic string, kafkaConsumer sarama.Consumer, keyAPI api.KeyInternalAPI, rsAPI roomserverAPI.RoomserverInternalAPI, store storage.Database, notifier *notifier.Notifier, stream types.PartitionedStreamProvider, ) *OutputKeyChangeEventConsumer
NewOutputKeyChangeEventConsumer creates a new OutputKeyChangeEventConsumer. Call Start() to begin consuming from the key server.
func (*OutputKeyChangeEventConsumer) Start ¶
func (s *OutputKeyChangeEventConsumer) Start() error
Start consuming from the key server
type OutputReceiptEventConsumer ¶ added in v0.3.0
type OutputReceiptEventConsumer struct {
// contains filtered or unexported fields
}
OutputReceiptEventConsumer consumes events that originated in the EDU server.
func NewOutputReceiptEventConsumer ¶ added in v0.3.0
func NewOutputReceiptEventConsumer( process *process.ProcessContext, cfg *config.SyncAPI, kafkaConsumer sarama.Consumer, store storage.Database, notifier *notifier.Notifier, stream types.StreamProvider, ) *OutputReceiptEventConsumer
NewOutputReceiptEventConsumer creates a new OutputReceiptEventConsumer. Call Start() to begin consuming from the EDU server.
func (*OutputReceiptEventConsumer) Start ¶ added in v0.3.0
func (s *OutputReceiptEventConsumer) Start() error
Start consuming from EDU api
type OutputRoomEventConsumer ¶
type OutputRoomEventConsumer struct {
// contains filtered or unexported fields
}
OutputRoomEventConsumer consumes events that originated in the room server.
func NewOutputRoomEventConsumer ¶
func NewOutputRoomEventConsumer( process *process.ProcessContext, cfg *config.SyncAPI, kafkaConsumer sarama.Consumer, store storage.Database, notifier *notifier.Notifier, pduStream types.StreamProvider, inviteStream types.StreamProvider, rsAPI api.RoomserverInternalAPI, ) *OutputRoomEventConsumer
NewOutputRoomEventConsumer creates a new OutputRoomEventConsumer. Call Start() to begin consuming from room servers.
func (*OutputRoomEventConsumer) Start ¶
func (s *OutputRoomEventConsumer) Start() error
Start consuming from room servers
type OutputSendToDeviceEventConsumer ¶
type OutputSendToDeviceEventConsumer struct {
// contains filtered or unexported fields
}
OutputSendToDeviceEventConsumer consumes events that originated in the EDU server.
func NewOutputSendToDeviceEventConsumer ¶
func NewOutputSendToDeviceEventConsumer( process *process.ProcessContext, cfg *config.SyncAPI, kafkaConsumer sarama.Consumer, store storage.Database, notifier *notifier.Notifier, stream types.StreamProvider, ) *OutputSendToDeviceEventConsumer
NewOutputSendToDeviceEventConsumer creates a new OutputSendToDeviceEventConsumer. Call Start() to begin consuming from the EDU server.
func (*OutputSendToDeviceEventConsumer) Start ¶
func (s *OutputSendToDeviceEventConsumer) Start() error
Start consuming from EDU api
type OutputTypingEventConsumer ¶
type OutputTypingEventConsumer struct {
// contains filtered or unexported fields
}
OutputTypingEventConsumer consumes events that originated in the EDU server.
func NewOutputTypingEventConsumer ¶
func NewOutputTypingEventConsumer( process *process.ProcessContext, cfg *config.SyncAPI, kafkaConsumer sarama.Consumer, store storage.Database, eduCache *cache.EDUCache, notifier *notifier.Notifier, stream types.StreamProvider, ) *OutputTypingEventConsumer
NewOutputTypingEventConsumer creates a new OutputTypingEventConsumer. Call Start() to begin consuming from the EDU server.
func (*OutputTypingEventConsumer) Start ¶
func (s *OutputTypingEventConsumer) Start() error
Start consuming from EDU api
Source Files