Struct relay_config::Processing

pub struct Processing {
    pub enabled: bool,
    pub geoip_path: Option<PathBuf>,
    pub max_secs_in_future: u32,
    pub max_secs_in_past: u32,
    pub max_session_secs_in_past: u32,
    pub kafka_config: Vec<KafkaConfigParam>,
    pub secondary_kafka_configs: BTreeMap<String, Vec<KafkaConfigParam>>,
    pub topics: TopicAssignments,
    pub redis: Option<RedisConfig>,
    pub attachment_chunk_size: ByteSize,
    pub projectconfig_cache_prefix: String,
    pub max_rate_limit: Option<u32>,
}

Controls Sentry-internal event processing.

Fields

enabled: bool

True if the Relay should do processing. Defaults to false.

geoip_path: Option<PathBuf>

GeoIp DB file source.

max_secs_in_future: u32

Maximum future timestamp of ingested events.

max_secs_in_past: u32

Maximum age of ingested events. Older events will be adjusted to now().

max_session_secs_in_past: u32

Maximum age of ingested sessions. Older sessions will be dropped.

kafka_config: Vec<KafkaConfigParam>

Kafka producer configurations.

secondary_kafka_configs: BTreeMap<String, Vec<KafkaConfigParam>>

Additional kafka producer configurations.

The kafka_config is the default producer configuration used for all topics. A secondary kafka config can be referenced in topics: like this:

secondary_kafka_configs:
  mycustomcluster:
    - name: 'bootstrap.servers'
      value: 'sentry_kafka_metrics:9093'

topics:
  transactions: ingest-transactions
  metrics:
    name: ingest-metrics
    config: mycustomcluster

Then metrics will be produced to an entirely different Kafka cluster.

topics: TopicAssignments

Kafka topic names.

redis: Option<RedisConfig>

Redis hosts to connect to for storing state for rate limits.

attachment_chunk_size: ByteSize

Maximum chunk size of attachments for Kafka.

projectconfig_cache_prefix: String

Prefix to use when looking up project configs in Redis. Defaults to “relayconfig”.

max_rate_limit: Option<u32>

Maximum rate limit to report to clients.

Trait Implementations

impl Debug for Processing

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for Processing

fn default() -> Self

Constructs a disabled processing configuration.

impl<'de> Deserialize<'de> for Processing

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for Processing

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.