kafkagen

Documentation

Index

• type JSONEvent
  • func (e JSONEvent) Encode() ([]byte, error)
  • func (e JSONEvent) Length() int
• type Main
  • func NewMain() *Main
  • func (m *Main) Run() error

Types

type JSONEvent

type JSONEvent fake.Event

JSONEvent implements the sarama.Encoder interface for Event using json.

func (JSONEvent) Encode

func (e JSONEvent) Encode() ([]byte, error)

Encode marshals the event to json.

func (JSONEvent) Length

func (e JSONEvent) Length() int

Length returns the length of the marshalled json.

type Main

type Main struct {
	Hosts        []string
	Topic        string
	Group        string
	RestProxyURL string

	Rate time.Duration
}

Main holds the execution state for the kafka generator.

func NewMain

func NewMain() *Main

NewMain returns a new Main.

func (*Main) Run

func (m *Main) Run() error

Run runs the kafka generator.