consumer

Documentation

Index

• type KafkaConsumerConfig
• type KafkaTransactionConsumer
  • func (ktc *KafkaTransactionConsumer) Close() error
  • func (ktc *KafkaTransactionConsumer) Consume(ctx context.Context) (TransactionDTO, error)
• type TransactionConsumer
  • func NewKafkaTransactionConsumer(cfg *KafkaConsumerConfig) TransactionConsumer
• type TransactionDTO

Types

type KafkaConsumerConfig

type KafkaConsumerConfig struct {
	BrokerUrls []string
	ClientID   string
	Topic      string
}

type KafkaTransactionConsumer

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

func (*KafkaTransactionConsumer) Close

func (ktc *KafkaTransactionConsumer) Close() error

func (*KafkaTransactionConsumer) Consume

func (ktc *KafkaTransactionConsumer) Consume(ctx context.Context) (TransactionDTO, error)

type TransactionConsumer

type TransactionConsumer interface {
	Consume(ctx context.Context) (TransactionDTO, error)
	Close() error
}

func NewKafkaTransactionConsumer

func NewKafkaTransactionConsumer(cfg *KafkaConsumerConfig) TransactionConsumer

type TransactionDTO

type TransactionDTO struct {
	UserId      int `form:"user_id" json:"user_id"`
	BalanceDiff int `form:"balance_diff" json:"balance_diff"`
}