nekufa

import re
from inspect import getmembers, isclass
from os import path
from posixpath import abspath

from schemas import settings

base = settings.BaseSettings.schema()
info = ''
toc = ''

nekufa

from types import GenericAlias
from typing import get_type_hints


async def tester(param: list[str]):
    return [
        x + '!' for x in param
    ]

nekufa

class Response:
   data: list

async def get_data():
   # we have 250k rows of lists with 7 tuples - str and int
   return []

async def handler_empty():
  await get_data(); # 2 sec
  return {'data': []} # 0 sec

nekufa

nekufa@fasiga ~/software/wfm % yc container repository lifecycle-policy create --repository-name crpf255p88b3bourvm4f  --rules ./rules.json                     
id: crp6l3eg11h899i55cjt
repository_id: crp4dn6lp7isk8p11t3l
status: DISABLED
created_at: "2023-03-02T08:13:12.555327449Z"
rules:
- description: keep weekly tags not less 8 images
  expire_period: 604800s
  tag_regexp: .*
  retained_top: "8"

nekufa

# Get version

nekufa@fasiga ~ % kubectl describe pod nats-2 -n wfm-test | grep Image
    Image:         nats:2.7.2-alpine
    Image ID:      docker-pullable://nats@sha256:8b3fb2423a8cce4607ef30a990b35545afe0a3c613cd05b8eec7b483df268b1d
    Image:         natsio/nats-server-config-reloader:0.6.2
    Image ID:      docker-pullable://natsio/nats-server-config-reloader@sha256:ad0374303b134b7d2d4a5a781107b426739df73fcf504c26c5ef15bc1c4ca10e
    Image:         natsio/prometheus-nats-exporter:0.9.0
    Image ID:      docker-pullable://natsio/prometheus-nats-exporter@sha256:cbeecd2159da4705dcde1b834f8efb97b3acd7a1be6fc393fe0cd2644fc30b50

nekufa

~ # nats stream report
Obtaining Stream stats

╭────────────────────────────────────────────────────────────────────────────────────────────────╮
│                                         Stream Report                                          │
├──────────────────────────┬─────────┬───────────┬──────────┬────────┬──────┬─────────┬──────────┤
│ Stream                   │ Storage │ Consumers │ Messages │ Bytes  │ Lost │ Deleted │ Replicas │
├──────────────────────────┼─────────┼───────────┼──────────┼────────┼──────┼─────────┼──────────┤
│ event_notify_budget      │ File    │ 1         │ 0        │ 0 B    │ 0    │ 0       │ nats-0*  │
│ action                   │ File    │ 1         │ 0        │ 0 B    │ 0    │ 0       │ nats-0*  │

nekufa

/data/jetstream/$G/streams:
total 76
drwxr-x---    4 root     root          4096 Feb  8 04:46 anomaly
drwxr-x---    4 root     root          4096 Feb  8 05:52 developer
drwxr-x---    4 root     root          4096 Feb  8 04:46 event
drwxr-x---    4 root     root          4096 Feb  8 04:46 event_changes
drwxr-x---    4 root     root          4096 Feb  8 04:46 event_notify_action
drwxr-x---    4 root     root          4096 Feb  8 04:46 event_notify_anomaly
drwxr-x---    4 root     root          4096 Feb  8 04:46 event_notify_flow
drwxr-x---    4 root     root          4096 Feb  8 04:46 event_notify_genesis

nekufa

Information for Stream gateway created 2022-02-07T13:06:25Z

Configuration:

             Subjects: gateway, gateway.channel.*
     Acknowledgements: true
            Retention: File - WorkQueue
             Replicas: 1
       Discard Policy: New
     Duplicate Window: 1m0s

nekufa

Configuration:

             Subjects: space
     Acknowledgements: true
            Retention: File - WorkQueue
             Replicas: 1
       Discard Policy: New
     Duplicate Window: 2m0s
    Allows Msg Delete: false
         Allows Purge: true

nekufa

package = 'data'
version = 'scm-1'
source  = {
    url = '/dev/null',
}
-- Put any modules your app depends on here
dependencies = {
    'cartridge == 2.6.0-1',
    'cartridge-cli-extensions == 1.1.1-1',
    'checks == 3.1.0-1',