package
0.18.0
Repository: https://github.com/mailgun/kafka-pixy.git
Documentation: pkg.go.dev

# Functions

Spawn creates a mapper instance and starts its internal goroutines.

# Structs

T maintains mapping of workers that generate requests to executors.

# Interfaces

Executor represents an entity that executes requests of workers via a particular broker connection.
Resolver defines an interface to resolve a broker connection that should serve requests of a particular worker, and to create an executor for a broker connection.
Worker represents an entity that makes requests via an assigned broker executor.