Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type DataReporterHTTP ¶
type DataReporterHTTP struct {
Logger polylog.Logger
// The URL of the Data Pipeline's HTTP server.
// Only JSON-accepting data pipelines are supported as of PR #215.
// e.g. Fluentd HTTP input plugin on localhost:8686.
DataProcessorURL string
// Timeout in milliseconds for HTTP POST operations.
// If zero or negative, the default timeout of defaultPostTimeoutMS (10s) is used.
PostTimeoutMS int
}
DataReporterHTTP sends the observation for each handled request to an HTTP endpoint. It assumes the HTTP server is part of the data pipeline, i.e. it processes and stores/forwards the observations as appropriate. For example: a Fluentd HTTP input plugin, with output plugin pointing to BigQuery. Implements the gateway.RequestResponseReporter
func (*DataReporterHTTP) Publish ¶
func (drh *DataReporterHTTP) Publish(observations *observation.RequestResponseObservations)
Publish the supplied observations: - Build the expected data records. - Send each record to the configured URL. - Track and log any failures encountered during processing.
Source Files
Click to show internal directories.
Click to hide internal directories.