o
    ɶd                     @   s8   d dl mZmZmZ d dlmZ eG dd deZdS )    )formatted_flat_dictNONE_SENTINEL#value_allowed_none_or_none_sentinel)init_model_state_from_kwargsc                   @   s   e Zd ZdZdd Zedd Zejdd Zedd Zejd	d Zed
d Z	e	jdd Z	edd Z
e
jdd Z
edd Zejdd Zedd Zejdd Zdd Zdd Zdd ZdS )Messagez 
    A message in a stream.
    c                 K   sP   ddddddd| _ ddddd	d
d| _d| _d| _d| _d| _d| _d| _dS )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intdatetime)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.10/site-packages/oci/streaming/models/message.py__init__   s(   
	
zMessage.__init__c                 C      | 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      
zMessage.streamc                 C   
   || _ dS )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      

c                 C   r   )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   r   zMessage.partitionc                 C   r   )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   r    c                 C   r   )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   r   zMessage.keyc                 C   r   )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      r    c                 C   r   )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      r   zMessage.valuec                 C   r   )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      r    c                 C   r   )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      r   zMessage.offsetc                 C   r   )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      r    c                 C   r   )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      r   zMessage.timestampc                 C   r   )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      r    c                 C   s   t | S N)r   r   r   r   r   __repr__   s   zMessage.__repr__c                 C   s   |d u rdS | j |j kS )NF)__dict__r   otherr   r   r   __eq__   s   zMessage.__eq__c                 C   s
   | |k S r&   r   r)   r   r   r   __ne__   s   
zMessage.__ne__N)__name__
__module____qualname____doc__r   propertyr
   setterr   r   r   r   r   r'   r+   r,   r   r   r   r   r      s<    7











r   N)Zoci.utilr   r   r   Zoci.decoratorsr   objectr   r   r   r   r   <module>   s   