Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type CacheUpdateConsumer ¶
func (*CacheUpdateConsumer) Start ¶
func (c *CacheUpdateConsumer) Start() error
type CacheUpdateManager ¶
type CacheUpdateManager struct {
// contains filtered or unexported fields
}
func NewCacheUpdateManager ¶
func NewCacheUpdateManager(cfg *config.Dendrite) *CacheUpdateManager
func (*CacheUpdateManager) Pool ¶
func (m *CacheUpdateManager) Pool() *redis.Pool
func (*CacheUpdateManager) Start ¶
func (m *CacheUpdateManager) Start() error
type DBEventSeqConsumer ¶
func (*DBEventSeqConsumer) CommitMessage ¶
func (c *DBEventSeqConsumer) CommitMessage(rawMsg []interface{})
func (*DBEventSeqConsumer) Start ¶
func (c *DBEventSeqConsumer) Start() error
type DBEventSeqManager ¶
type DBEventSeqManager struct {
// contains filtered or unexported fields
}
func NewDBEventSeqManager ¶
func NewDBEventSeqManager(cfg *config.Dendrite) *DBEventSeqManager
func (*DBEventSeqManager) Start ¶
func (m *DBEventSeqManager) Start() error
type IKafkaChannelSub ¶
Click to show internal directories.
Click to hide internal directories.