segment

Description

Any change to segment instance will produce this event. It’s purpose is to describe whatever changes were made to segment model so other services can rely on this information for their stuff.

class SegmentEvent(BaseKafkaModel):
    _topic = 'segments_events'
 
    def __init__(self, segment_id: int, event_type: str, payload_json: str = None, 
                 subscribed_count: int = None, channel_id: int = None, 
                 owner_email: str = None, subscribers_push_counter_json: str = None, **kwargs):
        super(SegmentEvent, self).__init__(**kwargs)
        self.segment_id = segment_id
        self.event_type = event_type
        self.payload_json = payload_json or ''
        self.subscribed_count = subscribed_count or 0
        self.subscribers_push_counter_json = subscribers_push_counter_json or ''
        self.channel_id = channel_id or 0
        self.owner_email = owner_email or ''