Documentation ¶
Index ¶
- type PushDataConsumer
- func (s *PushDataConsumer) Clean()
- func (s *PushDataConsumer) GetCB() common.MsgHandlerWithContext
- func (s *PushDataConsumer) GetTopic() string
- func (s *PushDataConsumer) HttpRequest(reqUrl string, content []byte) (int, []byte, error)
- func (s *PushDataConsumer) PushData(ctx context.Context, input *gomatrixserverlib.ClientEvent, ...)
- func (s *PushDataConsumer) SetPushFailTimes(pusherKey string, success bool) int
- func (s *PushDataConsumer) Start() error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type PushDataConsumer ¶
type PushDataConsumer struct {
// contains filtered or unexported fields
}
func NewPushDataConsumer ¶
func NewPushDataConsumer( cfg *config.Dendrite, pushDB model.PushAPIDatabase, client *common.RpcClient, ) *PushDataConsumer
func (*PushDataConsumer) Clean ¶
func (s *PushDataConsumer) Clean()
func (*PushDataConsumer) GetCB ¶
func (s *PushDataConsumer) GetCB() common.MsgHandlerWithContext
func (*PushDataConsumer) GetTopic ¶
func (s *PushDataConsumer) GetTopic() string
func (*PushDataConsumer) HttpRequest ¶
func (*PushDataConsumer) PushData ¶
func (s *PushDataConsumer) PushData( ctx context.Context, input *gomatrixserverlib.ClientEvent, pushers *pushapitypes.Pushers, senderDisplayName, roomName, userID, roomAlias string, action *pushapitypes.TweakAction, notifyCount int64, createContent interface{}, )
func (*PushDataConsumer) SetPushFailTimes ¶
func (s *PushDataConsumer) SetPushFailTimes(pusherKey string, success bool) int
func (*PushDataConsumer) Start ¶
func (s *PushDataConsumer) Start() error
Click to show internal directories.
Click to hide internal directories.