csle_collector.client_manager.dao package

Submodules

csle_collector.client_manager.dao.arrival_config module

class csle_collector.client_manager.dao.arrival_config.ArrivalConfig(client_arrival_type: csle_collector.client_manager.dao.client_arrival_type.ClientArrivalType)[source]

Bases: csle_base.json_serializable.JSONSerializable

Abstract arrival configuration class

static from_dict(d: Dict[str, Any]) → csle_collector.client_manager.dao.arrival_config.ArrivalConfig[source]

Converts a dict representation to an instance

Parameters: d – the dict to convert
Returns: the created instance

static from_json_file(json_file_path: str) → csle_collector.client_manager.dao.arrival_config.ArrivalConfig[source]

Reads a json file and converts it to a DTO

Parameters: json_file_path – the json file path
Returns: the converted DTO

to_dict() → Dict[str, Any][source]

Converts the object to a dict representation

Returns: a dict representation of the object

csle_collector.client_manager.dao.client module

class csle_collector.client_manager.dao.client.Client(id: int, workflow_distribution: List[float], arrival_config: csle_collector.client_manager.dao.arrival_config.ArrivalConfig, mu: float = 4, exponential_service_time: bool = False)[source]

Bases: csle_base.json_serializable.JSONSerializable, csle_base.grpc_serializable.GRPCSerializable

A client, which is characterized by its arrival process and its workflow distribution.

copy() → csle_collector.client_manager.dao.client.Client[source]

Returns: a copy of the DTO

static from_dict(d: Dict[str, Any]) → csle_collector.client_manager.dao.client.Client[source]

Converts a dict representation to an instance

Parameters: d – the dict to convert
Returns: the created instance

static from_grpc_object(obj: client_manager_pb2.ClientDTO) → csle_collector.client_manager.dao.client.Client[source]

Instantiates the object from a GRPC DTO

Parameters: obj – the object to instantiate from
Returns: the instantiated object

static from_json_file(json_file_path: str) → csle_collector.client_manager.dao.client.Client[source]

Reads a json file and converts it to a DTO

Parameters: json_file_path – the json file path
Returns: the converted DTO

generate_commands(workflows_config: csle_collector.client_manager.dao.workflows_config.WorkflowsConfig) → List[str][source]

Generate the commands for the client

Parameters: workflows_config – the workflows configuration
Returns: sampled list of commands for the client

to_dict() → Dict[str, Any][source]

Converts the object to a dict representation

Returns: a dict representation of the object

to_grpc_object() → client_manager_pb2.ClientDTO[source]

Returns: a GRPC serializable version of the object

csle_collector.client_manager.dao.client_arrival_type module

Type of process that generates new clients for an emulation

class csle_collector.client_manager.dao.client_arrival_type.ClientArrivalType(value)[source]

Bases: enum.IntEnum

Enum representing the different process types for generating client process in an emulation

CONSTANT = 0

EPTMP = 4

PIECE_WISE_CONSTANT = 3

SINE_MODULATED = 1

SPIKING = 2

csle_collector.client_manager.dao.constant_arrival_config module

class csle_collector.client_manager.dao.constant_arrival_config.ConstantArrivalConfig(lamb: float)[source]

Bases: csle_collector.client_manager.dao.arrival_config.ArrivalConfig

DTO representing the configuration of a stationary poisson arrival process with exponential service times

static from_dict(d: Dict[str, Any]) → csle_collector.client_manager.dao.constant_arrival_config.ConstantArrivalConfig[source]

Converts a dict representation of the object to an instance

Parameters: d – the dict to convert
Returns: the created instance

static from_grpc_object(obj: client_manager_pb2.ConstantArrivalConfigDTO) → csle_collector.client_manager.dao.constant_arrival_config.ConstantArrivalConfig[source]

Instantiates the object from a GRPC DTO

Parameters: obj – the object to instantiate from
Returns: the instantiated object

static from_json_file(json_file_path: str) → csle_collector.client_manager.dao.constant_arrival_config.ConstantArrivalConfig[source]

Reads a json file and converts it to a DTO

Parameters: json_file_path – the json file path
Returns: the converted DTO

to_dict() → Dict[str, Any][source]

Converts the object to a dict representation

