consumers

package
v0.0.0-...-9835270 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 22, 2021 License: AGPL-3.0, Apache-2.0 Imports: 31 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ProfileConsumer 

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

func NewProfileConsumer 

func NewProfileConsumer(
	cfg *config.Dendrite,
) *ProfileConsumer

func (*ProfileConsumer) OnMessage 

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

func (*ProfileConsumer) SetDisplayNameRepo 

func (s *ProfileConsumer) SetDisplayNameRepo(displayNameRepo *repos.DisplayNameRepo) *ProfileConsumer

func (*ProfileConsumer) Start 

func (s *ProfileConsumer) Start() error

type PushConsumer 

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

func NewPushConsumer 

func NewPushConsumer(
	cache service.Cache,
	client *common.RpcClient,
	complexCache *common.ComplexCache,
) *PushConsumer

func (*PushConsumer) DispthEvent 

func (s *PushConsumer) DispthEvent(ctx context.Context, ev *gomatrixserverlib.ClientEvent)

func (*PushConsumer) IsRelatesContent 

func (s *PushConsumer) IsRelatesContent(redactEv gomatrixserverlib.ClientEvent) bool

func (*PushConsumer) OnEvent 

func (s *PushConsumer) OnEvent(ctx context.Context, input *gomatrixserverlib.ClientEvent, eventOffset int64)

func (*PushConsumer) SetCountRepo 

func (s *PushConsumer) SetCountRepo(countRepo *repos.ReadCountRepo) *PushConsumer

func (*PushConsumer) SetEventRepo 

func (s *PushConsumer) SetEventRepo(eventRepo *repos.EventReadStreamRepo) *PushConsumer

func (*PushConsumer) SetRoomCurState 

func (s *PushConsumer) SetRoomCurState(roomCurState *repos.RoomCurStateRepo) *PushConsumer

func (*PushConsumer) SetRoomHistory 

func (s *PushConsumer) SetRoomHistory(roomHistory *repos.RoomHistoryTimeLineRepo) *PushConsumer

func (*PushConsumer) SetRsTimeline 

func (s *PushConsumer) SetRsTimeline(rsTimeline *repos.RoomStateTimeLineRepo) *PushConsumer

func (*PushConsumer) Start 

func (s *PushConsumer) Start()

type ReceiptConsumer 

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

func NewReceiptConsumer 

func NewReceiptConsumer(
	rpcClient *common.RpcClient,
	cfg *config.Dendrite,
	idg *uid.UidGenerator,
) *ReceiptConsumer

func (*ReceiptConsumer) OnReceipt 

func (s *ReceiptConsumer) OnReceipt(ctx context.Context, req *types.ReceiptContent)

it's a up to markers

func (*ReceiptConsumer) SetCountRepo 

func (s *ReceiptConsumer) SetCountRepo(countRepo *repos.ReadCountRepo) *ReceiptConsumer

func (*ReceiptConsumer) SetReceiptRepo 

func (s *ReceiptConsumer) SetReceiptRepo(receiptRepo *repos.ReceiptDataStreamRepo) *ReceiptConsumer

func (*ReceiptConsumer) SetRoomCurState 

func (s *ReceiptConsumer) SetRoomCurState(roomCurState *repos.RoomCurStateRepo) *ReceiptConsumer

func (*ReceiptConsumer) SetRoomHistory 

func (s *ReceiptConsumer) SetRoomHistory(roomHistory *repos.RoomHistoryTimeLineRepo) *ReceiptConsumer

func (*ReceiptConsumer) SetRsTimeline 

func (s *ReceiptConsumer) SetRsTimeline(rsTimeline *repos.RoomStateTimeLineRepo) *ReceiptConsumer

func (*ReceiptConsumer) SetUserReceiptRepo 

func (s *ReceiptConsumer) SetUserReceiptRepo(userReceiptRepo *repos.UserReceiptRepo) *ReceiptConsumer

func (*ReceiptConsumer) Start 

func (s *ReceiptConsumer) Start() error

Start consuming from room servers

type RoomEventFeedConsumer 

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

OutputRoomEventConsumer consumes events that originated in the room server.

