Struct SkywalkingPlugin 

pub struct SkywalkingPlugin {
    phase: Phase,
    endpoint_addr: String,
    service_name: String,
    service_instance_name: String,
    sample_ratio: f64,
    ssl_verify: bool,
    timeout: Duration,
    client: Arc<OutboundClient>,
}

SkyWalking tracing node (a start or end half, selected by phase).

Fields

phase: Phase

endpoint_addr: String

OAP HTTP base, e.g. http://127.0.0.1:12800 (no trailing slash).

service_name: String

service_instance_name: String

sample_ratio: f64

Fraction of new traces to sample, in 0.0..=1.0.

ssl_verify: bool

timeout: Duration

client: Arc<OutboundClient>

Shared pooled outbound HTTP client (used by the end node’s export).

Implementations

impl SkywalkingPlugin

pub fn from_config( config: &HashMap<String, Value>, resources: &Arc<PluginResources>, ) -> Result<Self, String>

Builds the plugin from node config.

Config keys:

Key	Type	Default	Description
phase	string	— (required)	start (before upstream) or end (after upstream).
endpoint_addr	string	http://127.0.0.1:12800	SkyWalking OAP HTTP base.
service_name	string	"featherbit"	Service name reported on the segment / sw8.
service_instance_name	string	"featherbit Instance Name"	Service instance name.
sample_ratio	number	1.0	Fraction of new traces to sample, in 0.0..=1.0. Requests arriving with a sampled sw8 are always continued.
ssl_verify	bool	true	Verify the OAP TLS certificate on export.
timeout	int (seconds)	3	Per-export HTTP timeout (end node).

# before upstream
- id: sw-start
  type: skywalking
  config: { phase: start, service_name: my-gateway, sample_ratio: 1.0 }
# after upstream
- id: sw-end
  type: skywalking
  config: { phase: end, endpoint_addr: http://127.0.0.1:12800, service_name: my-gateway }

fn should_sample(&self) -> bool

Sampling decision for a new trace (no inbound sw8).

fn run_start(&self, ctx: Context) -> Context

Start-node logic: continue or begin the trace, store the span, and inject the downstream sw8 header.

fn run_end(&self, ctx: Context) -> Context

End-node logic: load the span and, when sampled, fire-and-forget export the segment. Returns the context unchanged.

Trait Implementations

impl Plugin for SkywalkingPlugin

fn plugin_type(&self) -> &str

Unique identifier for the plugin type (e.g., “proxy-rewrite”, “upstream”). This is also the key its PortSpec is registered under in port_spec.

fn reads_response_body(&self) -> bool

Whether this configured instance reads context.response.body.

fn execute<'life0, 'async_trait>( &'life0 self, ctx: Context, ) -> Pin<Box<dyn Future<Output = Result<PluginOutput, PluginExecutionError>> + Send + 'async_trait>>

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

Executes the plugin logic against the request/response context.

fn cache_target(&self) -> Option<CacheTarget>

The cache backend this node writes to, if it is a proxy-cache half.