article

Documentation

Index

• type InteractiveReadEventConsumer
  • func NewInteractiveReadEventConsumer(client sarama.Client, l logger.LoggerV1, repo repository.InteractiveRepository) *InteractiveReadEventConsumer
  • func (r *InteractiveReadEventConsumer) Consume(msg *sarama.ConsumerMessage, t ReadEvent) error
  • func (r *InteractiveReadEventConsumer) Start() error
• type KafkaProducer
  • func (k *KafkaProducer) ProduceReadEvent(ctx context.Context, evt ReadEvent) error
• type Producer
  • func NewKafkaProducer(pc sarama.SyncProducer) Producer
• type ReadEvent

Types

type InteractiveReadEventConsumer

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

func NewInteractiveReadEventConsumer

func NewInteractiveReadEventConsumer(
	client sarama.Client,
	l logger.LoggerV1,
	repo repository.InteractiveRepository) *InteractiveReadEventConsumer

func (*InteractiveReadEventConsumer) Consume

func (r *InteractiveReadEventConsumer) Consume(msg *sarama.ConsumerMessage, t ReadEvent) error

Consume 这个不是幂等的

func (*InteractiveReadEventConsumer) Start

func (r *InteractiveReadEventConsumer) Start() error

type KafkaProducer

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

func (*KafkaProducer) ProduceReadEvent

func (k *KafkaProducer) ProduceReadEvent(ctx context.Context, evt ReadEvent) error

ProduceReadEvent 如果你有复杂的重试逻辑，就用装饰器 你认为你的重试逻辑很简单，你就放这里

type Producer

type Producer interface {
	ProduceReadEvent(ctx context.Context, evt ReadEvent) error
}

func NewKafkaProducer

func NewKafkaProducer(pc sarama.SyncProducer) Producer

type ReadEvent

type ReadEvent struct {
	Uid int64
	Aid int64
}