userver: pytest_userver.chaos.BaseGate Class Reference
Loading...
Searching...
No Matches
pytest_userver.chaos.BaseGate Class Reference

Detailed Description

This base class maintain endpoints of two types:

Server-side endpoints to receive messages from clients. Address of this endpoint is described by (host_for_client, port_for_client).

Client-side endpoints to forward messages to server. Server must listen on (host_to_server, port_to_server).

Asynchronously concurrently passes data from client to server and from server to client, allowing intercepting the data, injecting delays and dropping connections.

Warning
Do not use this class itself. Use one of the specifications TcpGate or UdpGate
See also
Chaos Testing

Definition at line 490 of file chaos.py.

+ Inheritance diagram for pytest_userver.chaos.BaseGate:

Public Member Functions

None __init__ (self, GateRoute route, EvLoop loop)
 
'BaseGate__aenter__ (self)
 
None __aexit__ (self, exc_type, exc_value, traceback)
 
 start (self)
 Open the socket and start accepting tasks.
 
None start_accepting (self)
 Start accepting tasks.
 
None stop_accepting (self)
 Stop accepting tasks without closing the accepting socket.
 
None stop (self)
 Stop accepting tasks, close all the sockets.
 
None sockets_close (self, *typing.Optional[int] count=None)
 Close all the connection going through the gate.
 
Address get_sockname_for_clients (self)
 Returns the client socket address that the gate listens on.
 
str info (self)
 Print info on open sockets.
 
None set_to_server_interceptor (self, Interceptor interceptor)
 Replace existing interceptor of client to server data with a custom.
 
None set_to_client_interceptor (self, Interceptor interceptor)
 Replace existing interceptor of server to client data with a custom.
 
None to_server_pass (self)
 Pass data as is.
 
None to_client_pass (self)
 Pass data as is.
 
None to_server_noop (self)
 Do not read data, causing client to keep multiple data.
 
None to_client_noop (self)
 Do not read data, causing server to keep multiple data.
 
None to_server_drop (self)
 Read and discard data.
 
None to_client_drop (self)
 Read and discard data.
 
None to_server_delay (self, float delay)
 Delay data transmission.
 
None to_client_delay (self, float delay)
 Delay data transmission.
 
None to_server_close_on_data (self)
 Close on first bytes of data from client.
 
None to_client_close_on_data (self)
 Close on first bytes of data from server.
 
None to_server_corrupt_data (self)
 Corrupt data received from client.
 
None to_client_corrupt_data (self)
 Corrupt data received from server.
 
None to_server_limit_bps (self, float bytes_per_second)
 Limit bytes per second transmission by network from client.
 
None to_client_limit_bps (self, float bytes_per_second)
 Limit bytes per second transmission by network from server.
 
None to_server_limit_time (self, float timeout, float jitter)
 Limit connection lifetime on receive of first bytes from client.
 
None to_client_limit_time (self, float timeout, float jitter)
 Limit connection lifetime on receive of first bytes from server.
 
None to_server_smaller_parts (self, int max_size, *float sleep_per_packet=0)
 Pass data to server in smaller parts.
 
None to_client_smaller_parts (self, int max_size, *float sleep_per_packet=0)
 Pass data to client in smaller parts.
 
None to_server_concat_packets (self, int packet_size)
 Pass data in bigger parts.
 
None to_client_concat_packets (self, int packet_size)
 Pass data in bigger parts.
 
None to_server_limit_bytes (self, int bytes_limit)
 Drop all connections each bytes_limit of data sent by network.
 
None to_client_limit_bytes (self, int bytes_limit)
 Drop all connections each bytes_limit of data sent by network.
 
None to_server_substitute (self, str pattern, str repl)
 Apply regex substitution to data from client.
 
None to_client_substitute (self, str pattern, str repl)
 Apply regex substitution to data from server.
 

Protected Member Functions

typing.List[Socket] _create_accepting_sockets (self)
 
None _collect_garbage (self)
 
None _do_accept (self, Socket accept_sock)
 This task should wait for connections and create SocketPair.
 

Protected Attributes

 _route
 
 _loop
 
 _NOT_IMPLEMENTED_MESSAGE
 
 _accept_tasks
 
 _sockets
 
 _to_server_intercept
 
 _to_client_intercept
 

Static Protected Attributes

str _NOT_IMPLEMENTED_MESSAGE = 'Do not use BaseGate itself, use one of ' 'specializations TcpGate or UdpGate'
 

Constructor & Destructor Documentation

◆ __init__()

None pytest_userver.chaos.BaseGate.__init__ ( self,
GateRoute route,
EvLoop loop )

Definition at line 514 of file chaos.py.

Member Function Documentation

◆ __aenter__()

'BaseGate' pytest_userver.chaos.BaseGate.__aenter__ ( self)

