consumers

Documentation

Index

• type ActDataConsumer
  • func NewActDataConsumer(cfg *config.Dendrite, store model.SyncAPIDatabase) *ActDataConsumer
  • func (s *ActDataConsumer) OnMessage(ctx context.Context, topic string, partition int32, data []byte, ...)
  • func (s *ActDataConsumer) SetClientDataStreamRepo(clientDataStreamRepo *repos.ClientDataStreamRepo) *ActDataConsumer
  • func (s *ActDataConsumer) Start() error
• type EventFeedConsumer
  • func NewEventFeedConsumer(cfg *config.Dendrite, store model.SyncAPIDatabase, cache service.Cache) *EventFeedConsumer
  • func (s *EventFeedConsumer) OnMessage(ctx context.Context, topic string, partition int32, data []byte, ...)
  • func (s *EventFeedConsumer) SetPresenceStreamRepo(presenceRepo *repos.PresenceDataStreamRepo) *EventFeedConsumer
  • func (s *EventFeedConsumer) SetUserTimeLine(userTimeLine *repos.UserTimeLineRepo) *EventFeedConsumer
  • func (s *EventFeedConsumer) Start() error
• type ProfileConsumer
  • func NewProfileConsumer(cfg *config.Dendrite, userTimeLine *repos.UserTimeLineRepo, ...) *ProfileConsumer
  • func (s *ProfileConsumer) OnMessage(ctx context.Context, topic string, partition int32, data []byte, ...)
  • func (s *ProfileConsumer) SetOnlineUserRepo(ol *repos.OnlineUserRepo)
  • func (s *ProfileConsumer) SetPresenceStreamRepo(presenceRepo *repos.PresenceDataStreamRepo) *ProfileConsumer
  • func (s *ProfileConsumer) Start() error
• type TypingConsumer
  • func NewTypingConsumer(calculateDelay int64, typingTimeOut int64, delay int64) *TypingConsumer
  • func (s *TypingConsumer) AddRoomJoined(roomID string, joined []string)
  • func (s *TypingConsumer) AddTyping(roomID, userID string)
  • func (s *TypingConsumer) ExistsTyping(userID, deviceID, curRoomID string) (exists bool)
  • func (s *TypingConsumer) GetTyping(userID, deviceID, curRoomID string) []gomatrixserverlib.ClientEvent
  • func (s *TypingConsumer) RemoveTyping(roomID, userID string)
  • func (s *TypingConsumer) StartCalculate()
• type UtlContent
• type UtlEvent

Types

type ActDataConsumer

type ActDataConsumer struct {
	// contains filtered or unexported fields
}

func NewActDataConsumer

func NewActDataConsumer(
	cfg *config.Dendrite,
	store model.SyncAPIDatabase,
) *ActDataConsumer

func (*ActDataConsumer) OnMessage

func (s *ActDataConsumer) OnMessage(ctx context.Context, topic string, partition int32, data []byte, rawMsg interface{})

func (*ActDataConsumer) SetClientDataStreamRepo

func (s *ActDataConsumer) SetClientDataStreamRepo(clientDataStreamRepo *repos.ClientDataStreamRepo) *ActDataConsumer

func (*ActDataConsumer) Start

func (s *ActDataConsumer) Start() error

type EventFeedConsumer

type EventFeedConsumer struct {
	// contains filtered or unexported fields
}

func NewEventFeedConsumer

func NewEventFeedConsumer(
	cfg *config.Dendrite,
	store model.SyncAPIDatabase,
	cache service.Cache,
) *EventFeedConsumer

func (*EventFeedConsumer) OnMessage

func (s *EventFeedConsumer) OnMessage(ctx context.Context, topic string, partition int32, data []byte, rawMsg interface{})

func (*EventFeedConsumer) SetPresenceStreamRepo

func (s *EventFeedConsumer) SetPresenceStreamRepo(presenceRepo *repos.PresenceDataStreamRepo) *EventFeedConsumer

func (*EventFeedConsumer) SetUserTimeLine

func (s *EventFeedConsumer) SetUserTimeLine(userTimeLine *repos.UserTimeLineRepo) *EventFeedConsumer

func (*EventFeedConsumer) Start

func (s *EventFeedConsumer) Start() error

type ProfileConsumer

type ProfileConsumer struct {
	// contains filtered or unexported fields
}

func NewProfileConsumer

func NewProfileConsumer(
	cfg *config.Dendrite,
	userTimeLine *repos.UserTimeLineRepo,
	syncDB model.SyncAPIDatabase,
	idg *uid.UidGenerator,
	cache service.Cache,
) *ProfileConsumer

func (*ProfileConsumer) OnMessage

func (s *ProfileConsumer) OnMessage(ctx context.Context, topic string, partition int32, data []byte, rawMsg interface{})

func (*ProfileConsumer) SetOnlineUserRepo

func (s *ProfileConsumer) SetOnlineUserRepo(ol *repos.OnlineUserRepo)

func (*ProfileConsumer) SetPresenceStreamRepo

func (s *ProfileConsumer) SetPresenceStreamRepo(presenceRepo *repos.PresenceDataStreamRepo) *ProfileConsumer

func (*ProfileConsumer) Start

func (s *ProfileConsumer) Start() error

type TypingConsumer

type TypingConsumer struct {
	// contains filtered or unexported fields
}

func NewTypingConsumer

func NewTypingConsumer(
	calculateDelay int64,
	typingTimeOut int64,
	delay int64,
) *TypingConsumer

func (*TypingConsumer) AddRoomJoined

func (s *TypingConsumer) AddRoomJoined(roomID string, joined []string)

func (*TypingConsumer) AddTyping

func (s *TypingConsumer) AddTyping(roomID, userID string)

func (*TypingConsumer) ExistsTyping

func (s *TypingConsumer) ExistsTyping(userID, deviceID, curRoomID string) (exists bool)

func (*TypingConsumer) GetTyping

func (s *TypingConsumer) GetTyping(userID, deviceID, curRoomID string) []gomatrixserverlib.ClientEvent

func (*TypingConsumer) RemoveTyping

func (s *TypingConsumer) RemoveTyping(roomID, userID string)

func (*TypingConsumer) StartCalculate

func (s *TypingConsumer) StartCalculate()

type UtlContent

type UtlContent struct {
	// contains filtered or unexported fields
}

type UtlEvent

type UtlEvent struct {
	Event        gomatrixserverlib.ClientEvent
	RelateJoined []string
	Joined       []string
}