events

Documentation

Index

• Constants
• type InconsistentEvent
• type Producer
• type SaramaProducer
  • func NewSaramaProducer(p sarama.SyncProducer, topic string) *SaramaProducer
  • func (s *SaramaProducer) ProduceInconsistentEvent(ctx context.Context, event InconsistentEvent) error

Constants

const (
	// InconsistentEventTypeTargetMissing target 中没有数据
	InconsistentEventTypeTargetMissing = "target_missing"
	// InconsistentEventTypeNotEqual 目标表和源表的数据不相等
	InconsistentEventTypeNotEqual = "neq"
	// InconsistentEventTypeBaseMissing base 中没有数据
	InconsistentEventTypeBaseMissing = "base_missing"
)

Types

type InconsistentEvent

type InconsistentEvent struct {
	Type      string
	ID        int64
	Direction string
}

type Producer

type Producer interface {
	ProduceInconsistentEvent(ctx context.Context, event InconsistentEvent) error
}

type SaramaProducer

type SaramaProducer struct {
	// contains filtered or unexported fields
}

func NewSaramaProducer

func NewSaramaProducer(p sarama.SyncProducer,
	topic string) *SaramaProducer

func (*SaramaProducer) ProduceInconsistentEvent

func (s *SaramaProducer) ProduceInconsistentEvent(ctx context.Context,
	event InconsistentEvent) error