Documentation
¶
Index ¶
- func NewCacheRoomserverEventsProcessor(name string, cfg *config.Dendrite, pool dbupdatetypes.Pool) dbupdatetypes.CacheProcessor
- func NewCacheRoomserverSettingProcessor(name string, cfg *config.Dendrite, pool dbupdatetypes.Pool) dbupdatetypes.CacheProcessor
- func NewDBRoomserverEventJSONProcessor(name string, cfg *config.Dendrite) dbupdatetypes.DBEventSeqProcessor
- func NewDBRoomserverEventsProcessor(name string, cfg *config.Dendrite) dbupdatetypes.DBEventSeqProcessor
- func NewDBRoomserverInvitesProcessor(name string, cfg *config.Dendrite) dbupdatetypes.DBEventSeqProcessor
- func NewDBRoomserverMembershipProcessor(name string, cfg *config.Dendrite) dbupdatetypes.DBEventSeqProcessor
- func NewDBRoomserverRoomAliasesProcessor(name string, cfg *config.Dendrite) dbupdatetypes.DBEventSeqProcessor
- func NewDBRoomserverRoomDomainsProcessor(name string, cfg *config.Dendrite) dbupdatetypes.DBEventSeqProcessor
- func NewDBRoomserverRoomsProcessor(name string, cfg *config.Dendrite) dbupdatetypes.DBEventSeqProcessor
- func NewDBRoomserverSettingProcessor(name string, cfg *config.Dendrite) dbupdatetypes.DBEventSeqProcessor
- func NewDBRoomserverStateSanpshotsProcessor(name string, cfg *config.Dendrite) dbupdatetypes.DBEventSeqProcessor
- type CacheRoomserverEventsProcessor
- type CacheRoomserverSettingProcessor
- type DBRoomserverEventJSONProcessor
- type DBRoomserverEventsProcessor
- type DBRoomserverInvitesProcessor
- type DBRoomserverMembershipProcessor
- type DBRoomserverRoomAliasesProcessor
- type DBRoomserverRoomDomainsProcessor
- type DBRoomserverRoomsProcessor
- type DBRoomserverSettingProcessor
- type DBRoomserverStateSanpshotsProcessor
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewCacheRoomserverEventsProcessor ¶
func NewCacheRoomserverEventsProcessor(name string, cfg *config.Dendrite, pool dbupdatetypes.Pool) dbupdatetypes.CacheProcessor
func NewCacheRoomserverSettingProcessor ¶
func NewCacheRoomserverSettingProcessor(name string, cfg *config.Dendrite, pool dbupdatetypes.Pool) dbupdatetypes.CacheProcessor
func NewDBRoomserverEventJSONProcessor ¶
func NewDBRoomserverEventJSONProcessor( name string, cfg *config.Dendrite, ) dbupdatetypes.DBEventSeqProcessor
func NewDBRoomserverEventsProcessor ¶
func NewDBRoomserverEventsProcessor( name string, cfg *config.Dendrite, ) dbupdatetypes.DBEventSeqProcessor
func NewDBRoomserverInvitesProcessor ¶
func NewDBRoomserverInvitesProcessor( name string, cfg *config.Dendrite, ) dbupdatetypes.DBEventSeqProcessor
func NewDBRoomserverMembershipProcessor ¶
func NewDBRoomserverMembershipProcessor( name string, cfg *config.Dendrite, ) dbupdatetypes.DBEventSeqProcessor
func NewDBRoomserverRoomAliasesProcessor ¶
func NewDBRoomserverRoomAliasesProcessor( name string, cfg *config.Dendrite, ) dbupdatetypes.DBEventSeqProcessor
func NewDBRoomserverRoomDomainsProcessor ¶
func NewDBRoomserverRoomDomainsProcessor( name string, cfg *config.Dendrite, ) dbupdatetypes.DBEventSeqProcessor
func NewDBRoomserverRoomsProcessor ¶
func NewDBRoomserverRoomsProcessor( name string, cfg *config.Dendrite, ) dbupdatetypes.DBEventSeqProcessor
func NewDBRoomserverSettingProcessor ¶
func NewDBRoomserverSettingProcessor( name string, cfg *config.Dendrite, ) dbupdatetypes.DBEventSeqProcessor
func NewDBRoomserverStateSanpshotsProcessor ¶
func NewDBRoomserverStateSanpshotsProcessor( name string, cfg *config.Dendrite, ) dbupdatetypes.DBEventSeqProcessor
Types ¶
type CacheRoomserverEventsProcessor ¶
type CacheRoomserverEventsProcessor struct {
// contains filtered or unexported fields
}
func (*CacheRoomserverEventsProcessor) Process ¶
func (p *CacheRoomserverEventsProcessor) Process(ctx context.Context, input dbupdatetypes.CacheInput) error
func (*CacheRoomserverEventsProcessor) Start ¶
func (p *CacheRoomserverEventsProcessor) Start()
type CacheRoomserverSettingProcessor ¶
type CacheRoomserverSettingProcessor struct {
// contains filtered or unexported fields
}
func (*CacheRoomserverSettingProcessor) Process ¶
func (p *CacheRoomserverSettingProcessor) Process(ctx context.Context, input dbupdatetypes.CacheInput) error
func (*CacheRoomserverSettingProcessor) Start ¶
func (p *CacheRoomserverSettingProcessor) Start()
type DBRoomserverEventJSONProcessor ¶
type DBRoomserverEventJSONProcessor struct {
// contains filtered or unexported fields
}
func (*DBRoomserverEventJSONProcessor) BatchKeys ¶
func (p *DBRoomserverEventJSONProcessor) BatchKeys() map[int64]bool
func (*DBRoomserverEventJSONProcessor) Process ¶
func (p *DBRoomserverEventJSONProcessor) Process(ctx context.Context, inputs []dbupdatetypes.DBEventDataInput) error
func (*DBRoomserverEventJSONProcessor) Start ¶
func (p *DBRoomserverEventJSONProcessor) Start()
type DBRoomserverEventsProcessor ¶
type DBRoomserverEventsProcessor struct {
// contains filtered or unexported fields
}
func (*DBRoomserverEventsProcessor) BatchKeys ¶
func (p *DBRoomserverEventsProcessor) BatchKeys() map[int64]bool
func (*DBRoomserverEventsProcessor) Process ¶
func (p *DBRoomserverEventsProcessor) Process(ctx context.Context, inputs []dbupdatetypes.DBEventDataInput) error
func (*DBRoomserverEventsProcessor) Start ¶
func (p *DBRoomserverEventsProcessor) Start()
type DBRoomserverInvitesProcessor ¶
type DBRoomserverInvitesProcessor struct {
// contains filtered or unexported fields
}
func (*DBRoomserverInvitesProcessor) BatchKeys ¶
func (p *DBRoomserverInvitesProcessor) BatchKeys() map[int64]bool
func (*DBRoomserverInvitesProcessor) Process ¶
func (p *DBRoomserverInvitesProcessor) Process(ctx context.Context, inputs []dbupdatetypes.DBEventDataInput) error
func (*DBRoomserverInvitesProcessor) Start ¶
func (p *DBRoomserverInvitesProcessor) Start()
type DBRoomserverMembershipProcessor ¶
type DBRoomserverMembershipProcessor struct {
// contains filtered or unexported fields
}
func (*DBRoomserverMembershipProcessor) BatchKeys ¶
func (p *DBRoomserverMembershipProcessor) BatchKeys() map[int64]bool
func (*DBRoomserverMembershipProcessor) Process ¶
func (p *DBRoomserverMembershipProcessor) Process(ctx context.Context, inputs []dbupdatetypes.DBEventDataInput) error
func (*DBRoomserverMembershipProcessor) Start ¶
func (p *DBRoomserverMembershipProcessor) Start()
type DBRoomserverRoomAliasesProcessor ¶
type DBRoomserverRoomAliasesProcessor struct {
// contains filtered or unexported fields
}
func (*DBRoomserverRoomAliasesProcessor) BatchKeys ¶
func (p *DBRoomserverRoomAliasesProcessor) BatchKeys() map[int64]bool
func (*DBRoomserverRoomAliasesProcessor) Process ¶
func (p *DBRoomserverRoomAliasesProcessor) Process(ctx context.Context, inputs []dbupdatetypes.DBEventDataInput) error
func (*DBRoomserverRoomAliasesProcessor) Start ¶
func (p *DBRoomserverRoomAliasesProcessor) Start()
type DBRoomserverRoomDomainsProcessor ¶
type DBRoomserverRoomDomainsProcessor struct {
// contains filtered or unexported fields
}
func (*DBRoomserverRoomDomainsProcessor) Process ¶
func (p *DBRoomserverRoomDomainsProcessor) Process(ctx context.Context, inputs []dbupdatetypes.DBEventDataInput) error
func (*DBRoomserverRoomDomainsProcessor) Start ¶
func (p *DBRoomserverRoomDomainsProcessor) Start()
type DBRoomserverRoomsProcessor ¶
type DBRoomserverRoomsProcessor struct {
// contains filtered or unexported fields
}
func (*DBRoomserverRoomsProcessor) BatchKeys ¶
func (p *DBRoomserverRoomsProcessor) BatchKeys() map[int64]bool
func (*DBRoomserverRoomsProcessor) Process ¶
func (p *DBRoomserverRoomsProcessor) Process(ctx context.Context, inputs []dbupdatetypes.DBEventDataInput) error
func (*DBRoomserverRoomsProcessor) Start ¶
func (p *DBRoomserverRoomsProcessor) Start()
type DBRoomserverSettingProcessor ¶
type DBRoomserverSettingProcessor struct {
// contains filtered or unexported fields
}
func (*DBRoomserverSettingProcessor) Process ¶
func (p *DBRoomserverSettingProcessor) Process(ctx context.Context, inputs []dbupdatetypes.DBEventDataInput) error
func (*DBRoomserverSettingProcessor) Start ¶
func (p *DBRoomserverSettingProcessor) Start()
type DBRoomserverStateSanpshotsProcessor ¶
type DBRoomserverStateSanpshotsProcessor struct {
// contains filtered or unexported fields
}
func (*DBRoomserverStateSanpshotsProcessor) Process ¶
func (p *DBRoomserverStateSanpshotsProcessor) Process(ctx context.Context, inputs []dbupdatetypes.DBEventDataInput) error
func (*DBRoomserverStateSanpshotsProcessor) Start ¶
func (p *DBRoomserverStateSanpshotsProcessor) Start()
Source Files
Click to show internal directories.
Click to hide internal directories.