beatzxbt

import numpy as np

cimport numpy as cnp
from libc.stdint cimport uint64_t, int64_t


cdef class RingBufferOneDim:
    """
    A 1-dimensional fixed-size circular buffer for floats/doubles.
    """

beatzxbt

from libc.stdint cimport uint32_t

from mm_toolbox.time.time cimport time_s

from .engine cimport OrderAction

cdef class RateLimitCounter:
    cdef:
        uint32_t    tokens_per_sec
        uint32_t    tokens_remaining

beatzxbt

import numpy as np
cimport numpy as np
from libc.stdint cimport uint16_t
from libc.stdlib cimport strtod
from cpython.unicode cimport PyUnicode_AsUTF8

cpdef np.ndarray[np.double_t, ndim=2] parse_list_list_str_to_floats(list[list[str]] data):
    """
    Parses a list of lists of strings into a NumPy array of floats.

beatzxbt

import xxhash
import asyncio
import platform
from collections import deque
from warnings import warn as warning
from typing import List, Dict, Optional

from mm_toolbox.time import time_ns, time_s

from .conn.raw cimport WsConnection

beatzxbt

import numpy as np
cimport numpy as np
from libc.stdlib cimport strtod
from cpython.unicode cimport PyUnicode_AsUTF8
from cython cimport boundscheck, wraparound

@boundscheck(False)
@wraparound(False)
cdef np.ndarray[np.float64_t, ndim=2] parse_list_strings_to_floats(list[list[str]] data):
    """

beatzxbt

import orjson
import asyncio
from warnings import warn as warning
from dataclasses import dataclass
from aiohttp import ClientSession, ClientWebSocketResponse, WSMsgType
from typing import List, Dict, Callable, Any, Optional

from mm_toolbox.src.logging import Logger
from mm_toolbox.src.time import time_ms
from mm_toolbox.src.ringbuffer import RingBufferSingleDimFloat

beatzxbt

def generate_new_buffer(size: float, strength: float) -> tuple[float, float]:
    """
    Generates a new buffer range based on the size and strength.
    """
    return (size * (1 - strength), size * (1 + strength))

def process_data(data) -> None:
    """
    Processes the data with varying buffer strengths and prints the results.
    """

beatzxbt

import zmq
import orjson
from time import time_ns
from abc import ABC, abstractmethod
from typing import Dict

from mm.frameworks.exch.base.status import Status


class OrderbookHandler(ABC):

beatzxbt

#!/bin/bash

# Set the date range to include all of yesterday
since_date=$(date -v -1d +%Y-%m-%dT00:00:00)
until_date=$(date -v +0d +%Y-%m-%dT00:00:00)

# Get the list of commits from yesterday
commits=$(git log --since="$since_date" --until="$until_date" --pretty=format:"%H")

# Initialize variables to count total additions and deletions

beatzxbt

import asyncio
import aiosonic
import orjson
from abc import ABC, abstractmethod
from typing import Tuple, Dict, Union, Any, Literal

from frameworks.tools.logging import Logger, time_ms


class Client(ABC):