neutron_fwaas.services.firewall.service_drivers.agents.agents module

class neutron_fwaas.services.firewall.service_drivers.agents.agents.FirewallAgentApi(topic: str, host: str)

Bases: object

Plugin side of plugin to agent RPC API

create_firewall_group(context: Context, rpc_payload: dict[str, Any]) → None

delete_firewall_group(context: Context, rpc_payload: dict[str, Any]) → None

update_firewall_group(context: Context, rpc_payload: dict[str, Any]) → None

class neutron_fwaas.services.firewall.service_drivers.agents.agents.FirewallAgentCallbacks(firewall_db: Any)

Bases: object

firewall_group_deleted(context: Context, fwg_id: str, **kwargs: Any) → bool

Agent uses this to indicate firewall is deleted.

get_firewall_group_for_port(context: Context, **kwargs: Any) → dict[str, Any] | None

Get firewall_group is associated with a port.

get_firewall_groups_for_project(context: Context, **kwargs: Any) → list[dict[str, Any]]

Gets all firewall_groups and rules on a project.

get_projects_with_firewall_groups(context: Context, **kwargs: Any) → list[str]

Get all projects that have firewall_groups.

set_firewall_group_status(context: Context, fwg_id: str, status: str, **kwargs: Any) → bool

Agent uses this to set a firewall_group’s status.

target = <Target version=1.1>

class neutron_fwaas.services.firewall.service_drivers.agents.agents.FirewallAgentDriver(service_plugin: Any)

Bases: FirewallDriverDB, FirewallDriverRPCMixin

Firewall driver to implement agent messages and callback methods

Implement RPC Firewall v2 API and callback methods for agents based on Neutron DB model.

create_firewall_group_postcommit(context: Context, firewall_group: dict[str, Any]) → None

create_firewall_group_precommit(context: Context, firewall_group: dict[str, Any]) → None

insert_rule_postcommit(context: Context, policy_id: str, rule_info: dict[str, Any]) → None

is_supported_l2_port(port: dict[str, Any]) → bool

is_supported_l3_port(port: dict[str, Any]) → bool

register_logging_driver() → None

remove_rule_postcommit(context: Context, policy_id: str, rule_info: dict[str, Any]) → None

start_rpc_listener() → list[Any]

update_firewall_group_postcommit(context: Context, old_firewall_group: dict[str, Any], new_firewall_group: dict[str, Any]) → None

update_firewall_group_precommit(context: Context, old_firewall_group: dict[str, Any], new_firewall_group: dict[str, Any]) → None

update_firewall_policy_postcommit(context: Context, old_firewall_policy: dict[str, Any], new_firewall_group: dict[str, Any]) → None

update_firewall_rule_postcommit(context: Context, old_firewall_rule: dict[str, Any], new_firewall_rule: dict[str, Any]) → None