o Á¿iâã@s.ddlmZddlmZd dd„Zdd„ZdS) é)Údata_streams_processor)ÚPROPAGATION_KEY_BASE_64TcCsFtƒ}|r!| |tƒ¡d|d|dg}|r| d¡| |¡SdS)aƒ :param typ: The type of the checkpoint, usually the streaming technology being used. Examples include kafka, kinesis, sns etc. (str) :param source: The source of data. This can be a topic, exchange or stream name. (str) :param carrier_get: A function used to extract context from the carrier (function (str) -> str) :param manual_checkpoint: Whether this checkpoint was manually set. Keep true if manually instrumenting. Manual instrumentation always overrides automatic instrumentation in the case a call is both manually and automatically instrumented. (bool) :returns DataStreamsCtx | None útype:útopic:z direction:inúmanual_checkpoint:trueN)rÚdecode_pathway_b64rÚappendÚset_checkpoint)ÚtypÚsourceÚ carrier_getÚmanual_checkpointÚ processorÚtags©rúH/home/ubuntu/.local/lib/python3.10/site-packages/ddtrace/data_streams.pyÚset_consume_checkpoints   ûrcCsBtƒ}|r| d|d|ddg¡}|dur|t| ¡ƒ|SdS)a§ :param typ: The type of the checkpoint, usually the streaming technology being used. Examples include kafka, kinesis, sns etc. (str) :param target: The destination to which the data is being sent. For instance: topic, exchange or stream name. (str) :param carrier_set: A function used to inject the context into the carrier (function (str, str) -> None) :returns DataStreamsCtx | None rrz direction:outrN)rr rÚ encode_b64)r ÚtargetÚ carrier_setrÚpathwayrrrÚset_produce_checkpoints ÿúrN)T)Úddtrace.internal.datastreamsrÚ&ddtrace.internal.datastreams.processorrrrrrrrÚs