Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type BulkResponse ¶
BulkResponse is a message published when Fetcher finish it job due to cancelled context or closed endpoints chanel
type EndpointRequest ¶
EndpointRequest is a struct passed to Fetcher with information about url to be fetched
type Fetcher ¶
type Fetcher struct {
// contains filtered or unexported fields
}
Fetcher is a struct responsible for fetching nodes endpoints
func New ¶
func New( tempdir string, client *http.Client, input <-chan EndpointRequest, statusUpdate chan<- StatusUpdate, output chan<- BulkResponse, prometheusVector prometheus.ObserverVec, ) (*Fetcher, error)
New creates new Fetcher. Fetcher needs to be started with Run()
type StatusUpdate ¶
StatusUpdate is an update message published by Fetcher when EndpointRequest is done. If error occurred during fetch then Error field is not nil.
Click to show internal directories.
Click to hide internal directories.