Documentation ¶
Index ¶
- type ReceiptRpcConsumer
- type SyncServerRpcConsumer
- func (s *SyncServerRpcConsumer) Clean()
- func (s *SyncServerRpcConsumer) GetCB() common.MsgHandlerWithContext
- func (s *SyncServerRpcConsumer) GetTopic() string
- func (s *SyncServerRpcConsumer) SetRoomHistory(roomHistory *repos.RoomHistoryTimeLineRepo) *SyncServerRpcConsumer
- func (s *SyncServerRpcConsumer) Start() error
- type SyncUnreadRpcConsumer
- type TypingRpcConsumer
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ReceiptRpcConsumer ¶
type ReceiptRpcConsumer struct {
// contains filtered or unexported fields
}
func NewReceiptRpcConsumer ¶
func NewReceiptRpcConsumer( receiptConsumer *consumers.ReceiptConsumer, rpcClient *common.RpcClient, cfg *config.Dendrite, ) *ReceiptRpcConsumer
func (*ReceiptRpcConsumer) Clean ¶
func (s *ReceiptRpcConsumer) Clean()
func (*ReceiptRpcConsumer) GetCB ¶
func (s *ReceiptRpcConsumer) GetCB() common.MsgHandlerWithContext
func (*ReceiptRpcConsumer) GetTopic ¶
func (s *ReceiptRpcConsumer) GetTopic() string
func (*ReceiptRpcConsumer) Start ¶
func (s *ReceiptRpcConsumer) Start() error
type SyncServerRpcConsumer ¶
type SyncServerRpcConsumer struct {
// contains filtered or unexported fields
}
func NewSyncServerRpcConsumer ¶
func NewSyncServerRpcConsumer( rpcClient *common.RpcClient, syncServer *consumers.SyncServer, cfg *config.Dendrite, ) *SyncServerRpcConsumer
func (*SyncServerRpcConsumer) Clean ¶
func (s *SyncServerRpcConsumer) Clean()
func (*SyncServerRpcConsumer) GetCB ¶
func (s *SyncServerRpcConsumer) GetCB() common.MsgHandlerWithContext
func (*SyncServerRpcConsumer) GetTopic ¶
func (s *SyncServerRpcConsumer) GetTopic() string
func (*SyncServerRpcConsumer) SetRoomHistory ¶
func (s *SyncServerRpcConsumer) SetRoomHistory(roomHistory *repos.RoomHistoryTimeLineRepo) *SyncServerRpcConsumer
func (*SyncServerRpcConsumer) Start ¶
func (s *SyncServerRpcConsumer) Start() error
type SyncUnreadRpcConsumer ¶
type SyncUnreadRpcConsumer struct {
// contains filtered or unexported fields
}
func NewSyncUnreadRpcConsumer ¶
func NewSyncUnreadRpcConsumer( rpcClient *common.RpcClient, readCountRepo *repos.ReadCountRepo, cfg *config.Dendrite, ) *SyncUnreadRpcConsumer
func (*SyncUnreadRpcConsumer) Clean ¶
func (s *SyncUnreadRpcConsumer) Clean()
func (*SyncUnreadRpcConsumer) GetCB ¶
func (s *SyncUnreadRpcConsumer) GetCB() common.MsgHandlerWithContext
func (*SyncUnreadRpcConsumer) GetTopic ¶
func (s *SyncUnreadRpcConsumer) GetTopic() string
func (*SyncUnreadRpcConsumer) Start ¶
func (s *SyncUnreadRpcConsumer) Start() error
type TypingRpcConsumer ¶
type TypingRpcConsumer struct {
// contains filtered or unexported fields
}
func NewTypingRpcConsumer ¶
func NewTypingRpcConsumer( roomCurState *repos.RoomCurStateRepo, rpcClient *common.RpcClient, cfg *config.Dendrite, ) *TypingRpcConsumer
func (*TypingRpcConsumer) Clean ¶
func (s *TypingRpcConsumer) Clean()
func (*TypingRpcConsumer) GetCB ¶
func (s *TypingRpcConsumer) GetCB() common.MsgHandlerWithContext
func (*TypingRpcConsumer) GetTopic ¶
func (s *TypingRpcConsumer) GetTopic() string
func (*TypingRpcConsumer) Start ¶
func (s *TypingRpcConsumer) Start() error
Click to show internal directories.
Click to hide internal directories.