Module enrgdaq.models

Classes

class LogVerbosity (*args, **kwds)

Expand source code

class LogVerbosity(str, Enum):
    """
    Enum representing the verbosity levels for logging.

    Used in DAQJobConfig.
    """

    DEBUG = "DEBUG"
    INFO = "INFO"
    WARNING = "WARNING"
    ERROR = "ERROR"

    def to_logging_level(self) -> int:
        return logging._nameToLevel[self.value]

Enum representing the verbosity levels for logging.

Used in DAQJobConfig.

Ancestors

• builtins.str
• enum.Enum

Class variables

var DEBUG

var ERROR

var INFO

var WARNING

Methods

def to_logging_level(self) ‑> int

Expand source code

def to_logging_level(self) -> int:
    return logging._nameToLevel[self.value]

class RestartScheduleInfo (job: str, restart_at: str)

Expand source code

class RestartScheduleInfo(Struct):
    """Information about a restart schedule."""

    job: str
    restart_at: str

Information about a restart schedule.

Ancestors

• msgspec.Struct
• msgspec._core._StructMixin

Instance variables

var job : str

Expand source code

class RestartScheduleInfo(Struct):
    """Information about a restart schedule."""

    job: str
    restart_at: str

var restart_at : str

Expand source code

class RestartScheduleInfo(Struct):
    """Information about a restart schedule."""

    job: str
    restart_at: str

class SupervisorCNCConfig (verbosity: LogVerbosity = LogVerbosity.INFO,
is_server: bool = False,
server_host: str = 'localhost',
server_port: int = 1638,
rest_api_enabled: bool = False,
rest_api_host: str = 'localhost',
rest_api_port: int = 8000)

Expand source code

class SupervisorCNCConfig(Struct):
    """
    Configuration for the Command and Control (C&C) system.

    Attributes:
        verbosity (LogVerbosity): The verbosity level for logging.
        is_server (bool): Whether this supervisor instance is the C&C server.
        server_host (str): The hostname or IP address of the C&C server.
        rest_api_enabled (bool): Whether to enable the REST API server.
        rest_api_host (str): The hostname or IP address for the REST API server.
        rest_api_port (int): The port for the REST API server.
    """

    verbosity: LogVerbosity = LogVerbosity.INFO

    is_server: bool = False
    server_host: str = "localhost"
    server_port: int = 1638
    rest_api_enabled: bool = False
    rest_api_host: str = "localhost"
    rest_api_port: int = 8000

Configuration for the Command and Control (C&C) system.

Attributes

verbosity : LogVerbosity

The verbosity level for logging.

is_server : bool

Whether this supervisor instance is the C&C server.

server_host : str

The hostname or IP address of the C&C server.

rest_api_enabled : bool

Whether to enable the REST API server.

rest_api_host : str

The hostname or IP address for the REST API server.

rest_api_port : int

The port for the REST API server.

Ancestors

• msgspec.Struct
• msgspec._core._StructMixin

Instance variables

var is_server : bool

Expand source code

class SupervisorCNCConfig(Struct):
    """
    Configuration for the Command and Control (C&C) system.

    Attributes:
        verbosity (LogVerbosity): The verbosity level for logging.
        is_server (bool): Whether this supervisor instance is the C&C server.
        server_host (str): The hostname or IP address of the C&C server.
        rest_api_enabled (bool): Whether to enable the REST API server.
        rest_api_host (str): The hostname or IP address for the REST API server.
        rest_api_port (int): The port for the REST API server.
    """

    verbosity: LogVerbosity = LogVerbosity.INFO

    is_server: bool = False
    server_host: str = "localhost"
    server_port: int = 1638
    rest_api_enabled: bool = False
    rest_api_host: str = "localhost"
    rest_api_port: int = 8000

var rest_api_enabled : bool

Expand source code

