<?php
declare(strict_types=1);

use SimpleKafkaClient\Exception;
use SimpleKafkaClient\Metadata;
use SimpleKafkaClient\Topic;
use SimpleKafkaClient\TopicPartition;

abstract class SimpleKafkaClient
{
    /**
     * @param bool $allTopics
     * @param int $timeoutMs
     * @param Topic $topic
     * @return Metadata
     * @throws Exception
     */
    public function getMetadata(bool $allTopics, int $timeoutMs, Topic $topic): Metadata {}

    /**
     * @return int
     */
    public function getOutQLen(): int {}

    /**
     * @param int $timeoutMs
     * @return int
     */
    public function poll(int $timeoutMs): int {}

    /**
     * @param string $topic
     * @param int $partition
     * @param int &$low is passed as reference, contains result after call
     * @param-out int $low
     * @param int &$high is passed as reference, contains result after call
     * @param-out int $high
     * @param int $timeoutMs
     * @throws Exception
     */
    public function queryWatermarkOffsets(string $topic, int $partition, int &$low, int &$high, int $timeoutMs): void {}

    /**
     * @param TopicPartition[] $topicPartitions
     * @param int $timeoutMs
     * @return TopicPartition[]
     * @throws Exception
     */
    public function offsetsForTimes(array $topicPartitions, int $timeoutMs): array {}

    /**
     * @param string $errorString
     */
    public function setOAuthBearerTokenFailure(string $errorString): void {}

    /**
     * @param string $token
     * @param int $lifetimeMs
     * @param string $principalName
     * @param string[]|null $extensions
     */
    public function setOAuthBearerToken(string $token, int $lifetimeMs, string $principalName, ?array $extensions = null): void {}
}