NATS

account info - информация об учетной записи

account report - отчет о показателях учетной записи

account backup - создание резервной копии всех потоков JetStream по сети NATS

account restore - восстановление резервной копии учетной записи по сети NATS

--pub=0 - количество одновременных издателей

--sub=0 - количество одновременных подписчиков

--js - используйте JetStream

--request - режим запроса-ответа: издатели отправляют запросы в ожидании ответа

--reply - режим запроса-ответа: подписчики отправляют ответы

--kv - в режиме KV подписчики получают доступ из корзины, а издатели помещают в корзину

--msgs=100000 - количество сообщений для публикации

--size="128" - размер тестовых сообщений

--no-progress - отключите индикатор выполнения во время публикации

--csv=CSV - сохраните контрольные данные в CSV-файл

--purge - очистите поток перед запуском

--storage=memory - хранилище JetStream (память/файл) для потока "benchstream"

--replicas=1 - количество реплик потока для потока "benchstream"

--maxbytes="1GB" - максимальный размер потока или сегмента KV в байтах

--stream="benchstream" - если установлено значение, отличное от "benchstream", то используйте указанный поток при создании постоянных подписчиков. В противном случае определите и используйте поток "benchstream"

--bucket="benchbucket" - если установлено значение, отличное от "benchbucket", то используйте указанную корзину в режиме KV. В противном случае определите и используйте корзину "benchbucket"

--consumer="natscli-bench" - укажите имя долговременного потребителя, которое будет использоваться

--jstimeout=30s - тайм-аут для операций JS

--syncpub - синхронная публикация в потоке

--pubbatch=100 - устанавливает размер пакета для асинхронной публикации JS

--pull - используйте общий долговременный явно подтвержденный pull-потребитель JS, а не отдельных эфемерных потребителей

--push - используйте общий долговременный явно подтвержденный push-потребитель JS с группой очередей, а не с отдельными эфемерными потребителями

--consumerbatch=100 - устанавливает размер пакета для долговременного pull-потребителя JS или максимальное значение ожидания подтверждения для долговременного push-потребителя JS

--subsleep=0s - спящий режим в течение указанного интервала перед отправкой подтверждения подписчика обратно в режиме --js, или отправкой ответа обратно в режиме --reply, или выполнением следующего получения в режиме --kv

--pubsleep=0s - cпящий режим в течение указанного интервала после публикации каждого сообщения

--history=1 - глубина истории для корзины в режиме KV

--multisubject - в режиме с несколькими темами каждое сообщение публикуется в теме, которая включает порядковый номер сообщения издателя в качестве маркера

--multisubjectmax=0 - максимальное количество объектов для использования в мультисубъектном режиме (0 означает отсутствие максимального количества)

--retries=3 - максимальное количество повторных попыток в операциях JS

--dedup - задает идентификатор сообщения в заголовке для использования дедупликации публикации JS

--dedupwindow=2m - устанавливает продолжительность действия функции дедупликации потока

consumer ls - список известных потребителей

consumer report - отчеты по статистике потребителей

consumer info - информация для потребителей

consumer add - создает нового потребителя

consumer edit - редактирует конфигурацию потребителя

consumer rm - удаляет потребителя

consumer copy - создает нового потребителя на основе конфигурации другого

consumer next - извлекает сообщения от pull-потребителей без интерактивных подсказок

consumer sub - извлекает сообщения от потребителей

consumer cluster - управляет кластеризованным потребителем

-a, --all - работать со всеми потоками, включая системные

context save - обновите или создайте контекст

context copy - копирует существующий контекст

context edit - отредактируйте контекст в вашем редакторе

context ls - перечислите известные контексты

context rm - удалить контекст

context select - выберите контекст по умолчанию

context info - отображает информацию о текущем или именованном контексте

context validate - проверка одного или всех контекстов

errors ls - перечислите все известные коды ошибок

errors lookup - ищет ошибку по ее коду

errors edit - отредактируйте или добавьте код ошибки с помощью вашего редактор

errors validate - проверяет правильность определения ошибок

--errors=FILE - файл errors.json для использования в качестве входных данных

-a, --all - показать все события

-j, --json - создать вывод в формате JSON

--cloudevent - создать выходные данные CloudEvents v1

--short - короткий формат события

--filter="." - фильтруйте по всему событию с помощью регулярных выражений

--js-metric - показывает события метрики JetStream (false)

--js-advisory - показывает рекомендуемые события (false)

--[no-]srv-advisory - показывает рекомендации сервера NATS (true)

--subjects=SUBJECTS - показывать рекомендации и показатели, полученные по конкретным темам

kv add - добавляет новую корзину хранилища KV

kv put - помещает значение в ключ

kv get - получает значение для ключа

kv create - помещает значение в ключ только в том случае, если ключ новый или его последней операцией было удаление

kv update - обновляет ключ новым значением, если предыдущее значение соответствует данной редакции

kv del - удаляет ключ или всю корзину целиком

kv purge - удаляет ключ из корзины, очищая историю перед созданием маркера удаления

kv history - показывает полную историю для ключа

kv revert - возвращает значение к предыдущей редакции с помощью put

kv info - просмотр статуса магазина KV