class SupervisorCNCConfig(Struct):
    """
    Configuration for the Command and Control (C&C) system.

    Attributes:
        verbosity (LogVerbosity): The verbosity level for logging.
        is_server (bool): Whether this supervisor instance is the C&C server.
        server_host (str): The hostname or IP address of the C&C server.
        rest_api_enabled (bool): Whether to enable the REST API server.
        rest_api_host (str): The hostname or IP address for the REST API server.
        rest_api_port (int): The port for the REST API server.
    """

    verbosity: LogVerbosity = LogVerbosity.INFO

    is_server: bool = False
    server_host: str = "localhost"
    server_port: int = 1638
    rest_api_enabled: bool = False
    rest_api_host: str = "localhost"
    rest_api_port: int = 8000

var rest_api_host : str

Expand source code

class SupervisorCNCConfig(Struct):
    """
    Configuration for the Command and Control (C&C) system.

    Attributes:
        verbosity (LogVerbosity): The verbosity level for logging.
        is_server (bool): Whether this supervisor instance is the C&C server.
        server_host (str): The hostname or IP address of the C&C server.
        rest_api_enabled (bool): Whether to enable the REST API server.
        rest_api_host (str): The hostname or IP address for the REST API server.
        rest_api_port (int): The port for the REST API server.
    """

    verbosity: LogVerbosity = LogVerbosity.INFO

    is_server: bool = False
    server_host: str = "localhost"
    server_port: int = 1638
    rest_api_enabled: bool = False
    rest_api_host: str = "localhost"
    rest_api_port: int = 8000

var rest_api_port : int

Expand source code

class SupervisorCNCConfig(Struct):
    """
    Configuration for the Command and Control (C&C) system.

    Attributes:
        verbosity (LogVerbosity): The verbosity level for logging.
        is_server (bool): Whether this supervisor instance is the C&C server.
        server_host (str): The hostname or IP address of the C&C server.
        rest_api_enabled (bool): Whether to enable the REST API server.
        rest_api_host (str): The hostname or IP address for the REST API server.
        rest_api_port (int): The port for the REST API server.
    """

    verbosity: LogVerbosity = LogVerbosity.INFO

    is_server: bool = False
    server_host: str = "localhost"
    server_port: int = 1638
    rest_api_enabled: bool = False
    rest_api_host: str = "localhost"
    rest_api_port: int = 8000

var server_host : str

Expand source code

class SupervisorCNCConfig(Struct):
    """
    Configuration for the Command and Control (C&C) system.

    Attributes:
        verbosity (LogVerbosity): The verbosity level for logging.
        is_server (bool): Whether this supervisor instance is the C&C server.
        server_host (str): The hostname or IP address of the C&C server.
        rest_api_enabled (bool): Whether to enable the REST API server.
        rest_api_host (str): The hostname or IP address for the REST API server.
        rest_api_port (int): The port for the REST API server.
    """

    verbosity: LogVerbosity = LogVerbosity.INFO

    is_server: bool = False
    server_host: str = "localhost"
    server_port: int = 1638
    rest_api_enabled: bool = False
    rest_api_host: str = "localhost"
    rest_api_port: int = 8000

var server_port : int

Expand source code

class SupervisorCNCConfig(Struct):
    """
    Configuration for the Command and Control (C&C) system.

    Attributes:
        verbosity (LogVerbosity): The verbosity level for logging.
        is_server (bool): Whether this supervisor instance is the C&C server.
        server_host (str): The hostname or IP address of the C&C server.
        rest_api_enabled (bool): Whether to enable the REST API server.
        rest_api_host (str): The hostname or IP address for the REST API server.
        rest_api_port (int): The port for the REST API server.
    """

    verbosity: LogVerbosity = LogVerbosity.INFO

    is_server: bool = False
    server_host: str = "localhost"
    server_port: int = 1638
    rest_api_enabled: bool = False
    rest_api_host: str = "localhost"
    rest_api_port: int = 8000

var verbosity : LogVerbosity

Expand source code

class SupervisorCNCConfig(Struct):
    """
    Configuration for the Command and Control (C&C) system.

    Attributes:
        verbosity (LogVerbosity): The verbosity level for logging.
        is_server (bool): Whether this supervisor instance is the C&C server.
        server_host (str): The hostname or IP address of the C&C server.
        rest_api_enabled (bool): Whether to enable the REST API server.
        rest_api_host (str): The hostname or IP address for the REST API server.
        rest_api_port (int): The port for the REST API server.
    """

    verbosity: LogVerbosity = LogVerbosity.INFO

    is_server: bool = False
    server_host: str = "localhost"
    server_port: int = 1638
    rest_api_enabled: bool = False
    rest_api_host: str = "localhost"
    rest_api_port: int = 8000

