dbupdatetypes

Documentation

Index

• type CacheFactory
• type CacheInput
• type CacheProcessor
• type DBEventDataInput
• type DBEventSeqBatch
• type DBEventSeqProcessor
• type KafkaCommiter
• type Pool
• type ProcessorFactory

Types

type CacheFactory

type CacheFactory = func(string, *config.Dendrite, Pool) CacheProcessor

type CacheInput

type CacheInput struct {
	Event *dbtypes.DBEvent
}

type CacheProcessor

type CacheProcessor interface {
	Start()
	Process(ctx context.Context, input CacheInput) error
}

type DBEventDataInput

type DBEventDataInput struct {
	Data   []byte
	RawMsg interface{}
	Event  *dbtypes.DBEvent
}

type DBEventSeqBatch

type DBEventSeqBatch interface {
	BatchKeys() map[int64]bool
}

type DBEventSeqProcessor

type DBEventSeqProcessor interface {
	Start()
	Process(ctx context.Context, input []DBEventDataInput) error
}

type KafkaCommiter

type KafkaCommiter interface {
	Commit(rawMsg []interface{}) error
}

type Pool

type Pool interface {
	Pool() *redis.Pool
}

type ProcessorFactory

type ProcessorFactory = func(string, *config.Dendrite) DBEventSeqProcessor