jetstream

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 PrepareForTests() (*process.ProcessContext, nats.JetStreamContext, *nats.Conn)
• func Tokenise(str string) string

Constants

const (
	UserID  = "user_id"
	RoomID  = "room_id"
	EventID = "event_id"
)

Variables

var (
	InputRoomEvent          = "InputRoomEvent"
	OutputRoomEvent         = "OutputRoomEvent"
	OutputSendToDeviceEvent = "OutputSendToDeviceEvent"
	OutputKeyChangeEvent    = "OutputKeyChangeEvent"
	OutputTypingEvent       = "OutputTypingEvent"
	OutputClientData        = "OutputClientData"
	OutputNotificationData  = "OutputNotificationData"
	OutputReceiptEvent      = "OutputReceiptEvent"
	OutputStreamEvent       = "OutputStreamEvent"
	OutputReadUpdate        = "OutputReadUpdate"
	RequestPresence         = "GetPresence"
	OutputPresenceEvent     = "OutputPresenceEvent"
)

Functions

func InputRoomEventSubj

func InputRoomEventSubj(roomID string) string

func JetStreamConsumer

func JetStreamConsumer(
	ctx context.Context, js nats.JetStreamContext, subj, durable string,
	f func(ctx context.Context, msg *nats.Msg) bool,
	opts ...nats.SubOpt,
) error

func Prepare

func Prepare(process *process.ProcessContext, cfg *config.JetStream) (natsclient.JetStreamContext, *natsclient.Conn)

func PrepareForTests

func PrepareForTests() (*process.ProcessContext, nats.JetStreamContext, *nats.Conn)

func Tokenise

func Tokenise(str string) string