Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type DeviceListUpdateConsumer ¶ added in v0.12.0
type DeviceListUpdateConsumer struct {
// contains filtered or unexported fields
}
DeviceListUpdateConsumer consumes device list updates that came in over federation.
func NewDeviceListUpdateConsumer ¶ added in v0.12.0
func NewDeviceListUpdateConsumer( process *process.ProcessContext, cfg *config.UserAPI, js nats.JetStreamContext, updater *internal.DeviceListUpdater, ) *DeviceListUpdateConsumer
NewDeviceListUpdateConsumer creates a new DeviceListConsumer. Call Start() to begin consuming from key servers.
func (*DeviceListUpdateConsumer) Start ¶ added in v0.12.0
func (t *DeviceListUpdateConsumer) Start() error
Start consuming from key servers
type OutputReceiptEventConsumer ¶ added in v0.10.0
type OutputReceiptEventConsumer struct {
// contains filtered or unexported fields
}
OutputReceiptEventConsumer consumes events that originated in the clientAPI.
func NewOutputReceiptEventConsumer ¶ added in v0.10.0
func NewOutputReceiptEventConsumer( process *process.ProcessContext, cfg *config.UserAPI, js nats.JetStreamContext, store storage.UserDatabase, syncProducer *producers.SyncAPI, pgClient pushgateway.Client, ) *OutputReceiptEventConsumer
NewOutputReceiptEventConsumer creates a new OutputReceiptEventConsumer. Call Start() to begin consuming from the EDU server.
func (*OutputReceiptEventConsumer) Start ¶ added in v0.10.0
func (s *OutputReceiptEventConsumer) Start() error
Start consuming receipts events.
type OutputRoomEventConsumer ¶ added in v0.10.0
type OutputRoomEventConsumer struct {
// contains filtered or unexported fields
}
func NewOutputRoomEventConsumer ¶ added in v0.10.0
func NewOutputRoomEventConsumer( process *process.ProcessContext, cfg *config.UserAPI, js nats.JetStreamContext, store storage.UserDatabase, pgClient pushgateway.Client, rsAPI rsapi.UserRoomserverAPI, syncProducer *producers.SyncAPI, ) *OutputRoomEventConsumer
func (*OutputRoomEventConsumer) Start ¶ added in v0.10.0
func (s *OutputRoomEventConsumer) Start() error
type SigningKeyUpdateConsumer ¶ added in v0.12.0
type SigningKeyUpdateConsumer struct {
// contains filtered or unexported fields
}
SigningKeyUpdateConsumer consumes signing key updates that came in over federation.
func NewSigningKeyUpdateConsumer ¶ added in v0.12.0
func NewSigningKeyUpdateConsumer( process *process.ProcessContext, cfg *config.UserAPI, js nats.JetStreamContext, userAPI api.UploadDeviceKeysAPI, ) *SigningKeyUpdateConsumer
NewSigningKeyUpdateConsumer creates a new SigningKeyUpdateConsumer. Call Start() to begin consuming from key servers.
func (*SigningKeyUpdateConsumer) Start ¶ added in v0.12.0
func (t *SigningKeyUpdateConsumer) Start() error
Start consuming from key servers
Source Files