msggen

Documentation

Index

• type GenManager
  • func NewGenManager() (*GenManager, error)
  • func (gm *GenManager) ProduceMessages(genName string, topicName string, partitions int, delay time.Duration, ...) error
  • func (gm *GenManager) RegisterGenerator(gen MessageGenerator) error
  • func (gm *GenManager) RegisterGenerators() error
• type MessageGenerator
• type PaymentGenerator
  • func (p *PaymentGenerator) GenerateMessage(_ int32, index int64, rnd *rand.Rand) (*kafka.Message, error)
  • func (p *PaymentGenerator) Name() string

Types

type GenManager

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

func NewGenManager

func NewGenManager() (*GenManager, error)

func (*GenManager) ProduceMessages

func (gm *GenManager) ProduceMessages(genName string, topicName string, partitions int, delay time.Duration,
	numMessages int64, indexStart int64, kafkaProps map[string]string) error

func (*GenManager) RegisterGenerator

func (gm *GenManager) RegisterGenerator(gen MessageGenerator) error

func (*GenManager) RegisterGenerators

func (gm *GenManager) RegisterGenerators() error

type MessageGenerator

type MessageGenerator interface {
	GenerateMessage(scope int32, index int64, rnd *rand.Rand) (*kafka.Message, error)
	Name() string
}

MessageGenerator - quick and dirty Kafka message generator for demos, tests etc

type PaymentGenerator

type PaymentGenerator struct {
}

func (*PaymentGenerator) GenerateMessage

func (p *PaymentGenerator) GenerateMessage(_ int32, index int64, rnd *rand.Rand) (*kafka.Message, error)

func (*PaymentGenerator) Name

func (p *PaymentGenerator) Name() string