event

Documentation

Index

• type Consumer
• type UserActivityEventConsumer
  • func NewUserActivityEventConsumer(repo repository.UserActivityRepository, client sarama.Client, l logger.Logger) *UserActivityEventConsumer
  • func (u *UserActivityEventConsumer) BatchConsume(messages []*sarama.ConsumerMessage, event article.ReadEvent) error
  • func (u *UserActivityEventConsumer) BatchStart() error
  • func (u *UserActivityEventConsumer) Consume(messages *sarama.ConsumerMessage, event article.ReadEvent) error
  • func (u *UserActivityEventConsumer) Start() error

Types

type Consumer

type Consumer interface {
	Start() error
	BatchStart() error
	Consume(messages *sarama.ConsumerMessage, event article.ReadEvent) error
	BatchConsume(messages []*sarama.ConsumerMessage, event article.ReadEvent) error
}

type UserActivityEventConsumer

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

func NewUserActivityEventConsumer

func NewUserActivityEventConsumer(repo repository.UserActivityRepository, client sarama.Client, l logger.Logger) *UserActivityEventConsumer

func (*UserActivityEventConsumer) BatchConsume

func (u *UserActivityEventConsumer) BatchConsume(messages []*sarama.ConsumerMessage, event article.ReadEvent) error

func (*UserActivityEventConsumer) BatchStart

func (u *UserActivityEventConsumer) BatchStart() error

func (*UserActivityEventConsumer) Consume

func (u *UserActivityEventConsumer) Consume(messages *sarama.ConsumerMessage, event article.ReadEvent) error

func (*UserActivityEventConsumer) Start

func (u *UserActivityEventConsumer) Start() error