Versions in this module Expand all Collapse all v0 v0.14.0 Dec 18, 2024 Changes in this version + const EventID + const RoomEventType + const RoomID + const UserID + var InputDeviceListUpdate = "InputDeviceListUpdate" + var InputFulltextReindex = "InputFulltextReindex" + var InputRoomEvent = "InputRoomEvent" + var InputSigningKeyUpdate = "InputSigningKeyUpdate" + var OutputAppserviceEvent = "OutputAppserviceEvent" + var OutputClientData = "OutputClientData" + var OutputKeyChangeEvent = "OutputKeyChangeEvent" + var OutputNotificationData = "OutputNotificationData" + var OutputPresenceEvent = "OutputPresenceEvent" + var OutputReadUpdate = "OutputReadUpdate" + var OutputReceiptEvent = "OutputReceiptEvent" + var OutputRoomEvent = "OutputRoomEvent" + var OutputSendToDeviceEvent = "OutputSendToDeviceEvent" + var OutputStreamEvent = "OutputStreamEvent" + var OutputTypingEvent = "OutputTypingEvent" + var RequestPresence = "GetPresence" + func DeleteAllStreams(js natsclient.JetStreamContext, cfg *config.JetStream) + func InputRoomEventSubj(roomID string) string + func JetStreamConsumer(ctx context.Context, js nats.JetStreamContext, subj, durable string, batch int, ...) error + func Tokenise(str string) string + type LogAdapter struct + func NewLogAdapter() *LogAdapter + func (l *LogAdapter) Debugf(format string, v ...interface{}) + func (l *LogAdapter) Errorf(format string, v ...interface{}) + func (l *LogAdapter) Fatalf(format string, v ...interface{}) + func (l *LogAdapter) Noticef(format string, v ...interface{}) + func (l *LogAdapter) Tracef(format string, v ...interface{}) + func (l *LogAdapter) Warnf(format string, v ...interface{}) + type NATSInstance struct + func (s *NATSInstance) Prepare(process *process.ProcessContext, cfg *config.JetStream) (natsclient.JetStreamContext, *natsclient.Conn)
Go to main page