ruạṛ
a ���f� � @ s8 d dl mZmZmZ d dlmZ eG dd� de��ZdS )� )�formatted_flat_dict� NONE_SENTINEL�#value_allowed_none_or_none_sentinel)�init_model_state_from_kwargsc @ s� e Zd ZdZdd� Zedd� �Zejdd� �Zedd� �Zejd d� �Zed d� �Z e jdd� �Z ed d� �Z e jdd� �Z edd� �Zejdd� �Zedd� �Zejdd� �Zdd� Z dd� Zdd� ZdS )�Messagez A message in a stream. c K sP ddddddd�| _ ddddd d d�| _d| _d| _d| _d| _d| _d| _dS )a� Initializes a new Message object with values from keyword arguments. The following keyword arguments are supported (corresponding to the getters/setters of this class): :param stream: The value to assign to the stream property of this Message. :type stream: str :param partition: The value to assign to the partition property of this Message. :type partition: str :param key: The value to assign to the key property of this Message. :type key: str :param value: The value to assign to the value property of this Message. :type value: str :param offset: The value to assign to the offset property of this Message. :type offset: int :param timestamp: The value to assign to the timestamp property of this Message. :type timestamp: datetime �str�intZdatetime)�stream� partition�key�value�offset� timestampr r r r r r N)Z swagger_typesZ attribute_map�_stream� _partition�_key�_value�_offset� _timestamp)�self�kwargs� r �@/usr/lib/python3.9/site-packages/oci/streaming/models/message.py�__init__ s( � � zMessage.__init__c C s | j S )z� **[Required]** Gets the stream of this Message. The name of the stream that the message belongs to. :return: The stream of this Message. :rtype: str �r �r r r r r I s zMessage.streamc C s || _ dS )z� Sets the stream of this Message. The name of the stream that the message belongs to. :param stream: The stream of this Message. :type: str Nr )r r r r r r U s c C s | j S )z� **[Required]** Gets the partition of this Message. The ID of the partition where the message is stored. :return: The partition of this Message. :rtype: str �r r r r r r a s zMessage.partitionc C s || _ dS )z� Sets the partition of this Message. The ID of the partition where the message is stored. :param partition: The partition of this Message. :type: str Nr )r r r r r r m s c C s | j S )z� **[Required]** Gets the key of this Message. The key associated with the message, expressed as a byte array. :return: The key of this Message. :rtype: str �r r r r r r y s zMessage.keyc C s || _ dS )z� Sets the key of this Message. The key associated with the message, expressed as a byte array. :param key: The key of this Message. :type: str Nr )r r r r r r � s c C s | j S )z� **[Required]** Gets the value of this Message. The value associated with the message, expressed as a byte array. :return: The value of this Message. :rtype: str �r r r r r r � s z Message.valuec C s || _ dS )z� Sets the value of this Message. The value associated with the message, expressed as a byte array. :param value: The value of this Message. :type: str Nr )r r r r r r � s c C s | j S )z� **[Required]** Gets the offset of this Message. The offset of the message, which uniquely identifies it within the partition. :return: The offset of this Message. :rtype: int �r r r r r r � s zMessage.offsetc C s || _ dS )z� Sets the offset of this Message. The offset of the message, which uniquely identifies it within the partition. :param offset: The offset of this Message. :type: int Nr )r r r r r r � s c C s | j S )z� **[Required]** Gets the timestamp of this Message. The timestamp indicating when the server appended the message to the stream. :return: The timestamp of this Message. :rtype: datetime �r r r r r r � s zMessage.timestampc C s || _ dS )z� Sets the timestamp of this Message. The timestamp indicating when the server appended the message to the stream. :param timestamp: The timestamp of this Message. :type: datetime Nr )r r r r r r � s c C s t | �S �N)r r r r r �__repr__� s zMessage.__repr__c C s |d u rdS | j |j kS )NF)�__dict__�r �otherr r r �__eq__� s zMessage.__eq__c C s | |k S r! r r$ r r r �__ne__� s zMessage.__ne__N)�__name__� __module__�__qualname__�__doc__r �propertyr �setterr r r r r r"