Documentation
¶
Index ¶
Constants ¶
View Source
const (
ServiceType = "http-ingester"
)
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Config ¶
type Config struct {
// Enabled indicates whether the HTTP ingester is enabled.
Enabled bool `yaml:"enabled" default:"false"`
// Addr is the address to listen on for HTTP requests.
Addr string `yaml:"addr" default:":8087"`
}
Config holds configuration for the HTTP ingester server. Note: The HTTP ingester reuses services.eventIngester config for auth, outputs, etc.
type Ingester ¶
type Ingester struct {
// contains filtered or unexported fields
}
Ingester handles HTTP event ingestion.
func NewIngester ¶
func NewIngester( ctx context.Context, log observability.ContextualLogger, conf *Config, eventIngesterConf *eventingester.Config, clockDrift *time.Duration, geoipProvider geoip.Provider, cache store.Cache, ) (*Ingester, error)
NewIngester creates a new HTTP event ingester. The eventIngesterConf is the shared event ingester configuration from services.eventIngester.
Source Files
Click to show internal directories.
Click to hide internal directories.