dQj ddlmZddlmZddlmZddlmZddlm Z m Z m Z m Z m Z ddlmZmZmZddlmZeeZdee d efd ZGd d Zy ))Callable) fnmatchcase) getLogger) Instrument) AggregationDefaultAggregation _Aggregation#_ExplicitBucketHistogramAggregation&_ExponentialBucketHistogramAggregation)'AlignedHistogramBucketExemplarReservoirExemplarReservoirBuilder SimpleFixedSizeExemplarReservoir) _Instrumentaggregation_typereturncft|trtSt|trtStS)z*Default reservoir factory per aggregation.) issubclassr r r r)rs m/home/oem/CyberBrain26-unified/.venv/lib/python3.12/site-packages/opentelemetry/sdk/metrics/_internal/view.py_default_reservoir_factoryrs."$GH66"$JK// ++ceZdZdZeZ ddeedzdedzdedzdedzdedzdedzd edzd e edzd e dzd e ee ge fdzd edzdedzfdZdedefdZy)Viewa A `View` configuration parameters can be used for the following purposes: 1. Match instruments: When an instrument matches a view, measurements received by that instrument will be processed. 2. Customize metric streams: A metric stream is identified by a match between a view and an instrument and a set of attributes. The metric stream can be customized by certain attributes of the corresponding view. The attributes documented next serve one of the previous two purposes. Args: instrument_type: This is an instrument matching attribute: the class the instrument must be to match the view. instrument_name: This is an instrument matching attribute: the name the instrument must have to match the view. Wild card characters are supported. Wild card characters should not be used with this attribute if the view has also a ``name`` defined. meter_name: This is an instrument matching attribute: the name the instrument meter must have to match the view. meter_version: This is an instrument matching attribute: the version the instrument meter must have to match the view. meter_schema_url: This is an instrument matching attribute: the schema URL the instrument meter must have to match the view. name: This is a metric stream customizing attribute: the name of the metric stream. If `None`, the name of the instrument will be used. description: This is a metric stream customizing attribute: the description of the metric stream. If `None`, the description of the instrument will be used. attribute_keys: This is a metric stream customizing attribute: this is a set of attribute keys. If not `None` then only the measurement attributes that are in ``attribute_keys`` will be used to identify the metric stream. aggregation: This is a metric stream customizing attribute: the aggregation instance to use when data is aggregated for the corresponding metrics stream. If `None` an instance of `DefaultAggregation` will be used. exemplar_reservoir_factory: This is a metric stream customizing attribute: the exemplar reservoir factory instrument_unit: This is an instrument matching attribute: the unit the instrument must have to match the view. aggregation_cardinality_limit: This is a metric stream customizing attribute: the maximum number of distinct attribute sets the stream aggregates per collection cycle. Measurements with further attribute sets are aggregated into one additional point identified by the attribute ``otel.metric.overflow=true``. If `None` the cardinality limit of the metric reader is used, which defaults to 2000. Must be a positive integer. This class is not intended to be subclassed by the user. Ninstrument_typeinstrument_name meter_name meter_versionmeter_schema_urlname descriptionattribute_keys aggregationexemplar_reservoir_factoryinstrument_unitaggregation_cardinality_limitc | 3t| tst| tr| dkrtd| ||cxur| cxur|cxur |cxur|cxur nnt d|||d|vsd|vrt d|d||_||_||_| |_||_ ||_ ||_ ||_ ||_ | xs |j|_| xst |_| |_y)Nz>aggregation_cardinality_limit must be a positive integer, got z=Some instrument selection criteria must be provided for View *?zView z5 declared with wildcard characters in instrument_name) isinstanceboolint ValueError Exception_name_instrument_type_instrument_name_instrument_unit _meter_name_meter_version_meter_schema_url _description_attribute_keys_default_aggregation _aggregationr_exemplar_reservoir_factory_aggregation_cardinality_limit) selfrrrrrrrr r!r"r#r$s r__init__z View.__init__hs7 ) 4 4d ;;SA,q0PQnPqr             [\`[abc c   ;AW[^bq[qeD6)^_` `  / / /%+!1'-'D4+D+D+E+cIc(.K+r instrumentrc:|jt||jsy|j/t|j|jj sy|j !t|j|j sy|j$|jj|jk7ry|j$|jj|jk7ry|j$|jj|jk7ryy)NFT)r/r)r0rrlowerr1unitr2instrumentation_scoper3versionr4 schema_url)r;r=s r_matchz View._matchs  ,j$*?*?@  , z0E0E0K0K0MN  ,z0E0EF    '//448H8HH    *//774;N;NN  ! ! -//::d>T>TTr) NNNNNNNNNNNN)__name__ __module__ __qualname____doc__rr7typerstrsetrrr r r+r<rr*rDrrrr&s%=~./48&*!%$('+"&*.*.fj&*487Lj)D07Lt7L$J 7L Tz 7L * 7LDj7L4Z7LC47L!4'7L%-d<.@-AC[-[$\_c$c7Lt7L(+Tz7LvrrN)collections.abcrfnmatchrloggingropentelemetry.metricsr/opentelemetry.sdk.metrics._internal.aggregationrrr r r ,opentelemetry.sdk.metrics._internal.exemplarr r r.opentelemetry.sdk.metrics._internal.instrumentrrE_loggerrIrrrLrrrUs] %, G H ,<(,,\\r