3
Re @ s d dl mZ d dlZd dlZd dlZejd dkZerDeefZ dZ
n6eZ y ej j Z
W n$ e
k
rx ej ejd Z
Y nX G dd deddZG dd deZdS ) )
namedtupleN c s e Zd ZdZ fddZ ZS )ExtTypez'ExtType represents ext type in msgpack.c sX t |tstdt |ts$tdd| ko6dkn sDtdtt| j| ||S )Nzcode must be intzdata must be bytesr zcode must be 0~127)
isinstanceint TypeErrorbytes
ValueErrorsuperr __new__)clscodedata) __class__ /builddir/build/BUILDROOT/alt-python36-pip-20.2.4-5.el8.x86_64/opt/alt/python36/lib/python3.6/site-packages/pip/_vendor/msgpack/ext.pyr s
zExtType.__new__)__name__
__module__ __qualname____doc__r
__classcell__r r )r r r s r z code datac @ s e Zd ZdZddgZd ddZdd Zd d
Zd d Zd
d Z e
dd Z dd Z e
dd Z
dd Ze
dd Zdd Zdd Ze
d d Zd S )! TimestampaR Timestamp represents the Timestamp extension type in msgpack.
When built with Cython, msgpack uses C methods to pack and unpack `Timestamp`. When using pure-Python
msgpack, :func:`to_bytes` and :func:`from_bytes` are used to pack and unpack `Timestamp`.
This class is immutable: Do not override seconds and nanoseconds.
seconds nanosecondsr c C sT t |tstdt |ts$tdd| ko6dk n sDtd|| _|| _dS ) a Initialize a Timestamp object.
:param int seconds:
Number of seconds since the UNIX epoch (00:00:00 UTC Jan 1 1970, minus leap seconds).
May be negative.
:param int nanoseconds:
Number of nanoseconds to add to `seconds` to get fractional time.
Maximum is 999_999_999. Default is 0.
Note: Negative times (before the UNIX epoch) are represented as negative seconds + positive ns.
zseconds must be an intergerz nanoseconds must be an integerr
z?nanoseconds must be a non-negative integer less than 999999999.Ni ʚ;)r int_typesr r
r r )selfr r r r r __init__- s
zTimestamp.__init__c C s dj | j| jS )z#String representation of Timestamp.z'Timestamp(seconds={0}, nanoseconds={1}))formatr r )r r r r __repr__E s zTimestamp.__repr__c C s* t || jkr&| j|jko$| j|jkS dS )z0Check for equality with another Timestamp objectF)typer r r )r otherr r r __eq__K s zTimestamp.__eq__c C s | j | S )z(not-equals method (see :func:`__eq__()`))r$ )r r# r r r __ne__S s zTimestamp.__ne__c C s t | j| jfS )N)hashr r )r r r r __hash__W s zTimestamp.__hash__c C s t | dkr"tjd| d }d}nTt | dkrPtjd| d }|d@ }|d? }n&t | dkrntjd | \}}ntd
t||S ) a Unpack bytes into a `Timestamp` object.
Used for pure-Python msgpack unpacking.
:param b: Payload from msgpack ext message with code -1
:type b: bytes
:returns: Timestamp object unpacked from msgpack ext payload
:rtype: Timestamp
z!Lr z!Ql " z!IqzFTimestamp type can only be created from 32, 64, or 96-bit byte objects)lenstructunpackr
r )br r data64r r r
from_bytesZ s
zTimestamp.from_bytesc C s\ | j d? dkrF| jd> | j B }|d@ dkr8tjd|}qXtjd|}ntjd| j| j }|S )zPack this Timestamp object into bytes.
Used for pure-Python msgpack packing.
:returns data: Payload for EXT message with code -1 (timestamp type)
:rtype: bytes
r* r l z!Lz!Qz!Iq)r r r- pack)r r0 r r r r to_bytesu s zTimestamp.to_bytesc C s& t | d }t | d d }t||S )zCreate a Timestamp from posix timestamp in seconds.
:param unix_float: Posix timestamp in seconds.
:type unix_float: int or float.
r r i ʚ;)r r )unix_secr r r r r from_unix s zTimestamp.from_unixc C s | j | jd S )znGet the timestamp as a floating-point value.
:returns: posix timestamp
:rtype: float
g eA)r r )r r r r to_unix s zTimestamp.to_unixc C s t t| d S )zCreate a Timestamp from posix timestamp in nanoseconds.
:param int unix_ns: Posix timestamp in nanoseconds.
:rtype: Timestamp
r r i ʚ;)r divmod)unix_nsr r r from_unix_nano s zTimestamp.from_unix_nanoc C s | j d | j S )z~Get the timestamp as a unixtime in nanoseconds.
:returns: posix timestamp in nanoseconds
:rtype: int
r r i ʚ;)r r )r r r r to_unix_nano s zTimestamp.to_unix_nanoc C s t j j| j tS )zlGet the timestamp as a UTC datetime.
Python 2 is not supported.
:rtype: datetime.
)datetime
fromtimestampr7 _utc)r r r r to_datetime s zTimestamp.to_datetimec C s t j| j S )zuCreate a Timestamp from datetime with tzinfo.
Python 2 is not supported.
:rtype: Timestamp
)r r6 timestamp)dtr r r
from_datetime s zTimestamp.from_datetimeN)r )r r r r __slots__r r! r$ r% r' staticmethodr1 r3 r6 r7 r: r; r? rB r r r r r " s
r ) collectionsr r< sysr- version_infoPY2r longr r> timezoneutcAttributeError timedeltar objectr r r r r s