aboutsummaryrefslogtreecommitdiffstats
path: root/core/Command/Memcache
diff options
context:
space:
mode:
Diffstat (limited to 'core/Command/Memcache')
-rw-r--r--core/Command/Memcache/DistributedClear.php47
-rw-r--r--core/Command/Memcache/DistributedDelete.php43
-rw-r--r--core/Command/Memcache/DistributedGet.php40
-rw-r--r--core/Command/Memcache/DistributedSet.php57
4 files changed, 187 insertions, 0 deletions
diff --git a/core/Command/Memcache/DistributedClear.php b/core/Command/Memcache/DistributedClear.php
new file mode 100644
index 00000000000..424f21f1e81
--- /dev/null
+++ b/core/Command/Memcache/DistributedClear.php
@@ -0,0 +1,47 @@
+<?php
+
+declare(strict_types=1);
+/**
+ * SPDX-FileCopyrightText: 2025 Nextcloud GmbH and Nextcloud contributors
+ * SPDX-License-Identifier: AGPL-3.0-or-later
+ */
+
+namespace OC\Core\Command\Memcache;
+
+use OC\Core\Command\Base;
+use OCP\ICacheFactory;
+use Symfony\Component\Console\Input\InputInterface;
+use Symfony\Component\Console\Input\InputOption;
+use Symfony\Component\Console\Output\OutputInterface;
+
+class DistributedClear extends Base {
+ public function __construct(
+ protected ICacheFactory $cacheFactory,
+ ) {
+ parent::__construct();
+ }
+
+ protected function configure(): void {
+ $this
+ ->setName('memcache:distributed:clear')
+ ->setDescription('Clear values from the distributed memcache')
+ ->addOption('prefix', null, InputOption::VALUE_REQUIRED, 'Only remove keys matching the prefix');
+ parent::configure();
+ }
+
+ protected function execute(InputInterface $input, OutputInterface $output): int {
+ $cache = $this->cacheFactory->createDistributed();
+ $prefix = $input->getOption('prefix');
+ if ($cache->clear($prefix)) {
+ if ($prefix) {
+ $output->writeln('<info>Distributed cache matching prefix ' . $prefix . ' cleared</info>');
+ } else {
+ $output->writeln('<info>Distributed cache cleared</info>');
+ }
+ return 0;
+ } else {
+ $output->writeln('<error>Failed to clear cache</error>');
+ return 1;
+ }
+ }
+}
diff --git a/core/Command/Memcache/DistributedDelete.php b/core/Command/Memcache/DistributedDelete.php
new file mode 100644
index 00000000000..ae0855acb03
--- /dev/null
+++ b/core/Command/Memcache/DistributedDelete.php
@@ -0,0 +1,43 @@
+<?php
+
+declare(strict_types=1);
+/**
+ * SPDX-FileCopyrightText: 2025 Nextcloud GmbH and Nextcloud contributors
+ * SPDX-License-Identifier: AGPL-3.0-or-later
+ */
+
+namespace OC\Core\Command\Memcache;
+
+use OC\Core\Command\Base;
+use OCP\ICacheFactory;
+use Symfony\Component\Console\Input\InputArgument;
+use Symfony\Component\Console\Input\InputInterface;
+use Symfony\Component\Console\Output\OutputInterface;
+
+class DistributedDelete extends Base {
+ public function __construct(
+ protected ICacheFactory $cacheFactory,
+ ) {
+ parent::__construct();
+ }
+
+ protected function configure(): void {
+ $this
+ ->setName('memcache:distributed:delete')
+ ->setDescription('Delete a value in the distributed memcache')
+ ->addArgument('key', InputArgument::REQUIRED, 'The key to delete');
+ parent::configure();
+ }
+
+ protected function execute(InputInterface $input, OutputInterface $output): int {
+ $cache = $this->cacheFactory->createDistributed();
+ $key = $input->getArgument('key');
+ if ($cache->remove($key)) {
+ $output->writeln('<info>Distributed cache key <info>' . $key . '</info> deleted</info>');
+ return 0;
+ } else {
+ $output->writeln('<error>Failed to delete cache key ' . $key . '</error>');
+ return 1;
+ }
+ }
+}
diff --git a/core/Command/Memcache/DistributedGet.php b/core/Command/Memcache/DistributedGet.php
new file mode 100644
index 00000000000..bf1b00d312d
--- /dev/null
+++ b/core/Command/Memcache/DistributedGet.php
@@ -0,0 +1,40 @@
+<?php
+
+declare(strict_types=1);
+/**
+ * SPDX-FileCopyrightText: 2025 Nextcloud GmbH and Nextcloud contributors
+ * SPDX-License-Identifier: AGPL-3.0-or-later
+ */
+
+namespace OC\Core\Command\Memcache;
+
+use OC\Core\Command\Base;
+use OCP\ICacheFactory;
+use Symfony\Component\Console\Input\InputArgument;
+use Symfony\Component\Console\Input\InputInterface;
+use Symfony\Component\Console\Output\OutputInterface;
+
+class DistributedGet extends Base {
+ public function __construct(
+ protected ICacheFactory $cacheFactory,
+ ) {
+ parent::__construct();
+ }
+
+ protected function configure(): void {
+ $this
+ ->setName('memcache:distributed:get')
+ ->setDescription('Get a value from the distributed memcache')
+ ->addArgument('key', InputArgument::REQUIRED, 'The key to retrieve');
+ parent::configure();
+ }
+
+ protected function execute(InputInterface $input, OutputInterface $output): int {
+ $cache = $this->cacheFactory->createDistributed();
+ $key = $input->getArgument('key');
+
+ $value = $cache->get($key);
+ $this->writeMixedInOutputFormat($input, $output, $value);
+ return 0;
+ }
+}
diff --git a/core/Command/Memcache/DistributedSet.php b/core/Command/Memcache/DistributedSet.php
new file mode 100644
index 00000000000..0f31c22f730
--- /dev/null
+++ b/core/Command/Memcache/DistributedSet.php
@@ -0,0 +1,57 @@
+<?php
+
+declare(strict_types=1);
+/**
+ * SPDX-FileCopyrightText: 2025 Nextcloud GmbH and Nextcloud contributors
+ * SPDX-License-Identifier: AGPL-3.0-or-later
+ */
+
+namespace OC\Core\Command\Memcache;
+
+use OC\Core\Command\Base;
+use OC\Core\Command\Config\System\CastHelper;
+use OCP\ICacheFactory;
+use Symfony\Component\Console\Input\InputArgument;
+use Symfony\Component\Console\Input\InputInterface;
+use Symfony\Component\Console\Input\InputOption;
+use Symfony\Component\Console\Output\OutputInterface;
+
+class DistributedSet extends Base {
+ public function __construct(
+ protected ICacheFactory $cacheFactory,
+ private CastHelper $castHelper,
+ ) {
+ parent::__construct();
+ }
+
+ protected function configure(): void {
+ $this
+ ->setName('memcache:distributed:set')
+ ->setDescription('Set a value in the distributed memcache')
+ ->addArgument('key', InputArgument::REQUIRED, 'The key to set')
+ ->addArgument('value', InputArgument::REQUIRED, 'The value to set')
+ ->addOption(
+ 'type',
+ null,
+ InputOption::VALUE_REQUIRED,
+ 'Value type [string, integer, float, boolean, json, null]',
+ 'string'
+ );
+ parent::configure();
+ }
+
+ protected function execute(InputInterface $input, OutputInterface $output): int {
+ $cache = $this->cacheFactory->createDistributed();
+ $key = $input->getArgument('key');
+ $value = $input->getArgument('value');
+ $type = $input->getOption('type');
+ ['value' => $value, 'readable-value' => $readable] = $this->castHelper->castValue($value, $type);
+ if ($cache->set($key, $value)) {
+ $output->writeln('Distributed cache key <info>' . $key . '</info> set to <info>' . $readable . '</info>');
+ return 0;
+ } else {
+ $output->writeln('<error>Failed to set cache key ' . $key . '</error>');
+ return 1;
+ }
+ }
+}