Documentation ¶
Index ¶
- func NewCacheDeviceDevicesProcessor(name string, cfg *config.Dendrite, pool dbupdatetypes.Pool) dbupdatetypes.CacheProcessor
- func NewCacheDeviceMigDevicesProcessor(name string, cfg *config.Dendrite, pool dbupdatetypes.Pool) dbupdatetypes.CacheProcessor
- func NewDBDeviceDevicesProcessor(name string, cfg *config.Dendrite) dbupdatetypes.DBEventSeqProcessor
- func NewDBDeviceMigDevicesProcessor(name string, cfg *config.Dendrite) dbupdatetypes.DBEventSeqProcessor
- type CacheDeviceDevicesProcessor
- type CacheDeviceMigDevicesProcessor
- type DBDeviceDevicesProcessor
- type DBDeviceMigDevicesProcessor
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewCacheDeviceDevicesProcessor ¶
func NewCacheDeviceDevicesProcessor(name string, cfg *config.Dendrite, pool dbupdatetypes.Pool) dbupdatetypes.CacheProcessor
func NewCacheDeviceMigDevicesProcessor ¶
func NewCacheDeviceMigDevicesProcessor(name string, cfg *config.Dendrite, pool dbupdatetypes.Pool) dbupdatetypes.CacheProcessor
func NewDBDeviceDevicesProcessor ¶
func NewDBDeviceDevicesProcessor( name string, cfg *config.Dendrite, ) dbupdatetypes.DBEventSeqProcessor
func NewDBDeviceMigDevicesProcessor ¶
func NewDBDeviceMigDevicesProcessor( name string, cfg *config.Dendrite, ) dbupdatetypes.DBEventSeqProcessor
Types ¶
type CacheDeviceDevicesProcessor ¶
type CacheDeviceDevicesProcessor struct {
// contains filtered or unexported fields
}
func (*CacheDeviceDevicesProcessor) Process ¶
func (p *CacheDeviceDevicesProcessor) Process(ctx context.Context, input dbupdatetypes.CacheInput) error
func (*CacheDeviceDevicesProcessor) Start ¶
func (p *CacheDeviceDevicesProcessor) Start()
type CacheDeviceMigDevicesProcessor ¶
type CacheDeviceMigDevicesProcessor struct {
// contains filtered or unexported fields
}
func (*CacheDeviceMigDevicesProcessor) Process ¶
func (p *CacheDeviceMigDevicesProcessor) Process(ctx context.Context, input dbupdatetypes.CacheInput) error
func (*CacheDeviceMigDevicesProcessor) Start ¶
func (p *CacheDeviceMigDevicesProcessor) Start()
type DBDeviceDevicesProcessor ¶
type DBDeviceDevicesProcessor struct {
// contains filtered or unexported fields
}
func (*DBDeviceDevicesProcessor) Process ¶
func (p *DBDeviceDevicesProcessor) Process(ctx context.Context, inputs []dbupdatetypes.DBEventDataInput) error
func (*DBDeviceDevicesProcessor) Start ¶
func (p *DBDeviceDevicesProcessor) Start()
type DBDeviceMigDevicesProcessor ¶
type DBDeviceMigDevicesProcessor struct {
// contains filtered or unexported fields
}
func (*DBDeviceMigDevicesProcessor) Process ¶
func (p *DBDeviceMigDevicesProcessor) Process(ctx context.Context, inputs []dbupdatetypes.DBEventDataInput) error
func (*DBDeviceMigDevicesProcessor) Start ¶
func (p *DBDeviceMigDevicesProcessor) Start()
Click to show internal directories.
Click to hide internal directories.