consumers

Documentation

Index

• type OutputReceiptEventConsumer
  • func NewOutputReceiptEventConsumer(process *process.ProcessContext, cfg *config.UserAPI, js nats.JetStreamContext, ...) *OutputReceiptEventConsumer
  • func (s *OutputReceiptEventConsumer) Start() error
• type OutputRoomEventConsumer
  • func NewOutputRoomEventConsumer(process *process.ProcessContext, cfg *config.UserAPI, js nats.JetStreamContext, ...) *OutputRoomEventConsumer
  • func (s *OutputRoomEventConsumer) Start() error

Types

type OutputReceiptEventConsumer

type OutputReceiptEventConsumer struct {
	// contains filtered or unexported fields
}

OutputReceiptEventConsumer consumes events that originated in the clientAPI.

func NewOutputReceiptEventConsumer

func NewOutputReceiptEventConsumer(
	process *process.ProcessContext,
	cfg *config.UserAPI,
	js nats.JetStreamContext,
	store storage.Database,
	syncProducer *producers.SyncAPI,
	pgClient pushgateway.Client,
) *OutputReceiptEventConsumer

NewOutputReceiptEventConsumer creates a new OutputReceiptEventConsumer. Call Start() to begin consuming from the EDU server.

func (*OutputReceiptEventConsumer) Start

func (s *OutputReceiptEventConsumer) Start() error

Start consuming receipts events.

type OutputRoomEventConsumer

type OutputRoomEventConsumer struct {
	// contains filtered or unexported fields
}

func NewOutputRoomEventConsumer

func NewOutputRoomEventConsumer(
	process *process.ProcessContext,
	cfg *config.UserAPI,
	js nats.JetStreamContext,
	store storage.Database,
	pgClient pushgateway.Client,
	rsAPI rsapi.UserRoomserverAPI,
	syncProducer *producers.SyncAPI,
) *OutputRoomEventConsumer

func (*OutputRoomEventConsumer) Start

func (s *OutputRoomEventConsumer) Start() error