class SupervisorConfig (*,
verbosity: LogVerbosity = LogVerbosity.INFO,
info: SupervisorInfo,
cnc: SupervisorCNCConfig | None = None,
ring_buffer_size_mb: int = 256,
ring_buffer_slot_size_kb: int = 10240)

Expand source code

class SupervisorConfig(Struct, kw_only=True):
    """
    A configuration class for a supervisor.
    Attributes:
        verbosity (LogVerbosity): The verbosity level for logging.
        info (SupervisorInfo): The information of the supervisor.
        cnc (SupervisorCNCConfig | None): The configuration for the Command and Control (C&C) system.
        ring_buffer_size_mb (int): Size of the shared memory ring buffer in MB for zero-copy message transfer.
        ring_buffer_slot_size_kb (int): Size of each slot in the ring buffer in KB.
    """

    verbosity: LogVerbosity = LogVerbosity.INFO
    info: "SupervisorInfo"
    cnc: Optional[SupervisorCNCConfig] = None

    # Ring buffer configuration for zero-copy PyArrow message transfer
    ring_buffer_size_mb: int = 256  # 256 MB total buffer
    ring_buffer_slot_size_kb: int = 10 * 1024  # 1 MB per slot

    def clone(self):
        return deepcopy(self)

A configuration class for a supervisor.

Attributes

verbosity : LogVerbosity

The verbosity level for logging.

info : SupervisorInfo

The information of the supervisor.

cnc : SupervisorCNCConfig | None

The configuration for the Command and Control (C&C) system.

ring_buffer_size_mb : int

Size of the shared memory ring buffer in MB for zero-copy message transfer.

ring_buffer_slot_size_kb : int

Size of each slot in the ring buffer in KB.

Ancestors

• msgspec.Struct
• msgspec._core._StructMixin

Instance variables

var cnc : SupervisorCNCConfig | None

Expand source code

class SupervisorConfig(Struct, kw_only=True):
    """
    A configuration class for a supervisor.
    Attributes:
        verbosity (LogVerbosity): The verbosity level for logging.
        info (SupervisorInfo): The information of the supervisor.
        cnc (SupervisorCNCConfig | None): The configuration for the Command and Control (C&C) system.
        ring_buffer_size_mb (int): Size of the shared memory ring buffer in MB for zero-copy message transfer.
        ring_buffer_slot_size_kb (int): Size of each slot in the ring buffer in KB.
    """

    verbosity: LogVerbosity = LogVerbosity.INFO
    info: "SupervisorInfo"
    cnc: Optional[SupervisorCNCConfig] = None

    # Ring buffer configuration for zero-copy PyArrow message transfer
    ring_buffer_size_mb: int = 256  # 256 MB total buffer
    ring_buffer_slot_size_kb: int = 10 * 1024  # 1 MB per slot

    def clone(self):
        return deepcopy(self)

var info : SupervisorInfo

Expand source code

class SupervisorConfig(Struct, kw_only=True):
    """
    A configuration class for a supervisor.
    Attributes:
        verbosity (LogVerbosity): The verbosity level for logging.
        info (SupervisorInfo): The information of the supervisor.
        cnc (SupervisorCNCConfig | None): The configuration for the Command and Control (C&C) system.
        ring_buffer_size_mb (int): Size of the shared memory ring buffer in MB for zero-copy message transfer.
        ring_buffer_slot_size_kb (int): Size of each slot in the ring buffer in KB.
    """

    verbosity: LogVerbosity = LogVerbosity.INFO
    info: "SupervisorInfo"
    cnc: Optional[SupervisorCNCConfig] = None

    # Ring buffer configuration for zero-copy PyArrow message transfer
    ring_buffer_size_mb: int = 256  # 256 MB total buffer
    ring_buffer_slot_size_kb: int = 10 * 1024  # 1 MB per slot

    def clone(self):
        return deepcopy(self)

var ring_buffer_size_mb : int

Expand source code

