Documentation
¶
Index ¶
- type BasicAuthConfig
- type Configuration
- type Source
- func (*Source) CanRun() error
- func (s *Source) Configure(_ context.Context, yamlConfig []byte, logger *log.Entry, ...) error
- func (s *Source) Dump() any
- func (*Source) GetAggregMetrics() []prometheus.Collector
- func (*Source) GetMetrics() []prometheus.Collector
- func (s *Source) GetMode() string
- func (*Source) GetName() string
- func (s *Source) GetUuid() string
- func (s *Source) RunServer(ctx context.Context, out chan pipeline.Event, t *tomb.Tomb) error
- func (s *Source) StreamingAcquisition(ctx context.Context, out chan pipeline.Event, t *tomb.Tomb) error
- func (s *Source) UnmarshalConfig(yamlConfig []byte) error
- type TLSConfig
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type BasicAuthConfig ¶
type Configuration ¶ added in v1.7.4
type Configuration struct {
// IPFilter []string `yaml:"ip_filter"`
// ChunkSize *int64 `yaml:"chunk_size"`
ListenAddr string `yaml:"listen_addr"`
ListenSocket string `yaml:"listen_socket"`
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 (*Configuration) NewTLSConfig ¶ added in v1.7.4
func (c *Configuration) NewTLSConfig() (*tls.Config, error)
func (*Configuration) Validate ¶ added in v1.7.4
func (c *Configuration) Validate() error
type Source ¶ added in v1.7.4
type Source struct {
Config Configuration
Server *http.Server
// contains filtered or unexported fields
}
func (*Source) GetAggregMetrics ¶ added in v1.7.4
func (*Source) GetAggregMetrics() []prometheus.Collector
func (*Source) GetMetrics ¶ added in v1.7.4
func (*Source) GetMetrics() []prometheus.Collector
func (*Source) StreamingAcquisition ¶ added in v1.7.4
func (*Source) UnmarshalConfig ¶ added in v1.7.4
Click to show internal directories.
Click to hide internal directories.