Documentation
¶
Index ¶
- type BasicAuthConfig
- type HTTPSource
- func (h *HTTPSource) CanRun() error
- func (h *HTTPSource) Configure(yamlConfig []byte, logger *log.Entry, metricsLevel int) error
- func (h *HTTPSource) ConfigureByDSN(string, map[string]string, *log.Entry, string) error
- func (h *HTTPSource) Dump() interface{}
- func (h *HTTPSource) GetAggregMetrics() []prometheus.Collector
- func (h *HTTPSource) GetMetrics() []prometheus.Collector
- func (h *HTTPSource) GetMode() string
- func (h *HTTPSource) GetName() string
- func (h *HTTPSource) GetUuid() string
- func (h *HTTPSource) OneShotAcquisition(ctx context.Context, out chan types.Event, t *tomb.Tomb) error
- func (h *HTTPSource) RunServer(out chan types.Event, t *tomb.Tomb) error
- func (h *HTTPSource) StreamingAcquisition(ctx context.Context, out chan types.Event, t *tomb.Tomb) error
- func (h *HTTPSource) UnmarshalConfig(yamlConfig []byte) error
- type HttpConfiguration
- type TLSConfig
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type BasicAuthConfig ¶
type HTTPSource ¶
type HTTPSource struct {
Config HttpConfiguration
Server *http.Server
// contains filtered or unexported fields
}
func (*HTTPSource) CanRun ¶
func (h *HTTPSource) CanRun() error
func (*HTTPSource) ConfigureByDSN ¶
func (*HTTPSource) Dump ¶
func (h *HTTPSource) Dump() interface{}
func (*HTTPSource) GetAggregMetrics ¶
func (h *HTTPSource) GetAggregMetrics() []prometheus.Collector
func (*HTTPSource) GetMetrics ¶
func (h *HTTPSource) GetMetrics() []prometheus.Collector
func (*HTTPSource) GetMode ¶
func (h *HTTPSource) GetMode() string
func (*HTTPSource) GetName ¶
func (h *HTTPSource) GetName() string
func (*HTTPSource) GetUuid ¶
func (h *HTTPSource) GetUuid() string
func (*HTTPSource) OneShotAcquisition ¶
func (*HTTPSource) StreamingAcquisition ¶
func (*HTTPSource) UnmarshalConfig ¶
func (h *HTTPSource) UnmarshalConfig(yamlConfig []byte) error
type HttpConfiguration ¶
type HttpConfiguration struct {
// IPFilter []string `yaml:"ip_filter"`
// ChunkSize *int64 `yaml:"chunk_size"`
ListenAddr string `yaml:"listen_addr"`
Path string `yaml:"path"`
AuthType string `yaml:"auth_type"`
BasicAuth *BasicAuthConfig `yaml:"basic_auth"`
Headers *map[string]string `yaml:"headers"`
TLS *TLSConfig `yaml:"tls"`
CustomStatusCode *int `yaml:"custom_status_code"`
CustomHeaders *map[string]string `yaml:"custom_headers"`
MaxBodySize *int64 `yaml:"max_body_size"`
Timeout *time.Duration `yaml:"timeout"`
configuration.DataSourceCommonCfg `yaml:",inline"`
}
func (*HttpConfiguration) NewTLSConfig ¶
func (hc *HttpConfiguration) NewTLSConfig() (*tls.Config, error)
func (*HttpConfiguration) Validate ¶
func (hc *HttpConfiguration) Validate() error
Click to show internal directories.
Click to hide internal directories.