Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type OutputRoomEventConsumer ¶
type OutputRoomEventConsumer struct {
// contains filtered or unexported fields
}
OutputRoomEventConsumer consumes events that originated in the room server.
func NewOutputRoomEventConsumer ¶
func NewOutputRoomEventConsumer( cfg *config.Dendrite, store model.PublicRoomAPIDatabase, rsRpcCli roomserverapi.RoomserverRPCAPI, ) *OutputRoomEventConsumer
NewOutputRoomEventConsumer creates a new OutputRoomEventConsumer. Call Start() to begin consuming from room servers.
func (*OutputRoomEventConsumer) OnMessage ¶
func (s *OutputRoomEventConsumer) OnMessage(ctx context.Context, topic string, partition int32, data []byte, rawMsg interface{})
OnMessage is called when the sync server receives a new event from the room server output log.
func (*OutputRoomEventConsumer) Start ¶
func (s *OutputRoomEventConsumer) Start() error
Start consuming from room servers
Source Files
Click to show internal directories.
Click to hide internal directories.