Struct LuaPactPlugin 

pub struct LuaPactPlugin { /* private fields */ }

A running Lua plugin instance. Each instance owns its own embedded Lua VM.

The mutex is tokio::sync::Mutex, not std::sync::Mutex: the two host functions plugins can call to reach a host-provided or another plugin’s capability (host_compare_contents, host_generate_content - see [register_host_functions] and proposal 007) need to hold the lock across an .await while they dispatch to an async crate::core_capabilities handler or forward to another plugin, which a std::sync::MutexGuard cannot do (it isn’t Send, and PluginInstance’s #[async_trait] methods require a Send future).

Trait Implementations

impl Debug for LuaPactPlugin

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl PactPluginRpc for LuaPactPlugin

fn init_plugin<'life0, 'async_trait>( &'life0 mut self, request: PluginInitRequest, ) -> Pin<Box<dyn Future<Output = Result<PluginInitResponse>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Send an init request to the plugin process

impl PluginInstance for LuaPactPlugin

fn manifest(&self) -> &PactPluginManifest

Return the manifest for this plugin.

fn instance_id(&self) -> &str

Return the instance ID assigned to this plugin at startup.

fn has_capability(&self, capability: &str) -> bool

Check whether the plugin declared a specific capability.

fn compare_contents<'life0, 'async_trait>( &'life0 self, request: CompareContentsRequest, ) -> Pin<Box<dyn Future<Output = Result<CompareContentsResponse>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Send a compare contents request to the plugin process

fn configure_interaction<'life0, 'async_trait>( &'life0 self, request: ConfigureInteractionRequest, ) -> Pin<Box<dyn Future<Output = Result<ConfigureInteractionResponse>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Send a configure contents request to the plugin process

fn generate_content<'life0, 'async_trait>( &'life0 self, request: GenerateContentRequest, ) -> Pin<Box<dyn Future<Output = Result<GenerateContentResponse>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Send a generate content request to the plugin

fn start_mock_server<'life0, 'async_trait>( &'life0 self, request: StartMockServerRequest, ) -> Pin<Box<dyn Future<Output = Result<StartMockServerResponse>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Start a mock server

fn start_mock_server_v2<'life0, 'async_trait>( &'life0 self, request: StartMockServerRequest, ) -> Pin<Box<dyn Future<Output = Result<StartMockServerResponse>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Start a mock server using V2 structured interaction data (no pact JSON).

fn shutdown_mock_server<'life0, 'async_trait>( &'life0 self, request: ShutdownMockServerRequest, ) -> Pin<Box<dyn Future<Output = Result<ShutdownMockServerResponse>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Shutdown a running mock server

fn get_mock_server_results<'life0, 'async_trait>( &'life0 self, request: MockServerRequest, ) -> Pin<Box<dyn Future<Output = Result<MockServerResults>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Get the matching results from a running mock server

fn prepare_interaction_for_verification<'life0, 'async_trait>( &'life0 self, request: VerificationPreparationRequest, ) -> Pin<Box<dyn Future<Output = Result<VerificationPreparationResponse>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Prepare an interaction for verification.

fn prepare_interaction_for_verification_v2<'life0, 'async_trait>( &'life0 self, request: VerificationPreparationRequest, ) -> Pin<Box<dyn Future<Output = Result<VerificationPreparationResponse>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Prepare an interaction for verification using V2 structured interaction data.

fn verify_interaction<'life0, 'async_trait>( &'life0 self, request: VerifyInteractionRequest, ) -> Pin<Box<dyn Future<Output = Result<VerifyInteractionResponse>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Execute the verification for the interaction.

fn verify_interaction_v2<'life0, 'async_trait>( &'life0 self, request: VerifyInteractionRequest, ) -> Pin<Box<dyn Future<Output = Result<VerifyInteractionResponse>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Execute the verification for the interaction using V2 structured interaction data.

fn update_catalogue<'life0, 'async_trait>( &'life0 self, request: Catalogue, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Updates the catalogue.

fn kill(&self)

Terminate the running plugin. The default no-op suits embedded runtimes that are not managed as a child process.

fn compare_contents_with_chain<'life0, 'life1, 'async_trait>( &'life0 self, request: CompareContentsRequest, chain_id: &'life1 str, deadline_ms: u64, ) -> Pin<Box<dyn Future<Output = Result<CompareContentsResponse>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Send a compare contents request to the plugin process, propagating call-chain cycle detection and deadline metadata (see crate::call_chain) for transports that support it. The default implementation ignores chain_id/deadline_ms and delegates to PluginInstance::compare_contents, which suits in-process runtimes (Lua, WASM) where a cycle is already caught by the native call stack; crate::grpc_plugin::GrpcPactPlugin overrides this to send the metadata over gRPC.

fn generate_content_with_chain<'life0, 'life1, 'async_trait>( &'life0 self, request: GenerateContentRequest, chain_id: &'life1 str, deadline_ms: u64, ) -> Pin<Box<dyn Future<Output = Result<GenerateContentResponse>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Send a generate content request to the plugin, propagating call-chain cycle detection and deadline metadata (see crate::call_chain) for transports that support it. See PluginInstance::compare_contents_with_chain for the default/override split.