Server IP : 103.119.228.120 / Your IP : 18.222.20.30 Web Server : Apache System : Linux v8.techscape8.com 3.10.0-1160.119.1.el7.tuxcare.els2.x86_64 #1 SMP Mon Jul 15 12:09:18 UTC 2024 x86_64 User : nobody ( 99) PHP Version : 5.6.40 Disable Function : shell_exec,symlink,system,exec,proc_get_status,proc_nice,proc_terminate,define_syslog_variables,syslog,openlog,closelog,escapeshellcmd,passthru,ocinum cols,ini_alter,leak,listen,chgrp,apache_note,apache_setenv,debugger_on,debugger_off,ftp_exec,dl,dll,myshellexec,proc_open,socket_bind,proc_close,escapeshellarg,parse_ini_filepopen,fpassthru,exec,passthru,escapeshellarg,escapeshellcmd,proc_close,proc_open,ini_alter,popen,show_source,proc_nice,proc_terminate,proc_get_status,proc_close,pfsockopen,leak,apache_child_terminate,posix_kill,posix_mkfifo,posix_setpgid,posix_setsid,posix_setuid,dl,symlink,shell_exec,system,dl,passthru,escapeshellarg,escapeshellcmd,myshellexec,c99_buff_prepare,c99_sess_put,fpassthru,getdisfunc,fx29exec,fx29exec2,is_windows,disp_freespace,fx29sh_getupdate,fx29_buff_prepare,fx29_sess_put,fx29shexit,fx29fsearch,fx29ftpbrutecheck,fx29sh_tools,fx29sh_about,milw0rm,imagez,sh_name,myshellexec,checkproxyhost,dosyayicek,c99_buff_prepare,c99_sess_put,c99getsource,c99sh_getupdate,c99fsearch,c99shexit,view_perms,posix_getpwuid,posix_getgrgid,posix_kill,parse_perms,parsesort,view_perms_color,set_encoder_input,ls_setcheckboxall,ls_reverse_all,rsg_read,rsg_glob,selfURL,dispsecinfo,unix2DosTime,addFile,system,get_users,view_size,DirFiles,DirFilesWide,DirPrintHTMLHeaders,GetFilesTotal,GetTitles,GetTimeTotal,GetMatchesCount,GetFileMatchesCount,GetResultFiles,fs_copy_dir,fs_copy_obj,fs_move_dir,fs_move_obj,fs_rmdir,SearchText,getmicrotime MySQL : ON | cURL : ON | WGET : ON | Perl : ON | Python : ON | Sudo : ON | Pkexec : ON Directory : /lib/mysqlsh/lib/python3.9/site-packages/oci/streaming/models/ |
Upload File : |
# coding: utf-8 # Copyright (c) 2016, 2024, Oracle and/or its affiliates. All rights reserved. # This software is dual-licensed to you under the Universal Permissive License (UPL) 1.0 as shown at https://oss.oracle.com/licenses/upl or Apache License 2.0 as shown at http://www.apache.org/licenses/LICENSE-2.0. You may choose either license. # NOTE: This class is auto generated by OracleSDKGenerator. DO NOT EDIT. API Version: 20180418 from oci.util import formatted_flat_dict, NONE_SENTINEL, value_allowed_none_or_none_sentinel # noqa: F401 from oci.decorators import init_model_state_from_kwargs @init_model_state_from_kwargs class Message(object): """ A message in a stream. """ def __init__(self, **kwargs): """ 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 """ self.swagger_types = { 'stream': 'str', 'partition': 'str', 'key': 'str', 'value': 'str', 'offset': 'int', 'timestamp': 'datetime' } self.attribute_map = { 'stream': 'stream', 'partition': 'partition', 'key': 'key', 'value': 'value', 'offset': 'offset', 'timestamp': 'timestamp' } self._stream = None self._partition = None self._key = None self._value = None self._offset = None self._timestamp = None @property def stream(self): """ **[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 """ return self._stream @stream.setter def stream(self, stream): """ 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 """ self._stream = stream @property def partition(self): """ **[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 """ return self._partition @partition.setter def partition(self, partition): """ 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 """ self._partition = partition @property def key(self): """ **[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 """ return self._key @key.setter def key(self, key): """ 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 """ self._key = key @property def value(self): """ **[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 """ return self._value @value.setter def value(self, value): """ 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 """ self._value = value @property def offset(self): """ **[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 """ return self._offset @offset.setter def offset(self, offset): """ 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 """ self._offset = offset @property def timestamp(self): """ **[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 """ return self._timestamp @timestamp.setter def timestamp(self, timestamp): """ 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 """ self._timestamp = timestamp def __repr__(self): return formatted_flat_dict(self) def __eq__(self, other): if other is None: return False return self.__dict__ == other.__dict__ def __ne__(self, other): return not self == other