package
1.0.1
Repository: https://github.com/syncromatics/kafmesh.git
Documentation: pkg.go.dev

# Functions

NewSubscribers creates new subscribers.

# Structs

ClientFactory generates WatchClients for a pod.
Processor provides processor watches.
Subscribers provides real time subscription handlers.

# Interfaces

Factory returns a watch grpc client.
PodLister gets the pods running in the cluster.
ProcessorRepository is the datastore repository for processors.
Watcher watches a processor by key.