class SupervisorConfig(Struct, kw_only=True):
    """
    A configuration class for a supervisor.
    Attributes:
        verbosity (LogVerbosity): The verbosity level for logging.
        info (SupervisorInfo): The information of the supervisor.
        cnc (SupervisorCNCConfig | None): The configuration for the Command and Control (C&C) system.
        ring_buffer_size_mb (int): Size of the shared memory ring buffer in MB for zero-copy message transfer.
        ring_buffer_slot_size_kb (int): Size of each slot in the ring buffer in KB.
    """

    verbosity: LogVerbosity = LogVerbosity.INFO
    info: "SupervisorInfo"
    cnc: Optional[SupervisorCNCConfig] = None

    # Ring buffer configuration for zero-copy PyArrow message transfer
    ring_buffer_size_mb: int = 256  # 256 MB total buffer
    ring_buffer_slot_size_kb: int = 10 * 1024  # 1 MB per slot

    def clone(self):
        return deepcopy(self)

var ring_buffer_slot_size_kb : int

Expand source code

class SupervisorConfig(Struct, kw_only=True):
    """
    A configuration class for a supervisor.
    Attributes:
        verbosity (LogVerbosity): The verbosity level for logging.
        info (SupervisorInfo): The information of the supervisor.
        cnc (SupervisorCNCConfig | None): The configuration for the Command and Control (C&C) system.
        ring_buffer_size_mb (int): Size of the shared memory ring buffer in MB for zero-copy message transfer.
        ring_buffer_slot_size_kb (int): Size of each slot in the ring buffer in KB.
    """

    verbosity: LogVerbosity = LogVerbosity.INFO
    info: "SupervisorInfo"
    cnc: Optional[SupervisorCNCConfig] = None

    # Ring buffer configuration for zero-copy PyArrow message transfer
    ring_buffer_size_mb: int = 256  # 256 MB total buffer
    ring_buffer_slot_size_kb: int = 10 * 1024  # 1 MB per slot

    def clone(self):
        return deepcopy(self)

var verbosity : LogVerbosity

Expand source code

class SupervisorConfig(Struct, kw_only=True):
    """
    A configuration class for a supervisor.
    Attributes:
        verbosity (LogVerbosity): The verbosity level for logging.
        info (SupervisorInfo): The information of the supervisor.
        cnc (SupervisorCNCConfig | None): The configuration for the Command and Control (C&C) system.
        ring_buffer_size_mb (int): Size of the shared memory ring buffer in MB for zero-copy message transfer.
        ring_buffer_slot_size_kb (int): Size of each slot in the ring buffer in KB.
    """

    verbosity: LogVerbosity = LogVerbosity.INFO
    info: "SupervisorInfo"
    cnc: Optional[SupervisorCNCConfig] = None

    # Ring buffer configuration for zero-copy PyArrow message transfer
    ring_buffer_size_mb: int = 256  # 256 MB total buffer
    ring_buffer_slot_size_kb: int = 10 * 1024  # 1 MB per slot

    def clone(self):
        return deepcopy(self)

Methods

def clone(self)

Expand source code

def clone(self):
    return deepcopy(self)

class SupervisorInfo (supervisor_id: str, supervisor_tags: list[str] = <factory>)

Expand source code

class SupervisorInfo(Struct):
    """
    A class to represent the information of a supervisor.
    Attributes:
        supervisor_id (str): The unique identifier for the supervisor.
    """

    supervisor_id: str
    supervisor_tags: list[str] = []

A class to represent the information of a supervisor.

Attributes

supervisor_id : str

The unique identifier for the supervisor.

Ancestors

• msgspec.Struct
• msgspec._core._StructMixin

Instance variables

var supervisor_id : str

Expand source code

class SupervisorInfo(Struct):
    """
    A class to represent the information of a supervisor.
    Attributes:
        supervisor_id (str): The unique identifier for the supervisor.
    """

    supervisor_id: str
    supervisor_tags: list[str] = []

var supervisor_tags : list[str]

Expand source code

class SupervisorInfo(Struct):
    """
    A class to represent the information of a supervisor.
    Attributes:
        supervisor_id (str): The unique identifier for the supervisor.
    """

    supervisor_id: str
    supervisor_tags: list[str] = []