subscriber

Documentation

Index

• func NewSubscriber(topoSubscriber topology.Subscriber, varSubscriber pdvariable.Subscriber, ...) *subscriber.Subscriber
• type Scraper
  • func NewScraper(ctx context.Context, component topology.Component, store store.Store, ...) *Scraper
  • func (s *Scraper) Close()
  • func (s *Scraper) IsDown() bool
  • func (s *Scraper) Run()
• type SubscriberController
  • func NewSubscriberController(store store.Store) *SubscriberController
  • func (sc *SubscriberController) IsEnabled() bool
  • func (sc *SubscriberController) Name() string
  • func (sc *SubscriberController) NewScraper(ctx context.Context, component topology.Component) subscriber.Scraper
  • func (sc *SubscriberController) UpdateConfig(cfg config.Config)
  • func (sc *SubscriberController) UpdatePDVariable(variable pdvariable.PDVariable)
  • func (sc *SubscriberController) UpdateTopology(components []topology.Component)

Functions

func NewSubscriber

func NewSubscriber(
	topoSubscriber topology.Subscriber,
	varSubscriber pdvariable.Subscriber,
	cfgSubscriber config.Subscriber,
	store store.Store,
) *subscriber.Subscriber

Types

type Scraper

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

func NewScraper

func NewScraper(ctx context.Context, component topology.Component, store store.Store, tlsConfig *tls.Config) *Scraper

func (*Scraper) Close

func (s *Scraper) Close()

func (*Scraper) IsDown

func (s *Scraper) IsDown() bool

func (*Scraper) Run

func (s *Scraper) Run()

type SubscriberController

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

func NewSubscriberController

func NewSubscriberController(store store.Store) *SubscriberController

func (*SubscriberController) IsEnabled

func (sc *SubscriberController) IsEnabled() bool

func (*SubscriberController) Name

func (sc *SubscriberController) Name() string

func (*SubscriberController) NewScraper

func (sc *SubscriberController) NewScraper(ctx context.Context, component topology.Component) subscriber.Scraper

func (*SubscriberController) UpdateConfig

func (sc *SubscriberController) UpdateConfig(cfg config.Config)

func (*SubscriberController) UpdatePDVariable

func (sc *SubscriberController) UpdatePDVariable(variable pdvariable.PDVariable)

func (*SubscriberController) UpdateTopology

func (sc *SubscriberController) UpdateTopology(components []topology.Component)