Documentation ¶
Index ¶
- type SyncAPIProducer
- func (p *SyncAPIProducer) SendPresence(ctx context.Context, userID string, presence types.Presence, statusMsg *string, ...) error
- func (p *SyncAPIProducer) SendReceipt(ctx context.Context, userID, roomID, eventID, receiptType string, ...) error
- func (p *SyncAPIProducer) SendToDevice(ctx context.Context, sender, userID, deviceID, eventType string, ...) error
- func (p *SyncAPIProducer) SendTyping(ctx context.Context, userID, roomID string, typing bool, timeoutMS int64) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type SyncAPIProducer ¶
type SyncAPIProducer struct { TopicReceiptEvent string TopicSendToDeviceEvent string TopicTypingEvent string TopicPresenceEvent string JetStream nats.JetStreamContext ServerName gomatrixserverlib.ServerName UserAPI userapi.UserInternalAPI }
SyncAPIProducer produces events for the sync API server to consume
func (*SyncAPIProducer) SendPresence ¶
func (*SyncAPIProducer) SendReceipt ¶
func (p *SyncAPIProducer) SendReceipt( ctx context.Context, userID, roomID, eventID, receiptType string, timestamp gomatrixserverlib.Timestamp, ) error
func (*SyncAPIProducer) SendToDevice ¶
func (p *SyncAPIProducer) SendToDevice( ctx context.Context, sender, userID, deviceID, eventType string, message interface{}, ) error
func (*SyncAPIProducer) SendTyping ¶
Click to show internal directories.
Click to hide internal directories.