consumers

Documentation

Index

• type ApplicationServiceTransaction
• type OutputRoomEventConsumer
  • func NewOutputRoomEventConsumer(process *process.ProcessContext, cfg *config.AppServiceAPI, ...) *OutputRoomEventConsumer
  • func (s *OutputRoomEventConsumer) Start() error

Types

type ApplicationServiceTransaction

type ApplicationServiceTransaction struct {
	Events []synctypes.ClientEvent `json:"events"`
}

ApplicationServiceTransaction is the transaction that is sent off to an application service.

type OutputRoomEventConsumer

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

OutputRoomEventConsumer consumes events that originated in the room server.

func NewOutputRoomEventConsumer

func NewOutputRoomEventConsumer(
	process *process.ProcessContext,
	cfg *config.AppServiceAPI,
	js nats.JetStreamContext,
	rsAPI api.AppserviceRoomserverAPI,
) *OutputRoomEventConsumer

NewOutputRoomEventConsumer creates a new OutputRoomEventConsumer. Call Start() to begin consuming from room servers.

func (*OutputRoomEventConsumer) Start

func (s *OutputRoomEventConsumer) Start() error

Start consuming from room servers