Returns: a dict representation of the object

to_grpc_object() → client_manager_pb2.ConstantArrivalConfigDTO[source]

Returns: a GRPC serializable version of the object

csle_collector.client_manager.dao.eptmp_arrival_config module

class csle_collector.client_manager.dao.eptmp_arrival_config.EPTMPArrivalConfig(thetas: List[float], gammas: List[float], phis: List[float], omegas: List[float])[source]

Bases: csle_collector.client_manager.dao.arrival_config.ArrivalConfig

DTO representing the configuration of a homogenous poisson arrival process with an Exponential-Polynomial-Trigonometric rate function having Multiple Periodicities

static from_dict(d: Dict[str, Any]) → csle_collector.client_manager.dao.eptmp_arrival_config.EPTMPArrivalConfig[source]

Converts a dict representation of the object to an instance

Parameters: d – the dict to convert
Returns: the created instance

static from_grpc_object(obj: client_manager_pb2.EPTMPArrivalConfigDTO) → csle_collector.client_manager.dao.eptmp_arrival_config.EPTMPArrivalConfig[source]

Instantiates the object from a GRPC DTO

Parameters: obj – the object to instantiate from
Returns: the instantiated object

static from_json_file(json_file_path: str) → csle_collector.client_manager.dao.eptmp_arrival_config.EPTMPArrivalConfig[source]

Reads a json file and converts it to a DTO

Parameters: json_file_path – the json file path
Returns: the converted DTO

to_dict() → Dict[str, Any][source]

Converts the object to a dict representation

Returns: a dict representation of the object

to_grpc_object() → client_manager_pb2.EPTMPArrivalConfigDTO[source]

Returns: a GRPC serializable version of the object

csle_collector.client_manager.dao.piece_wise_constant_arrival_config module

class csle_collector.client_manager.dao.piece_wise_constant_arrival_config.PieceWiseConstantArrivalConfig(breakvalues: List[float], breakpoints: List[int])[source]

Bases: csle_collector.client_manager.dao.arrival_config.ArrivalConfig

DTO representing the configuration of a piece-wise constant poisson arrival process with exponential service times

static from_dict(d: Dict[str, Any]) → csle_collector.client_manager.dao.piece_wise_constant_arrival_config.PieceWiseConstantArrivalConfig[source]

Converts a dict representation of the object to an instance

Parameters: d – the dict to convert
Returns: the created instance

static from_grpc_object(obj: client_manager_pb2.PieceWiseConstantArrivalConfigDTO) → csle_collector.client_manager.dao.piece_wise_constant_arrival_config.PieceWiseConstantArrivalConfig[source]

Instantiates the object from a GRPC DTO

Parameters: obj – the object to instantiate from
Returns: the instantiated object

static from_json_file(json_file_path: str) → csle_collector.client_manager.dao.piece_wise_constant_arrival_config.PieceWiseConstantArrivalConfig[source]

Reads a json file and converts it to a DTO

Parameters: json_file_path – the json file path
Returns: the converted DTO

to_dict() → Dict[str, Any][source]

Converts the object to a dict representation

Returns: a dict representation of the object

to_grpc_object() → client_manager_pb2.PieceWiseConstantArrivalConfigDTO[source]

Returns: a GRPC serializable version of the object

csle_collector.client_manager.dao.sine_arrival_config module

class csle_collector.client_manager.dao.sine_arrival_config.SineArrivalConfig(lamb: float, time_scaling_factor: float, period_scaling_factor: float)[source]

Bases: csle_collector.client_manager.dao.arrival_config.ArrivalConfig

DTO representing the configuration of a sine-modulated poisson arrival process with exponential service times

static from_dict(d: Dict[str, Any]) → csle_collector.client_manager.dao.sine_arrival_config.SineArrivalConfig[source]

Converts a dict representation of the object to an instance

Parameters: d – the dict to convert
Returns: the created instance

static from_grpc_object(obj: client_manager_pb2.SineArrivalConfigDTO) → csle_collector.client_manager.dao.sine_arrival_config.SineArrivalConfig[source]

Instantiates the object from a GRPC DTO

Parameters: obj – the object to instantiate from
Returns: the instantiated object

static from_json_file(json_file_path: str) → csle_collector.client_manager.dao.sine_arrival_config.SineArrivalConfig[source]

