Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ApplicationServiceTransaction ¶ added in v0.13.0
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
Click to show internal directories.
Click to hide internal directories.