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, appserviceDB model.AppServiceDatabase, rsDB model.RoomServerDatabase, workerStates []types.ApplicationServiceWorkerState, ) *OutputRoomEventConsumer
NewOutputRoomEventConsumer creates a new OutputRoomEventConsumer. Call Start() to begin consuming from room servers.
func (*OutputRoomEventConsumer) OnMessage ¶
func (c *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. It is not safe for this function to be called from multiple goroutines, or else the sync stream position may race and be incorrectly calculated.
func (*OutputRoomEventConsumer) Start ¶
func (c *OutputRoomEventConsumer) Start() error
Start consuming from room servers
Source Files
Click to show internal directories.
Click to hide internal directories.