Not Found

The requested URL was not found on this server.

Additionally, a 404 Not Found error was encountered while trying to use an ErrorDocument to handle the request.

1#@!#!123s

: / home / alamhospitals / public_html / vendor / symfony / var-dumper / Caster /

Filename : RdKafkaCaster.php

back

<?php

/*
 * This file is part of the Symfony package.
 *
 * (c) Fabien Potencier <fabien@symfony.com>
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */

namespace Symfony\Component\VarDumper\Caster;

use RdKafka\Conf;
use RdKafka\Exception as RdKafkaException;
use RdKafka\KafkaConsumer;
use RdKafka\Message;
use RdKafka\Metadata\Broker as BrokerMetadata;
use RdKafka\Metadata\Collection as CollectionMetadata;
use RdKafka\Metadata\Partition as PartitionMetadata;
use RdKafka\Metadata\Topic as TopicMetadata;
use RdKafka\Topic;
use RdKafka\TopicConf;
use RdKafka\TopicPartition;
use Symfony\Component\VarDumper\Cloner\Stub;

/**
 * Casts RdKafka related classes to array representation.
 *
 * @author Romain Neutron <imprec@gmail.com>
 */
class RdKafkaCaster
{
    /**
     * @return array
     */
    public static function castKafkaConsumer(KafkaConsumer $c, array $a, Stub $stub, bool $isNested)
    {
        $prefix = Caster::PREFIX_VIRTUAL;

        try {
            $assignment = $c->getAssignment();
        } catch (RdKafkaException) {
            $assignment = [];
        }

        $a += [
            $prefix.'subscription' => $c->getSubscription(),
            $prefix.'assignment' => $assignment,
        ];

        $a += self::extractMetadata($c);

        return $a;
    }

    /**
     * @return array
     */
    public static function castTopic(Topic $c, array $a, Stub $stub, bool $isNested)
    {
        $prefix = Caster::PREFIX_VIRTUAL;

        $a += [
            $prefix.'name' => $c->getName(),
        ];

        return $a;
    }

    /**
     * @return array
     */
    public static function castTopicPartition(TopicPartition $c, array $a)
    {
        $prefix = Caster::PREFIX_VIRTUAL;

        $a += [
            $prefix.'offset' => $c->getOffset(),
            $prefix.'partition' => $c->getPartition(),
            $prefix.'topic' => $c->getTopic(),
        ];

        return $a;
    }

    /**
     * @return array
     */
    public static function castMessage(Message $c, array $a, Stub $stub, bool $isNested)
    {
        $prefix = Caster::PREFIX_VIRTUAL;

        $a += [
            $prefix.'errstr' => $c->errstr(),
        ];

        return $a;
    }

    /**
     * @return array
     */
    public static function castConf(Conf $c, array $a, Stub $stub, bool $isNested)
    {
        $prefix = Caster::PREFIX_VIRTUAL;

        foreach ($c->dump() as $key => $value) {
            $a[$prefix.$key] = $value;
        }

        return $a;
    }

    /**
     * @return array
     */
    public static function castTopicConf(TopicConf $c, array $a, Stub $stub, bool $isNested)
    {
        $prefix = Caster::PREFIX_VIRTUAL;

        foreach ($c->dump() as $key => $value) {
            $a[$prefix.$key] = $value;
        }

        return $a;
    }

    /**
     * @return array
     */
    public static function castRdKafka(\RdKafka $c, array $a, Stub $stub, bool $isNested)
    {
        $prefix = Caster::PREFIX_VIRTUAL;

        $a += [
            $prefix.'out_q_len' => $c->getOutQLen(),
        ];

        $a += self::extractMetadata($c);

        return $a;
    }

    /**
     * @return array
     */
    public static function castCollectionMetadata(CollectionMetadata $c, array $a, Stub $stub, bool $isNested)
    {
        $a += iterator_to_array($c);

        return $a;
    }

    /**
     * @return array
     */
    public static function castTopicMetadata(TopicMetadata $c, array $a, Stub $stub, bool $isNested)
    {
        $prefix = Caster::PREFIX_VIRTUAL;

        $a += [
            $prefix.'name' => $c->getTopic(),
            $prefix.'partitions' => $c->getPartitions(),
        ];

        return $a;
    }

    /**
     * @return array
     */
    public static function castPartitionMetadata(PartitionMetadata $c, array $a, Stub $stub, bool $isNested)
    {
        $prefix = Caster::PREFIX_VIRTUAL;

        $a += [
            $prefix.'id' => $c->getId(),
            $prefix.'err' => $c->getErr(),
            $prefix.'leader' => $c->getLeader(),
        ];

        return $a;
    }