Reads a json file and converts it to a DTO

Parameters: json_file_path – the json file path
Returns: the converted DTO

to_dict() → Dict[str, Any][source]

Converts the object to a dict representation

Returns: a dict representation of the object

to_grpc_object() → client_manager_pb2.SineArrivalConfigDTO[source]

Returns: a GRPC serializable version of the object

csle_collector.client_manager.dao.spiking_arrival_config module

class csle_collector.client_manager.dao.spiking_arrival_config.SpikingArrivalConfig(exponents: List[float], factors: List[float])[source]

Bases: csle_collector.client_manager.dao.arrival_config.ArrivalConfig

DTO representing the configuration of a poisson arrival process with spiking arrivals

static from_dict(d: Dict[str, Any]) → csle_collector.client_manager.dao.spiking_arrival_config.SpikingArrivalConfig[source]

Converts a dict representation of the object to an instance

Parameters: d – the dict to convert
Returns: the created instance

static from_grpc_object(obj: client_manager_pb2.SpikingArrivalConfigDTO) → csle_collector.client_manager.dao.spiking_arrival_config.SpikingArrivalConfig[source]

Instantiates the object from a GRPC DTO

Parameters: obj – the object to instantiate from
Returns: the instantiated object

static from_json_file(json_file_path: str) → csle_collector.client_manager.dao.spiking_arrival_config.SpikingArrivalConfig[source]

Reads a json file and converts it to a DTO

Parameters: json_file_path – the json file path
Returns: the converted DTO

to_dict() → Dict[str, Any][source]

Converts the object to a dict representation

Returns: a dict representation of the object

to_grpc_object() → client_manager_pb2.SpikingArrivalConfigDTO[source]

Returns: a GRPC serializable version of the object

csle_collector.client_manager.dao.workflow_markov_chain module

class csle_collector.client_manager.dao.workflow_markov_chain.WorkflowMarkovChain(transition_matrix: List[List[float]], initial_state: int, id: int)[source]

Bases: csle_base.json_serializable.JSONSerializable, csle_base.grpc_serializable.GRPCSerializable

A Markov chain representation of a workflow.

copy() → csle_collector.client_manager.dao.workflow_markov_chain.WorkflowMarkovChain[source]

Returns: a copy of the DTO

static from_dict(d: Dict[str, Any]) → csle_collector.client_manager.dao.workflow_markov_chain.WorkflowMarkovChain[source]

Converts a dict representation to an instance

Parameters: d – the dict to convert
Returns: the created instance

static from_grpc_object(obj: client_manager_pb2.WorkflowMarkovChainDTO) → csle_collector.client_manager.dao.workflow_markov_chain.WorkflowMarkovChain[source]

Instantiates the object from a GRPC DTO

Parameters: obj – the object to instantiate from
Returns: the instantiated object

static from_json_file(json_file_path: str) → csle_collector.client_manager.dao.workflow_markov_chain.WorkflowMarkovChain[source]

Reads a json file and converts it to a DTO

Parameters: json_file_path – the json file path
Returns: the converted DTO

static markov_next_state(row: List[float]) → int[source]

Samples the next state of the Markov chain

Parameters: row – a numpy array of probabilities that sum up to 1.
Returns: an integer from 0 to len(row)-1.

reset() → None[source]

Resets the Markov chain

Returns: None

step_forward() → int[source]: Move t forward by one and possibly transition to a new state. Returns the new state.

to_dict() → Dict[str, Any][source]

Converts the object to a dict representation

Returns: a dict representation of the object

to_grpc_object() → client_manager_pb2.WorkflowMarkovChainDTO[source]

Returns: a GRPC serializable version of the object

csle_collector.client_manager.dao.workflow_service module

class csle_collector.client_manager.dao.workflow_service.WorkflowService(ips_and_commands: List[Tuple[str, List[str]]], id: int)[source]

Bases: csle_base.json_serializable.JSONSerializable, csle_base.grpc_serializable.GRPCSerializable

A service of the network. The service might be distributed across several network nodes. The service is defined by the series of commands that a client executes to make use of the service.

copy() → csle_collector.client_manager.dao.workflow_service.WorkflowService[source]