Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type DismissRoomConsumer ¶
type DismissRoomConsumer struct {
// contains filtered or unexported fields
}
func NewDismissRoomConsumer ¶
func NewDismissRoomConsumer(underlying, name string, rpcCli roomserverapi.RoomserverRPCAPI, cache service.Cache, accountDB model.AccountsDatabase, cfg *config.Dendrite, federation *fed.Federation, complexCache *common.ComplexCache, idg *uid.UidGenerator) *DismissRoomConsumer
func (*DismissRoomConsumer) OnMessage ¶
func (c *DismissRoomConsumer) OnMessage(ctx context.Context, topic string, partition int32, data []byte, rawMsg interface{})
if leave fail , continue
func (*DismissRoomConsumer) Start ¶
func (c *DismissRoomConsumer) Start() error
type InputRoomEventConsumer ¶
type InputRoomEventConsumer struct {
// contains filtered or unexported fields
}
consumes events that originated in the client api server.
func NewInputRoomEventConsumer ¶
func NewInputRoomEventConsumer( cfg *config.Dendrite, input roomserverapi.RoomserverInputAPI, client *common.RpcClient, ) *InputRoomEventConsumer
func (*InputRoomEventConsumer) OnMessage ¶
func (s *InputRoomEventConsumer) OnMessage(ctx context.Context, topic string, partition int32, data []byte, rawMsg interface{})
when kafka, write data to chan, called by kafka transport
func (*InputRoomEventConsumer) Start ¶
func (s *InputRoomEventConsumer) Start() error
type QueryConsumer ¶
type QueryConsumer struct {
// contains filtered or unexported fields
}
consumes events that originated in the client api server.
func NewQueryConsumer ¶
func NewQueryConsumer( cfg *config.Dendrite, db model.RoomServerDatabase, repo *repos.RoomServerCurStateRepo, umsRepo *repos.RoomServerUserMembershipRepo, rpcClient *common.RpcClient, alias *processors.AliasProcessor, rs *processors.RoomQryProcessor, ) *QueryConsumer
func (*QueryConsumer) Start ¶
func (s *QueryConsumer) Start() error
Source Files
Click to show internal directories.
Click to hide internal directories.