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

# Functions

NewScrapeService creates a new scrape service.

# Structs

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.

# Interfaces

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.