Module `materialize.scalability.workloads_test`

Expand source code Browse git

# Copyright Materialize, Inc. and contributors. All rights reserved.
#
# Use of this software is governed by the Business Source License
# included in the LICENSE file at the root of this repository.
#
# As of the Change Date specified in that file, in accordance with
# the Business Source License, use of this software will be governed
# by the Apache License, Version 2.0.

from materialize.scalability.operation import Operation
from materialize.scalability.operations_test import (
    EmptyOperation,
    EmptySqlStatement,
    SleepInClusterd,
    SleepInEnvironmentd,
    SleepInPython,
)
from materialize.scalability.workload_markers import SelfTestWorkload


class EmptyOperatorWorkload(SelfTestWorkload):
    def operations(self) -> list["Operation"]:
        return [EmptyOperation()]


class EmptySqlStatementWorkload(SelfTestWorkload):
    def operations(self) -> list["Operation"]:
        return [EmptySqlStatement()]


class Sleep10MsInEnvironmentdWorkload(SelfTestWorkload):
    def operations(self) -> list["Operation"]:
        return [SleepInEnvironmentd(duration_in_sec=0.01)]


class Sleep10MsInClusterdWorkload(SelfTestWorkload):
    def operations(self) -> list["Operation"]:
        return [SleepInClusterd(duration_in_sec=0.01)]


class Sleep10MsInPythonWorkload(SelfTestWorkload):
    def operations(self) -> list["Operation"]:
        return [SleepInPython(duration_in_sec=0.01)]

Classes

class EmptyOperatorWorkload

Used to self-test the framework, not relevant for regular benchmark runs.

Expand source code Browse git

class EmptyOperatorWorkload(SelfTestWorkload):
    def operations(self) -> list["Operation"]:
        return [EmptyOperation()]

Ancestors

Methods

def operations(self) ‑> list[Operation]

Expand source code Browse git

def operations(self) -> list["Operation"]:
    return [EmptyOperation()]

class EmptySqlStatementWorkload

Used to self-test the framework, not relevant for regular benchmark runs.

Expand source code Browse git

class EmptySqlStatementWorkload(SelfTestWorkload):
    def operations(self) -> list["Operation"]:
        return [EmptySqlStatement()]

Ancestors

Methods

def operations(self) ‑> list[Operation]

Expand source code Browse git

def operations(self) -> list["Operation"]:
    return [EmptySqlStatement()]

class Sleep10MsInClusterdWorkload

Used to self-test the framework, not relevant for regular benchmark runs.

Expand source code Browse git

class Sleep10MsInClusterdWorkload(SelfTestWorkload):
    def operations(self) -> list["Operation"]:
        return [SleepInClusterd(duration_in_sec=0.01)]

Ancestors

Methods

def operations(self) ‑> list[Operation]

Expand source code Browse git

def operations(self) -> list["Operation"]:
    return [SleepInClusterd(duration_in_sec=0.01)]

class Sleep10MsInEnvironmentdWorkload

Used to self-test the framework, not relevant for regular benchmark runs.

Expand source code Browse git

class Sleep10MsInEnvironmentdWorkload(SelfTestWorkload):
    def operations(self) -> list["Operation"]:
        return [SleepInEnvironmentd(duration_in_sec=0.01)]

Ancestors

Methods

def operations(self) ‑> list[Operation]

Expand source code Browse git

def operations(self) -> list["Operation"]:
    return [SleepInEnvironmentd(duration_in_sec=0.01)]

class Sleep10MsInPythonWorkload

Used to self-test the framework, not relevant for regular benchmark runs.

Expand source code Browse git

class Sleep10MsInPythonWorkload(SelfTestWorkload):
    def operations(self) -> list["Operation"]:
        return [SleepInPython(duration_in_sec=0.01)]

Ancestors

Methods

def operations(self) ‑> list[Operation]

Expand source code Browse git

def operations(self) -> list["Operation"]:
    return [SleepInPython(duration_in_sec=0.01)]