    /**
     * @return array
     */
    public static function castBrokerMetadata(BrokerMetadata $c, array $a, Stub $stub, bool $isNested)
    {
        $prefix = Caster::PREFIX_VIRTUAL;

        $a += [
            $prefix.'id' => $c->getId(),
            $prefix.'host' => $c->getHost(),
            $prefix.'port' => $c->getPort(),
        ];

        return $a;
    }

    /**
     * @return array
     */
    private static function extractMetadata(KafkaConsumer|\RdKafka $c)
    {
        $prefix = Caster::PREFIX_VIRTUAL;

        try {
            $m = $c->getMetadata(true, null, 500);
        } catch (RdKafkaException) {
            return [];
        }

        return [
            $prefix.'orig_broker_id' => $m->getOrigBrokerId(),
            $prefix.'orig_broker_name' => $m->getOrigBrokerName(),
            $prefix.'brokers' => $m->getBrokers(),
            $prefix.'topics' => $m->getTopics(),
        ];
    }
}

Name	Size	Last Modified	Owner	Permissions
AmqpCaster.php	6.718 KB	August 24 2023 2:21:04	alamhospitals	0644
ArgsStub.php	2.244 KB	August 24 2023 2:21:04	alamhospitals	0644
Caster.php	5.959 KB	August 24 2023 2:21:04	alamhospitals	0644
ClassStub.php	3.751 KB	August 24 2023 2:21:04	alamhospitals	0644
ConstStub.php	0.718 KB	August 24 2023 2:21:04	alamhospitals	0644
CutArrayStub.php	0.68 KB	August 24 2023 2:21:04	alamhospitals	0644
CutStub.php	1.885 KB	August 24 2023 2:21:04	alamhospitals	0644
DateCaster.php	4.938 KB	August 24 2023 2:21:04	alamhospitals	0644
DoctrineCaster.php	1.741 KB	August 24 2023 2:21:04	alamhospitals	0644
DOMCaster.php	9.35 KB	August 24 2023 2:21:04	alamhospitals	0644
DsCaster.php	1.553 KB	August 24 2023 2:21:04	alamhospitals	0644
DsPairStub.php	0.615 KB	August 24 2023 2:21:04	alamhospitals	0644
EnumStub.php	0.622 KB	August 24 2023 2:21:04	alamhospitals	0644
ExceptionCaster.php	16.383 KB	August 24 2023 2:21:04	alamhospitals	0644
FFICaster.php	5.165 KB	August 24 2023 2:21:04	alamhospitals	0644
FiberCaster.php	1.073 KB	August 24 2023 2:21:04	alamhospitals	0644
FrameStub.php	0.723 KB	August 24 2023 2:21:04	alamhospitals	0644
GmpCaster.php	0.731 KB	August 24 2023 2:21:04	alamhospitals	0644
ImagineCaster.php	0.927 KB	August 24 2023 2:21:04	alamhospitals	0644
ImgStub.php	0.622 KB	August 24 2023 2:21:04	alamhospitals	0644
IntlCaster.php	8.903 KB	August 24 2023 2:21:04	alamhospitals	0644
LinkStub.php	3.286 KB	August 24 2023 2:21:04	alamhospitals	0644
MemcachedCaster.php	2.269 KB	August 24 2023 2:21:04	alamhospitals	0644
MysqliCaster.php	0.675 KB	August 24 2023 2:21:04	alamhospitals	0644
PdoCaster.php	3.544 KB	August 24 2023 2:21:04	alamhospitals	0644
PgSqlCaster.php	5.464 KB	August 24 2023 2:21:04	alamhospitals	0644
ProxyManagerCaster.php	0.74 KB	August 24 2023 2:21:04	alamhospitals	0644
RdKafkaCaster.php	4.97 KB	August 24 2023 2:21:04	alamhospitals	0644
RedisCaster.php	5.435 KB	August 24 2023 2:21:04	alamhospitals	0644
ReflectionCaster.php	15.217 KB	August 24 2023 2:21:04	alamhospitals	0644
ResourceCaster.php	3.071 KB	August 24 2023 2:21:04	alamhospitals	0644
ScalarStub.php	0.541 KB	August 24 2023 2:21:04	alamhospitals	0644
SplCaster.php	8.126 KB	August 24 2023 2:21:04	alamhospitals	0644
StubCaster.php	2.475 KB	August 24 2023 2:21:04	alamhospitals	0644
SymfonyCaster.php	3.686 KB	August 24 2023 2:21:04	alamhospitals	0644
TraceStub.php	0.94 KB	August 24 2023 2:21:04	alamhospitals	0644
UuidCaster.php	0.652 KB	August 24 2023 2:21:04	alamhospitals	0644
XmlReaderCaster.php	3.261 KB	August 24 2023 2:21:04	alamhospitals	0644
XmlResourceCaster.php	2.521 KB	August 24 2023 2:21:04	alamhospitals	0644

2017 © D7net \| D704T team