Documentation
¶
Index ¶
- func NewCachePushPusherProcessor(name string, cfg *config.Dendrite, pool dbupdatetypes.Pool) dbupdatetypes.CacheProcessor
- func NewCachePushRulesEnableProcessor(name string, cfg *config.Dendrite, pool dbupdatetypes.Pool) dbupdatetypes.CacheProcessor
- func NewCachePushRulesProcessor(name string, cfg *config.Dendrite, pool dbupdatetypes.Pool) dbupdatetypes.CacheProcessor
- func NewDBPushPusersProcessor(name string, cfg *config.Dendrite) dbupdatetypes.DBEventSeqProcessor
- func NewDBPushRulesEnableProcessor(name string, cfg *config.Dendrite) dbupdatetypes.DBEventSeqProcessor
- func NewDBPushRulesProcessor(name string, cfg *config.Dendrite) dbupdatetypes.DBEventSeqProcessor
- type CachePushPusherProcessor
- type CachePushRulesEnableProcessor
- type CachePushRulesProcessor
- type DBPushPusersProcessor
- type DBPushRulesEnableProcessor
- type DBPushRulesProcessor
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewCachePushPusherProcessor ¶
func NewCachePushPusherProcessor(name string, cfg *config.Dendrite, pool dbupdatetypes.Pool) dbupdatetypes.CacheProcessor
func NewCachePushRulesEnableProcessor ¶
func NewCachePushRulesEnableProcessor(name string, cfg *config.Dendrite, pool dbupdatetypes.Pool) dbupdatetypes.CacheProcessor
func NewCachePushRulesProcessor ¶
func NewCachePushRulesProcessor(name string, cfg *config.Dendrite, pool dbupdatetypes.Pool) dbupdatetypes.CacheProcessor
func NewDBPushPusersProcessor ¶
func NewDBPushPusersProcessor( name string, cfg *config.Dendrite, ) dbupdatetypes.DBEventSeqProcessor
func NewDBPushRulesEnableProcessor ¶
func NewDBPushRulesEnableProcessor( name string, cfg *config.Dendrite, ) dbupdatetypes.DBEventSeqProcessor
func NewDBPushRulesProcessor ¶
func NewDBPushRulesProcessor( name string, cfg *config.Dendrite, ) dbupdatetypes.DBEventSeqProcessor
Types ¶
type CachePushPusherProcessor ¶
type CachePushPusherProcessor struct {
// contains filtered or unexported fields
}
func (*CachePushPusherProcessor) Process ¶
func (p *CachePushPusherProcessor) Process(ctx context.Context, input dbupdatetypes.CacheInput) error
func (*CachePushPusherProcessor) Start ¶
func (p *CachePushPusherProcessor) Start()
type CachePushRulesEnableProcessor ¶
type CachePushRulesEnableProcessor struct {
// contains filtered or unexported fields
}
func (*CachePushRulesEnableProcessor) Process ¶
func (p *CachePushRulesEnableProcessor) Process(ctx context.Context, input dbupdatetypes.CacheInput) error
func (*CachePushRulesEnableProcessor) Start ¶
func (p *CachePushRulesEnableProcessor) Start()
type CachePushRulesProcessor ¶
type CachePushRulesProcessor struct {
// contains filtered or unexported fields
}
func (*CachePushRulesProcessor) Process ¶
func (p *CachePushRulesProcessor) Process(ctx context.Context, input dbupdatetypes.CacheInput) error
func (*CachePushRulesProcessor) Start ¶
func (p *CachePushRulesProcessor) Start()
type DBPushPusersProcessor ¶
type DBPushPusersProcessor struct {
// contains filtered or unexported fields
}
func (*DBPushPusersProcessor) Process ¶
func (p *DBPushPusersProcessor) Process(ctx context.Context, inputs []dbupdatetypes.DBEventDataInput) error
func (*DBPushPusersProcessor) Start ¶
func (p *DBPushPusersProcessor) Start()
type DBPushRulesEnableProcessor ¶
type DBPushRulesEnableProcessor struct {
// contains filtered or unexported fields
}
func (*DBPushRulesEnableProcessor) Process ¶
func (p *DBPushRulesEnableProcessor) Process(ctx context.Context, inputs []dbupdatetypes.DBEventDataInput) error
func (*DBPushRulesEnableProcessor) Start ¶
func (p *DBPushRulesEnableProcessor) Start()
type DBPushRulesProcessor ¶
type DBPushRulesProcessor struct {
// contains filtered or unexported fields
}
func (*DBPushRulesProcessor) Process ¶
func (p *DBPushRulesProcessor) Process(ctx context.Context, inputs []dbupdatetypes.DBEventDataInput) error
func (*DBPushRulesProcessor) Start ¶
func (p *DBPushRulesProcessor) Start()
Source Files
Click to show internal directories.
Click to hide internal directories.