events

Documentation

Index

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

Constants

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

Types

type InconsistentEvent

type InconsistentEvent struct {
	Id        int64
	Direction string // 以哪个源为准 SRC 源表为准 DST 目标表为准
	Type      string
}

type Producer

type Producer interface {
	ProduceInsistentEvent(ctx context.Context, evt InconsistentEvent) error
}

type SaramaProducer

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

func NewSaramaProducer

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

func (*SaramaProducer) ProduceInsistentEvent

func (s *SaramaProducer) ProduceInsistentEvent(ctx context.Context, evt InconsistentEvent) error