fixer

Documentation

Index

• type Consumer
  • func NewConsumer[T migrator.Entity](client sarama.Client, l logger.LoggerV1, topic string, src *gorm.DB, ...) (*Consumer[T], error)
  • func (r *Consumer[T]) Consume(msg *sarama.ConsumerMessage, t events.InconsistentEvent) error
  • func (r *Consumer[T]) Start() error

Types

type Consumer

type Consumer[T migrator.Entity] struct {
	// contains filtered or unexported fields
}

func NewConsumer

func NewConsumer[T migrator.Entity](
	client sarama.Client,
	l logger.LoggerV1,
	topic string,
	src *gorm.DB,
	dst *gorm.DB) (*Consumer[T], error)

func (*Consumer[T]) Consume

func (r *Consumer[T]) Consume(msg *sarama.ConsumerMessage, t events.InconsistentEvent) error

func (*Consumer[T]) Start

func (r *Consumer[T]) Start() error

Start 这边就是自己启动 goroutine 了