Documentation ¶
Index ¶
- func NewSubscriber(topoSubscriber topology.Subscriber, varSubscriber pdvariable.Subscriber, ...) *subscriber.Subscriber
- type Scraper
- type SubscriberController
- func (sc *SubscriberController) GetConfig() *config.Config
- func (sc *SubscriberController) IsEnabled() bool
- func (sc *SubscriberController) Name() string
- func (sc *SubscriberController) NewHTTPClient() *http.Client
- func (sc *SubscriberController) NewScraper(ctx context.Context, component topology.Component, schemaInfo *sync.Map) subscriber.Scraper
- func (sc *SubscriberController) UpdateConfig(cfg config.Config)
- func (sc *SubscriberController) UpdatePDVariable(variable pdvariable.PDVariable)
- func (sc *SubscriberController) UpdateTopology(components []topology.Component)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewSubscriber ¶
func NewSubscriber( topoSubscriber topology.Subscriber, varSubscriber pdvariable.Subscriber, cfgSubscriber config.Subscriber, domain *domain.Domain, store store.Store, ) *subscriber.Subscriber
Types ¶
type SubscriberController ¶
type SubscriberController struct {
// contains filtered or unexported fields
}
func NewSubscriberController ¶
func NewSubscriberController(store store.Store) *SubscriberController
func (*SubscriberController) GetConfig ¶
func (sc *SubscriberController) GetConfig() *config.Config
func (*SubscriberController) IsEnabled ¶
func (sc *SubscriberController) IsEnabled() bool
func (*SubscriberController) Name ¶
func (sc *SubscriberController) Name() string
func (*SubscriberController) NewHTTPClient ¶
func (sc *SubscriberController) NewHTTPClient() *http.Client
func (*SubscriberController) NewScraper ¶
func (sc *SubscriberController) NewScraper(ctx context.Context, component topology.Component, schemaInfo *sync.Map) 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)
Click to show internal directories.
Click to hide internal directories.