func NewRoomEventFeedConsumer 

func NewRoomEventFeedConsumer(
	cfg *config.Dendrite,
	store model.SyncAPIDatabase,
	pushConsumer *PushConsumer,
	rpcClient *common.RpcClient,
	idg *uid.UidGenerator,
) *RoomEventFeedConsumer

func (*RoomEventFeedConsumer) OnMessage 

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

func (*RoomEventFeedConsumer) SetDisplayNameRepo 

func (s *RoomEventFeedConsumer) SetDisplayNameRepo(displayNameRepo *repos.DisplayNameRepo) *RoomEventFeedConsumer

func (*RoomEventFeedConsumer) SetReceiptRepo 

func (s *RoomEventFeedConsumer) SetReceiptRepo(receiptDataStreamRepo *repos.ReceiptDataStreamRepo) *RoomEventFeedConsumer

func (*RoomEventFeedConsumer) SetRoomHistory 

func (s *RoomEventFeedConsumer) SetRoomHistory(roomHistory *repos.RoomHistoryTimeLineRepo) *RoomEventFeedConsumer

func (*RoomEventFeedConsumer) SetRsCurState 

func (s *RoomEventFeedConsumer) SetRsCurState(rsCurState *repos.RoomCurStateRepo) *RoomEventFeedConsumer

func (*RoomEventFeedConsumer) SetRsTimeline 

func (s *RoomEventFeedConsumer) SetRsTimeline(rsTimeline *repos.RoomStateTimeLineRepo) *RoomEventFeedConsumer

func (*RoomEventFeedConsumer) Start 

func (s *RoomEventFeedConsumer) Start() error

type StateEvWithPrio 

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

type StateEvWithPrioSorter 

type StateEvWithPrioSorter []StateEvWithPrio

func (StateEvWithPrioSorter) Len 

func (s StateEvWithPrioSorter) Len() int

func (StateEvWithPrioSorter) Less 

func (s StateEvWithPrioSorter) Less(i, j int) bool

func (StateEvWithPrioSorter) Swap 

func (s StateEvWithPrioSorter) Swap(i, j int)

type SyncServer 

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

func NewSyncServer 

func NewSyncServer(
	db model.SyncAPIDatabase,
	slot uint32,
	chanSize int,
	cfg *config.Dendrite,
	rpcClient *common.RpcClient,
) *SyncServer

func (*SyncServer) OnSyncRequest 

func (s *SyncServer) OnSyncRequest(
	ctx context.Context,
	req *syncapitypes.SyncServerRequest,
)

func (*SyncServer) SetCache 

func (s *SyncServer) SetCache(cache service.Cache) *SyncServer

func (*SyncServer) SetDisplayNameRepo 

func (s *SyncServer) SetDisplayNameRepo(displayNameRepo *repos.DisplayNameRepo) *SyncServer

func (*SyncServer) SetReadCountRepo 

func (s *SyncServer) SetReadCountRepo(readCountRepo *repos.ReadCountRepo) *SyncServer

func (*SyncServer) SetReceiptDataStreamRepo 

func (s *SyncServer) SetReceiptDataStreamRepo(receiptDataStreamRepo *repos.ReceiptDataStreamRepo) *SyncServer

func (*SyncServer) SetRoomHistory 

func (s *SyncServer) SetRoomHistory(roomHistory *repos.RoomHistoryTimeLineRepo) *SyncServer

func (*SyncServer) SetRsCurState 

func (s *SyncServer) SetRsCurState(rsCurState *repos.RoomCurStateRepo) *SyncServer

func (*SyncServer) SetRsTimeline 

func (s *SyncServer) SetRsTimeline(rsTimeline *repos.RoomStateTimeLineRepo) *SyncServer

func (*SyncServer) SetSettings 

func (s *SyncServer) SetSettings(settings *common.Settings)

func (*SyncServer) SetUserReceiptDataRepo 

func (s *SyncServer) SetUserReceiptDataRepo(userReceiptDataRepo *repos.UserReceiptRepo) *SyncServer

func (*SyncServer) Start 

func (s *SyncServer) Start()

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.