vane 0.9.2

A flow-based reverse proxy with multi-layer routing and programmable pipelines.
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32

/* src/plugins/system/mod.rs */

pub mod exec;
pub mod httpx;
#[cfg(unix)]
pub mod unix;

use crate::engine::interfaces::{ExternalPluginDriver, MiddlewareOutput, ResolvedInputs};
use anyhow::Result;

/// Executes the appropriate driver logic based on the configuration.
pub async fn execute_driver(
	driver: &ExternalPluginDriver,
	name: &str,
	inputs: ResolvedInputs,
) -> Result<MiddlewareOutput> {
	match driver {
		ExternalPluginDriver::Http { url } => httpx::execute(url, name, inputs).await,
		#[cfg(unix)]
		ExternalPluginDriver::Unix { path } => unix::execute(path, name, inputs).await,
		#[cfg(not(unix))]
		ExternalPluginDriver::Unix { .. } => {
			anyhow::bail!(
				"Unix socket ipc call are not supported on windows platform (requested by plugin: {})",
				name
			)
		}
		ExternalPluginDriver::Command { program, args, env } => {
			exec::execute(program, args, env, inputs).await
		}
	}
}