Documentation ¶
Index ¶
- Constants
- Variables
- func InputRoomEventSubj(roomID string) string
- func JetStreamConsumer(ctx context.Context, js nats.JetStreamContext, subj, durable string, ...) error
- func Prepare(process *process.ProcessContext, cfg *config.JetStream) (natsclient.JetStreamContext, *natsclient.Conn)
- func Tokenise(str string) string
Constants ¶
View Source
const ( UserID = "user_id" RoomID = "room_id" )
Variables ¶
View Source
var ( InputRoomEvent = "InputRoomEvent" OutputRoomEvent = "OutputRoomEvent" OutputSendToDeviceEvent = "OutputSendToDeviceEvent" OutputKeyChangeEvent = "OutputKeyChangeEvent" OutputTypingEvent = "OutputTypingEvent" OutputClientData = "OutputClientData" OutputNotificationData = "OutputNotificationData" OutputReceiptEvent = "OutputReceiptEvent" OutputStreamEvent = "OutputStreamEvent" OutputReadUpdate = "OutputReadUpdate" )
Functions ¶
func InputRoomEventSubj ¶ added in v0.7.0
func JetStreamConsumer ¶ added in v0.6.1
func Prepare ¶
func Prepare(process *process.ProcessContext, cfg *config.JetStream) (natsclient.JetStreamContext, *natsclient.Conn)
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.