fixer

Documentation

Index

• type Consumer
  • func NewConsumer[T migrator.Entity](client sarama.Client, l logger.Logger, src *gorm.DB, dst *gorm.DB, ...) (*Consumer[T], error)
  • func (c *Consumer[T]) Consume(msg *sarama.ConsumerMessage, evt events.InconsistentEvent) error
  • func (c *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.Logger,
	src *gorm.DB, dst *gorm.DB, topic string) (*Consumer[T], error)

func (*Consumer[T]) Consume

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

func (*Consumer[T]) Start

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