subscriber

Documentation

Index

• type Manager
  • func NewManager(ctx context.Context, wg *sync.WaitGroup, do *domain.Domain, ...) *Manager
  • func (m *Manager) Run()
• type Scraper
• type ScraperFactory
• type SubscribeController
• type Subscriber
  • func NewSubscriber(do *domain.Domain, topoSubscriber topology.Subscriber, ...) *Subscriber
  • func (s *Subscriber) Close()

Types

type Manager

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

func NewManager

func NewManager(
	ctx context.Context,
	wg *sync.WaitGroup,
	do *domain.Domain,
	varSubscriber pdvariable.Subscriber,
	topoSubscriber topology.Subscriber,
	cfgSubscriber config.Subscriber,
	subscribeController SubscribeController,
) *Manager

func (*Manager) Run

func (m *Manager) Run()

type Scraper

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

type ScraperFactory

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

type SubscribeController

type SubscribeController interface {
	ScraperFactory

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

type Subscriber

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

func NewSubscriber

func NewSubscriber(
	do *domain.Domain,
	topoSubscriber topology.Subscriber,
	varSubscriber pdvariable.Subscriber,
	cfgSubscriber config.Subscriber,
	subscribeController SubscribeController,
) *Subscriber

func (*Subscriber) Close

func (s *Subscriber) Close()