subscriber

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

type Scraper interface {
	Run()
	IsDown() bool
	Close()
}

type ScraperFactory interface {
	NewScraper(ctx context.Context, component topology.Component) Scraper
}

type SubscribeController interface {
	ScraperFactory

	Name() string
	IsEnabled() bool
	UpdatePDVariable(pdvariable.PDVariable)
	UpdateConfig(config.Config)
	UpdateTopology([]topology.Component)
}

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