buffertest

Documentation

Index

• func Run(cfg Config) (int, error)
• type Config
  • func LoadConfig() Config
• type Map

Functions

func Run

func Run(cfg Config) (int, error)

Types

type Config

type Config struct {
	Writer          kafka.WriterConfig
	Reader          kafka.ReaderConfig
	Topic           kafka.TopicConfig
	NumEvents       int
	PipelineTimeout time.Duration
	WriterTick      time.Duration
	WaiterTick      time.Duration
}

func LoadConfig

func LoadConfig() Config

type Map

type Map map[string]interface{}