testing

Documentation

Overview

Package testing provides functions to aid in testing kafmesh services.

Index

• type Emitter
  • func NewEmitter(brokers []string, registry *runner.Registry) *Emitter
  • func (e *Emitter) Emit(key string, message runner.Message) error
  • func (e *Emitter) EmitToTopic(topic string, key string, message runner.Message) error

Types

type Emitter

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

Emitter is used to emit messages into kafka for testing

func NewEmitter

func NewEmitter(brokers []string, registry *runner.Registry) *Emitter

NewEmitter creates a new test emitter

func (*Emitter) Emit

func (e *Emitter) Emit(key string, message runner.Message) error

Emit a message to kafka using the topic extracted from the name

func (*Emitter) EmitToTopic

func (e *Emitter) EmitToTopic(topic string, key string, message runner.Message) error

EmitToTopic emits a message to kafka