Documentation
¶
Overview ¶
Package influxdb provides the InfluxDB Backend provider
Index ¶
- func MarshalTimeseries(ts timeseries.Timeseries, rlo *timeseries.RequestOptions, status int) ([]byte, error)
- func MarshalTimeseriesWriter(ts timeseries.Timeseries, rlo *timeseries.RequestOptions, status int, ...) error
- func NewClient(name string, o *bo.Options, router http.Handler, cache cache.Cache, ...) (backends.Backend, error)
- func NewModeler() *timeseries.Modeler
- func UnmarshalTimeseries(data []byte, trq *timeseries.TimeRangeQuery) (timeseries.Timeseries, error)
- func UnmarshalTimeseriesReader(reader io.Reader, trq *timeseries.TimeRangeQuery) (timeseries.Timeseries, error)
- type Client
- func (c *Client) DefaultHealthCheckConfig() *ho.Options
- func (c *Client) DefaultPathConfigs(_ *bo.Options) po.List
- func (c *Client) ParseTimeRangeQuery(r *http.Request) (*timeseries.TimeRangeQuery, *timeseries.RequestOptions, bool, error)
- func (c *Client) ProxyHandler(w http.ResponseWriter, r *http.Request)
- func (c *Client) QueryHandler(w http.ResponseWriter, r *http.Request)
- func (c *Client) RegisterHandlers(handlers.Lookup)
- func (c *Client) SetExtent(r *http.Request, trq *timeseries.TimeRangeQuery, extent *timeseries.Extent)
- func (c *Client) UnmarshalInstantaneous(_ []byte) (timeseries.Timeseries, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func MarshalTimeseries ¶
func MarshalTimeseries(ts timeseries.Timeseries, rlo *timeseries.RequestOptions, status int, ) ([]byte, error)
func MarshalTimeseriesWriter ¶
func MarshalTimeseriesWriter(ts timeseries.Timeseries, rlo *timeseries.RequestOptions, status int, w io.Writer, ) error
func NewClient ¶
func NewClient(name string, o *bo.Options, router http.Handler, cache cache.Cache, _ backends.Backends, _ types.Lookup, ) (backends.Backend, error)
NewClient returns a new Client Instance
func NewModeler ¶
func NewModeler() *timeseries.Modeler
NewModeler returns a collection of modeling functions for influxdb interoperability
func UnmarshalTimeseries ¶
func UnmarshalTimeseries(data []byte, trq *timeseries.TimeRangeQuery, ) (timeseries.Timeseries, error)
func UnmarshalTimeseriesReader ¶
func UnmarshalTimeseriesReader(reader io.Reader, trq *timeseries.TimeRangeQuery, ) (timeseries.Timeseries, error)
Types ¶
type Client ¶
type Client struct {
backends.TimeseriesBackend
}
Client Implements the Proxy Client Interface
func (*Client) DefaultHealthCheckConfig ¶
DefaultHealthCheckConfig returns the default HealthCheck Config for this backend provider
func (*Client) DefaultPathConfigs ¶
DefaultPathConfigs returns the default PathConfigs for the given Provider
func (*Client) ParseTimeRangeQuery ¶
func (c *Client) ParseTimeRangeQuery(r *http.Request) (*timeseries.TimeRangeQuery, *timeseries.RequestOptions, bool, error, )
ParseTimeRangeQuery parses the key parts of a TimeRangeQuery from the inbound HTTP Request
func (*Client) ProxyHandler ¶
func (c *Client) ProxyHandler(w http.ResponseWriter, r *http.Request)
ProxyHandler sends a request through the basic reverse proxy to the origin, and services non-cacheable InfluxDB API calls
func (*Client) QueryHandler ¶
func (c *Client) QueryHandler(w http.ResponseWriter, r *http.Request)
QueryHandler handles timeseries requests for InfluxDB and processes them through the delta proxy cache
func (*Client) RegisterHandlers ¶
func (*Client) SetExtent ¶
func (c *Client) SetExtent(r *http.Request, trq *timeseries.TimeRangeQuery, extent *timeseries.Extent, )
SetExtent will change the upstream request query to use the provided Extent
func (*Client) UnmarshalInstantaneous ¶
func (c *Client) UnmarshalInstantaneous(_ []byte) (timeseries.Timeseries, error)
UnmarshalInstantaneous is not used for InfluxDB and is here to conform to the Proxy Client interface
Source Files
Directories