jetstream

Documentation

Index

• Constants
• Variables
• func Prepare(cfg *config.JetStream) (nats.JetStreamContext, sarama.Consumer, sarama.SyncProducer)
• func WithJetStreamMessage(msg *nats.Msg, f func(msg *nats.Msg) bool)

Constants

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

Variables

var (
	InputRoomEvent          = "InputRoomEvent"
	OutputRoomEvent         = "OutputRoomEvent"
	OutputSendToDeviceEvent = "OutputSendToDeviceEvent"
	OutputKeyChangeEvent    = "OutputKeyChangeEvent"
	OutputTypingEvent       = "OutputTypingEvent"
	OutputClientData        = "OutputClientData"
	OutputReceiptEvent      = "OutputReceiptEvent"
)

Functions

func Prepare

func Prepare(cfg *config.JetStream) (nats.JetStreamContext, sarama.Consumer, sarama.SyncProducer)

func WithJetStreamMessage

func WithJetStreamMessage(msg *nats.Msg, f func(msg *nats.Msg) bool)