Definition at line 526 of file chaos.py.

◆ __aexit__()

None pytest_userver.chaos.BaseGate.__aexit__ ( self,
exc_type,
exc_value,
traceback )

Definition at line 530 of file chaos.py.

◆ _collect_garbage()

None pytest_userver.chaos.BaseGate._collect_garbage ( self)
protected

Definition at line 627 of file chaos.py.

◆ _create_accepting_sockets()

typing.List[Socket] pytest_userver.chaos.BaseGate._create_accepting_sockets ( self)
protected

Definition at line 533 of file chaos.py.

◆ _do_accept()

None pytest_userver.chaos.BaseGate._do_accept ( self,
Socket accept_sock )
protected

This task should wait for connections and create SocketPair.

Reimplemented in pytest_userver.chaos.TcpGate, and pytest_userver.chaos.UdpGate.

Definition at line 630 of file chaos.py.

◆ get_sockname_for_clients()

Address pytest_userver.chaos.BaseGate.get_sockname_for_clients ( self)

Returns the client socket address that the gate listens on.

This function allows to use 0 in GateRoute.port_for_client and retrieve the actual port and host.

Definition at line 610 of file chaos.py.

◆ info()

str pytest_userver.chaos.BaseGate.info ( self)

Print info on open sockets.

Definition at line 620 of file chaos.py.

◆ set_to_client_interceptor()

None pytest_userver.chaos.BaseGate.set_to_client_interceptor ( self,
Interceptor interceptor )

Replace existing interceptor of server to client data with a custom.

Definition at line 644 of file chaos.py.

◆ set_to_server_interceptor()

None pytest_userver.chaos.BaseGate.set_to_server_interceptor ( self,
Interceptor interceptor )

Replace existing interceptor of client to server data with a custom.

Definition at line 636 of file chaos.py.

◆ sockets_close()

None pytest_userver.chaos.BaseGate.sockets_close ( self,
*typing.Optional[int] count = None )

Close all the connection going through the gate.

Definition at line 600 of file chaos.py.

◆ start()

pytest_userver.chaos.BaseGate.start ( self)

Open the socket and start accepting tasks.

Definition at line 536 of file chaos.py.

◆ start_accepting()

None pytest_userver.chaos.BaseGate.start_accepting ( self)

Start accepting tasks.

Definition at line 560 of file chaos.py.

◆ stop()

None pytest_userver.chaos.BaseGate.stop ( self)

Stop accepting tasks, close all the sockets.

Definition at line 580 of file chaos.py.

◆ stop_accepting()

None pytest_userver.chaos.BaseGate.stop_accepting ( self)

Stop accepting tasks without closing the accepting socket.

Definition at line 572 of file chaos.py.

◆ to_client_close_on_data()

None pytest_userver.chaos.BaseGate.to_client_close_on_data ( self)

Close on first bytes of data from server.

Definition at line 713 of file chaos.py.

◆ to_client_concat_packets()

None pytest_userver.chaos.BaseGate.to_client_concat_packets ( self,
int packet_size )

Pass data in bigger parts.

Parameters
packet_sizeminimal size of the resulting packet

Reimplemented in pytest_userver.chaos.UdpGate.

Definition at line 804 of file chaos.py.

◆ to_client_corrupt_data()

None pytest_userver.chaos.BaseGate.to_client_corrupt_data ( self)

Corrupt data received from server.

Definition at line 723 of file chaos.py.

◆ to_client_delay()

None pytest_userver.chaos.BaseGate.to_client_delay ( self,
float delay )

Delay data transmission.

Definition at line 695 of file chaos.py.

◆ to_client_drop()

None pytest_userver.chaos.BaseGate.to_client_drop ( self)

Read and discard data.

Definition at line 677 of file chaos.py.

◆ to_client_limit_bps()

None pytest_userver.chaos.BaseGate.to_client_limit_bps ( self,
float bytes_per_second )

Limit bytes per second transmission by network from server.

Definition at line 736 of file chaos.py.

◆ to_client_limit_bytes()

None pytest_userver.chaos.BaseGate.to_client_limit_bytes ( self,
int bytes_limit )

Drop all connections each bytes_limit of data sent by network.

Definition at line 817 of file chaos.py.

◆ to_client_limit_time()

None pytest_userver.chaos.BaseGate.to_client_limit_time ( self,
float timeout,
float jitter )

Limit connection lifetime on receive of first bytes from server.

Definition at line 753 of file chaos.py.

◆ to_client_noop()

None pytest_userver.chaos.BaseGate.to_client_noop ( self)

Do not read data, causing server to keep multiple data.

Definition at line 667 of file chaos.py.

◆ to_client_pass()

None pytest_userver.chaos.BaseGate.to_client_pass ( self)

Pass data as is.

Definition at line 657 of file chaos.py.

