Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type PublicRoomsRpcConsumer ¶
type PublicRoomsRpcConsumer struct { DB model.PublicRoomAPIDatabase Repo *repos.RoomServerCurStateRepo UmsRepo *repos.RoomServerUserMembershipRepo Proc roomserverapi.RoomserverQueryAPI // contains filtered or unexported fields }
func NewPublicRoomsRpcConsumer ¶
func NewPublicRoomsRpcConsumer( cfg *config.Dendrite, rpcClient *common.RpcClient, db model.PublicRoomAPIDatabase, ) *PublicRoomsRpcConsumer
func (*PublicRoomsRpcConsumer) GetTopic ¶
func (s *PublicRoomsRpcConsumer) GetTopic() string
func (*PublicRoomsRpcConsumer) Start ¶
func (s *PublicRoomsRpcConsumer) Start() error
Click to show internal directories.
Click to hide internal directories.