Documentation ¶
Index ¶
- type RoomEventConsumer
- func (s *RoomEventConsumer) OnMessage(ctx context.Context, topic string, partition int32, data []byte, ...)
- func (s *RoomEventConsumer) SetDisplayNameRepo(displayNameRepo *repos.DisplayNameRepo) *RoomEventConsumer
- func (s *RoomEventConsumer) SetRoomHistory(roomHistory *repos.RoomHistoryTimeLineRepo) *RoomEventConsumer
- func (s *RoomEventConsumer) SetRsCurState(rsCurState *repos.RoomCurStateRepo) *RoomEventConsumer
- func (s *RoomEventConsumer) SetRsTimeline(rsTimeline *repos.RoomStateTimeLineRepo) *RoomEventConsumer
- func (s *RoomEventConsumer) Start() error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type RoomEventConsumer ¶
type RoomEventConsumer struct {
// contains filtered or unexported fields
}
OutputRoomEventConsumer consumes events that originated in the room server.
func NewRoomEventConsumer ¶
func NewRoomEventConsumer( cfg *config.Dendrite, store model.SyncAPIDatabase, ) *RoomEventConsumer
func (*RoomEventConsumer) SetDisplayNameRepo ¶
func (s *RoomEventConsumer) SetDisplayNameRepo(displayNameRepo *repos.DisplayNameRepo) *RoomEventConsumer
func (*RoomEventConsumer) SetRoomHistory ¶
func (s *RoomEventConsumer) SetRoomHistory(roomHistory *repos.RoomHistoryTimeLineRepo) *RoomEventConsumer
func (*RoomEventConsumer) SetRsCurState ¶
func (s *RoomEventConsumer) SetRsCurState(rsCurState *repos.RoomCurStateRepo) *RoomEventConsumer
func (*RoomEventConsumer) SetRsTimeline ¶
func (s *RoomEventConsumer) SetRsTimeline(rsTimeline *repos.RoomStateTimeLineRepo) *RoomEventConsumer
func (*RoomEventConsumer) Start ¶
func (s *RoomEventConsumer) Start() error
Click to show internal directories.
Click to hide internal directories.