◆ to_client_smaller_parts()

None pytest_userver.chaos.BaseGate.to_client_smaller_parts ( self,
int max_size,
*float sleep_per_packet = 0 )

Pass data to client in smaller parts.

Parameters
max_sizeMax packet size to send to client
sleep_per_packetOptional sleep interval per packet, seconds

Reimplemented in pytest_userver.chaos.UdpGate.

Definition at line 779 of file chaos.py.

◆ to_client_substitute()

None pytest_userver.chaos.BaseGate.to_client_substitute ( self,
str pattern,
str repl )

Apply regex substitution to data from server.

Definition at line 831 of file chaos.py.

◆ to_server_close_on_data()

None pytest_userver.chaos.BaseGate.to_server_close_on_data ( self)

Close on first bytes of data from client.

Definition at line 708 of file chaos.py.

◆ to_server_concat_packets()

None pytest_userver.chaos.BaseGate.to_server_concat_packets ( self,
int packet_size )

Pass data in bigger parts.

Parameters
packet_sizeminimal size of the resulting packet

Reimplemented in pytest_userver.chaos.UdpGate.

Definition at line 796 of file chaos.py.

◆ to_server_corrupt_data()

None pytest_userver.chaos.BaseGate.to_server_corrupt_data ( self)

Corrupt data received from client.

Definition at line 718 of file chaos.py.

◆ to_server_delay()

None pytest_userver.chaos.BaseGate.to_server_delay ( self,
float delay )

Delay data transmission.

Definition at line 682 of file chaos.py.

◆ to_server_drop()

None pytest_userver.chaos.BaseGate.to_server_drop ( self)

Read and discard data.

Definition at line 672 of file chaos.py.

◆ to_server_limit_bps()

None pytest_userver.chaos.BaseGate.to_server_limit_bps ( self,
float bytes_per_second )

Limit bytes per second transmission by network from client.

Definition at line 728 of file chaos.py.

◆ to_server_limit_bytes()

None pytest_userver.chaos.BaseGate.to_server_limit_bytes ( self,
int bytes_limit )

Drop all connections each bytes_limit of data sent by network.

Definition at line 812 of file chaos.py.

◆ to_server_limit_time()

None pytest_userver.chaos.BaseGate.to_server_limit_time ( self,
float timeout,
float jitter )

Limit connection lifetime on receive of first bytes from client.

Definition at line 744 of file chaos.py.

◆ to_server_noop()

None pytest_userver.chaos.BaseGate.to_server_noop ( self)

Do not read data, causing client to keep multiple data.

Definition at line 662 of file chaos.py.

◆ to_server_pass()

None pytest_userver.chaos.BaseGate.to_server_pass ( self)

Pass data as is.

Definition at line 652 of file chaos.py.

◆ to_server_smaller_parts()

None pytest_userver.chaos.BaseGate.to_server_smaller_parts ( self,
int max_size,
*float sleep_per_packet = 0 )

Pass data to server in smaller parts.

Parameters
max_sizeMax packet size to send to server
sleep_per_packetOptional sleep interval per packet, seconds

Reimplemented in pytest_userver.chaos.UdpGate.

Definition at line 762 of file chaos.py.

◆ to_server_substitute()

None pytest_userver.chaos.BaseGate.to_server_substitute ( self,
str pattern,
str repl )

Apply regex substitution to data from client.

Definition at line 822 of file chaos.py.

Member Data Documentation

◆ _accept_tasks

pytest_userver.chaos.BaseGate._accept_tasks
protected

Definition at line 563 of file chaos.py.

◆ _loop

pytest_userver.chaos.BaseGate._loop
protected

Definition at line 516 of file chaos.py.

◆ _NOT_IMPLEMENTED_MESSAGE [1/2]

str pytest_userver.chaos.BaseGate._NOT_IMPLEMENTED_MESSAGE = 'Do not use BaseGate itself, use one of ' 'specializations TcpGate or UdpGate'
staticprotected

Definition at line 512 of file chaos.py.

◆ _NOT_IMPLEMENTED_MESSAGE [2/2]

pytest_userver.chaos.BaseGate._NOT_IMPLEMENTED_MESSAGE
protected

Definition at line 534 of file chaos.py.

◆ _route

pytest_userver.chaos.BaseGate._route
protected

Definition at line 515 of file chaos.py.

◆ _sockets

pytest_userver.chaos.BaseGate._sockets
protected

Definition at line 606 of file chaos.py.

◆ _to_client_intercept

pytest_userver.chaos.BaseGate._to_client_intercept
protected

Definition at line 648 of file chaos.py.

◆ _to_server_intercept

pytest_userver.chaos.BaseGate._to_server_intercept
protected

Definition at line 640 of file chaos.py.


The documentation for this class was generated from the following file: