Documentation
¶
Index ¶
- func NewDBSyncapiClientDataStreamProcessor(name string, cfg *config.Dendrite) dbupdatetypes.DBEventSeqProcessor
- func NewDBSyncapiCurrentRoomStateProcessor(name string, cfg *config.Dendrite) dbupdatetypes.DBEventSeqProcessor
- func NewDBSyncapiEventProcessor(name string, cfg *config.Dendrite) dbupdatetypes.DBEventSeqProcessor
- func NewDBSyncapiKeyChangeStreamProcessor(name string, cfg *config.Dendrite) dbupdatetypes.DBEventSeqProcessor
- func NewDBSyncapiOutputMinStreamProcessor(name string, cfg *config.Dendrite) dbupdatetypes.DBEventSeqProcessor
- func NewDBSyncapiPresenceDataStreamProcessor(name string, cfg *config.Dendrite) dbupdatetypes.DBEventSeqProcessor
- func NewDBSyncapiReceiptDataStreamProcessor(name string, cfg *config.Dendrite) dbupdatetypes.DBEventSeqProcessor
- func NewDBSyncapiSendToDeviceProcessor(name string, cfg *config.Dendrite) dbupdatetypes.DBEventSeqProcessor
- func NewDBSyncapiUserReceiptDataProcessor(name string, cfg *config.Dendrite) dbupdatetypes.DBEventSeqProcessor
- func NewDBSyncapiUserTimelineProcessor(name string, cfg *config.Dendrite) dbupdatetypes.DBEventSeqProcessor
- type DBSyncapiClientDataStreamProcessor
- type DBSyncapiCurrentRoomStateProcessor
- type DBSyncapiEventProcessor
- type DBSyncapiKeyChangeStreamProcessor
- type DBSyncapiOutputMinStreamProcessor
- type DBSyncapiPresenceDataStreamProcessor
- type DBSyncapiReceiptDataStreamProcessor
- type DBSyncapiSendToDeviceProcessor
- type DBSyncapiUserReceiptDataProcessor
- type DBSyncapiUserTimelineProcessor
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewDBSyncapiClientDataStreamProcessor ¶
func NewDBSyncapiClientDataStreamProcessor( name string, cfg *config.Dendrite, ) dbupdatetypes.DBEventSeqProcessor
func NewDBSyncapiCurrentRoomStateProcessor ¶
func NewDBSyncapiCurrentRoomStateProcessor( name string, cfg *config.Dendrite, ) dbupdatetypes.DBEventSeqProcessor
func NewDBSyncapiEventProcessor ¶
func NewDBSyncapiEventProcessor( name string, cfg *config.Dendrite, ) dbupdatetypes.DBEventSeqProcessor
func NewDBSyncapiKeyChangeStreamProcessor ¶
func NewDBSyncapiKeyChangeStreamProcessor( name string, cfg *config.Dendrite, ) dbupdatetypes.DBEventSeqProcessor
func NewDBSyncapiOutputMinStreamProcessor ¶
func NewDBSyncapiOutputMinStreamProcessor( name string, cfg *config.Dendrite, ) dbupdatetypes.DBEventSeqProcessor
func NewDBSyncapiPresenceDataStreamProcessor ¶
func NewDBSyncapiPresenceDataStreamProcessor( name string, cfg *config.Dendrite, ) dbupdatetypes.DBEventSeqProcessor
func NewDBSyncapiReceiptDataStreamProcessor ¶
func NewDBSyncapiReceiptDataStreamProcessor( name string, cfg *config.Dendrite, ) dbupdatetypes.DBEventSeqProcessor
func NewDBSyncapiSendToDeviceProcessor ¶
func NewDBSyncapiSendToDeviceProcessor( name string, cfg *config.Dendrite, ) dbupdatetypes.DBEventSeqProcessor
func NewDBSyncapiUserReceiptDataProcessor ¶
func NewDBSyncapiUserReceiptDataProcessor( name string, cfg *config.Dendrite, ) dbupdatetypes.DBEventSeqProcessor
func NewDBSyncapiUserTimelineProcessor ¶
func NewDBSyncapiUserTimelineProcessor( name string, cfg *config.Dendrite, ) dbupdatetypes.DBEventSeqProcessor
Types ¶
type DBSyncapiClientDataStreamProcessor ¶
type DBSyncapiClientDataStreamProcessor struct {
// contains filtered or unexported fields
}
func (*DBSyncapiClientDataStreamProcessor) Process ¶
func (p *DBSyncapiClientDataStreamProcessor) Process(ctx context.Context, inputs []dbupdatetypes.DBEventDataInput) error
func (*DBSyncapiClientDataStreamProcessor) Start ¶
func (p *DBSyncapiClientDataStreamProcessor) Start()
type DBSyncapiCurrentRoomStateProcessor ¶
type DBSyncapiCurrentRoomStateProcessor struct {
// contains filtered or unexported fields
}
func (*DBSyncapiCurrentRoomStateProcessor) Process ¶
func (p *DBSyncapiCurrentRoomStateProcessor) Process(ctx context.Context, inputs []dbupdatetypes.DBEventDataInput) error
func (*DBSyncapiCurrentRoomStateProcessor) Start ¶
func (p *DBSyncapiCurrentRoomStateProcessor) Start()
type DBSyncapiEventProcessor ¶
type DBSyncapiEventProcessor struct {
// contains filtered or unexported fields
}
func (*DBSyncapiEventProcessor) BatchKeys ¶
func (p *DBSyncapiEventProcessor) BatchKeys() map[int64]bool
func (*DBSyncapiEventProcessor) Process ¶
func (p *DBSyncapiEventProcessor) Process(ctx context.Context, inputs []dbupdatetypes.DBEventDataInput) error
func (*DBSyncapiEventProcessor) Start ¶
func (p *DBSyncapiEventProcessor) Start()
type DBSyncapiKeyChangeStreamProcessor ¶
type DBSyncapiKeyChangeStreamProcessor struct {
// contains filtered or unexported fields
}
func (*DBSyncapiKeyChangeStreamProcessor) Process ¶
func (p *DBSyncapiKeyChangeStreamProcessor) Process(ctx context.Context, inputs []dbupdatetypes.DBEventDataInput) error
func (*DBSyncapiKeyChangeStreamProcessor) Start ¶
func (p *DBSyncapiKeyChangeStreamProcessor) Start()
type DBSyncapiOutputMinStreamProcessor ¶
type DBSyncapiOutputMinStreamProcessor struct {
// contains filtered or unexported fields
}
func (*DBSyncapiOutputMinStreamProcessor) Process ¶
func (p *DBSyncapiOutputMinStreamProcessor) Process(ctx context.Context, inputs []dbupdatetypes.DBEventDataInput) error
func (*DBSyncapiOutputMinStreamProcessor) Start ¶
func (p *DBSyncapiOutputMinStreamProcessor) Start()
type DBSyncapiPresenceDataStreamProcessor ¶
type DBSyncapiPresenceDataStreamProcessor struct {
// contains filtered or unexported fields
}
func (*DBSyncapiPresenceDataStreamProcessor) Process ¶
func (p *DBSyncapiPresenceDataStreamProcessor) Process(ctx context.Context, inputs []dbupdatetypes.DBEventDataInput) error
func (*DBSyncapiPresenceDataStreamProcessor) Start ¶
func (p *DBSyncapiPresenceDataStreamProcessor) Start()
type DBSyncapiReceiptDataStreamProcessor ¶
type DBSyncapiReceiptDataStreamProcessor struct {
// contains filtered or unexported fields
}
func (*DBSyncapiReceiptDataStreamProcessor) Process ¶
func (p *DBSyncapiReceiptDataStreamProcessor) Process(ctx context.Context, inputs []dbupdatetypes.DBEventDataInput) error
func (*DBSyncapiReceiptDataStreamProcessor) Start ¶
func (p *DBSyncapiReceiptDataStreamProcessor) Start()
type DBSyncapiSendToDeviceProcessor ¶
type DBSyncapiSendToDeviceProcessor struct {
// contains filtered or unexported fields
}
func (*DBSyncapiSendToDeviceProcessor) BatchKeys ¶
func (p *DBSyncapiSendToDeviceProcessor) BatchKeys() map[int64]bool
func (*DBSyncapiSendToDeviceProcessor) Process ¶
func (p *DBSyncapiSendToDeviceProcessor) Process(ctx context.Context, inputs []dbupdatetypes.DBEventDataInput) error
func (*DBSyncapiSendToDeviceProcessor) Start ¶
func (p *DBSyncapiSendToDeviceProcessor) Start()
type DBSyncapiUserReceiptDataProcessor ¶
type DBSyncapiUserReceiptDataProcessor struct {
// contains filtered or unexported fields
}
func (*DBSyncapiUserReceiptDataProcessor) Process ¶
func (p *DBSyncapiUserReceiptDataProcessor) Process(ctx context.Context, inputs []dbupdatetypes.DBEventDataInput) error
func (*DBSyncapiUserReceiptDataProcessor) Start ¶
func (p *DBSyncapiUserReceiptDataProcessor) Start()
type DBSyncapiUserTimelineProcessor ¶
type DBSyncapiUserTimelineProcessor struct {
// contains filtered or unexported fields
}
func (*DBSyncapiUserTimelineProcessor) BatchKeys ¶
func (p *DBSyncapiUserTimelineProcessor) BatchKeys() map[int64]bool
func (*DBSyncapiUserTimelineProcessor) Process ¶
func (p *DBSyncapiUserTimelineProcessor) Process(ctx context.Context, inputs []dbupdatetypes.DBEventDataInput) error
func (*DBSyncapiUserTimelineProcessor) Start ¶
func (p *DBSyncapiUserTimelineProcessor) Start()
Source Files
¶
Click to show internal directories.
Click to hide internal directories.