producers

package

v0.11.0 Latest Latest Go to latest Published: Oct 16, 2025 License: Apache-2.0 Imports: 9 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type KeyChange struct {
	Topic *config.QueueOptions
	Qm    queueutil.QueueManager
	DB    storage.KeyChangeDatabase
}

KeyChange produces key change events for the sync API and federation sender to consume

func (p *KeyChange) ProduceKeyChanges(ctx context.Context, keys []api.DeviceMessage) error

ProduceKeyChanges creates new change events for each key

func (p *KeyChange) ProduceSigningKeyUpdate(ctx context.Context, key api.CrossSigningKeyUpdate) error

type SyncAPI struct {
	// contains filtered or unexported fields
}

SyncAPI produces messages for the Sync API server to consume.

func NewSyncAPI(ctx context.Context, cfg *config.SyncAPI, db storage.UserDatabase, qm queueutil.QueueManager) (*SyncAPI, error)

func (p *SyncAPI) GetAndSendNotificationData(ctx context.Context, userID, roomID string) error

GetAndSendNotificationData reads the database and sends data about unread notifications to the Sync API server.

func (p *SyncAPI) SendAccountData(ctx context.Context, userID string, data eventutil.AccountData) error

SendAccountData sends account data to the Sync API server.