kv watch - следите за обновлениями в корзине или определенном ключе

kv ls - перечислите доступные корзины или ключи в корзине

kb kv compact - удаляет все исторические значения из хранилища, где последним значением является удаление

--server-b=SERVER-B - второй сервер, на который нужно подписаться

--size=8 - размер сообщения

--rate=1000 - скорость передачи сообщений в секунду

--duration=5s - продолжительность теста

--histogram=HISTOGRAM - выходной файл для сохранения гистограммы

object add - добавляет новую корзину хранилища объектов

object put - помещает файл в хранилище

object del - удаляет файл или корзину из хранилища

object get - извлекает файл из хранилища

object info - получение информации о корзине или объекте

object ls - перечислите сегменты или содержимое определенного сегмента

object seal - герметизирует корзину, предотвращая дальнейшие обновления

object watch - следите за изменениями в корзине

Count - номер сообщения

TimeStamp - текущее время в формате RFC3339

Unix - секунды с 1970 по UTC

UnixNano - наносекунды с 1970 по UTC

Time - текущее время

ID - уникальный идентификатор

Random(min, max) - случайная строка длиной не менее min, не более max

-r, --raw - показывать только полученный результат

-H, --header=HEADER - добавляет заголовки к сообщению

--count=1 - публиковать несколько сообщений

--replies=1 - дождитесь нескольких ответов от служб. 0 ожидает истечения времени ожидания

--reply-timeout=300ms - максимальное время ожидания между входящими ответами

Count - номер сообщения

TimeStamp - текущее время в формате RFC3339

Unix - секунды с 1970 по UTC

UnixNano - наносекунды с 1970 по UTC

Time - текущее время

ID - уникальный идентификатор

Request - полезная нагрузка запроса

Random(min, max) - случайная строка длиной не менее min, не более max

--echo - отразите то, что получено

--command=COMMAND - запускает команду и выдает результат, если код выхода равен 0

-q, --queue="NATS-RPLY-22" - имя группы очередей

--sleep=MAX - введите случайную задержку перехода в спящий режим между ответами до этой максимальной продолжительности

-H, --header=HEADER - добавляет заголовки к сообщению

--count=COUNT - выйти после получения такого количества сообщений

-j, --json - создать вывод в формате JSON

schema search - поиск схем с использованием шаблона

schema info - отображать содержимое схемы

schema validate - проверяет соответствие файла JSON схеме

server info - показывать информацию об одном сервере

server ls - список известных серверов

server ping - пропинговать все серверы

server report - отчет о различных показателях сервера

server request - запросить данные мониторинга с определенного сервера

server raft - управление кластеризацией JetStream

server mappings - шаблоны отображения испытуемого

server passwd - создает зашифрованные пароли для использования на сервере NATS

server check - проверка работоспособности серверов NATS

server purge - удаление активов из кластеров JetStream

stream add - создайте новый поток

stream ls - перечислите все известные потоки

stream report - отчеты по статистике потоков

stream find - находит потоки, соответствующие определенным критериям

stream info - потоковая информация

stream state - состояние потока

stream subjects - объекты запроса, хранящиеся в потоке

stream edit - редактирует существующий поток

stream rm - удаляет поток

stream purge - очистить поток, не удаляя его

stream copy - создает новый поток на основе конфигурации другого, не копирует данные

stream rmm - безопасное удаление отдельного сообщения из потока

stream view - просмотр сообщений в потоке

stream get - извлекает определенное сообщение из потока

stream backup - создает резервную копию потока по сети NATS

stream restore - восстановите поток по сети NATS

stream seal - блокирует поток, предотвращая дальнейшие обновления

stream cluster - управляет кластеризованным потоком

-a, --all - при перечислении или выборе потоков отображаются все потоки, включая системные

--queue=QUEUE - подпишитесь на именованную группу очередей

--durable=DURABLE - используйте устройство длительного пользования (требуется JetStream)

-r, --raw - показать полученные необработанные данные

--[no-]ack - подтвердите сообщение JetStream, содержащее правильные метаданные

--match-replies - сопоставляет ответы на запросы

-i, --inbox - подписывается на созданный почтовый ящик входящих сообщений

--count=COUNT - выйти после получения такого количества сообщений

--dump=DIRECTORY - сохраняет полученные сообщения в файлы, по 1 файлу на сообщение

--headers-only - не отображает никаких данных, показывает только заголовки

--start-sequence=SEQUENCE - запускается в определенной последовательности потоков (требуется JetStream)

--all - доставляет все сообщения, найденные в потоке (требуется JetStream)

--new - доставляет только будущие сообщения (требуется JetStream)

--last - доставляет самые последние и все будущие сообщения (требуется JetStream)

--since=DURATION - доставляет сообщения, полученные с промежутком времени, равным 1d3h5m2s (требуется JetStream)

--last-per-subject - доставляет самые последние сообщения для каждой темы в потоке (требуется JetStream)

--stream=STREAM - подпишитесь на определенный поток (требуется JetStream)

-I, --ignore-subject=SUBJECT - темы, для которых соответствующие сообщения будут проигнорированы и, следовательно, не будут показаны в выходных данных