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, js nats.JetStreamContext, store storage.Database, notifier *notifier.Notifier, stream types.StreamProvider, producer *producers.UserAPIReadProducer, ) *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, cfg *config.SyncAPI, topic string, js nats.JetStreamContext, rsAPI roomserverAPI.SyncRoomserverAPI, store storage.Database, notifier *notifier.Notifier, stream types.StreamProvider, ) *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 OutputNotificationDataConsumer ¶
type OutputNotificationDataConsumer struct {
// contains filtered or unexported fields
}
OutputNotificationDataConsumer consumes events that originated in the Push server.
func NewOutputNotificationDataConsumer ¶
func NewOutputNotificationDataConsumer( process *process.ProcessContext, cfg *config.SyncAPI, js nats.JetStreamContext, store storage.Database, notifier *notifier.Notifier, stream types.StreamProvider, ) *OutputNotificationDataConsumer
NewOutputNotificationDataConsumer creates a new consumer. Call Start() to begin consuming.
func (*OutputNotificationDataConsumer) Start ¶
func (s *OutputNotificationDataConsumer) Start() error
Start starts consumption.
type OutputReceiptEventConsumer ¶
type OutputReceiptEventConsumer struct {
// contains filtered or unexported fields
}
OutputReceiptEventConsumer consumes events that originated in the EDU server.
func NewOutputReceiptEventConsumer ¶
func NewOutputReceiptEventConsumer( process *process.ProcessContext, cfg *config.SyncAPI, js nats.JetStreamContext, store storage.Database, notifier *notifier.Notifier, stream types.StreamProvider, producer *producers.UserAPIReadProducer, ) *OutputReceiptEventConsumer
NewOutputReceiptEventConsumer creates a new OutputReceiptEventConsumer. Call Start() to begin consuming from the EDU server.
func (*OutputReceiptEventConsumer) Start ¶
func (s *OutputReceiptEventConsumer) Start() error
Start consuming receipts events.
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, js nats.JetStreamContext, store storage.Database, notifier *notifier.Notifier, pduStream types.StreamProvider, inviteStream types.StreamProvider, rsAPI api.SyncRoomserverAPI, producer *producers.UserAPIStreamEventProducer, ) *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, js nats.JetStreamContext, 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 send-to-device events.
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, js nats.JetStreamContext, eduCache *caching.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 typing events.
type PresenceConsumer ¶
type PresenceConsumer struct {
// contains filtered or unexported fields
}
OutputTypingEventConsumer consumes events that originated in the EDU server.
func NewPresenceConsumer ¶
func NewPresenceConsumer( process *process.ProcessContext, cfg *config.SyncAPI, js nats.JetStreamContext, nats *nats.Conn, db storage.Database, notifier *notifier.Notifier, stream types.StreamProvider, deviceAPI api.SyncUserAPI, ) *PresenceConsumer
NewPresenceConsumer creates a new PresenceConsumer. Call Start() to begin consuming events.
func (*PresenceConsumer) EmitPresence ¶
func (s *PresenceConsumer) EmitPresence(ctx context.Context, userID string, presence types.Presence, statusMsg *string, ts gomatrixserverlib.Timestamp, fromSync bool)
func (*PresenceConsumer) Start ¶
func (s *PresenceConsumer) Start() error
Start consuming typing events.
Source Files