Struct relay_kafka::TopicAssignments

pub struct TopicAssignments {Show 16 fields
    pub events: TopicAssignment,
    pub attachments: TopicAssignment,
    pub transactions: TopicAssignment,
    pub outcomes: TopicAssignment,
    pub outcomes_billing: TopicAssignment,
    pub metrics_sessions: TopicAssignment,
    pub metrics_generic: TopicAssignment,
    pub profiles: TopicAssignment,
    pub replay_events: TopicAssignment,
    pub replay_recordings: TopicAssignment,
    pub monitors: TopicAssignment,
    pub spans: TopicAssignment,
    pub metrics_summaries: TopicAssignment,
    pub cogs: TopicAssignment,
    pub feedback: TopicAssignment,
    pub unused: BTreeMap<String, TopicAssignment>,
}

Expand description

Configuration for topics.

Fields§

§events: TopicAssignment

Simple events topic name.

§attachments: TopicAssignment

Events with attachments topic name.

§transactions: TopicAssignment

Transaction events topic name.

§outcomes: TopicAssignment

Outcomes topic name.

§outcomes_billing: TopicAssignment

Outcomes topic name for billing critical outcomes.

§metrics_sessions: TopicAssignment

Topic name for metrics extracted from sessions, aka release health.

§metrics_generic: TopicAssignment

Topic name for all other kinds of metrics.

§profiles: TopicAssignment

Stacktrace topic name

§replay_events: TopicAssignment

Replay Events topic name.

§replay_recordings: TopicAssignment

Recordings topic name.

§monitors: TopicAssignment

Monitor check-ins.

§spans: TopicAssignment

Standalone spans without a transaction.

§metrics_summaries: TopicAssignment

Summary for metrics collected during a span.

§cogs: TopicAssignment

COGS measurements.

§feedback: TopicAssignment

Feedback events topic.

§unused: BTreeMap<String, TopicAssignment>

Additional topic assignments configured but currently unused by this Relay instance.

Implementations§

impl TopicAssignments

pub fn get(&self, kafka_topic: KafkaTopic) -> &TopicAssignment

Get a topic assignment by KafkaTopic value

Trait Implementations§

impl Debug for TopicAssignments

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

Formats the value using the given formatter. Read more

impl Default for TopicAssignments

fn default() -> Self

Returns the “default value” for a type. Read more

impl<'de> Deserialize<'de> for TopicAssignments
where TopicAssignments: Default,

fn deserialize<D>(deserializer: D) -> Result<Self, D::Error>
where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer. Read more

impl Serialize for TopicAssignments

fn serialize<S>(&self, serializer: S) -> Result<S::Ok, S::Error>
where S: Serializer,

Serialize this value into the given Serde serializer. Read more

Auto Trait Implementations§

impl Freeze for TopicAssignments

impl RefUnwindSafe for TopicAssignments

impl Send for TopicAssignments

impl Sync for TopicAssignments

impl Unpin for TopicAssignments

impl UnwindSafe for TopicAssignments

Blanket Implementations§

impl<T> Any for T
where T: 'static + ?Sized,

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more

impl<T> Borrow<T> for T
where T: ?Sized,

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more

impl<T> BorrowMut<T> for T
where T: ?Sized,

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more

impl<T> From<T> for T

fn from(t: T) -> T

Returns the argument unchanged.

impl<T> Instrument for T

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more

impl<T, U> Into<U> for T
where U: From<T>,

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

impl<T, U> TryFrom<U> for T
where U: Into<T>,

type Error = Infallible

The type returned in the event of a conversion error.

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

fn vzip(self) -> V

impl<T> WithSubscriber for T

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more

impl<T> DeserializeOwned for T
where T: for<'de> Deserialize<'de>,