o );ciV@sddlZddlZddlZddlmZmZddlmZm Z m Z ddl m Z ddZ edhZd d Zd d d dZddZedZddZddZddZddZddZddZddZd d!Zd"d#Zd$d%Zd&d'Zd(d)Z dS)*N)MetricMETRIC_LABEL_NAME_RE)ExemplarSample Timestamp)floatToGoStringccstt|EdHdS)z^Parse Openmetrics text format from a unicode string. See text_fd_to_metric_families. N)text_fd_to_metric_familiesStringIO)textr o/Users/cmarchbanks/go/src/github.com/prometheus/client_python/build/lib/prometheus_client/openmetrics/parser.pytext_string_to_metric_families srinfcCs t|}|tvr dS|t|kS)NF)float_CANONICAL_NUMBERSr)sfr r r _isUncanonicalNumbers r\ ")z\\z\nz\"cCst|dS)Nr)ESCAPE_SEQUENCESgroup)matchr r r _replace_escape_sequence&srz\\[\\n"]cCs tt|SN) ESCAPING_REsubr)rr r r _replace_escaping-s rcCsg}d}|D]8}|r2|dkr|dn|dkr|dn|dkr(|dn|d|d}q|dkr9d}q||q|rF|dd|S)NFrrnrT)appendjoin)r resultZslashcharr r r _unescape_help1s$      r&cCsRd|}||ksd|vrtd|zt|WSty(t|YSw)Nr!_zInvalid value: )r#strip ValueErrorintr)valuer r r _parse_valueLs    r,c Csd|}|s dS||ksd|vrtd|ztt|dWStyjz|dd}tt|dt|dddddWYStyit|}t |s\t |rctd||YYSww) Nr!r'zInvalid timestamp: r. 0) r#r(r)rr*splitljustrmathisnanisinf) timestamppartstsr r r _parse_timestampVs$   0  r9cCsPd}||kr"||d|dkr"|d7}||kr"||d|dks|ddkS)Nrr.rrr )rcharpos num_bslashesr r r _is_character_escapedls r<cCsd}g}g}i}d}|D]}|dkr!|dkrd}nd}||n|dkr2|dkr,d}n||n|dkrC|dkr=d }ntd ||d kr|d krNd }n|dkrzd |}t|sbtd|||vrltd|d |||<g}g}d}n]||nW|dkr|dkrd}nL|dkrd}nEtd ||d krd }|d kr|d n/|dkr|dn%|dkr|dn|d |n|dkr|dkr||fStd ||d7}q ||fS)NZstartoflabelnamer}Z endoflabels labelname=Zlabelvaluequoter labelvalueInvalid line: rZlabelvalueslashr!zInvalid line, bad label name: z$Invalid line, duplicate label name: Zendoflabelvalue,r r r.)r"r)r#rr)r stater>r@labels labels_lenr%Zlnr r r _parse_labels_with_state_machinetsn             rGc Csi}|r d|vr t|}z|r|d}|d|}||dd}|r*|ddkr,t|dd}|r:|ddkrcs"z(_parse_remaining_text..zExemplar labels are too long: ) r1r,rJiterr"r)rIrXrTr9sumitemsr)r Z split_textvalr6Zexemplar_valueZexemplar_timestampZexemplar_labelsrDitr%rZr^r8r]Zexemplar_lengthr r r rWs                       rWcCs~|dkriS|dkr|j|kr|j}|d=|S|dkr'|j}||=|S|dvr<|j|dkr<|j}|d=|S|jS)Ninfosummaryquantilestateset histogramgaugehistogram_bucketle)r\rEcopy)sampler\typdr r r _group_for_sampleos   r}c s>d}d}fdd}|D]}|jtd}t|d}||ks-|j|krB|dur4|ddddddd|}|j}|dkrwt|jd}|dkrXddurf|krftd |jkrqtd ||jq|d vr|jq|d vrdq|d vrd|jdkrdq|dur|dSdS)Ncstdkr tddurkrtdr&dur&tdr2dur2tds@s@dur@tdrJrJtdsTrVtddSdS) Nz+Infz+Inf bucket missing: z!Count does not match +Inf value: z+_count must be present if _sum is present: z-_gcount must be present if _gsum is present: z1_sum/_gsum must be present if _count is present: z(Cannot have _sum with negative buckets: z6Cannot have negative _gsum with non-negative buckets: )rr)r bucketcountZhas_gsumZhas_negative_bucketsZhas_negative_gsumZhas_sumr\r+r r do_checkss          z#_check_histogram..do_checksruFrrwrxTzBuckets out of order: zBucket values out of order: )_count_gcount)_sum)_gsum)r\rJr}r6rrEr)r+) samplesr\rr6rrsuffixgbr r~r _check_histogramsP      rc#sdg}d}tddggdgdgddgd fd d }|D]}|d d kr3|dd }|r;td||sAtd|dkrHd}q$|dr|dd}t|dkr_td||dkrm|rmtd||dkrdur|||| |V|dd} d}d}d} t} d} t} g}|dg}|ddkr|durtd|t|d}q$|ddkr|durtd||d}|dkrtd|fd d!|d"gD}q$|dd#kr| durtd$||d} q$td|t|}|j|vr+dur|||| |V|jd}d} d%}g}d} d} t} t} |jg}|d&kr<|j vrvr|j d1krtd?||jr|d@vr|jd(s|dAvr|jdstdB|q$dur|||| |V|stdCdS)DzParse Prometheus text format from a file descriptor. This is a laxer parser than the main Go parser, so successful parsing does not imply that the parsed text meets the specification. Yields Metric's. NF_total_created)r!rrr)rrrwr)rrrw_info)counterrqrurvrpcs|durd}t|gdgD]}||vr!td||||q|dur/d}|dur5d}|rD|d|sDtd||rP|dvrPtd||dvrYt||t||||}||_|S) Nunknownr!zClashing name: r'z!Unit does not match metric name: )rprsz(Units not allowed for this metric type: rt)setgetr)addendswithrrr)r\ documentationr{unitrrmetric) seen_names type_suffixesr r build_metrics&     z0text_fd_to_metric_families..build_metricrHrzReceived line after # EOF: zReceived blank linez# EOFTrarCrArz!Received metadata after samples: r.HELPzMore than one HELP for metric: TYPEzMore than one TYPE for metric: untypedzInvalid TYPE for metric: csg|]}|qSr r )rfr )r\r r sz.text_fd_to_metric_families..r!ZUNITzMore than one UNIT for metric: rrszStateset missing label: rwrxNaNzInvalid le label: z!Bucket value must be an integer: rrz Count value must be an integer: rqrrrzInvalid quantile label: zInvalid metric grouping: z*Mix of timestamp presence within a group: rpz*Timestamps went backwards within a group: )rr.z4Stateset samples can only have values zero and one: z&Info samples can only have value one: z$Quantile values cannot be negative: )rrrrwrrz$Counter-like samples cannot be NaN: )rrrrwrz)Counter-like samples cannot be negative: rt)rzTInvalid line only histogram/gaugehistogram buckets and counters can have exemplars: zMissing # EOF at end)rr)rKr1rJr&rr`r\rEr isinstancer+r* is_integerrtuplesortedr}rmr6r"rr3r4r]r)fd allowed_nameseofrliner7rrr{rrZ seen_groupsZgroup_timestampZgroup_timestamp_samplesrzrZ series_idr )r\rrr r s                                *           "  $   r )!ior r3re metrics_corerrrrrrutilsrrrrrrrcompilerrr&r,r9r<rGrTr`rWr}rr r r r r s6    BDV ;