producer

Documentation

Index

• func Run(configPath string, p Config)
• type Config
• type Producer
  • func NewProducer(ctx context.Context, pc Config, w *kafka.Writer, ants *ants.Pool) *Producer

Functions

func Run

func Run(configPath string, p Config)

Types

type Config

type Config struct {
	FilePath   string
	Round      int
	Mode       string
	Data       string
	Topic      string
	FakeType   string
	ServerAddr string
	BatchSize  int
}

type Producer

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

func NewProducer

func NewProducer(ctx context.Context, pc Config, w *kafka.Writer, ants *ants.Pool) *Producer