jetstream

Documentation

Index

• Constants
• Variables
• func JetStreamConsumer(ctx context.Context, js nats.JetStreamContext, subj, durable string, ...) error
• func Prepare(cfg *config.JetStream) natsclient.JetStreamContext

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 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(cfg *config.JetStream) natsclient.JetStreamContext