Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type LookoutIngesterV2Configuration ¶
type LookoutIngesterV2Configuration struct { // Database configuration Postgres configuration.PostgresConfig // Metrics configuration MetricsPort uint16 // General Pulsar configuration Pulsar configuration.PulsarConfig // Pulsar subscription name SubscriptionName string // Size in bytes above which job specs will be compressed when inserting in the database MinJobSpecCompressionSize int // Number of event messages that will be batched together before being inserted into the database BatchSize int // Maximum time since the last batch before a batch will be inserted into the database BatchDuration time.Duration // Time for which the pulsar consumer will wait for a new message before retrying PulsarReceiveTimeout time.Duration // Time for which the pulsar consumer will back off after receiving an error on trying to receive a message PulsarBackoffTime time.Duration // User annotations have a common prefix to avoid clashes with other annotations. This prefix will be stripped from // The annotation before storing in the db UserAnnotationPrefix string // Between each attempt to store data in the database, there is an exponential backoff (starting out as 1s). // MaxBackoff caps this backoff to whatever it is specified (in seconds) MaxBackoff int // If non-nil, configures pprof profiling Profiling *profilingconfig.ProfilingConfig // List of Regexes which will identify fatal errors when inserting into postgres FatalInsertionErrors []string }
Click to show internal directories.
Click to hide internal directories.