NewScrapeService creates a new scrape service.

DiscoverAPI provides methods for discovering and reporting kafmesh enabled pod info.

PingAPI provides uptime status for the kafmesh service.

ScrapeService periodically scrapes pods in the k8s cluster for kafmesh info.

WatcherService is the grpc interface to the watcher.

Deleter deletes pods out of storage.

GetPodser gets the existing pods from storage.

Scraper scrapes pods for kafmesh discovery info.

Updater updates pods in storage.

Watcher watches parts of the kafmesh system.