jetstream

Documentation

Index

• Constants
• Variables
• func DeleteAllStreams(js nats.JetStreamContext, cfg *config.JetStream)
• func InputRoomEventSubj(roomID string) string
• func JetStreamConsumer(ctx context.Context, js nats.JetStreamContext, subj, durable string, ...) error
• func Tokenise(str string) string
• type NATSInstance
  • func (s *NATSInstance) Prepare(process *process.ProcessContext, cfg *config.JetStream) (natsclient.JetStreamContext, *natsclient.Conn)

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 DeleteAllStreams

func DeleteAllStreams(js nats.JetStreamContext, cfg *config.JetStream)

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 Tokenise

func Tokenise(str string) string

Types

type NATSInstance

type NATSInstance struct {
	*natsserver.Server
	sync.Mutex
}

func (*NATSInstance) Prepare

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