File Manager

X7ROOT File Manager

Current Path: /home/prisjneg/public_html/vendor/symfony/var-dumper/Caster

home / prisjneg / public_html / vendor / symfony / var-dumper / Caster /

📁 ..
📄 AmqpCaster.php(6.72 KB)
📄 ArgsStub.php(2.24 KB)
📄 Caster.php(6.73 KB)
📄 ClassStub.php(3.76 KB)
📄 ConstStub.php(740 B)
📄 CutArrayStub.php(696 B)
📄 CutStub.php(1.89 KB)
📄 DOMCaster.php(9.03 KB)
📄 DateCaster.php(4.94 KB)
📄 DoctrineCaster.php(1.74 KB)
📄 DsCaster.php(1.55 KB)
📄 DsPairStub.php(625 B)
📄 EnumStub.php(637 B)
📄 ExceptionCaster.php(16.38 KB)
📄 FFICaster.php(5.53 KB)
📄 FiberCaster.php(1.07 KB)
📄 FrameStub.php(740 B)
📄 GmpCaster.php(749 B)
📄 ImagineCaster.php(949 B)
📄 ImgStub.php(637 B)
📄 IntlCaster.php(8.9 KB)
📄 LinkStub.php(3.29 KB)
📄 MemcachedCaster.php(2.27 KB)
📄 MysqliCaster.php(691 B)
📄 PdoCaster.php(3.54 KB)
📄 PgSqlCaster.php(5.46 KB)
📄 ProxyManagerCaster.php(758 B)
📄 RdKafkaCaster.php(4.97 KB)
📄 RedisCaster.php(5.43 KB)
📄 ReflectionCaster.php(15.35 KB)
📄 ResourceCaster.php(3.07 KB)
📄 ScalarStub.php(554 B)
📄 SplCaster.php(8.13 KB)
📄 StubCaster.php(2.47 KB)
📄 SymfonyCaster.php(3.69 KB)
📄 TraceStub.php(964 B)
📄 UninitializedStub.php(615 B)
📄 UuidCaster.php(668 B)
📄 XmlReaderCaster.php(3.33 KB)
📄 XmlResourceCaster.php(2.52 KB)

Editing: RdKafkaCaster.php

<?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(),
        ];
    }
}

X7ROOT File Manager

Editing: RdKafkaCaster.php

Upload File

Create Folder